/dports/games/megaglest/megaglest-source-3.13.0/source/shared_lib/sources/feathery_ftp/ |
H A D | ftpTargetPosix.c | 253 socket_t dataSocket; in ftpEstablishDataConnection() local 259 if(dataSocket < 0) in ftpEstablishDataConnection() 269 ftpCloseSocket(&dataSocket); in ftpEstablishDataConnection() 281 ftpCloseSocket(&dataSocket); in ftpEstablishDataConnection() 357 return dataSocket; in ftpEstablishDataConnection() 364 socket_t dataSocket; in ftpAcceptDataConnection() local 369 if(dataSocket < 0) in ftpAcceptDataConnection() 372 dataSocket = -1; in ftpAcceptDataConnection() 390 ftpCloseSocket(&dataSocket); in ftpAcceptDataConnection() 391 dataSocket = -1; in ftpAcceptDataConnection() [all …]
|
H A D | ftpTargetWin32.c | 278 SOCKET dataSocket; in ftpEstablishDataConnection() local 294 ftpCloseSocket(&dataSocket); in ftpEstablishDataConnection() 306 ftpCloseSocket(&dataSocket); in ftpEstablishDataConnection() 319 ftpCloseSocket(&dataSocket); in ftpEstablishDataConnection() 339 ftpCloseSocket(&dataSocket); in ftpEstablishDataConnection() 348 ftpCloseSocket(&dataSocket); in ftpEstablishDataConnection() 360 ftpCloseSocket(&dataSocket); in ftpEstablishDataConnection() 382 return (socket_t)dataSocket; in ftpEstablishDataConnection() 389 SOCKET dataSocket; in ftpAcceptDataConnection() local 416 ftpCloseSocket(&dataSocket); in ftpAcceptDataConnection() [all …]
|
H A D | ftpSession.c | 87 sessions[n].activeTrans.dataSocket = -1; in ftpOpenSession() 138 …\n",sessions[id].ctrlSocket,sessions[id].passiveDataSocket,sessions[id].activeTrans.dataSocket,id); in ftpCloseSession() 151 sessions[id].activeTrans.dataSocket = 0; in ftpCloseSession() 329 void ftpOpenTransmission(int id, operation_E op, void* fsHandle, socket_t dataSocket, uint32_t file… in ftpOpenTransmission() argument 334 sessions[id].activeTrans.dataSocket = dataSocket; in ftpOpenTransmission() 344 …sessions[id].activeTrans.dataSocket, id,sessions[id].activeTrans.fsHandle,sessions[id].activeTrans… in ftpCloseTransmission() 346 if(sessions[id].activeTrans.dataSocket > 0) in ftpCloseTransmission() 348 ftpUntrackSocket(sessions[id].activeTrans.dataSocket); in ftpCloseTransmission() 349 ftpCloseSocket(&sessions[id].activeTrans.dataSocket); in ftpCloseTransmission() 364 sessions[id].activeTrans.dataSocket = 0; in ftpCloseTransmission()
|
H A D | ftpCmds.c | 103 if(ftpSend(pTrans->dataSocket, scratchBuf, (int)len)) in ftpExecTransmission() 126 len = ftpReceive(pTrans->dataSocket, &scratchBuf[rxLen], LEN_SCRATCHBUF - rxLen); in ftpExecTransmission() 131 … ON RECEIVE for socket = %d, data len = %d, error = %d [%s]\n",pTrans->dataSocket,(LEN_SCRATCHBUF … in ftpExecTransmission() 275 LOCAL int sendListing(socket_t dataSocket, int sessionId, const char* path, int format) in sendListing() argument 296 …about to read dir contents [%s] for sessionId = %d, dataSocket = %d\n", path,sessionId,dataSocket); in sendListing() 354 ftpSend(dataSocket, scratchBuf, len + 1); in sendListing() 360 ftpSend(dataSocket, scratchBuf, len); in sendListing() 383 ftpSend(dataSocket, scratchBuf, len); in sendListing() 393 ftpSend(dataSocket, scratchBuf, len); in sendListing() 407 …isting err = %d, path = [%s] for sessionId = %d, dataSocket = %d\n",err,path,sessionId,dataSocket); in sendListing() [all …]
|
/dports/net-im/openfire/Openfire-4.7.1/xmppserver/src/main/java/org/jivesoftware/openfire/mediaproxy/ |
H A D | Channel.java | 41 protected DatagramSocket dataSocket; field in Channel 57 public Channel(DatagramSocket dataSocket, InetAddress host, int port) { in Channel() argument 58 this.dataSocket = dataSocket; in Channel() 125 if (dataSocket != null){ in cancel() 126 dataSocket.close(); in cancel() 139 dataSocket.receive(packet); in run() 177 dataSocket.send(echo); in relayPacket()
|
H A D | DynamicAddressChannel.java | 40 public DynamicAddressChannel(DatagramSocket dataSocket, InetAddress host, int port) { in DynamicAddressChannel() argument 41 super(dataSocket, host, port); in DynamicAddressChannel()
|
/dports/ftp/ncftp3/ncftp-3.2.6/libncftp/ |
H A D | ftp.c | 685 DisposeSocket(cip->dataSocket); in CloseDataConnection() 691 DisposeSocket(cip->dataSocket); in CloseDataConnection() 991 int dataSocket; in OpenDataConnection() local 1010 if (dataSocket < 0) { in OpenDataConnection() 1066 if (listen(dataSocket, 1) < 0) { in OpenDataConnection() 1168 (void) DisposeSocket(dataSocket); in OpenDataConnection() 1186 (void) DisposeSocket(dataSocket); in OpenDataConnection() 1189 if (dataSocket < 0) { in OpenDataConnection() 1218 cip->dataSocket = dataSocket; in OpenDataConnection() 1221 (void) DisposeSocket(dataSocket); in OpenDataConnection() [all …]
|
H A D | io_get.c | 525 (void) shutdown(cip->dataSocket, 2); in FTPGetOneF() 531 (void) shutdown(cip->dataSocket, 2); in FTPGetOneF() 555 (void) shutdown(cip->dataSocket, 2); in FTPGetOneF() 561 (void) shutdown(cip->dataSocket, 2); in FTPGetOneF() 653 (void) shutdown(cip->dataSocket, 2); in FTPGetOneF() 682 (void) shutdown(cip->dataSocket, 2); in FTPGetOneF() 688 (void) shutdown(cip->dataSocket, 2); in FTPGetOneF() 716 (void) shutdown(cip->dataSocket, 2); in FTPGetOneF() 722 (void) shutdown(cip->dataSocket, 2); in FTPGetOneF() 787 (void) shutdown(cip->dataSocket, 2); in FTPGetOneF() [all …]
|
H A D | io_putmem.c | 142 …nwrote = (write_return_t) SWrite(cip->dataSocket, cp, (size_t) nread, (int) cip->xferTimeout, kNoF… in FTPPutFileFromMemory() 157 (void) shutdown(cip->dataSocket, 2); in FTPPutFileFromMemory() 161 nwrote = write(cip->dataSocket, cp, (write_size_t) nread); in FTPPutFileFromMemory() 173 (void) shutdown(cip->dataSocket, 2); in FTPPutFileFromMemory() 201 (void) shutdown(cip->dataSocket, 1); in FTPPutFileFromMemory()
|
H A D | u_shutdownci.c | 32 if (cip->dataSocket != kClosedFileDescriptor) in FTPShutdownHost() 33 (void) SetSocketLinger(cip->dataSocket, 0, 0); in FTPShutdownHost()
|
H A D | rcmd.c | 658 (void) shutdown(cip->dataSocket, ((netMode == kNetReading) ? 1 : 0)); in FTPStartDataCmd3() 717 if (cip->dataSocket != kClosedFileDescriptor) { in FTPAbortDataTransfer() 726 (void) SetSocketLinger(cip->dataSocket, 0, 0); in FTPAbortDataTransfer() 747 (void) SetSocketLinger(cip->dataSocket, 0, 0); in FTPAbortDataTransfer() 754 (void) SetSocketLinger(cip->dataSocket, 0, 0); in FTPAbortDataTransfer() 788 (void) SetSocketLinger(cip->dataSocket, 0, 0); in FTPAbortDataTransfer() 810 (void) SetSocketLinger(cip->dataSocket, 0, 0); in FTPAbortDataTransfer() 828 (void) SetSocketLinger(cip->dataSocket, 0, 0); in FTPAbortDataTransfer()
|
H A D | io_list.c | 51 …if (InitSReadlineInfo(&lsSrl, cip->dataSocket, secondaryBuf, sizeof(secondaryBuf), (int) cip->xfer… in FTPList() 109 …nread = BufferGets(line, sizeof(line), cip->dataSocket, secondaryBuf, &secBufPtr, &secBufLimit, si… in FTPList()
|
H A D | io_getmem.c | 161 …nread = (read_return_t) SRead(cip->dataSocket, memBuf, ntoread, (int) cip->xferTimeout, kFullBuffe… in FTPGetFileToMemory() 186 nread = read(cip->dataSocket, memBuf, (read_size_t) ntoread); in FTPGetFileToMemory() 198 (void) shutdown(cip->dataSocket, 2); in FTPGetFileToMemory()
|
/dports/cad/ldview/ldview-4.4/TCFoundation/ |
H A D | TCNetwork.cpp | 64 if ((unsigned)socketRecv(dataSocket, (char *)&length, sizeof(length), 0) < in getData() 79 if ((n = (int)socketRecv(dataSocket, (char *)data, length, 0)) < length) in getData() 84 if (socketSend(dataSocket, (char *)&n, sizeof(n), 0) != sizeof(n)) in getData() 108 if (socketSend(dataSocket, (char *)&length, sizeof(length), 0) != in sendData() 115 if (socketSend(dataSocket, (char *)data, length, 0) != length) in sendData() 121 if ((unsigned)socketRecv(dataSocket, (char *)&ack, sizeof(ack), 0) < in sendData() 164 closesocket(dataSocket); in closeConnection()
|
H A D | TCNetworkClient.cpp | 65 if (setsockopt(dataSocket, SOL_SOCKET, SO_LINGER, (const char*)&ling, in setLinger() 78 if (setsockopt(dataSocket, IPPROTO_TCP, TCP_NODELAY, (const char*)&flag, in setTcpNoDelay() 90 dataSocket = socket(AF_INET, SOCK_STREAM, 0); in setupSocket() 120 if (connect(dataSocket, (struct sockaddr*)&portOut, sizeof(portOut)) < 0) in openConnection() 131 closesocket(dataSocket); in openConnection()
|
H A D | TCWebClient.cpp | 610 receiveLength = (int)recv(dataSocket, buf, sizeof(buf) - 1, 0); in receiveHeader() 1412 if (ioctlsocket(dataSocket, FIONBIO, &input) == SOCKET_ERROR) 1423 if (fcntl(dataSocket, F_SETFL, O_NDELAY) == -1) 1468 FD_SET(dataSocket, &errorDescs); 1515 if (FD_ISSET(dataSocket, &errorDescs)) 1524 if (readDescs && FD_ISSET(dataSocket, readDescs)) 1528 if ((readDescs && !FD_ISSET(dataSocket, readDescs)) || 1529 (writeDescs && !FD_ISSET(dataSocket, writeDescs))) 1543 FD_SET(dataSocket, &readDescs); 1552 FD_SET(dataSocket, &writeDescs); [all …]
|
/dports/net/h323plus/h323plus-1_27_2/src/ |
H A D | rtp.cxx | 1427 delete dataSocket; in ~RTP_UDP() 1428 dataSocket = NULL; in ~RTP_UDP() 1436 if (dataSocket != NULL) in ApplyQOS() 1453 if (dataSocket != NULL) in ModifyQOS() 1471 if (dataSocket != NULL) in GetQOS() 1503 delete dataSocket; 1505 dataSocket = NULL; 1550 dataSocket = new H323UDPSocket(); 1555 dataSocket->Close(); 1665 if (!controlSocket || !dataSocket) [all …]
|
/dports/net/opal/opal-3.10.10/src/rtp/ |
H A D | rtp.cxx | 1837 dataSocket = NULL; in RTP_UDP() 1858 delete dataSocket; in ~RTP_UDP() 1867 if (dataSocket != NULL) in ApplyQOS() 1883 if (dataSocket != NULL) in ModifyQOS() 1906 delete dataSocket; in Open() 1908 dataSocket = NULL; in Open() 1948 delete dataSocket; in Open() 1950 dataSocket = NULL; in Open() 1976 dataSocket->Close(); in Open() 2180 if (shutdownRead || dataSocket == NULL) in FlushData() [all …]
|
/dports/www/aria2/aria2-1.36.0/src/ |
H A D | FtpDownloadCommand.cc | 55 const std::shared_ptr<SocketCore>& dataSocket, in FtpDownloadCommand() argument 57 : DownloadCommand(cuid, req, fileEntry, requestGroup, e, dataSocket, in FtpDownloadCommand() 58 std::make_shared<SocketRecvBuffer>(dataSocket)), in FtpDownloadCommand()
|
/dports/finance/quickfix/quickfix-1.15.1/src/C++/test/ |
H A D | SocketServerTestCase.cpp | 42 dataSocket( 0 ), disconnectSocket( 0 ), in socketServerFixture() 51 data++; dataSocket = socket; in onData() 62 int dataSocket, disconnectSocket; member in socketServerFixture 129 CHECK( dataSocket > 0 ); in SUITE()
|
/dports/devel/ptlib/ptlib-2.10.11/src/ptclib/ |
H A D | ftpsrvr.cxx | 654 PTCPSocket * dataSocket; in SendToClient() local 656 dataSocket = new PTCPSocket(*passiveSocket); in SendToClient() 660 dataSocket = new PTCPSocket(remoteHost, remotePort); in SendToClient() 661 if (!dataSocket->IsOpen()) in SendToClient() 674 if (!dataSocket->Write((const char *)line, line.GetLength())) { in SendToClient() 691 if (!dataSocket->Write(buffer, file.GetLastReadCount())) { in SendToClient() 699 delete dataSocket; in SendToClient()
|
H A D | ftpclnt.cxx | 243 PTCPSocket * dataSocket = (PTCPSocket *)socket->Clone(); in NormalClientTransfer() local 244 if (dataSocket->Accept(*listenSocket)) in NormalClientTransfer() 245 return dataSocket; in NormalClientTransfer() 247 delete dataSocket; in NormalClientTransfer()
|
/dports/editors/cpeditor/cpeditor-6.8.2/third_party/singleapplication/ |
H A D | singleapplication_p.cpp | 490 void SingleApplicationPrivate::slotDataAvailable( QLocalSocket *dataSocket, quint32 instanceId ) in slotDataAvailable() argument 494 if ( !isFrameComplete( dataSocket ) ) in slotDataAvailable() 497 Q_EMIT q->receivedMessage( instanceId, dataSocket->readAll() ); in slotDataAvailable() 499 writeAck( dataSocket ); in slotDataAvailable() 501 ConnectionInfo &info = connectionMap[dataSocket]; in slotDataAvailable()
|
/dports/net-im/nheko/nheko-0.9.0/third_party/SingleApplication-3.3.0/ |
H A D | singleapplication_p.cpp | 490 void SingleApplicationPrivate::slotDataAvailable( QLocalSocket *dataSocket, quint32 instanceId ) in slotDataAvailable() argument 494 if ( !isFrameComplete( dataSocket ) ) in slotDataAvailable() 497 Q_EMIT q->receivedMessage( instanceId, dataSocket->readAll() ); in slotDataAvailable() 499 writeAck( dataSocket ); in slotDataAvailable() 501 ConnectionInfo &info = connectionMap[dataSocket]; in slotDataAvailable()
|
/dports/ftp/gnustep-ftp/FTP-0.6/ |
H A D | ftpclient.m | 940 if ((dataSocket = socket(AF_INET, SOCK_STREAM, 0)) == INVALID_SOCKET) 1017 if ((dataSocket = socket(AF_INET, SOCK_STREAM, 0)) == INVALID_SOCKET) 1037 if (bind(dataSocket, (struct sockaddr *)&dataSockName, sizeof (dataSockName)) < 0) 1046 if (getsockname(dataSocket, (struct sockaddr *)&dataSockName, &addrLen) < 0) 1053 if (listen(dataSocket, 1) < 0) 1104 initStream(&dataStream, dataSocket); 1105 localSocket = dataSocket; 1108 if ((localSocket = accept(dataSocket, &from, &fromLen)) < 0) 1121 closesocket(dataSocket); 1127 // a passive localSocket is just a copy of the dataSocket [all …]
|