Home
last modified time | relevance | path

Searched refs:connected_socket (Results 1 – 25 of 127) sorted by relevance

123456

/dports/graphics/openjpeg15/openjpeg-version.1.5.2/applications/jpip/libopenjpip/
H A Dimgsock_manager.c39 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 Ddec_clientmsg_handler.c84 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 Dimgsock_manager.h47 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 Ddec_clientmsg_handler.h49 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 Dauxtrans_manager.c166 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 Dsock_manager.c103 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 Dsock_manager.h69 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 Dimgsock_manager.c39 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 Ddec_clientmsg_handler.c99 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 Ddec_clientmsg_handler.h49 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 Dimgsock_manager.h47 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 Dauxtrans_manager.c182 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 Dsock_manager.c104 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 Dmonitor_network.c51 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 Dtcpserver.cc322 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 Dtcpserver.cc278 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 Dexistingconnectionserver.py24 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 Dmonitor_network.c54 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 Dsession_fixture.c62 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 Dsession_fixture.c62 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 Dsession_fixture.c62 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 Dsession_fixture.c62 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 Dsession_fixture.c62 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 Dsession_fixture.c62 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 Dsession_fixture.c62 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()

123456