1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
|
// ---------------------------------------------------------
// - Small utility lib for sending messages from C through
// - the PULSE scheduler.
// -
// - The caveat is that you can't send messages to a named/
// - registered process from a NIF. Therefore a little bit
// - of machinery is used to keep track of the Pid of PULSE
// - and to enable message sends to PULSE via the pulse_send
// - function.
//
// ----------------------------------------------------------
#ifdef PULSE
#include "erl_nif.h"
#include "erl_nif_compat.h"
#include "pulse_c_send.h"
// The global place to store the pid of PULSE
ErlNifPid* THE_PULSE_PID;
// Send atom, initialized on_load
static ERL_NIF_TERM ATOM_SEND;
static ERL_NIF_TERM ATOM_OK;
ERL_NIF_TERM set_pulse_pid(ErlNifEnv* env, int argc, const ERL_NIF_TERM argv[]){
if(!THE_PULSE_PID){
THE_PULSE_PID = (ErlNifPid *)malloc(sizeof(ErlNifPid));
}
enif_get_local_pid(env, argv[0], THE_PULSE_PID);
return ATOM_OK;
}
int pulse_send(ErlNifEnv* env, ErlNifPid* dest_pid,
ErlNifEnv* msg_env, ERL_NIF_TERM msg,
char* file, int line){
ERL_NIF_TERM t_self =
enif_make_pid(msg_env, enif_self(msg_env, (ErlNifPid *)malloc(sizeof(ErlNifPid))));
ERL_NIF_TERM t_src_loc =
enif_make_tuple2(msg_env, enif_make_string(msg_env, file, ERL_NIF_LATIN1),
enif_make_int(msg_env, line));
ERL_NIF_TERM t_args = enif_make_list(msg_env, 2, enif_make_pid(msg_env, dest_pid), msg);
ERL_NIF_TERM pulse_msg = enif_make_tuple4(msg_env,
ATOM_SEND,
t_self,
t_src_loc,
t_args);
return enif_send(env, THE_PULSE_PID, msg_env, pulse_msg);
}
int pulse_c_send_on_load(ErlNifEnv* env){
THE_PULSE_PID = (ErlNifPid *)0L;
ATOM_SEND = enif_make_atom(env, "send");
ATOM_OK = enif_make_atom(env, "ok");
return 0;
}
#endif // ifdef PULSE
|
