xref: /unit/go/nxt_cgo_lib.c (revision 1713:f5ba5973a0a3)
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 *, 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 *, nxt_unit_port_t *port,
16     void *buf, size_t buf_size, void *oob, size_t oob_size);
17 
18 int
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 
34     init.data = (void *) handler;
35 
36     ctx = nxt_unit_init(&init);
37     if (ctx == NULL) {
38         return NXT_UNIT_ERROR;
39     }
40 
41     rc = nxt_unit_run_ctx(ctx);
42 
43     nxt_unit_done(ctx);
44 
45     return rc;
46 }
47 
48 
49 static ssize_t
50 nxt_cgo_port_send(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port,
51     const void *buf, size_t buf_size, const void *oob, size_t oob_size)
52 {
53     return nxt_go_port_send(port->id.pid, port->id.id,
54                             (void *) buf, buf_size, (void *) oob, oob_size);
55 }
56 
57 
58 static ssize_t
59 nxt_cgo_port_recv(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port,
60     void *buf, size_t buf_size, void *oob, size_t oob_size)
61 {
62     return nxt_go_port_recv(port->id.pid, port->id.id,
63                             buf, buf_size, oob, oob_size);
64 }
65 
66 
67 ssize_t
68 nxt_cgo_response_write(nxt_unit_request_info_t *req, uintptr_t start,
69     uint32_t len)
70 {
71     return nxt_unit_response_write_nb(req, (void *) start, len, 0);
72 }
73 
74 
75 ssize_t
76 nxt_cgo_request_read(nxt_unit_request_info_t *req, uintptr_t dst,
77     uint32_t dst_len)
78 {
79     return nxt_unit_request_read(req, (void *) dst, dst_len);
80 }
81 
82 
83 void
84 nxt_cgo_warn(const char *msg, uint32_t msg_len)
85 {
86     nxt_unit_warn(NULL, "%.*s", (int) msg_len, (char *) msg);
87 }
88 
89 
90 void
91 nxt_cgo_alert(const char *msg, uint32_t msg_len)
92 {
93     nxt_unit_alert(NULL, "%.*s", (int) msg_len, (char *) msg);
94 }
95