Home
last modified time | relevance | path

Searched refs:conn_ (Results 1 – 25 of 398) sorted by relevance

12345678910>>...16

/dports/net/mvfst/mvfst-248b2dc39bbd36863bbaa50385e8683428610009/quic/flowcontrol/test/
H A DQuicFlowControlTest.cpp28 conn_, conn_.nodeType, conn_.transportSettings); in SetUp()
57 conn_.lossState.srtt = 100us; in TEST_F()
63 conn_, *conn_.flowControlState.timeOfLastFlowControlUpdate + 100us); in TEST_F()
70 conn_, *conn_.flowControlState.timeOfLastFlowControlUpdate + 300us); in TEST_F()
85 conn_, *conn_.flowControlState.timeOfLastFlowControlUpdate + 300us); in TEST_F()
88 conn_, *conn_.flowControlState.timeOfLastFlowControlUpdate + 300us); in TEST_F()
101 conn_, *conn_.flowControlState.timeOfLastFlowControlUpdate + 300us); in TEST_F()
115 conn_, *conn_.flowControlState.timeOfLastFlowControlUpdate + 300us); in TEST_F()
460 handleConnBlocked(conn_); in TEST_F()
571 conn_.qLogger = qLogger; in TEST_F()
[all …]
/dports/net/mvfst/mvfst-248b2dc39bbd36863bbaa50385e8683428610009/quic/congestion_control/
H A DCopa.cpp20 : conn_(conn), in Copa()
30 << " inflight=" << conn_.lossState.inflightBytes << " " << conn_; in Copa()
41 << " inflight=" << conn_.lossState.inflightBytes << " " << conn_; in onRemoveBytesFromInflight()
42 if (conn_.qLogger) { in onRemoveBytesFromInflight()
58 if (conn_.qLogger) { in onPacketSent()
139 if (conn_.pacer) { in onPacketAckOrLoss()
179 << conn_; in onPacketAcked()
181 if (conn_.qLogger) { in onPacketAcked()
211 << conn_; in onPacketAcked()
285 if (conn_.pacer) { in onPacketAcked()
[all …]
H A DNewReno.cpp19 : conn_(conn), in NewReno()
33 << " inflight=" << conn_.lossState.inflightBytes << " " << conn_; in onRemoveBytesFromInflight()
34 if (conn_.qLogger) { in onRemoveBytesFromInflight()
48 if (conn_.qLogger) { in onPacketSent()
61 << " inflight=" << conn_.lossState.inflightBytes << " " << conn_; in onAckEvent()
62 if (conn_.qLogger) { in onAckEvent()
127 << " inflight=" << conn_.lossState.inflightBytes << " " << conn_; in onPacketLoss()
131 << " inflight=" << conn_.lossState.inflightBytes << " " << conn_; in onPacketLoss()
134 if (conn_.qLogger) { in onPacketLoss()
143 << " inflight=" << conn_.lossState.inflightBytes << " " << conn_; in onPacketLoss()
[all …]
H A DCopa2.cpp19 : conn_(conn), in Copa2()
24 << " inflight=" << conn_.lossState.inflightBytes << " " << conn_; in Copa2()
31 << " inflight=" << conn_.lossState.inflightBytes << " " << conn_; in onRemoveBytesFromInflight()
32 if (conn_.qLogger) { in onRemoveBytesFromInflight()
48 if (conn_.qLogger) { in onPacketSent()
61 if (conn_.pacer) { in onPacketAckOrLoss()
113 << " inflight=" << conn_.lossState.inflightBytes << " " << conn_; in onPacketLoss()
114 if (conn_.qLogger) { in onPacketLoss()
127 if (conn_.pacer) { in onPacketLoss()
129 conn_.pacer->refreshPacingRate(cwndBytes_, conn_.lossState.mrtt); in onPacketLoss()
[all …]
H A DQuicCubic.cpp35 if (conn_.qLogger) { in Cubic()
73 auto minCwnd = conn_.transportSettings.minCwndInMss * conn_.udpSendPacketLen; in onPersistentCongestion()
87 if (conn_.qLogger) { in onPersistentCongestion()
123 if (conn_.pacer) { in onPacketLoss()
153 if (conn_.qLogger) { in onRemoveBytesFromInflight()
163 if (conn_.qLogger) { in setAppIdle()
205 if (conn_.qLogger) { in updateTimeToOrigin()
264 if (conn_.qLogger) { in calculateCubicCwndDelta()
281 return conn_.transportSettings.maxCwndInMss * conn_.udpSendPacketLen; in calculateCubicCwnd()
286 return conn_.transportSettings.minCwndInMss * conn_.udpSendPacketLen; in calculateCubicCwnd()
[all …]
H A DBbr.cpp32 : conn_(conn), in BbrCongestionController()
77 conn_.udpSendPacketLen, in onPacketLoss()
93 if (conn_.qLogger) { in onPacketLoss()
155 if (conn_.pacer) { in onPacketAckOrLoss()
170 if (conn_.qLogger) { in onPacketAcked()
252 if (!conn_.pacer) { in updatePacing()
270 conn_.pacer->setRttFactor( in updatePacing()
274 conn_.pacer->setRttFactor( in updatePacing()
280 conn_.pacer->reset(); in updatePacing()
454 conn_.udpSendPacketLen, in updateRecoveryWindowWithAck()
[all …]
/dports/games/widelands/widelands-build21/src/network/
H A Dnetclientproxy.cc11 if (ptr->conn_ == nullptr || !ptr->conn_->is_connected()) { in connect()
22 return conn_ && conn_->is_connected(); in is_connected()
26 if (conn_ && conn_->is_connected()) { in close()
27 conn_->close(); in close()
51 if (conn_ == nullptr || !conn_->is_connected()) { in NetClientProxy()
63 conn_.reset(); in NetClientProxy()
72 conn_->close(); in NetClientProxy()
73 conn_.reset(); in NetClientProxy()
82 conn_.reset(); in NetClientProxy()
90 conn_.reset(); in NetClientProxy()
[all …]
H A Dnethostproxy.cc13 if (ptr->conn_ == nullptr || !ptr->conn_->is_connected()) { in connect()
20 if (conn_ && conn_->is_connected()) { in ~NetHostProxy()
25 conn_->close(); in ~NetHostProxy()
131 if (conn_ == nullptr || !conn_->is_connected()) { in NetHostProxy()
143 conn_.reset(); in NetHostProxy()
155 conn_->close(); in NetHostProxy()
156 conn_.reset(); in NetHostProxy()
166 conn_.reset(); in NetHostProxy()
176 conn_->close(); in NetHostProxy()
177 conn_.reset(); in NetHostProxy()
[all …]
/dports/net/mvfst/mvfst-248b2dc39bbd36863bbaa50385e8683428610009/quic/client/
H A DQuicClientTransport.cpp84 conn_->qLogger->setDcid(conn_->clientChosenDestConnectionId); in QuicClientTransport()
88 conn_->peerAckDelayExponent, conn_->originalVersion.value())); in QuicClientTransport()
333 conn_->version = conn_->originalVersion; in processPacketData()
730 *conn_, in processPacketData()
809 *conn_, in writeData()
819 *conn_, in writeData()
832 *conn_, in writeData()
916 *conn_, in writeData()
931 *conn_, in writeData()
948 conn_->flowControlState, conn_->transportSettings); in startCryptoHandshake()
[all …]
/dports/net/mvfst/mvfst-248b2dc39bbd36863bbaa50385e8683428610009/quic/server/
H A DQuicServerTransport.cpp145 if (conn_) { in setTransportStatsCallback()
199 conn_->flowControlState, conn_->transportSettings); in accept()
205 if (!conn_->clientConnectionId || !conn_->serverConnectionId) { in writeData()
208 auto version = conn_->version.value_or(*(conn_->originalVersion)); in writeData()
227 *conn_, in writeData()
237 *conn_, in writeData()
250 *conn_, in writeData()
353 *conn_, in writeData()
471 if (conn_->readCodec && conn_->readCodec->getOneRttReadCipher()) { in processPendingData()
476 } else if (conn_->readCodec && conn_->readCodec->getZeroRttReadCipher()) { in processPendingData()
[all …]
/dports/net/mvfst/mvfst-248b2dc39bbd36863bbaa50385e8683428610009/quic/api/
H A DQuicTransportBase.cpp76 CHECK(conn_); in setCongestionControllerFactory()
102 conn_->qLogger->setDcid(conn_->clientChosenDestConnectionId); in setQLogger()
104 conn_->qLogger->setScid(conn_->serverConnectionId); in setQLogger()
106 conn_->qLogger->setScid(conn_->clientConnectionId); in setQLogger()
2753 if (!conn_) { in getConnectionsStats()
2806 CHECK(conn_); in getDatagramSizeLimit()
2838 CHECK(conn_); in readDatagrams()
3260 CHECK(conn_); in describe()
3383 conn_->outstandings.packets, conn_->writeCount); in notifyStartWritingFromAppRateLimited()
3393 conn_->outstandings.packets, conn_->writeCount); in notifyPacketsWritten()
[all …]
H A DQuicPacketScheduler.cpp140 : conn_(conn), in Builder()
197 AckScheduler(conn_, getAckState(conn_, packetNumberSpace_))); in build()
210 conn_, *getCryptoStream(*conn_.cryptoState, encryptionLevel_))); in build()
357 : conn_(conn) {} in StreamFrameScheduler()
521 << conn_; in writeStreamFrame()
757 conn_(conn), in CloningScheduler()
766 conn_.d6d.outstandingProbes + conn_.outstandings.dsrCount; in hasData()
819 CHECK(conn_.bufAccessor && conn_.bufAccessor->ownsBuffer()); in scheduleFramesForPacket()
869 CHECK(conn_.bufAccessor && conn_.bufAccessor->ownsBuffer()); in scheduleFramesForPacket()
887 : conn_(conn), in D6DProbeScheduler()
[all …]
/dports/www/squid/squid-4.15/src/comm/
H A DConnOpener.cc37 conn_(c), in ConnOpener()
55 if (conn_ == NULL) { in doneAll()
220 Must(conn_ != NULL); in keepFd()
232 Must(conn_ != NULL); in start()
239 conn_->noteStart(); in start()
273 if (conn_->tos && in createFd()
275 conn_->tos = 0; in createFd()
277 if (conn_->nfmark && in createFd()
298 params.conn = conn_; in createFd()
328 fd_table[conn_->fd].local_addr = conn_->local; in connected()
[all …]
/dports/devel/cargo-c/cargo-c-0.9.6+cargo-0.58/cargo-crates/libnghttp2-sys-0.1.7+1.45.0/nghttp2/src/
H A Dshrpx_live_check.cc317 ev_io_set(&conn_.wev, conn_.fd, EV_WRITE); in initiate_connection()
318 ev_io_set(&conn_.rev, conn_.fd, EV_READ); in initiate_connection()
325 ev_timer_again(conn_.loop, &conn_.wt); in initiate_connection()
349 ev_timer_again(conn_.loop, &conn_.wt); in connected()
380 conn_.last_read = ev_now(conn_.loop); in tls_handshake()
449 conn_.last_read = ev_now(conn_.loop); in read_tls()
473 conn_.last_read = ev_now(conn_.loop); in write_tls()
512 ev_timer_stop(conn_.loop, &conn_.wt); in write_tls()
522 conn_.last_read = ev_now(conn_.loop); in read_clear()
544 conn_.last_read = ev_now(conn_.loop); in write_clear()
[all …]
H A Dshrpx_memcached_connection.cc208 ev_timer_again(conn_.loop, &conn_.wt); in initiate_connection()
244 ev_timer_stop(conn_.loop, &conn_.wt); in connected()
262 conn_.last_read = ev_now(conn_.loop); in tls_handshake()
286 ev_timer_stop(conn_.loop, &conn_.rt); in tls_handshake()
287 ev_timer_stop(conn_.loop, &conn_.wt); in tls_handshake()
304 conn_.last_read = ev_now(conn_.loop); in write_tls()
333 ev_timer_stop(conn_.loop, &conn_.wt); in write_tls()
343 conn_.last_read = ev_now(conn_.loop); in read_tls()
371 conn_.last_read = ev_now(conn_.loop); in write_clear()
389 ev_timer_stop(conn_.loop, &conn_.wt); in write_clear()
[all …]
/dports/net/proby/proby-1.0.2/cargo-crates/libnghttp2-sys-0.1.4+1.41.0/nghttp2/src/
H A Dshrpx_live_check.cc317 ev_io_set(&conn_.wev, conn_.fd, EV_WRITE); in initiate_connection()
318 ev_io_set(&conn_.rev, conn_.fd, EV_READ); in initiate_connection()
325 ev_timer_again(conn_.loop, &conn_.wt); in initiate_connection()
349 ev_timer_again(conn_.loop, &conn_.wt); in connected()
380 conn_.last_read = ev_now(conn_.loop); in tls_handshake()
449 conn_.last_read = ev_now(conn_.loop); in read_tls()
473 conn_.last_read = ev_now(conn_.loop); in write_tls()
512 ev_timer_stop(conn_.loop, &conn_.wt); in write_tls()
522 conn_.last_read = ev_now(conn_.loop); in read_clear()
544 conn_.last_read = ev_now(conn_.loop); in write_clear()
[all …]
/dports/devel/cargo-generate/cargo-generate-0.9.0/cargo-crates/libnghttp2-sys-0.1.6+1.43.0/nghttp2/src/
H A Dshrpx_live_check.cc317 ev_io_set(&conn_.wev, conn_.fd, EV_WRITE); in initiate_connection()
318 ev_io_set(&conn_.rev, conn_.fd, EV_READ); in initiate_connection()
325 ev_timer_again(conn_.loop, &conn_.wt); in initiate_connection()
349 ev_timer_again(conn_.loop, &conn_.wt); in connected()
380 conn_.last_read = ev_now(conn_.loop); in tls_handshake()
449 conn_.last_read = ev_now(conn_.loop); in read_tls()
473 conn_.last_read = ev_now(conn_.loop); in write_tls()
512 ev_timer_stop(conn_.loop, &conn_.wt); in write_tls()
522 conn_.last_read = ev_now(conn_.loop); in read_clear()
544 conn_.last_read = ev_now(conn_.loop); in write_clear()
[all …]
/dports/www/libnghttp2/nghttp2-1.46.0/src/
H A Dshrpx_live_check.cc317 ev_io_set(&conn_.wev, conn_.fd, EV_WRITE); in initiate_connection()
318 ev_io_set(&conn_.rev, conn_.fd, EV_READ); in initiate_connection()
325 ev_timer_again(conn_.loop, &conn_.wt); in initiate_connection()
349 ev_timer_again(conn_.loop, &conn_.wt); in connected()
380 conn_.last_read = ev_now(conn_.loop); in tls_handshake()
449 conn_.last_read = ev_now(conn_.loop); in read_tls()
473 conn_.last_read = ev_now(conn_.loop); in write_tls()
512 ev_timer_stop(conn_.loop, &conn_.wt); in write_tls()
522 conn_.last_read = ev_now(conn_.loop); in read_clear()
544 conn_.last_read = ev_now(conn_.loop); in write_clear()
[all …]
H A Dshrpx_memcached_connection.cc208 ev_timer_again(conn_.loop, &conn_.wt); in initiate_connection()
244 ev_timer_stop(conn_.loop, &conn_.wt); in connected()
262 conn_.last_read = ev_now(conn_.loop); in tls_handshake()
286 ev_timer_stop(conn_.loop, &conn_.rt); in tls_handshake()
287 ev_timer_stop(conn_.loop, &conn_.wt); in tls_handshake()
304 conn_.last_read = ev_now(conn_.loop); in write_tls()
333 ev_timer_stop(conn_.loop, &conn_.wt); in write_tls()
343 conn_.last_read = ev_now(conn_.loop); in read_tls()
371 conn_.last_read = ev_now(conn_.loop); in write_clear()
389 ev_timer_stop(conn_.loop, &conn_.wt); in write_clear()
[all …]
/dports/lang/rust/rustc-1.58.1-src/vendor/libnghttp2-sys/nghttp2/src/
H A Dshrpx_live_check.cc317 ev_io_set(&conn_.wev, conn_.fd, EV_WRITE); in initiate_connection()
318 ev_io_set(&conn_.rev, conn_.fd, EV_READ); in initiate_connection()
325 ev_timer_again(conn_.loop, &conn_.wt); in initiate_connection()
349 ev_timer_again(conn_.loop, &conn_.wt); in connected()
380 conn_.last_read = ev_now(conn_.loop); in tls_handshake()
449 conn_.last_read = ev_now(conn_.loop); in read_tls()
473 conn_.last_read = ev_now(conn_.loop); in write_tls()
512 ev_timer_stop(conn_.loop, &conn_.wt); in write_tls()
522 conn_.last_read = ev_now(conn_.loop); in read_clear()
544 conn_.last_read = ev_now(conn_.loop); in write_clear()
[all …]
/dports/www/nghttp2/nghttp2-1.46.0/src/
H A Dshrpx_live_check.cc317 ev_io_set(&conn_.wev, conn_.fd, EV_WRITE); in initiate_connection()
318 ev_io_set(&conn_.rev, conn_.fd, EV_READ); in initiate_connection()
325 ev_timer_again(conn_.loop, &conn_.wt); in initiate_connection()
349 ev_timer_again(conn_.loop, &conn_.wt); in connected()
380 conn_.last_read = ev_now(conn_.loop); in tls_handshake()
449 conn_.last_read = ev_now(conn_.loop); in read_tls()
473 conn_.last_read = ev_now(conn_.loop); in write_tls()
512 ev_timer_stop(conn_.loop, &conn_.wt); in write_tls()
522 conn_.last_read = ev_now(conn_.loop); in read_clear()
544 conn_.last_read = ev_now(conn_.loop); in write_clear()
[all …]
H A Dshrpx_memcached_connection.cc208 ev_timer_again(conn_.loop, &conn_.wt); in initiate_connection()
244 ev_timer_stop(conn_.loop, &conn_.wt); in connected()
262 conn_.last_read = ev_now(conn_.loop); in tls_handshake()
286 ev_timer_stop(conn_.loop, &conn_.rt); in tls_handshake()
287 ev_timer_stop(conn_.loop, &conn_.wt); in tls_handshake()
304 conn_.last_read = ev_now(conn_.loop); in write_tls()
333 ev_timer_stop(conn_.loop, &conn_.wt); in write_tls()
343 conn_.last_read = ev_now(conn_.loop); in read_tls()
371 conn_.last_read = ev_now(conn_.loop); in write_clear()
389 ev_timer_stop(conn_.loop, &conn_.wt); in write_clear()
[all …]
/dports/net/mvfst/mvfst-248b2dc39bbd36863bbaa50385e8683428610009/quic/server/handshake/test/
H A DDefaultAppTokenValidatorTest.cpp389 conn_.transportSettings.limitedCwndInMss * conn_.udpSendPacketLen); in TEST_F()
391 conn_.tokenSourceAddresses, in TEST_F()
401 conn_.transportSettings.limitedCwndInMss * conn_.udpSendPacketLen); in TEST_F()
403 conn_.tokenSourceAddresses, in TEST_F()
414 conn_.tokenSourceAddresses, in TEST_F()
427 conn_.transportSettings.limitedCwndInMss * conn_.udpSendPacketLen); in TEST_F()
429 conn_.tokenSourceAddresses, in TEST_F()
445 conn_.tokenSourceAddresses, in TEST_F()
466 conn_.tokenSourceAddresses, in TEST_F()
476 conn_.tokenSourceAddresses, in TEST_F()
[all …]
/dports/net/mvfst/mvfst-248b2dc39bbd36863bbaa50385e8683428610009/quic/dsr/test/
H A DTestCommon.h23 scheduler_(conn_), in DSRCommonTestFixture()
25 conn_.clientConnectionId = getTestConnectionId(0); in DSRCommonTestFixture()
26 conn_.serverConnectionId = getTestConnectionId(1); in DSRCommonTestFixture()
36 conn_.oneRttWriteCipher = std::move(mockCipher); in DSRCommonTestFixture()
39 conn_, in DSRCommonTestFixture()
45 conn_.handshakeLayer = std::move(serverHandshake_); in DSRCommonTestFixture()
56 conn_.flowControlState.peerAdvertisedMaxOffset = in prepareFlowControlAndStreamLimit()
70 auto stream = conn_.streamManager->findStream(id);
104 conn_.outstandings.packets.begin(), in verifyAllOutstandingsAreDSR()
105 conn_.outstandings.packets.end(), in verifyAllOutstandingsAreDSR()
[all …]
/dports/databases/cppdb/cppdb-0.3.1/src/
H A Dfrontend.cpp34 conn_ = 0; in done()
60 conn_(conn) in result()
69 conn_(other.conn_) in result()
80 conn_ = other.conn_; in operator =()
147 conn_.reset(); in clear()
225 conn_(other.conn_) in statement()
232 conn_=other.conn_; in operator =()
239 conn_(conn) in statement()
473 conn_(other.conn_) in session()
478 conn_ = other.conn_; in operator =()
[all …]

12345678910>>...16