| /dports/net-im/jabberd/jabberd-2.7.0/sx/ |
| H A D | error.c | 60 …jqueue_push(s->wbufq, _sx_buffer_new("<open xmlns='" uri_XFRAMING "' version='1.0' />", sizeof(uri… in _sx_error()
62 …jqueue_push(s->wbufq, _sx_buffer_new("<stream:stream xmlns:stream='" uri_STREAMS "' version='1.0'>… in _sx_error()
80 jqueue_push(s->wbufq, buf, 0); in _sx_error()
85 …jqueue_push(s->wbufq, _sx_buffer_new("<close xmlns='" uri_XFRAMING "' />", sizeof(uri_XFRAMING) + … in _sx_error()
87 jqueue_push(s->wbufq, _sx_buffer_new("</stream:stream>", 16, NULL, NULL), 0); in _sx_error()
134 jqueue_push(s->wbufq, buf, 0); in _sx_error_extended()
|
| H A D | io.c | 183 …jqueue_push(s->wbufq, _sx_buffer_new("<close xmlns='" uri_XFRAMING "' />", sizeof(uri_XFRAMING) + … in _sx_process_read()
185 jqueue_push(s->wbufq, _sx_buffer_new("</stream:stream>", 16, NULL, NULL), 0); in _sx_process_read()
299 in = jqueue_pull(s->wbufq); in _sx_get_pending_write()
307 s->want_write = jqueue_size(s->wbufq); in _sx_get_pending_write()
319 jqueue_push(s->wbufq, in, (s->wbufq->front != NULL) ? s->wbufq->front->priority : 0); in _sx_get_pending_write()
438 jqueue_push(s->wbufq, _sx_buffer_new(out, len, NULL, NULL), 0); in _sx_nad_write()
474 jqueue_push(s->wbufq, _sx_buffer_new(buf, len, NULL, NULL), 0); in _sx_raw_write()
503 …jqueue_push(s->wbufq, _sx_buffer_new("<close xmlns='" uri_XFRAMING "' />", sizeof(uri_XFRAMING) + … in _sx_close()
505 jqueue_push(s->wbufq, _sx_buffer_new("</stream:stream>", 16, NULL, NULL), 0); in _sx_close()
|
| H A D | ack.c | 65 jqueue_push(s->wbufq, _sx_buffer_new("<ack:pong/>", 11, NULL, NULL), 0); in _sx_ack_process()
75 jqueue_push(s->wbufq, _sx_buffer_new("<ack:enabled/>", 14, NULL, NULL), 254); in _sx_ack_process()
91 jqueue_push(s->wbufq, _sx_buffer_new(buf, NAD_AVAL_L(nad, attr) + 13, NULL, NULL), 255); in _sx_ack_process()
|
| H A D | sx.c | 54 s->wbufq = jqueue_new(); in sx_new()
96 while((buf = jqueue_pull(s->wbufq)) != NULL) in sx_free()
104 jqueue_free(s->wbufq); in sx_free()
|
| H A D | server.c | 65 jqueue_push(s->wbufq, buf, 0); in _sx_server_notify_header()
205 jqueue_push(s->wbufq, buf, 0); in _sx_server_element_start()
|
| H A D | compress.c | 62 …jqueue_push(s->wbufq, _sx_buffer_new("<compressed xmlns='" uri_COMPRESS "'/>", sizeof(uri_COMPRESS… in _sx_compress_process()
362 …jqueue_push(s->wbufq, _sx_buffer_new("<compress xmlns='" uri_COMPRESS "'><method>zlib</method></co… in sx_compress_client_compress()
|
| H A D | client.c | 171 jqueue_push(s->wbufq, buf, 0); in sx_client_init()
|
| H A D | websocket.c | 206 jqueue_push(s->wbufq, buf, 0); in libwebsock_send_fragment()
307 jqueue_push(s->wbufq, buf, 0); in _sx_websocket_http_return()
|
| H A D | sx.h | 301 jqueue_t wbufq; /* buffers waiting to go to wio */ member
|
| H A D | sasl.c | 456 ((sx_buf_t) s->wbufq->front->data)->notify = _sx_sasl_notify_success; in _sx_sasl_client_process()
457 ((sx_buf_t) s->wbufq->front->data)->notify_arg = (void *) p; in _sx_sasl_client_process()
|
| H A D | ssl.c | 221 …jqueue_push(s->wbufq, _sx_buffer_new("<proceed xmlns='" uri_TLS "'/>", strlen(uri_TLS) + 19, _sx_s… in _sx_ssl_process()
1177 …jqueue_push(s->wbufq, _sx_buffer_new("<starttls xmlns='" uri_TLS "'/>", strlen(uri_TLS) + 20, NULL… in sx_ssl_client_starttls()
|