Home
last modified time | relevance | path

Searched refs:dataSocket (Results 1 – 25 of 55) sorted by relevance

123

/dports/games/megaglest/megaglest-source-3.13.0/source/shared_lib/sources/feathery_ftp/
H A DftpTargetPosix.c253 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 DftpTargetWin32.c278 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 DftpSession.c87 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 DftpCmds.c103 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 DChannel.java41 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 DDynamicAddressChannel.java40 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 Dftp.c685 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 Dio_get.c525 (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 Dio_putmem.c142 …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 Du_shutdownci.c32 if (cip->dataSocket != kClosedFileDescriptor) in FTPShutdownHost()
33 (void) SetSocketLinger(cip->dataSocket, 0, 0); in FTPShutdownHost()
H A Drcmd.c658 (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 Dio_list.c51 …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 Dio_getmem.c161 …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 DTCNetwork.cpp64 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 DTCNetworkClient.cpp65 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 DTCWebClient.cpp610 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 Drtp.cxx1427 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 Drtp.cxx1837 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 DFtpDownloadCommand.cc55 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 DSocketServerTestCase.cpp42 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 Dftpsrvr.cxx654 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 Dftpclnt.cxx243 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 Dsingleapplication_p.cpp490 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 Dsingleapplication_p.cpp490 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 Dftpclient.m940 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 …]

123