Mercurial > hg > nginx

comparison src/event/ngx_event.h @ 8628:45db1b5c1706 quic

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
QUIC: connection multiplexing per port. Also, connection migration within a single worker is implemented.
author Roman Arutyunyan <arut@nginx.com>
date Wed, 11 Nov 2020 11:57:50 +0000
parents efd71d49bde0
children c61fcdc1b8e3
comparison
equal deleted inserted replaced
8627:405b6e8eb523 8628:45db1b5c1706
165 }; 165 };
166 166
167 #endif 167 #endif
168 168
169 169
170 #if !(NGX_WIN32)
171
172 struct ngx_udp_connection_s {
173 ngx_rbtree_node_t node;
174 ngx_connection_t *connection;
175 ngx_str_t key;
176 ngx_buf_t *buffer;
177 };
178
179 #endif
180
181
170 typedef struct { 182 typedef struct {
171 ngx_int_t (*add)(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags); 183 ngx_int_t (*add)(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags);
172 ngx_int_t (*del)(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags); 184 ngx_int_t (*del)(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags);
173 185
174 ngx_int_t (*enable)(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags); 186 ngx_int_t (*enable)(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags);
499 void ngx_event_accept(ngx_event_t *ev); 511 void ngx_event_accept(ngx_event_t *ev);
500 #if !(NGX_WIN32) 512 #if !(NGX_WIN32)
501 void ngx_event_recvmsg(ngx_event_t *ev); 513 void ngx_event_recvmsg(ngx_event_t *ev);
502 void ngx_udp_rbtree_insert_value(ngx_rbtree_node_t *temp, 514 void ngx_udp_rbtree_insert_value(ngx_rbtree_node_t *temp,
503 ngx_rbtree_node_t *node, ngx_rbtree_node_t *sentinel); 515 ngx_rbtree_node_t *node, ngx_rbtree_node_t *sentinel);
516 void ngx_insert_udp_connection(ngx_connection_t *c, ngx_udp_connection_t *udp,
517 ngx_str_t *key);
504 #endif 518 #endif
505 void ngx_delete_udp_connection(void *data); 519 void ngx_delete_udp_connection(void *data);
506 ngx_int_t ngx_trylock_accept_mutex(ngx_cycle_t *cycle); 520 ngx_int_t ngx_trylock_accept_mutex(ngx_cycle_t *cycle);
507 ngx_int_t ngx_enable_accept_events(ngx_cycle_t *cycle); 521 ngx_int_t ngx_enable_accept_events(ngx_cycle_t *cycle);
508 u_char *ngx_accept_log_error(ngx_log_t *log, u_char *buf, size_t len); 522 u_char *ngx_accept_log_error(ngx_log_t *log, u_char *buf, size_t len);