Home
last modified time | relevance | path

Searched refs:clientsock (Results 1 – 25 of 70) sorted by relevance

123

/dports/net/mptsd/mptsd-1.1/libfuncs/
H A Dhttp_response.c31 fdputs(clientsock,buf); in send_http_response()
43 send_header_textplain(clientsock); in send_http_error()
47 fdputs(clientsock,"\n"); in send_http_error()
51 void send_200_ok(int clientsock) { in send_200_ok() argument
56 send_200_ok(clientsock); in send_http_ok()
57 send_header_textplain(clientsock); in send_http_ok()
58 fdputs(clientsock, "\n"); in send_http_ok()
59 fdputs(clientsock, message); in send_http_ok()
60 fdputs(clientsock, "\n"); in send_http_ok()
70 send_http_ok(clientsock, msg); in send_http_ok_msg()
[all …]
H A Dhttp_response.h19 void send_header_textplain(int clientsock);
22 void send_http_ok(int clientsock, const char *message);
23 void send_http_ok_msg(int clientsock, const char *fmt, ...);
25 void send_200_ok(int clientsock);
26 void send_302_redirect(int clientsock, const char * url);
27 void send_400_bad_request(int clientsock, const char *msg);
29 void send_403_forbidden(int clientsock);
30 void send_404_not_found(int clientsock);
31 void send_409_conflict(int clientsock, const char * msg);
33 void send_501_not_implemented(int clientsock);
[all …]
/dports/databases/sqlrelay/sqlrelay-1.7.0/src/protocols/
H A Dsqlrclient.cpp270 clientsock=NULL; in sqlrprotocol_sqlrclient()
401 clientsock=cs; in clientSession()
857 clientsock->write(len); in noAvailableCursors()
1008 clientsock->write(idlen); in identifyCommand()
1108 clientsock->write(bflen); in bindFormatCommand()
1230 clientsock->write(id); in getLastInsertIdCommand()
3295 clientsock->write(type); in sendColumnDefinition()
3296 clientsock->write(size); in sendColumnDefinition()
3368 clientsock->write(size); in sendColumnDefinitionString()
3551 clientsock->write(size); in sendField()
[all …]
/dports/biology/protomol/protomol/framework/imd/
H A DIMDElf.cpp16 if (clientsock) in ~IMDElf()
17 vmdsock_destroy(clientsock); in ~IMDElf()
33 clientsock = 0; in hookup()
35 if (!clientsock) { in hookup()
46 if (!clientsock) { in hookup()
50 if (!connect(clientsock)) { in hookup()
53 clientsock = NULL; in hookup()
116 vmdsock_destroy(clientsock); in get_haptics()
117 clientsock = 0; in get_haptics()
131 clientsock = NULL; in get_haptics()
[all …]
/dports/net/mptsd/mptsd-1.1/
H A Dweb_server.c32 int clientsock; member
49 int clientsock; in web_server_thread() local
51 if (clientsock < 0) { in web_server_thread()
64 req->clientsock = clientsock; in web_server_thread()
91 int clientsock = req->clientsock; in process_web_request() local
107 if (fdgetline(clientsock,buf,BUF_SIZE)<=0) { in process_web_request()
114 send_501_not_implemented(clientsock); in process_web_request()
124 while (fdgetline(clientsock,buf,BUF_SIZE) > 0) { in process_web_request()
130 cmd_index(clientsock); in process_web_request()
132 cmd_reconnect(clientsock); in process_web_request()
[all …]
H A Dweb_pages.c34 void cmd_index(int clientsock) { in cmd_index() argument
35 send_200_ok(clientsock); in cmd_index()
36 send_header_textplain(clientsock); in cmd_index()
37 fdputs(clientsock, "\nHi from mptsd.\n"); in cmd_index()
40 void cmd_reconnect(int clientsock) { in cmd_reconnect() argument
41 send_200_ok(clientsock); in cmd_reconnect()
42 send_header_textplain(clientsock); in cmd_reconnect()
43 fdputsf(clientsock, "\nReconnecting %d inputs.\n", config->inputs->items); in cmd_reconnect()
/dports/devel/p5-IO-Async/IO-Async-0.800/t/
H A D24listener.t67 my $clientsock = IO::Socket::INET->new( Type => SOCK_STREAM )
70 $clientsock->connect( $listensock->sockname ) or die "Cannot connect() - $!";
72 ok( defined $clientsock->peername, '$clientsock is connected' );
104 my $clientsock = IO::Socket::INET->new( Type => SOCK_STREAM )
119 my $clientsock = IO::Socket::INET->new( Type => SOCK_STREAM )
143 my $clientsock = IO::Socket::INET->new( Type => SOCK_STREAM )
167 my $clientsock = IO::Socket::INET->new( Type => SOCK_STREAM )
225 ok( defined $clientsock->peername, 'subclass $clientsock is connected' );
257 my $clientsock = IO::Socket::INET->new( Type => SOCK_STREAM )
303 my $clientsock = IO::Socket::INET->new( Type => SOCK_STREAM )
[all …]
H A D52loop-listen.t54 my $clientsock = IO::Socket::INET->new( Type => SOCK_STREAM )
57 $clientsock->connect( $listensock->sockname ) or die "Cannot connect() - $!";
59 ok( defined $clientsock->peername, '$clientsock is connected' );
64 [ unpack_sockaddr_in $clientsock->sockname ], '$newclient peer is correct' );
100 my $clientsock = IO::Socket::INET->new( Type => SOCK_STREAM )
103 $clientsock->connect( $listenaddr ) or die "Cannot connect() - $!";
105 …is( (unpack_sockaddr_in( $clientsock->peername ))[0], $listenport, '$clientsock on the correct por…
112 [ unpack_sockaddr_in $clientsock->sockname ], '$newclient peer is correct' );
/dports/emulators/pcsxr/pcsxr-codeplex-final/pcsxr/plugins/bladesio1/
H A Dconnection.c44 static int clientsock = -1; variable
98 clientsock = -1; in connectionOpen()
99 while(clientsock < 0) in connectionOpen()
100 clientsock = accept(serversock, NULL, NULL); in connectionOpen()
112 clientsock = socket(AF_INET, SOCK_STREAM, 0); in connectionOpen()
113 if(clientsock == -1) { in connectionOpen()
140 if(clientsock >= 0) { in connectionClose()
142 clientsock = -1; in connectionClose()
160 if(clientsock >= 0) in connectionSend()
170 if(clientsock >= 0) in connectionRecv()
[all …]
/dports/devel/rudiments/rudiments-1.2.2/bench/
H A Dsocket.cpp88 filedescriptor *clientsock=NULL; in listen() local
91 clientsock=inetsock.accept(); in listen()
97 clientsock=unixsock.accept(); in listen()
99 if (!clientsock) { in listen()
119 clientsock->useAsyncWrite(); in listen()
150 clientsock-> in listen()
173 if (clientsock->read(bytes, in listen()
196 clientsock-> in listen()
220 if (clientsock->write(bytes, in listen()
237 clientsock->close(); in listen()
[all …]
H A Dinetsocketserver.cpp49 filedescriptor *clientsock=accept(); in listen() local
50 clientsock->allowShortReads(); in listen()
51 clientsock->setReadBufferSize(buffersize); in listen()
55 while (clientsock->read(&buffer)>0) {} in listen()
58 clientsock->close(); in listen()
59 delete clientsock; in listen()
/dports/dns/kadnode/KadNode-2.3.0/src/
H A Dext-nss.c23 static void nss_client_handler(int rc, int clientsock) in nss_client_handler() argument
36 rc = recv(clientsock, &req, sizeof(req), 0); in nss_client_handler()
85 write(clientsock, &res, sizeof(res)); in nss_client_handler()
88 close(clientsock); in nss_client_handler()
89 net_remove_handler(clientsock, &nss_client_handler); in nss_client_handler()
95 int clientsock; in nss_server_handler() local
103 clientsock = accept(serversock, (struct sockaddr *) &addr, &addrlen); in nss_server_handler()
104 if (clientsock < 0) { in nss_server_handler()
109 net_add_handler(clientsock, &nss_client_handler); in nss_server_handler()
H A Dext-cmd.c238 static void cmd_client_handler(int rc, int clientsock) in cmd_client_handler() argument
248 size = recv(clientsock, request, sizeof(request) - 1, 0); in cmd_client_handler()
253 fp = fdopen(clientsock, "w"); in cmd_client_handler()
262 close(clientsock); in cmd_client_handler()
265 net_remove_handler(clientsock, &cmd_client_handler); in cmd_client_handler()
271 int clientsock; in cmd_server_handler() local
279 clientsock = accept(serversock, (struct sockaddr *) &addr, &addrlen); in cmd_server_handler()
280 if (clientsock < 0) { in cmd_server_handler()
285 net_add_handler(clientsock, &cmd_client_handler); in cmd_server_handler()
/dports/devel/log4cplus/log4cplus-1.1.2/loggingserver/
H A Dloggingserver.cxx36 ClientThread(log4cplus::helpers::Socket clientsock) in ClientThread() argument
37 : clientsock(clientsock) in ClientThread()
50 log4cplus::helpers::Socket clientsock; member in loggingserver::ClientThread
97 if(!clientsock.isOpen()) { in run()
101 if(!clientsock.read(msgSizeBuffer)) { in run()
108 if(!clientsock.read(buffer)) { in run()
/dports/devel/rudiments/rudiments-1.2.2/test/
H A Dlistener.cpp53 filedescriptor *clientsock=NULL; in listen() local
55 clientsock=inetsock.accept(); in listen()
57 clientsock=unixsock.accept(); in listen()
59 test("listener - accept",clientsock); in listen()
64 ssize_t readlen=clientsock->read(buffer,4); in listen()
75 ssize_t writelen=clientsock->write("listener",8); in listen()
79 test("listener - close",clientsock->close()); in listen()
80 delete clientsock; in listen()
H A Dhandoff.cpp70 inetsocketclient *clientsock= in handoff1() local
79 handoffclientsock->passSocket(clientsock->getFileDescriptor())); in handoff1()
119 inetsocketclient clientsock; in handoff2() local
120 clientsock.setFileDescriptor(sock); in handoff2()
121 test("handoff2 - write to socket",clientsock.write("hello",5)==5); in handoff2()
122 test("handoff2 - close",clientsock.close()); in handoff2()
/dports/databases/sqlrelay/sqlrelay-1.7.0/src/server/
H A Dsqlrlistener.cpp1137 if (!clientsock) { in handleTraffic()
1143 if (!clientsock) { in handleTraffic()
1149 if (!clientsock) { in handleTraffic()
1181 if (!clientsock) { in handleTraffic()
1189 delete clientsock; in handleTraffic()
1199 if (!clientsock) { in handleTraffic()
1387 clientsock->write(err); in errorClientSession()
1392 delete clientsock; in errorClientSession()
1435 csa->clientsock=clientsock; in forkChild()
1497 delete clientsock; in forkChild()
[all …]
/dports/sysutils/py-execnet/execnet-1.6.0/execnet/script/
H A Dshell.py44 def __init__(self, clientsock): argument
47 self.clientsock = clientsock
51 clientfile = self.clientsock.makefile('w')
53 filein = self.clientsock.makefile('r')
54 loc = self.clientsock.getsockname()
80 self.clientsock.close()
/dports/databases/sqlrelay/sqlrelay-1.7.0/src/server/sqlrelay/private/
H A Dsqlrlistener.h30 bool deniedIp(filedescriptor *clientsock);
31 void forkChild(filedescriptor *clientsock,
34 void clientSession(filedescriptor *clientsock,
37 void errorClientSession(filedescriptor *clientsock,
63 filedescriptor *clientsock);
73 filedescriptor *clientsock);
/dports/science/lammps/lammps-stable_29Sep2021/src/MISC/
H A Dfix_imd.cpp496 clientsock = nullptr; in FixIMD()
514 clientsock = nullptr; in FixIMD()
584 imdsock_shutdown(clientsock); in ~FixIMD()
585 imdsock_destroy(clientsock); in ~FixIMD()
588 clientsock=nullptr; in ~FixIMD()
622 if (clientsock) return 1; in reconnect()
631 clientsock = nullptr; in reconnect()
794 if (clientsock && imdsock_selwrite(clientsock,0)) { in ioworker()
861 clientsock = nullptr; in post_force()
879 clientsock = nullptr; in post_force()
[all …]
/dports/japanese/skkserv/skk-9.6/skkserv/
H A Dskkserv.c127 int clientsock[MAXCLNT]; /* socket for each client */ variable
563 write(clientsock[--nclients], SERVER_FULL, 1); in main_loop()
564 close(clientsock[nclients]); in main_loop()
570 if (FD_ISSET(clientsock[i], &readfds)) { in main_loop()
571 if (search(clientsock[i]) < 0) { in main_loop()
573 close(clientsock[i]); in main_loop()
574 clientsock[i] = clientsock[nclients - 1]; in main_loop()
606 if (clientsock[i] > 0) { in getrfds()
607 FD_SET(clientsock[i], &r.fds); in getrfds()
608 if (clientsock[i] > r.maxfd) in getrfds()
[all …]
/dports/devel/rudiments/rudiments-1.2.2/src/
H A Dinetsocketserver.cpp200 int32_t clientsock; in accept() local
203 clientsock=::accept(fd(), in accept()
206 } while (clientsock==-1 && error::getErrorNumber()==EINTR); in accept()
207 if (clientsock==-1) { in accept()
212 returnsock->setFileDescriptor(clientsock); in accept()
H A Dunixsocketserver.cpp196 int32_t clientsock; in accept()
199 clientsock=::accept(fd(), in accept()
203 } while (clientsock==-1 && error::getErrorNumber()==EINTR); in accept()
204 if (clientsock==-1) { in accept()
209 returnsock->setFileDescriptor(clientsock); in accept()
/dports/sysutils/symon/symon-2.88/symux/
H A Dshare.c93 int clientsock; /* connected client */ variable
219 close(clientsock); in client_waitread()
300 clientsock = 0; in spawn_client()
302 clientsock = accept_connection(sock); in spawn_client()
315 close(clientsock); in spawn_client()
425 … if ((written = write(clientsock, (char *) (shared_getmem(slot) + sent), total - sent)) == -1) { in client_loop()
/dports/benchmarks/tsung/tsung-1.7.0/src/tsung_recorder/
H A Dts_client_proxy.erl83 {ok, #proxy{clientsock=Socket, plugin=?config(plugin),
107 handle_cast({set_active}, State=#proxy{clientsock=Socket}) ->
123 when ClientSock == State#proxy.clientsock ->
134 send(State#proxy.clientsock, NewData, Plugin),
210 sockname(Socket,#proxy{clientsock=Socket})-> client;

123