/dports/net/freeswitch/freeswitch-1.10.3.-release/src/mod/endpoints/mod_verto/ |
H A D | ws.c | 268 …while((bytes = ws_raw_read(wsh, wsh->buffer + wsh->datalen, wsh->buflen - wsh->datalen, WS_BLOCK))… in ws_handshake() 637 memset(wsh, 0, sizeof(*wsh)); in ws_init() 654 wsh->bbuflen = wsh->buflen; in ws_init() 792 wsh->body = wsh->bbuffer; in ws_read_frame() 814 if ((wsh->datalen = ws_raw_read(wsh, wsh->buffer, 9, wsh->block)) < 0) { in ws_read_frame() 822 ssize_t bytes = ws_raw_read(wsh, wsh->buffer + wsh->datalen, 9 - wsh->datalen, WS_BLOCK); in ws_read_frame() 880 more = ws_raw_read(wsh, wsh->buffer + wsh->datalen, need - wsh->datalen, WS_BLOCK); in ws_read_frame() 943 memcpy(wsh->body, wsh->payload, wsh->rplen); in ws_read_frame() 970 ws_write_frame(wsh, WSOC_PONG, wsh->body, wsh->rplen); in ws_read_frame() 975 wsh->packetlen += wsh->rplen; in ws_read_frame() [all …]
|
H A D | ws.h | 117 ssize_t ws_send_buf(wsh_t *wsh, ws_opcode_t oc); 118 ssize_t ws_feed_buf(wsh_t *wsh, void *data, size_t bytes); 121 ssize_t ws_raw_read(wsh_t *wsh, void *data, size_t bytes, int block); 122 ssize_t ws_raw_write(wsh_t *wsh, void *data, size_t bytes); 123 ssize_t ws_read_frame(wsh_t *wsh, ws_opcode_t *oc, uint8_t **data); 124 ssize_t ws_write_frame(wsh_t *wsh, ws_opcode_t oc, void *data, size_t bytes); 125 int ws_init(wsh_t *wsh, ws_socket_t sock, SSL_CTX *ssl_ctx, int close_sock, int block, int stay_ope… 126 ssize_t ws_close(wsh_t *wsh, int16_t reason); 127 void ws_destroy(wsh_t *wsh);
|
/dports/net/freeswitch/freeswitch-1.10.3.-release/libs/sofia-sip/libsofia-sip-ua/tport/ |
H A D | ws.c | 268 …while((bytes = ws_raw_read(wsh, wsh->buffer + wsh->datalen, wsh->buflen - wsh->datalen, WS_BLOCK))… in ws_handshake() 631 memset(wsh, 0, sizeof(*wsh)); in ws_init() 648 wsh->bbuflen = wsh->buflen; in ws_init() 773 wsh->body = wsh->bbuffer; in ws_read_frame() 795 if ((wsh->datalen = ws_raw_read(wsh, wsh->buffer, 9, wsh->block)) < 0) { in ws_read_frame() 803 ssize_t bytes = ws_raw_read(wsh, wsh->buffer + wsh->datalen, 9 - wsh->datalen, WS_BLOCK); in ws_read_frame() 861 more = ws_raw_read(wsh, wsh->buffer + wsh->datalen, need - wsh->datalen, WS_BLOCK); in ws_read_frame() 924 memcpy(wsh->body, wsh->payload, wsh->rplen); in ws_read_frame() 951 ws_write_frame(wsh, WSOC_PONG, wsh->body, wsh->rplen); in ws_read_frame() 956 wsh->packetlen += wsh->rplen; in ws_read_frame() [all …]
|
H A D | ws.h | 119 ssize_t ws_send_buf(wsh_t *wsh, ws_opcode_t oc); 120 ssize_t ws_feed_buf(wsh_t *wsh, void *data, size_t bytes); 122 int establish_logical_layer(wsh_t *wsh); 123 ssize_t ws_raw_read(wsh_t *wsh, void *data, size_t bytes, int block); 124 ssize_t ws_raw_write(wsh_t *wsh, void *data, size_t bytes); 125 ssize_t ws_read_frame(wsh_t *wsh, ws_opcode_t *oc, uint8_t **data); 126 ssize_t ws_write_frame(wsh_t *wsh, ws_opcode_t oc, void *data, size_t bytes); 127 int ws_init(wsh_t *wsh, ws_socket_t sock, SSL_CTX *ssl_ctx, int close_sock, int block, int stay_ope… 128 ssize_t ws_close(wsh_t *wsh, int16_t reason); 129 void ws_destroy(wsh_t *wsh);
|
/dports/net/sofia-sip/sofia-sip-1.13.4/libsofia-sip-ua/tport/ |
H A D | ws.c | 268 …while((bytes = ws_raw_read(wsh, wsh->buffer + wsh->datalen, wsh->buflen - wsh->datalen, WS_BLOCK))… in ws_handshake() 691 memset(wsh, 0, sizeof(*wsh)); in ws_init() 708 wsh->bbuflen = wsh->buflen; in ws_init() 833 wsh->body = wsh->bbuffer; in ws_read_frame() 855 if ((wsh->datalen = ws_raw_read(wsh, wsh->buffer, 9, wsh->block)) < 0) { in ws_read_frame() 863 ssize_t bytes = ws_raw_read(wsh, wsh->buffer + wsh->datalen, 9 - wsh->datalen, WS_BLOCK); in ws_read_frame() 921 more = ws_raw_read(wsh, wsh->buffer + wsh->datalen, need - wsh->datalen, WS_BLOCK); in ws_read_frame() 984 memcpy(wsh->body, wsh->payload, wsh->rplen); in ws_read_frame() 1011 ws_write_frame(wsh, WSOC_PONG, wsh->body, wsh->rplen); in ws_read_frame() 1016 wsh->packetlen += wsh->rplen; in ws_read_frame() [all …]
|
H A D | ws.h | 122 ssize_t ws_send_buf(wsh_t *wsh, ws_opcode_t oc); 123 ssize_t ws_feed_buf(wsh_t *wsh, void *data, size_t bytes); 125 int establish_logical_layer(wsh_t *wsh); 126 ssize_t ws_raw_read(wsh_t *wsh, void *data, size_t bytes, int block); 127 ssize_t ws_raw_write(wsh_t *wsh, void *data, size_t bytes); 128 ssize_t ws_read_frame(wsh_t *wsh, ws_opcode_t *oc, uint8_t **data); 129 ssize_t ws_write_frame(wsh_t *wsh, ws_opcode_t oc, void *data, size_t bytes); 130 int ws_init(wsh_t *wsh, ws_socket_t sock, SSL_CTX *ssl_ctx, int close_sock, int block, int stay_ope… 131 ssize_t ws_close(wsh_t *wsh, int16_t reason); 132 void ws_destroy(wsh_t *wsh);
|
/dports/net/freeswitch/freeswitch-1.10.3.-release/src/mod/xml_int/mod_xml_rpc/ |
H A D | ws.c | 340 memset(wsh, 0, sizeof(*wsh)); in ws_init() 342 wsh->buflen = sizeof(wsh->buffer); in ws_init() 406 if ((wsh->datalen = ws_raw_read(wsh, wsh->buffer, 14)) < need) { in ws_read_frame() 407 …while (!wsh->down && (wsh->datalen += ws_raw_read(wsh, wsh->buffer + wsh->datalen, 14 - wsh->datal… in ws_read_frame() 410 …if (0 && (wsh->datalen += ws_raw_read(wsh, wsh->buffer + wsh->datalen, 14 - wsh->datalen)) < need)… in ws_read_frame() 422 wsh->plen = wsh->buffer[1] & 0x7f; in ws_read_frame() 447 wsh->payload = &wsh->buffer[2]; in ws_read_frame() 494 wsh->rplen = wsh->plen - need; in ws_read_frame() 497 issize_t r = ws_raw_read(wsh, wsh->payload + wsh->rplen, need); in ws_read_frame() 520 ws_write_frame(wsh, WSOC_PONG, wsh->payload, wsh->rplen); in ws_read_frame() [all …]
|
H A D | ws.h | 77 issize_t ws_send_buf(wsh_t *wsh, ws_opcode_t oc); 78 issize_t ws_feed_buf(wsh_t *wsh, void *data, size_t bytes); 81 issize_t ws_raw_read(wsh_t *wsh, void *data, size_t bytes); 82 issize_t ws_raw_write(wsh_t *wsh, void *data, size_t bytes); 83 issize_t ws_read_frame(wsh_t *wsh, ws_opcode_t *oc, uint8_t **data); 84 issize_t ws_write_frame(wsh_t *wsh, ws_opcode_t oc, void *data, size_t bytes); 86 issize_t ws_close(wsh_t *wsh, int16_t reason); 87 void ws_destroy(wsh_t *wsh); 90 int ws_handshake_kvp(wsh_t *wsh, char *key, char *version, char *proto);
|
/dports/devel/libunit/unit-1.26.1/src/ |
H A D | nxt_h1proto_websocket.c | 167 nxt_websocket_header_t *wsh; in nxt_h1p_conn_ws_keepalive() local 193 wsh->fin = 1; in nxt_h1p_conn_ws_keepalive() 194 wsh->opcode = NXT_WEBSOCKET_OP_PING; in nxt_h1p_conn_ws_keepalive() 225 nxt_websocket_header_t *wsh; in nxt_h1p_conn_ws_frame_header_read() local 417 if (wsh->payload_len >= 2) { in nxt_h1p_conn_ws_frame_process() 548 nxt_websocket_header_t *wsh; in nxt_h1p_conn_ws_frame_payload_read() local 585 nxt_websocket_header_t *wsh; in hxt_h1p_send_ws_error() local 615 wsh->fin = 1; in hxt_h1p_send_ws_error() 651 nxt_websocket_header_t *wsh; in nxt_h1p_conn_ws_pong() local 660 payload_len = wsh->payload_len; in nxt_h1p_conn_ws_pong() [all …]
|
/dports/www/unit/unit-1.26.1/src/ |
H A D | nxt_h1proto_websocket.c | 167 nxt_websocket_header_t *wsh; in nxt_h1p_conn_ws_keepalive() local 193 wsh->fin = 1; in nxt_h1p_conn_ws_keepalive() 194 wsh->opcode = NXT_WEBSOCKET_OP_PING; in nxt_h1p_conn_ws_keepalive() 225 nxt_websocket_header_t *wsh; in nxt_h1p_conn_ws_frame_header_read() local 417 if (wsh->payload_len >= 2) { in nxt_h1p_conn_ws_frame_process() 548 nxt_websocket_header_t *wsh; in nxt_h1p_conn_ws_frame_payload_read() local 585 nxt_websocket_header_t *wsh; in hxt_h1p_send_ws_error() local 615 wsh->fin = 1; in hxt_h1p_send_ws_error() 651 nxt_websocket_header_t *wsh; in nxt_h1p_conn_ws_pong() local 660 payload_len = wsh->payload_len; in nxt_h1p_conn_ws_pong() [all …]
|
/dports/www/unit-php/unit-1.26.1/src/ |
H A D | nxt_h1proto_websocket.c | 167 nxt_websocket_header_t *wsh; in nxt_h1p_conn_ws_keepalive() local 193 wsh->fin = 1; in nxt_h1p_conn_ws_keepalive() 194 wsh->opcode = NXT_WEBSOCKET_OP_PING; in nxt_h1p_conn_ws_keepalive() 225 nxt_websocket_header_t *wsh; in nxt_h1p_conn_ws_frame_header_read() local 417 if (wsh->payload_len >= 2) { in nxt_h1p_conn_ws_frame_process() 548 nxt_websocket_header_t *wsh; in nxt_h1p_conn_ws_frame_payload_read() local 585 nxt_websocket_header_t *wsh; in hxt_h1p_send_ws_error() local 615 wsh->fin = 1; in hxt_h1p_send_ws_error() 651 nxt_websocket_header_t *wsh; in nxt_h1p_conn_ws_pong() local 660 payload_len = wsh->payload_len; in nxt_h1p_conn_ws_pong() [all …]
|
/dports/www/unit-python/unit-1.26.1/src/ |
H A D | nxt_h1proto_websocket.c | 167 nxt_websocket_header_t *wsh; in nxt_h1p_conn_ws_keepalive() local 193 wsh->fin = 1; in nxt_h1p_conn_ws_keepalive() 194 wsh->opcode = NXT_WEBSOCKET_OP_PING; in nxt_h1p_conn_ws_keepalive() 225 nxt_websocket_header_t *wsh; in nxt_h1p_conn_ws_frame_header_read() local 417 if (wsh->payload_len >= 2) { in nxt_h1p_conn_ws_frame_process() 548 nxt_websocket_header_t *wsh; in nxt_h1p_conn_ws_frame_payload_read() local 585 nxt_websocket_header_t *wsh; in hxt_h1p_send_ws_error() local 615 wsh->fin = 1; in hxt_h1p_send_ws_error() 651 nxt_websocket_header_t *wsh; in nxt_h1p_conn_ws_pong() local 660 payload_len = wsh->payload_len; in nxt_h1p_conn_ws_pong() [all …]
|
/dports/www/unit-java/unit-1.26.1/src/ |
H A D | nxt_h1proto_websocket.c | 167 nxt_websocket_header_t *wsh; in nxt_h1p_conn_ws_keepalive() local 193 wsh->fin = 1; in nxt_h1p_conn_ws_keepalive() 194 wsh->opcode = NXT_WEBSOCKET_OP_PING; in nxt_h1p_conn_ws_keepalive() 225 nxt_websocket_header_t *wsh; in nxt_h1p_conn_ws_frame_header_read() local 417 if (wsh->payload_len >= 2) { in nxt_h1p_conn_ws_frame_process() 548 nxt_websocket_header_t *wsh; in nxt_h1p_conn_ws_frame_payload_read() local 585 nxt_websocket_header_t *wsh; in hxt_h1p_send_ws_error() local 615 wsh->fin = 1; in hxt_h1p_send_ws_error() 651 nxt_websocket_header_t *wsh; in nxt_h1p_conn_ws_pong() local 660 payload_len = wsh->payload_len; in nxt_h1p_conn_ws_pong() [all …]
|
/dports/www/unit-perl/unit-1.26.1/src/ |
H A D | nxt_h1proto_websocket.c | 167 nxt_websocket_header_t *wsh; in nxt_h1p_conn_ws_keepalive() local 193 wsh->fin = 1; in nxt_h1p_conn_ws_keepalive() 194 wsh->opcode = NXT_WEBSOCKET_OP_PING; in nxt_h1p_conn_ws_keepalive() 225 nxt_websocket_header_t *wsh; in nxt_h1p_conn_ws_frame_header_read() local 417 if (wsh->payload_len >= 2) { in nxt_h1p_conn_ws_frame_process() 548 nxt_websocket_header_t *wsh; in nxt_h1p_conn_ws_frame_payload_read() local 585 nxt_websocket_header_t *wsh; in hxt_h1p_send_ws_error() local 615 wsh->fin = 1; in hxt_h1p_send_ws_error() 651 nxt_websocket_header_t *wsh; in nxt_h1p_conn_ws_pong() local 660 payload_len = wsh->payload_len; in nxt_h1p_conn_ws_pong() [all …]
|
/dports/net/arataga/restinio-v.0.6.13/dev/sample/websocket_detailed/ |
H A D | main.cpp | 72 void start( rws::ws_handle_t wsh ) in start() argument 74 m_wsh = std::move(wsh); in start() 92 wsh->send_message( in on_message() 101 wsh->send_message( pong ); in on_message() 109 const auto id = wsh->connection_id(); in on_message() 111 wsh->send_message( *m ); in on_message() 112 wsh->shutdown(); in on_message() 124 wsh->send_message( *m ); in on_message() 213 auto wsh = rws::upgrade< traits_t >( in server_handler() local 221 registry.emplace( wsh->connection_id(), handler ); in server_handler() [all …]
|
/dports/math/octave-forge-io/io-2.6.4/inst/private/ |
H A D | __OCT_oct2gnm__.m | 30 if (isnumeric (wsh)) 31 if (wsh < 1) 36 xls.sheets.sh_names(wsh) = sprintf ("Sheet%d", wsh); 40 elseif (ischar (wsh)) 44 xls.sheets.sh_names(end+1) = wsh; 48 wsh = idx; variable 55 wsh = 1; variable 63 wsh = numel (xls.sheets.sh_names); variable 71 idx_s = xls.sheets.shtidx(wsh); 72 idx_e = xls.sheets.shtidx(wsh+1) - 1; [all …]
|
H A D | __JOD_oct2spsh__.m | 29 if (isempty (wsh)) 30 wsh = 1; variable 33 if (isnumeric (wsh)) 34 if (wsh > 1024) 36 elseif (wsh > sh_cnt) 38 wsh, sh_cnt); 40 wsh = wsh - 1; variable 49 wsh = sprintf ("Sheet%d", wsh+1); variable 57 if (isempty (sh) && ischar (wsh)) 58 sh = ods.workbook.getSheet (wsh); [all …]
|
H A D | __COM_spsh2oct__.m | 22 ## Get cell contents in @var{range} in worksheet @var{wsh} in an Excel 50 if (size (wsh, 2) > 31) 52 wsh = wsh(1:31); variable 67 if (isnumeric (wsh)) 68 if (wsh < 1 || wsh > wb_cnt) 74 old_sh = wsh; 77 ## Find worksheet number corresponding to name in wsh 81 if (strcmp (sh_name, wsh)) 86 errstr = sprintf ("xls2oct: worksheet name \"%s\" not present", wsh); 89 wsh = old_sh; variable [all …]
|
H A D | __UNO_oct2spsh__.m | 51 if (isnumeric (wsh)); wsh = sprintf ("Sheet%d", wsh); endif 53 sh.queryInterface (unotmp).setName (wsh); 58 if (isnumeric (wsh)) 59 if (wsh < 1) 60 error ("oct2xls: illegal sheet index: %d", wsh); 61 elseif (wsh > numel (sh_names)) 80 wsh = shname; variable 84 wsh = sh_names {wsh}; variable 87 ## wsh is a sheet name. See if it exists already 88 if (isempty (find (strcmp (wsh, sh_names)))) [all …]
|
H A D | chknmrange.m | 17 …deftypefn {Function File} [ @var{range}, @var{wsh}, @var{xls}] = chkrange (@var{xls}, @var{range},… 26 function [datrange, wsh, xls] = chknmrange (xls, datrange, wsh) 41 if (isnumeric (wsh)) 47 elseif (ischar (wsh)) 48 jdx = find (strncmpi (wsh, xls.nmranges(idx, 2), numel (wsh))); 50 ## No match with specified wsh => just pick the first 53 datrange, wsh, xls.nmranges{idx, 2}); 65 wsh = xls.nmranges{idx, 2}; variable
|
H A D | __OCT_oct2ods__.m | 30 if (isnumeric (wsh)) 31 if (wsh < 1) 36 wsh = 1; variable 39 ods.sheets.sh_names(wsh) = sprintf ("Sheet%d", wsh); 43 elseif (ischar (wsh)) 48 ods.sheets.sh_names(1) = wsh; 52 ods.sheets.sh_names(end+1) = wsh; 57 wsh = idx; variable 66 wsh = numel (ods.sheets.sh_names); variable 72 idx_s = ods.sheets.shtidx(wsh); [all …]
|
H A D | __COM_oct2spsh__.m | 52 if (isnumeric (wsh)) 53 if (wsh < 1) error ("oct2xls: illegal worksheet number: %i\n", wsh); endif 54 elseif (size (wsh, 2) > 31) 104 if (isnumeric (wsh)) 105 if (wsh <= ws_cnt) 108 old_sh = wsh; 123 if (! isnumeric (wsh) && strcmp (sh_name, wsh)) 156 if (! isnumeric (wsh)) 157 sh.Name = wsh; 192 if (isnumeric (wsh)) [all …]
|
H A D | __OXS_spsh2oct__.m | 20 ## Get cell contents in @var{range} in worksheet @var{wsh} in an Excel 30 function [ rawarr, xls, rstatus ] = __OXS_spsh2oct__ (xls, wsh, cellrange, spsh_opts) 49 if (isnumeric (wsh)) 50 if (wsh > nr_of_sheets) 53 wsh, nr_of_sheets, xls.filename)); 55 sh = wb.getWorkSheet (wsh - 1); ## OXS sheet count 0-based 58 sh = wb.getWorkSheet (wsh); 60 error (sprintf ("xls2oct: worksheet %s not found in file %s", wsh, xls.filename)); 66 wsh = sh.getTabIndex (); variable 68 [firstrow, lastrow, lcol, rcol] = getusedrange (xls, wsh+1); [all …]
|
/dports/net/arataga/restinio-v.0.6.13/dev/sample/websocket/ |
H A D | main.cpp | 31 auto wsh = in server_handler() local 35 [ ®istry ]( auto wsh, auto m ){ in server_handler() argument 40 wsh->send_message( *m ); in server_handler() 46 wsh->send_message( resp ); in server_handler() 50 registry.erase( wsh->connection_id() ); in server_handler() 54 registry.emplace( wsh->connection_id(), wsh ); in server_handler()
|
/dports/math/octave-forge-io/io-2.6.4/inst/ |
H A D | xls2oct.m | 21 ## Read data contained within cell range @var{range} from worksheet @var{wsh} 27 ## @var{wsh} is either numerical or text, in the latter case it is 29 ## long. Note that in case of a numerical @var{wsh} this number refers to 38 ## in @var{wsh}. If no range is specified or is specified as an empty string 75 ## argument to be @var{wsh}. In that case xls2oct will try to read all 141 if (! (ischar (wsh) || isnumeric (wsh))) 142 error ("xls2oct: integer (index) or text (wsh name) expected for arg #2\n"); 143 elseif (isempty (wsh)) 144 wsh = 1; variable 153 [datrange, wsh, xls] = chknmrange (xls, datrange, wsh); [all …]
|