/dports/net/nxproxy/nx-libs-3.5.99.20-1/nxcomp/src/ |
H A D | ClientProxy.cpp | 108 return handleNewXConnection(clientFd); in handleNewConnection() 128 return handleNewSlaveConnection(clientFd); in handleNewConnection() 193 int clientFd = agent -> getLocalFd(); in handleNewAgentConnection() local 195 int channelId = allocateChannelMap(clientFd); in handleNewAgentConnection() 214 return handleNewXConnection(clientFd); in handleNewAgentConnection() 217 int ClientProxy::handleNewXConnection(int clientFd) in handleNewXConnection() argument 219 int channelId = getChannel(clientFd); in handleNewXConnection() 228 channelId = allocateChannelMap(clientFd); in handleNewXConnection() 245 *logofs << "ClientProxy: X client descriptor FD#" << clientFd in handleNewXConnection() 256 SetNoDelay(clientFd, control -> OptionClientNoDelay); in handleNewXConnection() [all …]
|
H A D | ServerProxy.cpp | 142 int ServerProxy::handleNewConnection(T_channel_type type, int clientFd) in handleNewConnection() argument 148 return handleNewGenericConnection(clientFd, channel_font, "font"); in handleNewConnection() 152 return handleNewSlaveConnection(clientFd); in handleNewConnection() 231 int ServerProxy::handleNewXConnection(int clientFd) in handleNewXConnection() argument 235 << "with FD#" << clientFd << " at this side.\n" in handleNewXConnection() 240 << "with FD#" << clientFd << " at this side.\n"; in handleNewXConnection()
|
H A D | ClientProxy.h | 61 virtual int handleNewConnection(T_channel_type type, int clientFd); 67 virtual int handleNewXConnection(int clientFd);
|
H A D | ServerProxy.h | 67 virtual int handleNewConnection(T_channel_type type, int clientFd); 73 virtual int handleNewXConnection(int clientFd);
|
H A D | Proxy.h | 280 virtual int handleNewConnection(T_channel_type type, int clientFd) = 0; 286 virtual int handleNewXConnection(int clientFd) = 0; 290 int handleNewGenericConnection(int clientFd, T_channel_type type, const char *label); 301 int handleNewSlaveConnection(int clientFd); 311 int handleCloseConnection(int clientFd);
|
/dports/x11/nxcomp/nx-libs-3.5.0.32/nxcomp/ |
H A D | ClientProxy.cpp | 93 return handleNewXConnection(clientFd); in handleNewConnection() 113 return handleNewSlaveConnection(clientFd); in handleNewConnection() 178 int clientFd = agent -> getLocalFd(); in handleNewAgentConnection() local 180 int channelId = allocateChannelMap(clientFd); in handleNewAgentConnection() 199 return handleNewXConnection(clientFd); in handleNewAgentConnection() 202 int ClientProxy::handleNewXConnection(int clientFd) in handleNewXConnection() argument 204 int channelId = getChannel(clientFd); in handleNewXConnection() 213 channelId = allocateChannelMap(clientFd); in handleNewXConnection() 230 *logofs << "ClientProxy: X client descriptor FD#" << clientFd in handleNewXConnection() 241 SetNoDelay(clientFd, control -> OptionClientNoDelay); in handleNewXConnection() [all …]
|
H A D | ServerProxy.cpp | 127 int ServerProxy::handleNewConnection(T_channel_type type, int clientFd) in handleNewConnection() argument 133 return handleNewGenericConnection(clientFd, channel_font, "font"); in handleNewConnection() 137 return handleNewSlaveConnection(clientFd); in handleNewConnection() 215 int ServerProxy::handleNewXConnection(int clientFd) in handleNewXConnection() argument 219 << "with FD#" << clientFd << " at this side.\n" in handleNewXConnection() 224 << "with FD#" << clientFd << " at this side.\n"; in handleNewXConnection()
|
H A D | ClientProxy.h | 50 virtual int handleNewConnection(T_channel_type type, int clientFd); 56 virtual int handleNewXConnection(int clientFd);
|
H A D | ServerProxy.h | 55 virtual int handleNewConnection(T_channel_type type, int clientFd); 61 virtual int handleNewXConnection(int clientFd);
|
/dports/comms/limesuite/LimeSuite-20.10.0/src/ConnectionRemote/ |
H A D | LMS64CProtocol_remote.cpp | 111 SOCKET clientFd; in ProcessConnections() local 114 int clientFd; in ProcessConnections() local 121 clientFd = accept(socketFd, (struct sockaddr*)&cli_addr, &clilen); in ProcessConnections() 125 if(clientFd < 0) in ProcessConnections() 140 int brecv = recv(clientFd, data+r, msgSize-r, 0); in ProcessConnections() 170 int r = send(clientFd, data+bsent, msgSize-bsent, 0); in ProcessConnections() 180 if (clientFd >= 0) in ProcessConnections() 184 closesocket(clientFd); in ProcessConnections() 186 shutdown(clientFd, SHUT_RDWR); in ProcessConnections() 187 close(clientFd); in ProcessConnections()
|
/dports/devel/cxxtools/cxxtools-2.2.1/src/ |
H A D | tcpserverimpl.cpp | 446 int clientFd; in accept() local 456 } while (clientFd < 0 && errno == EINTR); in accept() 458 if( clientFd < 0 ) in accept() 475 } while (clientFd < 0 && errno == EINTR); in accept() 477 if( clientFd < 0 ) in accept() 481 int clientFd; in accept() local 485 } while (clientFd < 0 && errno == EINTR); in accept() 487 if( clientFd < 0 ) in accept() 492 int flags = ::fcntl(clientFd, F_GETFD); in accept() 494 int ret = ::fcntl(clientFd, F_SETFD, flags); in accept() [all …]
|
/dports/comms/hylafax/hylafax-6.0.7/hfaxd/ |
H A D | FIFO.c++ | 49 clientFd = Sys::open(clientFIFOName, CONFIG_OPENFIFO|O_NDELAY); in initClientFIFO() 50 if (clientFd == -1) { in initClientFIFO() 55 if (!Sys::isFIFOFile(clientFd)) { in initClientFIFO() 60 if (fcntl(clientFd, F_SETFL, fcntl(clientFd, F_GETFL, 0) | O_NDELAY) < 0) in initClientFIFO() 62 Dispatcher::instance().link(clientFd, Dispatcher::ReadMask, this); in initClientFIFO() 277 if (clientFd == -1) { in vsendQueuerACK()
|
/dports/security/wolfssl/wolfssl-5.1.0/IDE/INTIME-RTOS/ |
H A D | wolfExamples.c | 147 int sockFd, clientFd = -1; in wolfExample_TLSServer() local 204 clientFd = accept(sockFd, (struct sockaddr*)&clientAddr, &addrSize); in wolfExample_TLSServer() 207 if (clientFd == -1) { in wolfExample_TLSServer() 221 wolfSSL_set_fd(ssl, clientFd); in wolfExample_TLSServer() 259 close(clientFd); /* close the connected socket */ in wolfExample_TLSServer() 260 clientFd = -1; in wolfExample_TLSServer() 265 if (clientFd != -1) in wolfExample_TLSServer() 266 close(clientFd); in wolfExample_TLSServer()
|
/dports/databases/mariadb105-client/mariadb-10.5.15/extra/wolfssl/wolfssl/IDE/INTIME-RTOS/ |
H A D | wolfExamples.c | 147 int sockFd, clientFd = -1; in wolfExample_TLSServer() local 204 clientFd = accept(sockFd, (struct sockaddr*)&clientAddr, &addrSize); in wolfExample_TLSServer() 207 if (clientFd == -1) { in wolfExample_TLSServer() 221 wolfSSL_set_fd(ssl, clientFd); in wolfExample_TLSServer() 259 close(clientFd); /* close the connected socket */ in wolfExample_TLSServer() 260 clientFd = -1; in wolfExample_TLSServer() 265 if (clientFd != -1) in wolfExample_TLSServer() 266 close(clientFd); in wolfExample_TLSServer()
|
/dports/databases/mariadb104-server/mariadb-10.4.24/extra/wolfssl/wolfssl/IDE/INTIME-RTOS/ |
H A D | wolfExamples.c | 147 int sockFd, clientFd = -1; in wolfExample_TLSServer() local 204 clientFd = accept(sockFd, (struct sockaddr*)&clientAddr, &addrSize); in wolfExample_TLSServer() 207 if (clientFd == -1) { in wolfExample_TLSServer() 221 wolfSSL_set_fd(ssl, clientFd); in wolfExample_TLSServer() 259 close(clientFd); /* close the connected socket */ in wolfExample_TLSServer() 260 clientFd = -1; in wolfExample_TLSServer() 265 if (clientFd != -1) in wolfExample_TLSServer() 266 close(clientFd); in wolfExample_TLSServer()
|
/dports/databases/mariadb105-server/mariadb-10.5.15/extra/wolfssl/wolfssl/IDE/INTIME-RTOS/ |
H A D | wolfExamples.c | 147 int sockFd, clientFd = -1; in wolfExample_TLSServer() local 204 clientFd = accept(sockFd, (struct sockaddr*)&clientAddr, &addrSize); in wolfExample_TLSServer() 207 if (clientFd == -1) { in wolfExample_TLSServer() 221 wolfSSL_set_fd(ssl, clientFd); in wolfExample_TLSServer() 259 close(clientFd); /* close the connected socket */ in wolfExample_TLSServer() 260 clientFd = -1; in wolfExample_TLSServer() 265 if (clientFd != -1) in wolfExample_TLSServer() 266 close(clientFd); in wolfExample_TLSServer()
|
/dports/databases/mariadb104-client/mariadb-10.4.24/extra/wolfssl/wolfssl/IDE/INTIME-RTOS/ |
H A D | wolfExamples.c | 147 int sockFd, clientFd = -1; in wolfExample_TLSServer() local 204 clientFd = accept(sockFd, (struct sockaddr*)&clientAddr, &addrSize); in wolfExample_TLSServer() 207 if (clientFd == -1) { in wolfExample_TLSServer() 221 wolfSSL_set_fd(ssl, clientFd); in wolfExample_TLSServer() 259 close(clientFd); /* close the connected socket */ in wolfExample_TLSServer() 260 clientFd = -1; in wolfExample_TLSServer() 265 if (clientFd != -1) in wolfExample_TLSServer() 266 close(clientFd); in wolfExample_TLSServer()
|
/dports/lang/nim/nim-1.6.2/tests/async/ |
H A D | tasyncdial.nim | 39 let clientFd = await clientFdFut 42 await clientFd.send("Hi") 46 clientFd.closeSocket()
|
/dports/net/eternalterminal/EternalTerminal-et-v5.1.9/src/terminal/ |
H A D | TerminalClient.cpp | 392 int clientFd = globalClient->getSocketFd(); in main() local 393 if (clientFd > 0) { in main() 394 FD_SET(clientFd, &rfd); in main() 395 maxfd = max(maxfd, clientFd); in main() 425 if (clientFd > 0 && FD_ISSET(clientFd, &rfd)) { in main() 474 if (clientFd > 0 && keepaliveTime < time(NULL)) { in main() 487 if (clientFd < 0) { in main()
|
/dports/devel/capnproto080/capnproto-0.8.0/c++/src/kj/ |
H A D | async-unix-test.c++ | 533 kj::AutoCloseFd clientFd(tmpFd); in TEST() local 538 KJ_SYSCALL(send(clientFd, &c, 1, 0)); in TEST() 549 KJ_SYSCALL(recv(clientFd, &c, 1, 0)); in TEST() 555 kj::AutoCloseFd clientFd(tmpFd); in TEST() local 558 UnixEventPort::FdObserver observer(port, clientFd, in TEST() 572 KJ_SYSCALL(recv(clientFd, &c, 1, 0)); in TEST() 574 KJ_SYSCALL(recv(clientFd, &c, 1, MSG_OOB)); in TEST() 578 KJ_SYSCALL(recv(clientFd, &c, 1, MSG_OOB)); in TEST() 580 KJ_SYSCALL(recv(clientFd, &c, 1, 0)); in TEST() 589 KJ_SYSCALL(send(clientFd, &c, 1, 0)); in TEST() [all …]
|
/dports/devel/capnproto/capnproto-0.9.0/c++/src/kj/ |
H A D | async-unix-test.c++ | 533 kj::AutoCloseFd clientFd(tmpFd); in TEST() local 538 KJ_SYSCALL(send(clientFd, &c, 1, 0)); in TEST() 549 KJ_SYSCALL(recv(clientFd, &c, 1, 0)); in TEST() 555 kj::AutoCloseFd clientFd(tmpFd); in TEST() local 558 UnixEventPort::FdObserver observer(port, clientFd, in TEST() 572 KJ_SYSCALL(recv(clientFd, &c, 1, 0)); in TEST() 574 KJ_SYSCALL(recv(clientFd, &c, 1, MSG_OOB)); in TEST() 578 KJ_SYSCALL(recv(clientFd, &c, 1, MSG_OOB)); in TEST() 580 KJ_SYSCALL(recv(clientFd, &c, 1, 0)); in TEST() 589 KJ_SYSCALL(send(clientFd, &c, 1, 0)); in TEST() [all …]
|
/dports/net/freeswitch/freeswitch-1.10.3.-release/libs/xmlrpc-c/src/cpp/test/ |
H A D | server_pstream.cpp | 232 int clientFd; member in __anonfbdf39d90111::client 256 this->clientFd = sockets[CLIENT]; in client() 264 XMLRPC_CLOSESOCKET(this->clientFd); in ~client() 275 rc = send(this->clientFd, packetBytes.c_str(), packetBytes.length(), 0); in sendCall() 310 shutdown(this->clientFd, 1); // Shutdown for transmission only in hangup() 323 rc = recv(this->clientFd, buffer, sizeof(buffer), 0); in recvResp()
|
/dports/net/xmlrpc-c/xmlrpc-c-1.51.07/test/cpp/ |
H A D | server_pstream.cpp | 233 int clientFd; member in __anonccb2ae750111::client 257 this->clientFd = sockets[CLIENT]; in client() 265 XMLRPC_CLOSESOCKET(this->clientFd); in ~client() 276 rc = send(this->clientFd, packetBytes.c_str(), packetBytes.length(), 0); in sendCall() 311 shutdown(this->clientFd, 1); // Shutdown for transmission only in hangup() 324 rc = recv(this->clientFd, buffer, sizeof(buffer), 0); in recvResp()
|
/dports/security/zebedee/zebedee-2.5.3/ |
H A D | zebedee.c | 4868 argP->fd = clientFd; in spawnHandler() 5128 int clientFd; in clientListener() local 5326 if (clientFd != -1) in clientListener() 5364 setNoLinger(clientFd); in clientListener() 5368 setKeepAlive(clientFd); in clientListener() 6033 closesocket(clientFd); in client() 6046 if (clientFd != -1) closesocket(clientFd); in client() 6074 int clientFd; in serverListener() local 6139 int clientFd = -1; in serverInitiator() local 6248 closesocket(clientFd); in serverInitiator() [all …]
|
/dports/multimedia/vapoursynth/vapoursynth-R54/src/avfs/include/ |
H A D | pfmapi.h | 225 PT_INTERFACE_FUN1( int/*error*/, FastPipeCancel , PT_FD_T clientFd); 226 PT_INTERFACE_FUN1( int/*error*/, FastPipeEnableFastMapping, PT_FD_T clientFd); 228 PT_INTERFACE_FUN2( int/*error*/, FastPipeClientContext , PT_FD_T clientFd,int* clientContext); 229 …PT_INTERFACE_FUN8( void , FastPipeSend , PT_FD_T clientFd,int clientContext,PT_…
|