diff options
author | Igor Sysoev <igor@sysoev.ru> | 2017-02-22 15:10:28 +0300 |
---|---|---|
committer | Igor Sysoev <igor@sysoev.ru> | 2017-02-22 15:10:28 +0300 |
commit | b379dae85e6edcb4af1ac665ab66d99e63bf34f4 (patch) | |
tree | 84b1d69d355e4722ebee02748e512306913a92d7 /src/nxt_port_socket.h | |
parent | 029942f4eb7196c2cff0d0e26bc6ff274138f7d8 (diff) | |
download | unit-b379dae85e6edcb4af1ac665ab66d99e63bf34f4.tar.gz unit-b379dae85e6edcb4af1ac665ab66d99e63bf34f4.tar.bz2 |
Port changes.
Diffstat (limited to 'src/nxt_port_socket.h')
-rw-r--r-- | src/nxt_port_socket.h | 73 |
1 files changed, 0 insertions, 73 deletions
diff --git a/src/nxt_port_socket.h b/src/nxt_port_socket.h deleted file mode 100644 index 4740368d..00000000 --- a/src/nxt_port_socket.h +++ /dev/null @@ -1,73 +0,0 @@ - -/* - * Copyright (C) Igor Sysoev - * Copyright (C) NGINX, Inc. - */ - -#ifndef _NXT_PORT_SOCKET_H_INCLUDED_ -#define _NXT_PORT_SOCKET_H_INCLUDED_ - - -typedef struct { - uint32_t stream; - - uint16_t type; - uint8_t last; /* 1 bit */ -} nxt_port_msg_t; - - -typedef struct { - nxt_queue_link_t link; - nxt_buf_t *buf; - size_t share; - nxt_fd_t fd; - nxt_port_msg_t port_msg; -} nxt_port_send_msg_t; - - -typedef struct nxt_port_recv_msg_s nxt_port_recv_msg_t; -typedef void (*nxt_port_handler_t)(nxt_task_t *task, nxt_port_recv_msg_t *msg); - - -typedef struct { - /* Must be the first field. */ - nxt_fd_event_t socket; - - nxt_queue_t messages; /* of nxt_port_send_msg_t */ - - /* Maximum size of message part. */ - uint32_t max_size; - /* Maximum interleave of message parts. */ - uint32_t max_share; - - nxt_port_handler_t handler; - void *data; - - nxt_mem_pool_t *mem_pool; - nxt_buf_t *free_bufs; - nxt_socket_t pair[2]; -} nxt_port_t; - - -struct nxt_port_recv_msg_s { - uint32_t stream; - uint16_t type; - - nxt_fd_t fd; - nxt_buf_t *buf; - nxt_port_t *port; -}; - - -NXT_EXPORT nxt_port_t *nxt_port_alloc(nxt_task_t *task); -NXT_EXPORT nxt_port_t *nxt_port_create(nxt_task_t *task, size_t bufsize); -NXT_EXPORT void nxt_port_destroy(nxt_port_t *port); -NXT_EXPORT void nxt_port_write_enable(nxt_task_t *task, nxt_port_t *port); -NXT_EXPORT void nxt_port_write_close(nxt_port_t *port); -NXT_EXPORT void nxt_port_read_enable(nxt_task_t *task, nxt_port_t *port); -NXT_EXPORT void nxt_port_read_close(nxt_port_t *port); -NXT_EXPORT nxt_int_t nxt_port_write(nxt_task_t *task, nxt_port_t *port, - nxt_uint_t type, nxt_fd_t fd, uint32_t stream, nxt_buf_t *b); - - -#endif /* _NXT_PORT_SOCKET_H_INCLUDED_ */ |