/dports/graphics/openjpeg15/openjpeg-version.1.5.2/applications/jpip/libopenjpip/ |
H A D | imgsock_manager.c | 39 msgtype_t identify_clientmsg( SOCKET connected_socket) in identify_clientmsg() argument 48 receive_size = receive_line( connected_socket, buf); in identify_clientmsg() 126 send_stream( connected_socket, header, 5); in send_XMLstream() 127 send_stream( connected_socket, xmlstream, length); in send_XMLstream() 134 send_IDstream( connected_socket, cid, cidlen, "CID"); in send_CIDstream() 151 send_stream( connected_socket, header, 4); in send_IDstream() 152 send_stream( connected_socket, id, idlen); in send_IDstream() 170 send_stream( connected_socket, header, 7); in send_PNMstream() 171 send_stream( connected_socket, pnmstream, pnmlen); in send_PNMstream() 188 send_stream( connected_socket, responce, 9); in send_SIZstream() [all …]
|
H A D | dec_clientmsg_handler.c | 84 response_signal( connected_socket, true); in handle_JPIPstreamMSG() 105 receive_line( connected_socket, tmp); in handle_PNMreqMSG() 108 receive_line( connected_socket, tmp); in handle_PNMreqMSG() 127 cid = receive_string( connected_socket); in handle_XMLreqMSG() 149 target = receive_string( connected_socket); in handle_TIDreqMSG() 167 target = receive_string( connected_socket); in handle_CIDreqMSG() 185 cid = receive_string( connected_socket); in handle_dstCIDreqMSG() 187 response_signal( connected_socket, true); in handle_dstCIDreqMSG() 198 tid = receive_string( connected_socket); in handle_SIZreqMSG() 199 cid = receive_string( connected_socket); in handle_SIZreqMSG() [all …]
|
H A D | imgsock_manager.h | 47 msgtype_t identify_clientmsg( SOCKET connected_socket); 59 Byte_t * receive_JPIPstream( SOCKET connected_socket, char **target, char **tid, char **cid, int *s… 71 void send_PNMstream( SOCKET connected_socket, Byte_t *pnmstream, unsigned int width, unsigned int h… 80 void send_XMLstream( SOCKET connected_socket, Byte_t *xmlstream, int length); 89 void send_TIDstream( SOCKET connected_socket, char *tid, int tidlen); 98 void send_CIDstream( SOCKET connected_socket, char *cid, int cidlen); 107 void send_SIZstream( SOCKET connected_socket, unsigned int width, unsigned int height); 115 void response_signal( SOCKET connected_socket, bool succeed);
|
H A D | dec_clientmsg_handler.h | 49 void handle_JPIPstreamMSG( SOCKET connected_socket, cachelist_param_t *cachelist, Byte_t **jpipstre… 59 void handle_PNMreqMSG( SOCKET connected_socket, Byte_t *jpipstream, msgqueue_param_t *msgqueue, cac… 68 void handle_XMLreqMSG( SOCKET connected_socket, Byte_t *jpipstream, cachelist_param_t *cachelist); 76 void handle_TIDreqMSG( SOCKET connected_socket, cachelist_param_t *cachelist); 84 void handle_CIDreqMSG( SOCKET connected_socket, cachelist_param_t *cachelist); 92 void handle_dstCIDreqMSG( SOCKET connected_socket, cachelist_param_t *cachelist); 100 void handle_SIZreqMSG( SOCKET connected_socket, Byte_t *jpipstream, msgqueue_param_t *msgqueue, cac… 110 void handle_JP2saveMSG( SOCKET connected_socket, cachelist_param_t *cachelist, msgqueue_param_t *ms…
|
H A D | auxtrans_manager.c | 166 bool identify_cid( SOCKET connected_socket, char refcid[], FILE *fp); 168 bool recv_ack( SOCKET connected_socket, void *data); 176 SOCKET connected_socket; in aux_streaming() local 194 if( identify_cid( connected_socket, auxresponse->cid, FCGI_stderr)){ in aux_streaming() 208 send_stream( connected_socket, chunk, chunklen); in aux_streaming() 209 }while( !recv_ack( connected_socket, chunk)); in aux_streaming() 214 if( close_socket( connected_socket) != 0) in aux_streaming() 233 bool identify_cid( SOCKET connected_socket, char refcid[], FILE *fp) in identify_cid() argument 238 if(!(cid = receive_string( connected_socket))){ in identify_cid() 252 bool recv_ack( SOCKET connected_socket, void *data) in recv_ack() argument [all …]
|
H A D | sock_manager.c | 103 void send_stream( SOCKET connected_socket, void *stream, int length) in send_stream() argument 109 int sentlen = send( connected_socket, ptr, remlen, 0); in send_stream() 119 void * receive_stream( SOCKET connected_socket, int length) in receive_stream() argument 128 redlen = recv( connected_socket, ptr, remlen, 0); in receive_stream() 141 int receive_line(SOCKET connected_socket, char *p) in receive_line() argument 146 ret = recv( connected_socket, p, 1, 0); in receive_line() 166 char * receive_string( SOCKET connected_socket) in receive_string() argument 170 receive_line( connected_socket, buf); in receive_string()
|
H A D | sock_manager.h | 69 int receive_line(SOCKET connected_socket, char *buf); 77 char * receive_string( SOCKET connected_socket); 86 void * receive_stream( SOCKET connected_socket, int length); 95 void send_stream( SOCKET connected_socket, void *stream, int length);
|
/dports/graphics/openjpeg/openjpeg-2.4.0/src/lib/openjpip/ |
H A D | imgsock_manager.c | 39 msgtype_t identify_clientmsg(SOCKET connected_socket) in identify_clientmsg() argument 49 receive_size = receive_line(connected_socket, buf); in identify_clientmsg() 145 send_stream(connected_socket, header, 5); in send_XMLstream() 146 send_stream(connected_socket, xmlstream, length); in send_XMLstream() 154 send_IDstream(connected_socket, cid, cidlen, "CID"); in send_CIDstream() 172 send_stream(connected_socket, header, 4); in send_IDstream() 173 send_stream(connected_socket, id, idlen); in send_IDstream() 192 send_stream(connected_socket, header, 7); in send_PNMstream() 193 send_stream(connected_socket, pnmstream, pnmlen); in send_PNMstream() 211 send_stream(connected_socket, response, 9); in send_SIZstream() [all …]
|
H A D | dec_clientmsg_handler.c | 99 response_signal(connected_socket, OPJ_TRUE); in handle_JPIPstreamMSG() 112 CIDorTID = receive_string(connected_socket); in handle_PNMreqMSG() 122 receive_line(connected_socket, tmp); in handle_PNMreqMSG() 125 receive_line(connected_socket, tmp); in handle_PNMreqMSG() 149 cid = receive_string(connected_socket); in handle_XMLreqMSG() 171 target = receive_string(connected_socket); in handle_TIDreqMSG() 189 target = receive_string(connected_socket); in handle_CIDreqMSG() 207 cid = receive_string(connected_socket); in handle_dstCIDreqMSG() 221 tid = receive_string(connected_socket); in handle_SIZreqMSG() 222 cid = receive_string(connected_socket); in handle_SIZreqMSG() [all …]
|
H A D | dec_clientmsg_handler.h | 49 void handle_JPIPstreamMSG(SOCKET connected_socket, cachelist_param_t *cachelist, 60 void handle_PNMreqMSG(SOCKET connected_socket, Byte_t *jpipstream, 70 void handle_XMLreqMSG(SOCKET connected_socket, Byte_t *jpipstream, 79 void handle_TIDreqMSG(SOCKET connected_socket, cachelist_param_t *cachelist); 87 void handle_CIDreqMSG(SOCKET connected_socket, cachelist_param_t *cachelist); 95 void handle_dstCIDreqMSG(SOCKET connected_socket, cachelist_param_t *cachelist); 105 void handle_SIZreqMSG(SOCKET connected_socket, Byte_t *jpipstream, 116 void handle_JP2saveMSG(SOCKET connected_socket, cachelist_param_t *cachelist,
|
H A D | imgsock_manager.h | 47 msgtype_t identify_clientmsg(SOCKET connected_socket); 59 Byte_t * receive_JPIPstream(SOCKET connected_socket, char **target, char **tid, 72 void send_PNMstream(SOCKET connected_socket, Byte_t *pnmstream, 82 void send_XMLstream(SOCKET connected_socket, Byte_t *xmlstream, 92 void send_TIDstream(SOCKET connected_socket, const char *tid, 102 void send_CIDstream(SOCKET connected_socket, const char *cid, 112 void send_SIZstream(SOCKET connected_socket, unsigned int width, 121 void response_signal(SOCKET connected_socket, OPJ_BOOL succeed);
|
H A D | auxtrans_manager.c | 182 OPJ_BOOL identify_cid(SOCKET connected_socket, char refcid[], FILE *fp); 184 OPJ_BOOL recv_ack(SOCKET connected_socket, void *data); 192 SOCKET connected_socket; in aux_streaming() local 224 send_stream(connected_socket, chunk, chunklen); in aux_streaming() 225 } while (!recv_ack(connected_socket, chunk)); in aux_streaming() 230 if (close_socket(connected_socket) != 0) { in aux_streaming() 235 if (close_socket(connected_socket) != 0) { in aux_streaming() 253 OPJ_BOOL identify_cid(SOCKET connected_socket, char refcid[], FILE *fp) in identify_cid() argument 258 if (!(cid = receive_string(connected_socket))) { in identify_cid() 274 OPJ_BOOL recv_ack(SOCKET connected_socket, void *data) in recv_ack() argument [all …]
|
H A D | sock_manager.c | 104 void send_stream(SOCKET connected_socket, const void *stream, OPJ_SIZE_T length) in send_stream() argument 110 ssize_t sentlen = send(connected_socket, ptr, remlen, 0); in send_stream() 120 void * receive_stream(SOCKET connected_socket, OPJ_SIZE_T length) in receive_stream() argument 129 ssize_t redlen = recv(connected_socket, ptr, remlen, 0); in receive_stream() 142 OPJ_SIZE_T receive_line(SOCKET connected_socket, char *p) in receive_line() argument 147 ret = recv(connected_socket, p, 1, 0); in receive_line() 169 char * receive_string(SOCKET connected_socket) in receive_string() argument 175 receive_line(connected_socket, buf); in receive_string()
|
/dports/emulators/vice/vice-3.5/src/monitor/ |
H A D | monitor_network.c | 51 static vice_network_socket_t * connected_socket = NULL; variable 60 if (connected_socket) { in monitor_network_transmit() 75 vice_network_socket_close(connected_socket); in monitor_network_quit() 76 connected_socket = NULL; in monitor_network_quit() 84 if (!connected_socket) { in monitor_network_receive() 88 count = vice_network_receive(connected_socket, buffer, buffer_length, 0); in monitor_network_receive() 103 if (connected_socket != NULL) { in monitor_network_data_available() 104 available = vice_network_select_poll_one(connected_socket); in monitor_network_data_available() 109 connected_socket = vice_network_accept(listen_socket); in monitor_network_data_available() 387 return connected_socket; in monitor_get_connected_socket() [all …]
|
/dports/databases/xapian-core/xapian-core-1.4.18/net/ |
H A D | tcpserver.cc | 322 int connected_socket = accept_connection(); in run() local 328 handle_one_connection(connected_socket); in run() 329 close(connected_socket); in run() 342 close(connected_socket); in run() 346 close(connected_socket); in run() 413 int connected_socket; member 421 int socket = param->connected_socket; in run_thread() 445 int connected_socket = accept_connection(); in run() local 446 if (connected_socket == -1) in run() 453 thread_param *param = new thread_param(this, connected_socket); in run() [all …]
|
/dports/databases/xapian-core12/xapian-core-1.2.25/net/ |
H A D | tcpserver.cc | 278 int connected_socket = accept_connection(); in run_once() local 284 handle_one_connection(connected_socket); in run_once() 285 close(connected_socket); in run_once() 296 close(connected_socket); in run_once() 300 close(connected_socket); in run_once() 413 int connected_socket; member 421 int socket = param->connected_socket; in run_thread() 445 int connected_socket = accept_connection(); in run() local 446 if (connected_socket == -1) in run() 453 thread_param *param = new thread_param(this, connected_socket); in run() [all …]
|
/dports/devel/py-pyro/Pyro4-4.77/src/Pyro4/socketserver/ |
H A D | existingconnectionserver.py | 24 def init(self, daemon, connected_socket): argument 25 connected_socket.getpeername() # check that it is connected 26 if config.SSL and not isinstance(connected_socket, ssl.SSLSocket): 29 self.sock = connected_socket 30 log.info("starting server on user-supplied connected socket " + str(connected_socket)) 31 sn = connected_socket.getsockname() 32 if hasattr(socket, "AF_UNIX") and connected_socket.family == socket.AF_UNIX: 40 self.conn = socketutil.SocketConnection(connected_socket)
|
/dports/emulators/libretro-vice/vice-libretro-5725415/vice/src/monitor/ |
H A D | monitor_network.c | 54 static vice_network_socket_t * connected_socket = NULL; variable 66 if (connected_socket) { in monitor_network_transmit() 67 size_t len = vice_network_send(connected_socket, buffer, buffer_length, 0); in monitor_network_transmit() 81 vice_network_socket_close(connected_socket); in monitor_network_quit() 82 connected_socket = NULL; in monitor_network_quit() 90 if (!connected_socket) { in monitor_network_receive() 94 count = vice_network_receive(connected_socket, buffer, buffer_length, 0); in monitor_network_receive() 109 if (connected_socket != NULL) { in monitor_network_data_available() 110 available = vice_network_select_poll_one(connected_socket); in monitor_network_data_available() 115 connected_socket = vice_network_accept(listen_socket); in monitor_network_data_available() [all …]
|
/dports/devel/cargo-c/cargo-c-0.9.6+cargo-0.58/cargo-crates/libssh2-sys-0.2.23/libssh2/tests/ |
H A D | session_fixture.c | 62 int connected_socket = -1; variable 67 connected_socket = open_socket_to_openssh_server(); in connect_to_server() 68 if(connected_socket <= 0) { in connect_to_server() 72 rc = libssh2_session_handshake(connected_session, connected_socket); in connect_to_server() 151 shutdown(connected_socket, 2); in stop_session_fixture()
|
/dports/security/libssh2/libssh2-1.10.0/tests/ |
H A D | session_fixture.c | 62 int connected_socket = -1; variable 67 connected_socket = open_socket_to_openssh_server(); in connect_to_server() 68 if(connected_socket <= 0) { in connect_to_server() 72 rc = libssh2_session_handshake(connected_session, connected_socket); in connect_to_server() 151 shutdown(connected_socket, 2); in stop_session_fixture()
|
/dports/security/cargo-audit/rustsec-cargo-audit-v0.15.2/cargo-audit/cargo-crates/libssh2-sys-0.2.21/libssh2/tests/ |
H A D | session_fixture.c | 62 int connected_socket = -1; variable 67 connected_socket = open_socket_to_openssh_server(); in connect_to_server() 68 if(connected_socket <= 0) { in connect_to_server() 72 rc = libssh2_session_handshake(connected_session, connected_socket); in connect_to_server() 151 shutdown(connected_socket, 2); in stop_session_fixture()
|
/dports/devel/gbump/gbump-1.0.1/cargo-crates/libssh2-sys-0.2.13/libssh2/tests/ |
H A D | session_fixture.c | 62 int connected_socket = -1; variable 67 connected_socket = open_socket_to_openssh_server(); in connect_to_server() 68 if(connected_socket <= 0) { in connect_to_server() 72 rc = libssh2_session_handshake(connected_session, connected_socket); in connect_to_server() 151 shutdown(connected_socket, 2); in stop_session_fixture()
|
/dports/devel/cargo-generate/cargo-generate-0.9.0/cargo-crates/libssh2-sys-0.2.21/libssh2/tests/ |
H A D | session_fixture.c | 62 int connected_socket = -1; variable 67 connected_socket = open_socket_to_openssh_server(); in connect_to_server() 68 if(connected_socket <= 0) { in connect_to_server() 72 rc = libssh2_session_handshake(connected_session, connected_socket); in connect_to_server() 151 shutdown(connected_socket, 2); in stop_session_fixture()
|
/dports/devel/pijul/pijul-1.0.0.a55/cargo-crates/libssh2-sys-0.2.23/libssh2/tests/ |
H A D | session_fixture.c | 62 int connected_socket = -1; variable 67 connected_socket = open_socket_to_openssh_server(); in connect_to_server() 68 if(connected_socket <= 0) { in connect_to_server() 72 rc = libssh2_session_handshake(connected_session, connected_socket); in connect_to_server() 151 shutdown(connected_socket, 2); in stop_session_fixture()
|
/dports/lang/rust/rustc-1.58.1-src/vendor/libssh2-sys/libssh2/tests/ |
H A D | session_fixture.c | 62 int connected_socket = -1; variable 67 connected_socket = open_socket_to_openssh_server(); in connect_to_server() 68 if(connected_socket <= 0) { in connect_to_server() 72 rc = libssh2_session_handshake(connected_session, connected_socket); in connect_to_server() 151 shutdown(connected_socket, 2); in stop_session_fixture()
|