/dports/net/mptsd/mptsd-1.1/libfuncs/ |
H A D | http_response.c | 31 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 D | http_response.h | 19 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 D | sqlrclient.cpp | 270 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 D | IMDElf.cpp | 16 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 D | web_server.c | 32 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 D | web_pages.c | 34 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 D | 24listener.t | 67 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 D | 52loop-listen.t | 54 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 D | connection.c | 44 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 D | socket.cpp | 88 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 D | inetsocketserver.cpp | 49 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 D | ext-nss.c | 23 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 D | ext-cmd.c | 238 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 D | loggingserver.cxx | 36 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 D | listener.cpp | 53 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 D | handoff.cpp | 70 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 D | sqlrlistener.cpp | 1137 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 D | shell.py | 44 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 D | sqlrlistener.h | 30 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 D | fix_imd.cpp | 496 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 D | skkserv.c | 127 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 D | inetsocketserver.cpp | 200 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 D | unixsocketserver.cpp | 196 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 D | share.c | 93 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 D | ts_client_proxy.erl | 83 {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;
|