Home
last modified time | relevance | path

Searched refs:clientFd (Results 1 – 25 of 47) sorted by relevance

12

/dports/net/nxproxy/nx-libs-3.5.99.20-1/nxcomp/src/
H A DClientProxy.cpp108 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 DServerProxy.cpp142 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 DClientProxy.h61 virtual int handleNewConnection(T_channel_type type, int clientFd);
67 virtual int handleNewXConnection(int clientFd);
H A DServerProxy.h67 virtual int handleNewConnection(T_channel_type type, int clientFd);
73 virtual int handleNewXConnection(int clientFd);
H A DProxy.h280 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 DClientProxy.cpp93 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 DServerProxy.cpp127 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 DClientProxy.h50 virtual int handleNewConnection(T_channel_type type, int clientFd);
56 virtual int handleNewXConnection(int clientFd);
H A DServerProxy.h55 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 DLMS64CProtocol_remote.cpp111 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 Dtcpserverimpl.cpp446 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 DFIFO.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 DwolfExamples.c147 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 DwolfExamples.c147 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 DwolfExamples.c147 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 DwolfExamples.c147 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 DwolfExamples.c147 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 Dtasyncdial.nim39 let clientFd = await clientFdFut
42 await clientFd.send("Hi")
46 clientFd.closeSocket()
/dports/net/eternalterminal/EternalTerminal-et-v5.1.9/src/terminal/
H A DTerminalClient.cpp392 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 Dasync-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 Dasync-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 Dserver_pstream.cpp232 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 Dserver_pstream.cpp233 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 Dzebedee.c4868 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 Dpfmapi.h225 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_…

12