/dports/net/mvfst/mvfst-248b2dc39bbd36863bbaa50385e8683428610009/quic/flowcontrol/test/ |
H A D | QuicFlowControlTest.cpp | 28 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 D | Copa.cpp | 20 : 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 D | NewReno.cpp | 19 : 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 D | Copa2.cpp | 19 : 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 D | QuicCubic.cpp | 35 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 D | Bbr.cpp | 32 : 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 D | netclientproxy.cc | 11 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 D | nethostproxy.cc | 13 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 D | QuicClientTransport.cpp | 84 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 D | QuicServerTransport.cpp | 145 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 D | QuicTransportBase.cpp | 76 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 D | QuicPacketScheduler.cpp | 140 : 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 D | ConnOpener.cc | 37 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 D | shrpx_live_check.cc | 317 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 D | shrpx_memcached_connection.cc | 208 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 D | shrpx_live_check.cc | 317 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 D | shrpx_live_check.cc | 317 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 D | shrpx_live_check.cc | 317 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 D | shrpx_memcached_connection.cc | 208 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 D | shrpx_live_check.cc | 317 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 D | shrpx_live_check.cc | 317 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 D | shrpx_memcached_connection.cc | 208 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 D | DefaultAppTokenValidatorTest.cpp | 389 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 D | TestCommon.h | 23 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 D | frontend.cpp | 34 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 …]
|