xref: /unit/go/nxt_cgo_lib.c (revision 1996:35873fa78fed)
11316Smax.romanov@nginx.com 
21316Smax.romanov@nginx.com /*
31316Smax.romanov@nginx.com  * Copyright (C) Max Romanov
41316Smax.romanov@nginx.com  * Copyright (C) NGINX, Inc.
51316Smax.romanov@nginx.com  */
61316Smax.romanov@nginx.com 
71316Smax.romanov@nginx.com #include "_cgo_export.h"
81316Smax.romanov@nginx.com 
91316Smax.romanov@nginx.com #include <nxt_unit.h>
101316Smax.romanov@nginx.com #include <nxt_unit_request.h>
111316Smax.romanov@nginx.com 
121316Smax.romanov@nginx.com 
13*1996St.nateldemoura@f5.com static ssize_t nxt_cgo_port_send(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port,
141316Smax.romanov@nginx.com     const void *buf, size_t buf_size, const void *oob, size_t oob_size);
15*1996St.nateldemoura@f5.com static ssize_t nxt_cgo_port_recv(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port,
16*1996St.nateldemoura@f5.com     void *buf, size_t buf_size, void *oob, size_t *oob_size);
171316Smax.romanov@nginx.com 
181316Smax.romanov@nginx.com int
nxt_cgo_run(uintptr_t handler)191316Smax.romanov@nginx.com nxt_cgo_run(uintptr_t handler)
201316Smax.romanov@nginx.com {
211316Smax.romanov@nginx.com     int              rc;
221316Smax.romanov@nginx.com     nxt_unit_ctx_t   *ctx;
231316Smax.romanov@nginx.com     nxt_unit_init_t  init;
241316Smax.romanov@nginx.com 
251316Smax.romanov@nginx.com     memset(&init, 0, sizeof(init));
261316Smax.romanov@nginx.com 
271713Smax.romanov@nginx.com     init.callbacks.request_handler = nxt_go_request_handler;
281713Smax.romanov@nginx.com     init.callbacks.add_port        = nxt_go_add_port;
291713Smax.romanov@nginx.com     init.callbacks.remove_port     = nxt_go_remove_port;
301316Smax.romanov@nginx.com     init.callbacks.port_send       = nxt_cgo_port_send;
311316Smax.romanov@nginx.com     init.callbacks.port_recv       = nxt_cgo_port_recv;
321713Smax.romanov@nginx.com     init.callbacks.shm_ack_handler = nxt_go_shm_ack_handler;
331993Smax.romanov@nginx.com     init.callbacks.ready_handler   = nxt_go_ready;
341316Smax.romanov@nginx.com 
351316Smax.romanov@nginx.com     init.data = (void *) handler;
361316Smax.romanov@nginx.com 
371316Smax.romanov@nginx.com     ctx = nxt_unit_init(&init);
381316Smax.romanov@nginx.com     if (ctx == NULL) {
391316Smax.romanov@nginx.com         return NXT_UNIT_ERROR;
401316Smax.romanov@nginx.com     }
411316Smax.romanov@nginx.com 
421547Smax.romanov@nginx.com     rc = nxt_unit_run_ctx(ctx);
431316Smax.romanov@nginx.com 
441316Smax.romanov@nginx.com     nxt_unit_done(ctx);
451316Smax.romanov@nginx.com 
461316Smax.romanov@nginx.com     return rc;
471316Smax.romanov@nginx.com }
481316Smax.romanov@nginx.com 
491316Smax.romanov@nginx.com 
501316Smax.romanov@nginx.com 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)511544Smax.romanov@nginx.com nxt_cgo_port_send(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port,
521316Smax.romanov@nginx.com     const void *buf, size_t buf_size, const void *oob, size_t oob_size)
531316Smax.romanov@nginx.com {
541544Smax.romanov@nginx.com     return nxt_go_port_send(port->id.pid, port->id.id,
551316Smax.romanov@nginx.com                             (void *) buf, buf_size, (void *) oob, oob_size);
561316Smax.romanov@nginx.com }
571316Smax.romanov@nginx.com 
581316Smax.romanov@nginx.com 
591316Smax.romanov@nginx.com 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)601544Smax.romanov@nginx.com nxt_cgo_port_recv(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port,
61*1996St.nateldemoura@f5.com     void *buf, size_t buf_size, void *oob, size_t *oob_size)
621316Smax.romanov@nginx.com {
631544Smax.romanov@nginx.com     return nxt_go_port_recv(port->id.pid, port->id.id,
641316Smax.romanov@nginx.com                             buf, buf_size, oob, oob_size);
651316Smax.romanov@nginx.com }
661316Smax.romanov@nginx.com 
671316Smax.romanov@nginx.com 
681713Smax.romanov@nginx.com ssize_t
nxt_cgo_response_write(nxt_unit_request_info_t * req,uintptr_t start,uint32_t len)691713Smax.romanov@nginx.com nxt_cgo_response_write(nxt_unit_request_info_t *req, uintptr_t start,
701713Smax.romanov@nginx.com     uint32_t len)
711316Smax.romanov@nginx.com {
721713Smax.romanov@nginx.com     return nxt_unit_response_write_nb(req, (void *) start, len, 0);
731316Smax.romanov@nginx.com }
741316Smax.romanov@nginx.com 
751316Smax.romanov@nginx.com 
761316Smax.romanov@nginx.com ssize_t
nxt_cgo_request_read(nxt_unit_request_info_t * req,uintptr_t dst,uint32_t dst_len)771713Smax.romanov@nginx.com nxt_cgo_request_read(nxt_unit_request_info_t *req, uintptr_t dst,
781713Smax.romanov@nginx.com     uint32_t dst_len)
791316Smax.romanov@nginx.com {
801713Smax.romanov@nginx.com     return nxt_unit_request_read(req, (void *) dst, dst_len);
811316Smax.romanov@nginx.com }
821316Smax.romanov@nginx.com 
831316Smax.romanov@nginx.com 
841316Smax.romanov@nginx.com void
nxt_cgo_warn(const char * msg,uint32_t msg_len)851713Smax.romanov@nginx.com nxt_cgo_warn(const char *msg, uint32_t msg_len)
861316Smax.romanov@nginx.com {
871713Smax.romanov@nginx.com     nxt_unit_warn(NULL, "%.*s", (int) msg_len, (char *) msg);
881316Smax.romanov@nginx.com }
891316Smax.romanov@nginx.com 
901316Smax.romanov@nginx.com 
911316Smax.romanov@nginx.com void
nxt_cgo_alert(const char * msg,uint32_t msg_len)921713Smax.romanov@nginx.com nxt_cgo_alert(const char *msg, uint32_t msg_len)
931547Smax.romanov@nginx.com {
941713Smax.romanov@nginx.com     nxt_unit_alert(NULL, "%.*s", (int) msg_len, (char *) msg);
951547Smax.romanov@nginx.com }
96