/dports/net/nylon/nylon-1.21/src/ |
H A D | socks5.c | 60 socks5_negotiate(int clisock, struct conndesc *conn) in socks5_negotiate() argument 78 if (atomicio(read, clisock, &nmethods, 1) != 1) { in socks5_negotiate() 87 if (atomicio(read, clisock, &junk, 1) != 1) { in socks5_negotiate() 100 if (atomicio(write, clisock, &rep5, 2) != 2) { in socks5_negotiate() 106 if (atomicio(read, clisock, &req5, 4) != 4) { in socks5_negotiate() 125 if (atomicio(read, clisock, &len, 1) != 1) { in socks5_negotiate() 129 if (atomicio(read, clisock, hostname, len) != len) { in socks5_negotiate() 166 return (socks5_bind(clisock, &rem_in, &req5)); in socks5_negotiate() 204 if (atomicio(write, clisock, req5, 10) != 10) { in socks5_connect() 245 if (atomicio(write, clisock, req5, 10) != 10) in socks5_bind() [all …]
|
H A D | socks4.c | 64 socks4_negotiate(int clisock, struct conndesc *conn) in socks4_negotiate() argument 79 if (atomicio(read, clisock, &hdr4.cd, 7) != 7) in socks4_negotiate() 94 while ((ret = atomicio(read, clisock, &data, 1)) == 1 && data != 0); in socks4_negotiate() 107 if (_getstr(clisock, hostname, sizeof(hostname)) < 0) in socks4_negotiate() 124 return (_socks4_tryconnect(clisock, &rem_in, &hdr4, conn)); in socks4_negotiate() 128 _socks4_tryconnect(int clisock, struct sockaddr_in *rem_in, in _socks4_tryconnect() argument 171 if (atomicio(write, clisock, hdr4, sizeof(*hdr4)) != sizeof(*hdr4)) in _socks4_tryconnect()
|
H A D | net.c | 245 int clisock, remsock; in net_accept() local 266 close(clisock); in net_accept() 283 if (net_setup_proxy(clisock, remsock) == -1) { in net_accept() 295 close(clisock); in net_accept() 301 net_setup_proxy(int clisock, int remsock) in net_setup_proxy() argument 313 clidesc->sock = clisock; in net_setup_proxy() 316 if (fcntl(clisock, F_SETFL, O_NONBLOCK) == -1) { in net_setup_proxy() 384 net_negotiate(int clisock, struct conndesc *conn) in net_negotiate() argument 394 if (atomicio(read, clisock, &vn, 1) != 1) { in net_negotiate() 406 remsock = socks4_negotiate(clisock, conn); in net_negotiate() [all …]
|
/dports/net/seda/seda-release-20020712/seda/src/seda/nbio/test/test/ |
H A D | NBIOSelectServer.java | 44 NonblockingSocket clisock = null; in main() local 54 clisock = s.nbAccept(); in main() 55 if (clisock == null) throw new IOException("Got ACCEPT_READY but no connection?"); in main() 57 } while (clisock == null); in main() 59 selitem = new SelectItem(clisock, Selectable.READ_READY); in main() 62 System.err.println("Got connection from "+clisock.getInetAddress().getHostName()); in main() 63 InputStream is = clisock.getInputStream(); in main()
|
H A D | BlockingServer.java | 41 Socket clisock = s.accept(); in main() local 43 System.err.println("Got connection from "+clisock.getInetAddress().getHostName()); in main() 44 InputStream is = clisock.getInputStream(); in main()
|
H A D | NBIOServer.java | 41 NonblockingSocket clisock = s.accept(); in main() local 43 System.err.println("Got connection from "+clisock.getInetAddress().getHostName()); in main() 44 InputStream is = clisock.getInputStream(); in main()
|
/dports/net/seda/seda-release-20020712/seda/src/seda/sandStorm/lib/aSocket/ |
H A D | ATcpConnectRequest.java | 37 public ATcpClientSocket clisock; field in ATcpConnectRequest 44 public ATcpConnectRequest(ATcpClientSocket clisock, InetAddress addr, int port, in ATcpConnectRequest() argument 46 this.clisock = clisock; in ATcpConnectRequest()
|
/dports/net/3proxy/3proxy-0.9.4/src/ |
H A D | pop3p.c | 18 …if(socksend(param->clisock, (unsigned char *)"+OK Proxy\r\n", 11, conf.timeouts[STRING_S])!=11) {R… in pop3pchild() 22 socksend(param->clisock, (unsigned char *)"+OK\r\n", 5,conf.timeouts[STRING_S]); in pop3pchild() 25 …socksend(param->clisock, (unsigned char *)"-ERR need USER first\r\n", 22, conf.timeouts[STRING_S])… in pop3pchild() 55 if(param->clisock != INVALID_SOCKET) { in pop3pchild() 56 …am->res < 100) || (param->res > 611 && param->res <700)) socksend(param->clisock, (unsigned char *… in pop3pchild()
|
H A D | smtpp.c | 33 socksend(param->clisock, buf, i, conf.timeouts[STRING_S]); in readreply() 104 …if(socksend(param->clisock, (unsigned char *)"220 Proxy\r\n", 11, conf.timeouts[STRING_S])!=11) {R… in smtppchild() 108 socksend(param->clisock, (unsigned char *)"221 Proxy\r\n", 11,conf.timeouts[STRING_S]); in smtppchild() 112 socksend(param->clisock, (unsigned char *)"250 Proxy\r\n", 11,conf.timeouts[STRING_S]); in smtppchild() 115 socksend(param->clisock, (unsigned char *)ehlo, sizeof(ehlo) - 1,conf.timeouts[STRING_S]); in smtppchild() 117 …else if(!param->hostname) socksend(param->clisock, (unsigned char *)"571 need AUTH first\r\n", 22,… in smtppchild() 128 socksend(param->clisock, (unsigned char *)"334 VXNlcm5hbWU6\r\n", 18,conf.timeouts[STRING_S]); in smtppchild() 136 socksend(param->clisock, (unsigned char *)"334 UGFzc3dvcmQ6\r\n", 18,conf.timeouts[STRING_S]); in smtppchild() 152 socksend(param->clisock, (unsigned char *)"334\r\n", 5,conf.timeouts[STRING_S]); in smtppchild() 207 socksend(param->clisock, (unsigned char *)"235 auth required\r\n", 19,conf.timeouts[STRING_S]); in smtppchild() [all …]
|
H A D | udppm.c | 59 if((param->clisock=so._socket(SASOCK(¶m->sincr), SOCK_DGRAM, IPPROTO_UDP)) == INVALID_SOCKET) { in udppmchild() 62 …if(so._setsockopt(param->clisock, SOL_SOCKET, SO_REUSEADDR, (char *)&ul, sizeof(int))) {RETURN(820… in udppmchild() 63 ioctlsocket(param->clisock, FIONBIO, &ul); in udppmchild() 66 if(so._bind(param->clisock,(struct sockaddr *)¶m->sinsl,SASIZE(¶m->sinsl))) { in udppmchild() 70 param->clisock = param->srv->srvsock; in udppmchild() 104 param->clisock = INVALID_SOCKET; in udppmchild()
|
H A D | socks.c | 57 if(socksend(param->clisock, buf, 2, conf.timeouts[STRING_S])!=2){RETURN(401);} in sockschild() 73 if(socksend(param->clisock, buf, 2, conf.timeouts[STRING_S])!=2){RETURN(481);} in sockschild() 218 param->ctrlsock = param->clisock; in sockschild() 219 param->clisock = so._socket(SASOCK(¶m->sincr), SOCK_DGRAM, IPPROTO_UDP); in sockschild() 220 if(param->clisock == INVALID_SOCKET) {RETURN(11);} in sockschild() 236 if(param->clisock != INVALID_SOCKET){ in sockschild() 241 else so._getsockname(param->clisock, (struct sockaddr *)&sin, &sasize); in sockschild() 272 socksend(param->clisock, buf, 8, conf.timeouts[STRING_S]); in sockschild() 288 fds[1].fd = param->clisock; in sockschild() 325 socksend(param->clisock, buf, 8, conf.timeouts[STRING_S]); in sockschild() [all …]
|
H A D | dnspr.c | 46 if((param->clisock=so._socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP)) == INVALID_SOCKET) { in dnsprchild() 49 ioctlsocket(param->clisock, FIONBIO, &ul); in dnsprchild() 50 …if(so._setsockopt(param->clisock, SOL_SOCKET, SO_REUSEADDR, (char *)&ul, sizeof(int))) {RETURN(820… in dnsprchild() 51 if(so._bind(param->clisock,(struct sockaddr *)¶m->sincl,SASIZE(¶m->sincl))) { in dnsprchild() 56 param->clisock = param->srv->srvsock; in dnsprchild() 177 …if(socksendto(param->clisock, (struct sockaddr *)¶m->sincr, buf, len, conf.timeouts[SINGLEBYTE… in dnsprchild() 188 …res = socksendto(param->clisock, (struct sockaddr *)¶m->sincr, buf, len, conf.timeouts[SINGLEB… in dnsprchild() 206 param->clisock = INVALID_SOCKET; in dnsprchild()
|
H A D | proxy.c | 252 fds[0].fd = param->clisock; in proxychild() 411 socksend(param->clisock, buf, (int)strlen((char *)buf), conf.timeouts[STRING_S]); in proxychild() 786 if((unsigned)socksend(param->clisock, buf, inbuf, conf.timeouts[STRING_S]) != inbuf){ in proxychild() 815 socksend(param->clisock, (unsigned char *)ftpbuf, (int)strlen(ftpbuf), conf.timeouts[STRING_S]); in proxychild() 817 socksend(param->clisock, buf, inbuf, conf.timeouts[STRING_S]); in proxychild() 827 …socksend(param->clisock, (unsigned char *)proxy_stringtable[8], (int)strlen(proxy_stringtable[8]),… in proxychild() 1045 …if((socksend(param->clisock, buf, (int)strlen((char *)buf), conf.timeouts[STRING_S])) != (int)strl… in proxychild() 1054 if (socksend(param->clisock, smallbuf, i, conf.timeouts[STRING_S]) != i){ in proxychild() 1063 if (socksend(param->clisock, smallbuf, i, conf.timeouts[STRING_S]) != i){ in proxychild() 1068 if (socksend(param->clisock, smallbuf, i, conf.timeouts[STRING_S]) != i){ in proxychild() [all …]
|
H A D | ftppr.c | 28 param->ctrlsock = param->clisock; in ftpprchild() 252 param->clisock = clidatasock; in ftpprchild() 258 if(param->clisock != INVALID_SOCKET) { in ftpprchild() 259 so._shutdown (param->clisock, SHUT_RDWR); in ftpprchild() 260 so._closesocket(param->clisock); in ftpprchild() 262 param->clisock = param->ctrlsock; in ftpprchild()
|
/dports/net/seda/seda-release-20020712/seda/src/seda/sandStorm/lib/aSocket/nbio/ |
H A D | ConnectSockState.java | 63 this.clisock = req.clisock; in ConnectSockState() 72 …compQ.enqueue_lossy(new ATcpConnectFailedEvent(clisock, "Got error trying to connect: "+ioe.getMes… in ConnectSockState() 88 conn = new ATcpConnection(clisock, nbsock.getInetAddress(), nbsock.getPort()); in complete() 127 error(new ATcpConnectFailedEvent(clisock, "Got error trying to connect: "+ioe.getMessage())); in complete()
|
/dports/security/sslproxy/SSLproxy-0.9.2/src/ |
H A D | privsep.c | 783 if (sys_sendmsgfd(clisock, req, sizeof(req), -1) == -1) { in privsep_client_openfile() 820 privsep_client_opensock(int clisock, const proxyspec_t *spec) in privsep_client_opensock() argument 833 if (sys_sendmsgfd(clisock, req, sizeof(req), -1) == -1) { in privsep_client_opensock() 870 privsep_client_certfile(int clisock, const char *fn) in privsep_client_certfile() argument 883 if (sys_sendmsgfd(clisock, req, sizeof(req), -1) == -1) { in privsep_client_certfile() 920 privsep_client_close(int clisock) in privsep_client_close() argument 926 if (sys_sendmsgfd(clisock, req, sizeof(req), -1) == -1) { in privsep_client_close() 927 close(clisock); in privsep_client_close() 931 close(clisock); in privsep_client_close() 948 if (sys_sendmsgfd(clisock, req, sizeof(req), -1) == -1) { in privsep_client_update_atime() [all …]
|
H A D | proxy.c | 153 , evutil_socket_t clisock in proxy_conn_ctx_new() argument 196 ctx->clisock = clisock; in proxy_conn_ctx_new() 253 , lctx->clisock in proxy_listener_acceptcb() 327 proxyspec_t *spec, global_t *global, evutil_socket_t clisock) in proxy_listener_setup() argument 332 if ((fd = privsep_client_opensock(clisock, spec)) == -1) { in proxy_listener_setup() 346 lctx->clisock = clisock; in proxy_listener_setup() 421 proxy_new(global_t *global, int clisock) in proxy_new() argument 489 spec, global, clisock); in proxy_new() 512 privsep_client_close(clisock); in proxy_new()
|
/dports/security/sslsplit/sslsplit-0.5.5/ |
H A D | privsep.c | 703 privsep_client_openfile(int clisock, const char *fn, int mkpath) in privsep_client_openfile() argument 716 if (sys_sendmsgfd(clisock, req, sizeof(req), -1) == -1) { in privsep_client_openfile() 753 privsep_client_opensock(int clisock, const proxyspec_t *spec) in privsep_client_opensock() argument 766 if (sys_sendmsgfd(clisock, req, sizeof(req), -1) == -1) { in privsep_client_opensock() 803 privsep_client_certfile(int clisock, const char *fn) in privsep_client_certfile() argument 816 if (sys_sendmsgfd(clisock, req, sizeof(req), -1) == -1) { in privsep_client_certfile() 853 privsep_client_close(int clisock) in privsep_client_close() argument 859 if (sys_sendmsgfd(clisock, req, sizeof(req), -1) == -1) { in privsep_client_close() 860 close(clisock); in privsep_client_close() 864 close(clisock); in privsep_client_close() [all …]
|
H A D | proxy.c | 166 proxyspec_t *spec, opts_t *opts, int clisock) in proxy_listener_setup() argument 171 if ((fd = privsep_client_opensock(clisock, spec)) == -1) { in proxy_listener_setup() 255 proxy_new(opts_t *opts, int clisock) in proxy_new() argument 323 spec, opts, clisock); in proxy_new() 344 privsep_client_close(clisock); in proxy_new()
|
/dports/net/seda/seda-release-20020712/seda/src/seda/sandStorm/lib/aSocket/nio/ |
H A D | ConnectSockState.java | 68 this.clisock = req.clisock; in ConnectSockState() 80 …compQ.enqueue_lossy(new ATcpConnectFailedEvent(clisock, "Got error trying to connect: "+ioe.getMes… in ConnectSockState() 99 … conn = new ATcpConnection(clisock, nio_sc.socket().getInetAddress(), nio_sc.socket().getPort()); in complete() 137 error(new ATcpConnectFailedEvent(clisock, "Got error trying to connect: "+ioe.getMessage())); in complete()
|
/dports/security/sslproxy/SSLproxy-0.9.2/tests/testproxy/lp/ |
H A D | privsep.c | 601 privsep_client_openfile(int clisock, const char *fn, int mkpath) in privsep_client_openfile() argument 614 if (sys_sendmsgfd(clisock, req, sizeof(req), -1) == -1) { in privsep_client_openfile() 618 if ((n = sys_recvmsgfd(clisock, ans, sizeof(ans), &fd)) == -1) { in privsep_client_openfile() 651 privsep_client_opensock(int clisock, const proxyspec_t *spec) in privsep_client_opensock() argument 664 if (sys_sendmsgfd(clisock, req, sizeof(req), -1) == -1) { in privsep_client_opensock() 701 privsep_client_close(int clisock) in privsep_client_close() argument 707 if (sys_sendmsgfd(clisock, req, sizeof(req), -1) == -1) { in privsep_client_close() 708 close(clisock); in privsep_client_close() 712 close(clisock); in privsep_client_close() 724 privsep_fork(opts_t *opts, int clisock[], size_t nclisock) in privsep_fork() argument [all …]
|
H A D | main.c | 364 int clisock[6]; in main() local 365 if (privsep_fork(opts, clisock, in main() 366 sizeof(clisock)/sizeof(clisock[0])) != 0) { in main() 381 proxy_ctx_t *proxy = proxy_new(opts, clisock[0]); in main() 399 if (log_init(opts, proxy, &clisock[1]) == -1) { in main()
|
H A D | proxy.c | 252 proxyspec_t *spec, opts_t *opts, evutil_socket_t clisock) in proxy_listener_setup() argument 257 if ((fd = privsep_client_opensock(clisock, spec)) == -1) { in proxy_listener_setup() 325 proxy_new(opts_t *opts, int clisock) in proxy_new() argument 366 spec, opts, clisock); in proxy_new() 389 privsep_client_close(clisock); in proxy_new()
|
/dports/net/seda/seda-release-20020712/seda/src/seda/sandStorm/lib/Gnutella/ |
H A D | GnutellaServer.java | 60 private ATcpClientSocket clisock; field in GnutellaServer 132 clisock = new ATcpClientSocket(hostname, port, mySink, WRITE_CLOG_THRESHOLD, -1); in init() 150 … ATcpClientSocket clisock = new ATcpClientSocket(hostname, port, mySink, WRITE_CLOG_THRESHOLD, -1); in openConnection() local 151 pendingConnTable.put(clisock, clisock); in openConnection() 161 … ATcpClientSocket clisock = new ATcpClientSocket(address, port, mySink, WRITE_CLOG_THRESHOLD, -1); in openConnection() local 162 pendingConnTable.put(clisock, clisock); in openConnection()
|
/dports/shells/bash/bash-5.1/examples/loadables/ |
H A D | accept.c | 53 int servsock, clisock; local 166 if ((clisock = accept (servsock, (struct sockaddr *)&client, &clientlen)) < 0) 175 accept_bind_variable (fdvar, clisock);
|