Home
last modified time | relevance | path

Searched refs:toAck (Results 1 – 4 of 4) sorted by relevance

/dports/www/proxygen/proxygen-2021.12.27.00/proxygen/lib/http/codec/compress/
H A DQPACKDecoder.cpp395 uint32_t toAck = table_.getInsertCount() - lastAcked_; in encodeInsertCountInc() local
396 if (toAck > 0) { in encodeInsertCountInc()
397 VLOG(6) << "encodeInsertCountInc toAck=" << toAck; in encodeInsertCountInc()
399 ackEncoder.encodeInteger(toAck, HPACK::Q_INSERT_COUNT_INC); in encodeInsertCountInc()
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/dbcon/joblist/
H A Ddistributedenginecomm.cpp702 uint16_t* toAck; in sendAcks() local
712 toAck = &ism->Size; in sendAcks()
723 nextPMToACK(mqe, l_msgCount, &sockIndex, toAck); in sendAcks()
724 idbassert(*toAck <= l_msgCount); in sendAcks()
725 l_msgCount -= *toAck; in sendAcks()
742 *toAck = 1; in sendAcks()
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/dbcon/joblist/
H A Ddistributedenginecomm.cpp702 uint16_t* toAck; in sendAcks() local
712 toAck = &ism->Size; in sendAcks()
723 nextPMToACK(mqe, l_msgCount, &sockIndex, toAck); in sendAcks()
724 idbassert(*toAck <= l_msgCount); in sendAcks()
725 l_msgCount -= *toAck; in sendAcks()
742 *toAck = 1; in sendAcks()
/dports/net-im/ktp-common-internals/ktp-common-internals-21.12.3/KTp/OTR/
H A Dchannel-adapter.cpp249 QList<Tp::ReceivedMessage> toAck; in acknowledge() local
257 toAck << mes; in acknowledge()
260 d->otrProxy->AcknowledgePendingMessages(KTp::Utils::getPendingMessagesIDs(toAck)); in acknowledge()