1
2 /*
3 * Copyright (C) Max Romanov
4 * Copyright (C) NGINX, Inc.
5 */
6
7 #include "_cgo_export.h"
8
9 #include <nxt_unit.h>
10 #include <nxt_unit_request.h>
11
12
13 static ssize_t nxt_cgo_port_send(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port,
14 const void *buf, size_t buf_size, const void *oob, size_t oob_size);
15 static ssize_t nxt_cgo_port_recv(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port,
16 void *buf, size_t buf_size, void *oob, size_t *oob_size);
17
18 int
nxt_cgo_run(uintptr_t handler)19 nxt_cgo_run(uintptr_t handler)
20 {
21 int rc;
22 nxt_unit_ctx_t *ctx;
23 nxt_unit_init_t init;
24
25 memset(&init, 0, sizeof(init));
26
27 init.callbacks.request_handler = nxt_go_request_handler;
28 init.callbacks.add_port = nxt_go_add_port;
29 init.callbacks.remove_port = nxt_go_remove_port;
30 init.callbacks.port_send = nxt_cgo_port_send;
31 init.callbacks.port_recv = nxt_cgo_port_recv;
32 init.callbacks.shm_ack_handler = nxt_go_shm_ack_handler;
33 init.callbacks.ready_handler = nxt_go_ready;
34
35 init.data = (void *) handler;
36
37 ctx = nxt_unit_init(&init);
38 if (ctx == NULL) {
39 return NXT_UNIT_ERROR;
40 }
41
42 rc = nxt_unit_run_ctx(ctx);
43
44 nxt_unit_done(ctx);
45
46 return rc;
47 }
48
49
50 static ssize_t
nxt_cgo_port_send(nxt_unit_ctx_t * ctx,nxt_unit_port_t * port,const void * buf,size_t buf_size,const void * oob,size_t oob_size)51 nxt_cgo_port_send(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port,
52 const void *buf, size_t buf_size, const void *oob, size_t oob_size)
53 {
54 return nxt_go_port_send(port->id.pid, port->id.id,
55 (void *) buf, buf_size, (void *) oob, oob_size);
56 }
57
58
59 static ssize_t
nxt_cgo_port_recv(nxt_unit_ctx_t * ctx,nxt_unit_port_t * port,void * buf,size_t buf_size,void * oob,size_t * oob_size)60 nxt_cgo_port_recv(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port,
61 void *buf, size_t buf_size, void *oob, size_t *oob_size)
62 {
63 return nxt_go_port_recv(port->id.pid, port->id.id,
64 buf, buf_size, oob, oob_size);
65 }
66
67
68 ssize_t
nxt_cgo_response_write(nxt_unit_request_info_t * req,uintptr_t start,uint32_t len)69 nxt_cgo_response_write(nxt_unit_request_info_t *req, uintptr_t start,
70 uint32_t len)
71 {
72 return nxt_unit_response_write_nb(req, (void *) start, len, 0);
73 }
74
75
76 ssize_t
nxt_cgo_request_read(nxt_unit_request_info_t * req,uintptr_t dst,uint32_t dst_len)77 nxt_cgo_request_read(nxt_unit_request_info_t *req, uintptr_t dst,
78 uint32_t dst_len)
79 {
80 return nxt_unit_request_read(req, (void *) dst, dst_len);
81 }
82
83
84 void
nxt_cgo_warn(const char * msg,uint32_t msg_len)85 nxt_cgo_warn(const char *msg, uint32_t msg_len)
86 {
87 nxt_unit_warn(NULL, "%.*s", (int) msg_len, (char *) msg);
88 }
89
90
91 void
nxt_cgo_alert(const char * msg,uint32_t msg_len)92 nxt_cgo_alert(const char *msg, uint32_t msg_len)
93 {
94 nxt_unit_alert(NULL, "%.*s", (int) msg_len, (char *) msg);
95 }
96