Enif_send 来自创建线程问题的函数

Question

我试图从创建的线程中调用 enif_send。主要是，我有一个 erlang 进程，它监听从我的 nif 发出的接收到的消息。

首先，在我的 enif 函数中，我得到了我的 erlang 进程的 pid 并对其进行了转换，然后我调用 enif_send 发送消息如下：

ErlNifPid* pid = (ErlNifPid*) enif_alloc(sizeof(ErlNifPid));
ErlNifPid * erlang_pid = (ErlNifPid*)argv;
ERL_NIF_TERM pid1 = enif_make_pid(env , erlang_pid);

if(enif_is_pid(env,pid1))
printf(" it's pid\n");
else
printf(" it's not pid\n");

msg_env = enif_alloc_env();
ERL_NIF_TERM replay = (ERL_NIF_TERM) *text;
msg = enif_make_tuple(msg_env, replay);
if(enif_send(NULL, erlang_pid, msg_env,msg))
printf("  send succeed\n");
else
printf(" send failed\n");

直到这个阶段，我才能向我的 erlang 进程发送消息。

之后我生成了一个 enif_thread 并将 env 和 pid 作为参数传递给它，我尝试从我的线程中调用 enif_send，例如：

ERL_NIF_TERM pid1 = enif_make_pid(conn->env , conn->pid);
if(enif_is_pid(conn->env,pid1))
printf("it's pid\n");
else
printf(" it's not pid\n");
for (int i=0;i<index;i++)
{
msg_env = enif_alloc_env();

msg = enif_make_int(msg_env, 1); 
 if(enif_send(conn->env, conn->pid, msg_env,msg))
printf("  send succeed\n");
else
printf(" send failed\n");

但是当我用 enif_is_pid 检查 pid 时，我得到了一个无效的 pid，即使它是在生成线程的函数中检查的相同 pid，因此发送失败。有什么想法吗？

Answer 1

如 documentation for enif_send 所述，当从创建的线程调用函数时，env 参数应为 NULL。

顺便说一句，如果不看所有代码就很难判断，但是您显示的这部分代码可能有问题：

ErlNifPid * erlang_pid = (ErlNifPid*)argv;
ERL_NIF_TERM pid1 = enif_make_pid(env, erlang_pid);

如果你想要调用者的 pid，你应该使用 the enif_self function or if the pid is passed to the NIF as an argument, you should extract it using enif_get_local_pid。例如，如果它是从 Erlang 调用者传递的第一个参数：

ErlNifPid pid;
if (!enif_get_local_pid(env, argv[0], &pid))
    return enif_make_badarg(env);

然后您可以复制它以在创建的发送线程中使用。

Enif_send 来自创建线程问题的函数

Enif_send function from created thread issue

c

erlang

erlang-nif

erlang-driver