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
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
|
/*
* Copyright (C) Max Romanov
* Copyright (C) NGINX, Inc.
*/
#include <nxt_main.h>
#include <nxt_application.h>
static nxt_int_t nxt_go_init(nxt_task_t *task, nxt_common_app_conf_t *conf);
static nxt_int_t nxt_go_run(nxt_task_t *task,
nxt_app_rmsg_t *rmsg, nxt_app_wmsg_t *msg);
nxt_application_module_t nxt_go_module = {
0,
NULL,
nxt_string("go"),
nxt_string("go"),
nxt_go_init,
nxt_go_run,
};
extern char **environ;
nxt_inline int
nxt_sock_no_cloexec(nxt_socket_t fd)
{
if (fd == -1) {
return 0;
}
return fcntl(fd, F_SETFD, 0);
}
static nxt_int_t
nxt_go_init(nxt_task_t *task, nxt_common_app_conf_t *conf)
{
char *go_path;
char *argv[2];
u_char buf[256];
u_char *p;
u_char stream_buf[32];
nxt_port_t *port;
nxt_runtime_t *rt;
nxt_go_app_conf_t *c;
c = &conf->u.go;
rt = task->thread->runtime;
p = buf;
nxt_runtime_port_each(rt, port) {
if (port->pid != nxt_pid && port->type != NXT_PROCESS_MAIN) {
continue;
}
if (port->pid == nxt_pid) {
nxt_sprintf(stream_buf, stream_buf + sizeof(stream_buf),
"%uD", port->process->init->stream);
setenv("NXT_GO_STREAM", (char *)stream_buf, 1);
}
nxt_debug(task, "port %PI, %ud, (%d, %d)", port->pid, port->id,
port->pair[0], port->pair[1]);
p = nxt_sprintf(p, buf + sizeof(buf), "%PI,%ud,%d,%d,%d;",
port->pid, port->id, (int)port->type,
port->pair[0], port->pair[1]);
if (nxt_slow_path(nxt_sock_no_cloexec(port->pair[0]))) {
nxt_log(task, NXT_LOG_WARN, "fcntl() failed %E", nxt_errno);
}
if (nxt_slow_path(nxt_sock_no_cloexec(port->pair[1]))) {
nxt_log(task, NXT_LOG_WARN, "fcntl() failed %E", nxt_errno);
}
} nxt_runtime_port_loop;
*p = '\0';
nxt_debug(task, "update NXT_GO_PORTS=%s", buf);
setenv("NXT_GO_PORTS", (char *)buf, 1);
go_path = malloc(c->executable.length + 1);
nxt_memcpy(go_path, c->executable.start, c->executable.length);
go_path[c->executable.length] = '\0';
argv[0] = go_path;
argv[1] = NULL;
(void) execve(go_path, argv, environ);
nxt_log(task, NXT_LOG_WARN, "execve(%s) failed %E", go_path, nxt_errno);
return NXT_ERROR;
}
static nxt_int_t
nxt_go_run(nxt_task_t *task,
nxt_app_rmsg_t *rmsg, nxt_app_wmsg_t *msg)
{
return NXT_ERROR;
}
|
