Home
last modified time | relevance | path

Searched refs:pTransport (Results 1 – 20 of 20) sorted by relevance

/dports/net/gamenetworkingsockets/GameNetworkingSockets-1.3.0/src/steamnetworkingsockets/clientlib/
H A Dsteamnetworkingsockets_p2p_ice.cpp572 if ( Setup( pTransport ) ) in RunOrQueue()
579 inline bool Setup( CConnectionTransportP2PICE *pTransport ) in Setup() argument
581 CSteamNetworkConnectionP2P &conn = pTransport->Connection(); in Setup()
582 if ( conn.m_pTransportICE != pTransport ) in Setup()
703 if ( pTransport->BCanSendEndToEndData() ) in OnWritableStateChanged()
707 …SpewMsgGroup( pTransport->LogLevel_P2PRendezvous(), "[%s] ICE reports we are writable\n", pTranspo… in OnWritableStateChanged()
710 if ( pTransport->m_bNeedToConfirmEndToEndConnectivity ) in OnWritableStateChanged()
711 pTransport->RouteOrWritableStateChanged(); in OnWritableStateChanged()
717 if ( !pTransport->m_bNeedToConfirmEndToEndConnectivity ) in OnWritableStateChanged()
721 …SpewMsgGroup( pTransport->LogLevel_P2PRendezvous(), "[%s] ICE reports we are no longer writable\n"… in OnWritableStateChanged()
[all …]
H A Dsteamnetworkingsockets_udp.cpp987 if ( connection.m_pTransport != pTransport ) in Populate()
1116 pTransport[0]->m_pSocket = sock[0]; in CreateLoopbackPair()
1117 pTransport[1]->m_pSocket = sock[1]; in CreateLoopbackPair()
1160 if ( !pTransport->BConnect( netadrRemote, errMsg ) ) in BInitConnect()
1162 pTransport->TransportDestroySelfNow(); in BInitConnect()
1165 m_pTransport = pTransport; in BInitConnect()
1227 pTransport->TransportDestroySelfNow(); in BBeginAccept()
1230 m_pTransport = pTransport; in BBeginAccept()
1838 CConnectionTransportUDP *pTransport[2] = { in APICreateSocketPair() local
1842 pConn[0]->m_pTransport = pTransport[0]; in APICreateSocketPair()
[all …]
H A Dsteamnetworkingsockets_p2p.cpp1040 if ( pTransport->m_bNeedToConfirmEndToEndConnectivity == ( pTransport == m_pCurrentTransportP2P ) ) in TransportEndToEndConnectivityChanged()
1053 pTransport->m_nKeepTryingToPingCounter = std::max( pTransport->m_nKeepTryingToPingCounter, 5 ); in TransportEndToEndConnectivityChanged()
1059 if ( !pTransport->m_bNeedToConfirmEndToEndConnectivity && BStateIsActive() ) in TransportEndToEndConnectivityChanged()
1080 if ( pTransport == m_pTransportICE && !m_msgICESessionSummary.has_negotiation_ms() ) in TransportEndToEndConnectivityChanged()
1357 #define CHECK_READY_TO_SWITCH( pTransport ) \ in ThinkSelectTransport() argument
1366 else if ( pTransport->m_usecEndToEndInFlightReplyTimeout > 0 ) \ in ThinkSelectTransport()
1378 pTransport->m_pszP2PTransportDebugName \ in ThinkSelectTransport()
1476 m_pTransport = pTransport; in SelectTransport()
1513 #define UPDATE_SECONDS_SELECTED( pTransport, msg ) \ in UpdateTransportSummaries() argument
1514 if ( pTransport ) \ in UpdateTransportSummaries()
[all …]
H A Dsteamnetworkingsockets_udp.h53 …ize_t cbHdrtReserve, EStatsReplyRequest eReplyRequested, CConnectionTransportUDPBase *pTransport );
177 static bool CreateLoopbackPair( CConnectionTransportUDP *pTransport[2] );
H A Dsteamnetworkingsockets_snp.cpp1425 bool CSteamNetworkConnectionBase::SNP_SendPacket( CConnectionTransport *pTransport, SendPacketConte… in SNP_SendPacket() argument
1431 if ( !BStateIsActive() || m_senderState.m_mapInFlightPacketsByPktNum.empty() || !pTransport ) in SNP_SendPacket()
1435 Assert( pTransport ); in SNP_SendPacket()
1509 || pTransport != m_pTransport // transport is not the selected transport in SNP_SendPacket()
1753 …m_statsEndToEnd.m_nNextSendSequenceNumber, SNPInFlightPacket_t{ usecNow, false, pTransport, {} } ); in SNP_SendPacket()
1907 nBytesSent = pTransport->SendEncryptedDataChunk( payload, cbPlainText, ctx ); in SNP_SendPacket()
1943 nBytesSent = pTransport->SendEncryptedDataChunk( arEncryptedChunk, cbEncrypted, ctx ); in SNP_SendPacket()
1973 void CSteamNetworkConnectionBase::SNP_SentNonDataPacket( CConnectionTransport *pTransport, int cbPk… in SNP_SentNonDataPacket() argument
1975 …statsEndToEnd.m_nNextSendSequenceNumber-1, SNPInFlightPacket_t{ usecNow, false, pTransport, {} } ); in SNP_SentNonDataPacket()
H A Dsteamnetworkingsockets_connections.h533 bool SNP_SendPacket( CConnectionTransport *pTransport, SendPacketContext_t &ctx );
537 …void SNP_SentNonDataPacket( CConnectionTransport *pTransport, int cbPkt, SteamNetworkingMicrosecon…
H A Dsteamnetworkingsockets_p2p.h401 …void SelectTransport( CConnectionTransportP2PBase *pTransport, SteamNetworkingMicroseconds usecNow…
/dports/www/domoticz/domoticz-2020.2/hardware/plugins/
H A DPythonObjects.cpp1100 if (self->pTransport) in CConnection_dealloc()
1233 if (pTransport) in CConnection_init()
1282 if (self->pTransport && self->pTransport->IsConnecting()) in CConnection_connect()
1288 if (self->pTransport && self->pTransport->IsConnected()) in CConnection_connect()
1316 if (self->pTransport && self->pTransport->IsConnecting()) in CConnection_listen()
1322 if (self->pTransport && self->pTransport->IsConnected()) in CConnection_listen()
1366 if (self->pTransport) in CConnection_disconnect()
1368 if (self->pTransport->IsConnecting() || self->pTransport->IsConnected()) in CConnection_disconnect()
1384 if (self->pTransport) in CConnection_bytes()
1394 if (self->pTransport) in CConnection_isconnecting()
[all …]
H A DPlugins.cpp1389 if (pConnection->pTransport && pConnection->pTransport->IsConnected()) in ConnectionConnect()
1432 if (pConnection->pTransport) in ConnectionConnect()
1452 if (pConnection->pTransport && pConnection->pTransport->IsConnected()) in ConnectionListen()
1498 if (pConnection->pTransport) in ConnectionListen()
1527 if (pConnection->pTransport) in ConnectionWrite()
1542 if (!pConnection->pTransport) in ConnectionWrite()
1579 delete pConnection->pTransport; in ConnectionWrite()
1580 pConnection->pTransport = NULL; in ConnectionWrite()
1595 if (pConnection->pTransport) in ConnectionDisconnect()
1713 if (pConnection->pTransport) in DisconnectEvent()
[all …]
H A DPythonObjects.h206 CPluginTransport* pTransport; member
H A DPluginTransports.cpp188 pConnection->pTransport = pTcpTransport; in handleAsyncAccept()
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/thrift/lib/cpp/src/thrift/server/
H A DTServerFramework.cpp97 static void releaseOneDescriptor(const string& name, T& pTransport) { in releaseOneDescriptor() argument
98 if (pTransport) { in releaseOneDescriptor()
100 pTransport->close(); in releaseOneDescriptor()
/dports/net/storj/storj-1.45.3/vendor/github.com/apache/thrift/lib/cpp/src/thrift/server/
H A DTServerFramework.cpp98 static void releaseOneDescriptor(const string& name, T& pTransport) { in releaseOneDescriptor() argument
99 if (pTransport) { in releaseOneDescriptor()
101 pTransport->close(); in releaseOneDescriptor()
/dports/www/fabio/fabio-1.5.14/vendor/github.com/apache/thrift/thrift-da1169d75b15/lib/cpp/src/thrift/server/
H A DTServerFramework.cpp98 static void releaseOneDescriptor(const string& name, T& pTransport) { in releaseOneDescriptor() argument
99 if (pTransport) { in releaseOneDescriptor()
101 pTransport->close(); in releaseOneDescriptor()
/dports/devel/thrift-c_glib/thrift-0.14.0/lib/cpp/src/thrift/server/
H A DTServerFramework.cpp97 static void releaseOneDescriptor(const string& name, T& pTransport) { in releaseOneDescriptor() argument
98 if (pTransport) { in releaseOneDescriptor()
100 pTransport->close(); in releaseOneDescriptor()
/dports/devel/thrift-cpp/thrift-0.14.0/lib/cpp/src/thrift/server/
H A DTServerFramework.cpp97 static void releaseOneDescriptor(const string& name, T& pTransport) { in releaseOneDescriptor() argument
98 if (pTransport) { in releaseOneDescriptor()
100 pTransport->close(); in releaseOneDescriptor()
/dports/devel/thrift/thrift-0.14.0/lib/cpp/src/thrift/server/
H A DTServerFramework.cpp97 static void releaseOneDescriptor(const string& name, T& pTransport) { in releaseOneDescriptor() argument
98 if (pTransport) { in releaseOneDescriptor()
100 pTransport->close(); in releaseOneDescriptor()
/dports/misc/concourse/concourse-6.7.2/vendor/github.com/apache/thrift/lib/cpp/src/thrift/server/
H A DTServerFramework.cpp97 static void releaseOneDescriptor(const string& name, T& pTransport) { in releaseOneDescriptor() argument
98 if (pTransport) { in releaseOneDescriptor()
100 pTransport->close(); in releaseOneDescriptor()
/dports/devel/node-thrift/thrift-0.14.0/lib/cpp/src/thrift/server/
H A DTServerFramework.cpp97 static void releaseOneDescriptor(const string& name, T& pTransport) { in releaseOneDescriptor() argument
98 if (pTransport) { in releaseOneDescriptor()
100 pTransport->close(); in releaseOneDescriptor()
/dports/devel/py-thrift/thrift-0.14.0/lib/cpp/src/thrift/server/
H A DTServerFramework.cpp97 static void releaseOneDescriptor(const string& name, T& pTransport) { in releaseOneDescriptor() argument
98 if (pTransport) { in releaseOneDescriptor()
100 pTransport->close(); in releaseOneDescriptor()