Searched refs:full_subscriber_t (Results 1 – 8 of 8) sorted by relevance
26 full_subscriber_t *fsub = (full_subscriber_t *)sub; in sudden_abort_handler()40 full_subscriber_t *fsub; in longpoll_subscriber_create()97 full_subscriber_t *fsub = (full_subscriber_t *)sub; in longpoll_subscriber_destroy()155 full_subscriber_t *fsub = (full_subscriber_t *)self; in longpoll_reserve()162 full_subscriber_t *fsub = (full_subscriber_t *)self; in longpoll_release()176 full_subscriber_t *fsub = (full_subscriber_t *)self; in longpoll_enqueue()197 full_subscriber_t *fsub = (full_subscriber_t *)self; in longpoll_dequeue()279 full_subscriber_t *fsub = (full_subscriber_t *)self; in longpoll_respond_message()425 full_subscriber_t *fsub = (full_subscriber_t *)self; in longpoll_respond_status()499 full_subscriber_t *fsub = (full_subscriber_t *)self; in longpoll_set_enqueue_callback()[all …]
315 full_subscriber_t *fsub = (full_subscriber_t *)sub; in sudden_abort_handler()715 full_subscriber_t *fsub = (full_subscriber_t *)ev->data; in closing_ev_handler()1154 full_subscriber_t *fsub = (full_subscriber_t *)self; in websocket_reserve()1161 full_subscriber_t *fsub = (full_subscriber_t *)self; in websocket_release()1175 full_subscriber_t *fsub = (full_subscriber_t *)ev->data; in ping_ev_handler()1192 full_subscriber_t *fsub = (full_subscriber_t *)self; in websocket_enqueue()1233 full_subscriber_t *fsub = (full_subscriber_t *)self; in websocket_dequeue()1254 full_subscriber_t *fsub = (full_subscriber_t *)self; in websocket_set_enqueue_callback()1261 full_subscriber_t *fsub = (full_subscriber_t *)self; in websocket_set_dequeue_callback()1924 full_subscriber_t *fsub = (full_subscriber_t *)self; in websocket_respond_message()[all …]
14 static void rawstream_ensure_headers_sent(full_subscriber_t *fsub) { in rawstream_ensure_headers_sent()28 full_subscriber_t *fsub = (full_subscriber_t *)sub; in rawstream_respond_message()100 full_subscriber_t *fsub = (full_subscriber_t *)sub; in rawstream_respond_status()119 full_subscriber_t *fsub = (full_subscriber_t *)sub; in rawstream_enqueue()136 full_subscriber_t *fsub = (full_subscriber_t *)sub; in http_raw_stream_subscriber_create()
14 static nchan_bufchain_pool_t *fsub_bcp(full_subscriber_t *fsub) { in fsub_bcp()28 static void es_ensure_headers_sent(full_subscriber_t *fsub) { in es_ensure_headers_sent()62 static ngx_int_t create_dataline_bufchain(full_subscriber_t *fsub, ngx_chain_t **first_chain, ngx_c… in create_dataline_bufchain()88 static void prepend_es_response_line(full_subscriber_t *fsub, ngx_str_t *lbl, ngx_chain_t **first_c… in prepend_es_response_line()107 full_subscriber_t *fsub = (full_subscriber_t *)sub; in es_respond_message()251 full_subscriber_t *fsub = (full_subscriber_t *)sub; in es_respond_status()288 full_subscriber_t *fsub = (full_subscriber_t *)ev->data; in ping_ev_handler()347 full_subscriber_t *fsub = (full_subscriber_t *)sub; in es_enqueue()364 full_subscriber_t *fsub = (full_subscriber_t *)sub; in es_dequeue()379 full_subscriber_t *fsub = (full_subscriber_t *)sub; in eventsource_subscriber_create()
22 static void chunked_ensure_headers_sent(full_subscriber_t *fsub) { in chunked_ensure_headers_sent()46 full_subscriber_t *fsub = (full_subscriber_t *)sub; in chunked_respond_message()118 full_subscriber_t *fsub = (full_subscriber_t *)sub; in chunked_respond_status()160 full_subscriber_t *fsub = (full_subscriber_t *)sub; in chunked_enqueue()176 full_subscriber_t *fsub = (full_subscriber_t *)sub; in http_chunked_subscriber_create()
25 static nchan_bufchain_pool_t *fsub_bcp(full_subscriber_t *fsub) { in fsub_bcp()30 static void multipart_ensure_headers_sent(full_subscriber_t *fsub) { in multipart_ensure_headers_sent()77 full_subscriber_t *fsub = (full_subscriber_t *)sub; in multipart_respond_message()198 full_subscriber_t *fsub = (full_subscriber_t *)sub; in multipart_respond_status()236 full_subscriber_t *fsub = (full_subscriber_t *)sub; in multipart_enqueue()253 full_subscriber_t *fsub = (full_subscriber_t *)sub; in http_multipart_subscriber_create()
31 } full_subscriber_t; typedef36 void subscriber_maybe_dequeue_after_status_response(full_subscriber_t *fsub, ngx_int_t status_code);38 ngx_int_t subscriber_respond_unqueued_status(full_subscriber_t *fsub, ngx_int_t status_code, const …
17 full_subscriber_t *fsub; in intervalpoll_subscriber_create()21 fsub = (full_subscriber_t *)sub; in intervalpoll_subscriber_create()