Home
last modified time | relevance | path

Searched refs:wsh (Results 1 – 25 of 305) sorted by relevance

12345678910>>...13

/dports/net/freeswitch/freeswitch-1.10.3.-release/src/mod/endpoints/mod_verto/
H A Dws.c268 …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 Dws.h117 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 Dws.c268 …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 Dws.h119 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 Dws.c268 …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 Dws.h122 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 Dws.c340 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 Dws.h77 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 Dnxt_h1proto_websocket.c167 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 Dnxt_h1proto_websocket.c167 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 Dnxt_h1proto_websocket.c167 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 Dnxt_h1proto_websocket.c167 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 Dnxt_h1proto_websocket.c167 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 Dnxt_h1proto_websocket.c167 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 Dmain.cpp72 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__.m30 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__.m29 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__.m22 ## 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__.m51 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 Dchknmrange.m17 …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__.m30 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__.m52 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__.m20 ## 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 Dmain.cpp31 auto wsh = in server_handler() local
35 [ &registry ]( 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 Dxls2oct.m21 ## 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 …]

12345678910>>...13