| /dports/www/proxygen/proxygen-2021.12.27.00/proxygen/lib/http/session/ |
| H A D | HQUpstreamSession.cpp | 174 hq::PushId pushId, in tryBindIngressStreamToTxn() argument
180 << " to pushID=" << pushId; in tryBindIngressStreamToTxn()
194 << pushId; in tryBindIngressStreamToTxn()
199 << " to pushID=" << pushId; in tryBindIngressStreamToTxn()
214 std::forward_as_tuple(pushId), in createIngressPushStream()
217 pushId, in createIngressPushStream()
278 auto pushId = res->second; in erasePushStream() local
285 pushIdToStreamId_.erase(pushId); in erasePushStream()
314 << " pushId=" << pushId; in onNewPushStream()
396 ingressPushStreams_.erase(pushId); in eraseUnboundStream()
[all …]
|
| H A D | HQDownstreamSession.cpp | 72 HQDownstreamSession::createEgressPushStream(hq::PushId pushId, in createEgressPushStream() argument
86 << " sess=" << *this << " pushId=" << pushId in createEgressPushStream()
100 pushId, in createEgressPushStream()
107 pushIdToStreamId_[pushId] = streamId; in createEgressPushStream()
108 streamIdToPushId_[streamId] = pushId; in createEgressPushStream()
162 auto pushId = createNewPushId(); in newPushedTransaction() local
166 pushId, pushStreamId.value(), parentRequestStreamId); in newPushedTransaction()
174 VLOG(4) << "New pushed transaction: pushId=" << pushId in newPushedTransaction()
202 auto pushId = pushIdIter->second; in erasePushStream() local
203 pushIdToStreamId_.erase(pushId); in erasePushStream()
[all …]
|
| H A D | HQUpstreamSession.h | 121 hq::PushId pushId,
130 static_cast<HTTPCodec::StreamID>(pushId), in SSIngress()
137 pushId_(pushId) { in SSIngress()
149 cb->onHalfOpenPushedTxn(&txn_, pushId, *parentTxnId, false); in SSIngress()
156 void onPushMessageBegin(HTTPCodec::StreamID pushId, in onPushMessageBegin() argument
160 << " txn=" << txn_ << " pushID=" << pushId in onPushMessageBegin()
211 hq::PushId pushId,
216 hq::PushId pushId) override;
|
| H A D | HQUnidirectionalCallbacks.cpp | 105 auto pushId = quic::decodeQuicInteger(cursor); in onDataAvailable() local
109 if (pushId) { in onDataAvailable()
110 consumed += pushId->second; in onDataAvailable()
111 sink_.onNewPushStream(releaseOwnership(id), pushId->first, consumed); in onDataAvailable()
|
| H A D | HQDownstreamSession.h | 101 hq::PushId pushId,
118 pushId_(pushId) { in SSEgress()
174 createEgressPushStream(hq::PushId pushId,
|
| H A D | HQSession.cpp | 596 auto iter = pushIdToStreamId_.find(pushId); in sendPushPriority()
603 << " with pushId=" << pushId << " presented in id map"; in sendPushPriority()
613 controlStream->writeBuf_, pushId, priority); in sendPushPriority()
628 auto pushId = txn->getID(); in changePriority() local
629 return session_.sendPushPriority(pushId, priority); in changePriority()
1717 void HQSession::onPushPriority(hq::PushId pushId, const HTTPPriority& pri) { in onPushPriority() argument
1724 if (maxAllowedPushId_.hasValue() && *maxAllowedPushId_ < pushId) { in onPushPriority()
1725 VLOG(4) << "Priority update stream id=" << pushId in onPushPriority()
1732 auto iter = pushIdToStreamId_.find(pushId); in onPushPriority()
1734 VLOG(4) << "Priority update of unknown push id=" << pushId; in onPushPriority()
[all …]
|
| /dports/www/proxygen/proxygen-2021.12.27.00/proxygen/lib/http/session/test/ |
| H A D | HQUpstreamSessionTest.cpp | 1240 return (pushId % 2) == 1; in isPushIdValid()
1401 if (pushId == kUnknownPushId) { in sendPushPromise()
1402 pushId = nextPushId(); in sendPushPromise()
1448 if (pushId.has_value()) { in createPushStreamImpl()
1545 hq::PushId pushId = nextPushId(); in TEST_P() local
1576 hq::PushId pushId = nextPushId(); in TEST_P() local
1636 hq::PushId pushId = nextPushId(); in TEST_P() local
1685 hq::PushId pushId = nextPushId(); in TEST_P() local
1737 pushId, in TEST_P()
1843 pushId, in TEST_P()
[all …]
|
| H A D | HQUnidirectionalCallbacksTest.cpp | 49 uint64_t pushId, in sendData() argument
55 encodeQuicIntegerWithAtLeast(pushId, atLeast, appender); in sendData()
134 [&](quic::StreamId id, hq::PushId pushId, size_t consumed) { in TEST_F() argument
136 ASSERT_EQ(pushId, expectedPushId); in TEST_F()
|
| H A D | HQUpstreamSessionTest.h | 93 : codecId(cId), codec(std::move(c)), pushId(pId) { in codecId()
105 folly::Optional<proxygen::hq::PushId> pushId; member
|
| H A D | HQSessionTestCommon.h | 270 auto pushId = quic::decodeQuicInteger(cursor); in unidirectionalReadCallback() local
271 if (pushId) { in unidirectionalReadCallback()
272 pushes_.emplace(id, pushId->first); in unidirectionalReadCallback()
|
| /dports/www/proxygen/proxygen-2021.12.27.00/proxygen/lib/http/codec/ |
| H A D | HQFramer.cpp | 140 if (!pushId) { in parsePushPromise()
143 outPushId = pushId->first; in parsePushPromise()
144 frameLength -= pushId->second; in parsePushPromise()
232 PushId pushId) noexcept { in writeCancelPush() argument
233 auto pushIdSize = quic::getQuicIntegerSize(pushId); in writeCancelPush()
239 quic::encodeQuicInteger(pushId, in writeCancelPush()
280 PushId pushId, in writePushPromise() argument
283 auto pushIdSize = quic::getQuicIntegerSize(pushId); in writePushPromise()
348 hq::PushId pushId, in writePushPriorityUpdate() argument
351 auto streamIdSize = quic::getQuicIntegerSize(pushId); in writePushPriorityUpdate()
[all …]
|
| H A D | HQStreamCodec.cpp | 316 StreamID pushId, in generatePushPromise() argument
322 writeBuf, msg, pushId, size, folly::none /* extraHeaders */); in generatePushPromise()
328 folly::Optional<StreamID> pushId, in generateHeaderImpl() argument
351 if (pushId) { in generateHeaderImpl()
352 res = hq::writePushPromise(writeBuf, *pushId, std::move(result)); in generateHeaderImpl()
359 << ((pushId) ? "push promise: " : "headers: ") << res.error(); in generateHeaderImpl()
|
| H A D | HQFramer.h | 250 PushId pushId) noexcept;
276 PushId pushId,
317 hq::PushId pushId,
|
| H A D | HQControlCodec.cpp | 270 StreamID pushId, in generatePushPriority() argument
280 auto writeRet = hq::writePushPriorityUpdate(writeBuf, pushId, updateString); in generatePushPriority()
282 LOG(ERROR) << "error writing push priority update, pushId=" << pushId in generatePushPriority()
|
| H A D | HQMultiCodec.h | 213 void onIngressPushId(uint64_t pushId) { in onIngressPushId() argument
214 minUnseenPushID_ = std::max(minUnseenPushID_, pushId + 1); in onIngressPushId()
|
| H A D | HTTPCodecFilter.cpp | 350 folly::IOBufQueue& writeBuf, StreamID pushId, HTTPPriority priority) { in generatePushPriority() argument
351 return call_->generatePriority(writeBuf, pushId, priority); in generatePushPriority()
|
| H A D | HQControlCodec.h | 101 StreamID pushId,
|
| H A D | HQStreamCodec.h | 155 folly::Optional<StreamID> pushId,
|
| H A D | HTTPCodecFilter.h | 232 StreamID pushId,
|
| /dports/security/keybase/client-v5.7.1/shared/android/app/src/main/java/io/keybase/ossifrage/ |
| H A D | KeybasePushNotificationListenerService.java | 186 n.membersType, n.displayPlaintext, n.messageId, n.pushId, in onMessageReceived()
258 final String pushId; field in NotificationData
279 pushId = ""; in NotificationData()
291 pushId = pushIdTmp; in NotificationData()
|
| /dports/www/proxygen/proxygen-2021.12.27.00/proxygen/lib/http/codec/test/ |
| H A D | TestUtils.h | 129 pushId = pushPromiseId; in onPushMessageBegin()
329 pushId = 0; in reset()
374 VLOG(verbosity) << "pushId: " << pushId; in dumpCounters()
406 HTTPCodec::StreamID pushId{0};
|
| H A D | HQFramerTest.cpp | 32 bool isValidPushId(folly::Optional<PushId> maxAllowedPushId, PushId pushId) { in isValidPushId() argument
36 } else if (!comparePushId(maxAllowedPushId.value(), pushId)) { in isValidPushId()
37 VLOG(3) << __func__ << "given pushid=" << pushId in isValidPushId()
|
| H A D | HQCodecTest.cpp | 236 hq::PushId pushId = 1234; in TEST_F() local
242 downstreamCodec_->generatePushPromise(queue_, streamId_, msg, pushId, false); in TEST_F()
250 EXPECT_EQ(callbacks_.pushId, pushId); in TEST_F()
|
| /dports/www/proxygen/proxygen-2021.12.27.00/proxygen/lib/http/stats/ |
| H A D | HTTPCodecStatsFilter.cpp | 225 StreamID pushId, in generatePushPriority() argument
228 return call_->generatePushPriority(writeBuf, pushId, pri); in generatePushPriority()
|
| H A D | HTTPCodecStatsFilter.h | 132 StreamID pushId,
|