/dports/devel/google-cloud-cpp117/google-cloud-cpp-1.17.0/google/cloud/pubsub/internal/ |
H A D | subscription_flow_control_test.cc | 88 acks_.push_back(m.ack_id()); in SaveAcks() 137 EXPECT_THAT(ack_id, "ack-0-0"); in TEST_F() 142 EXPECT_THAT(ack_id, "ack-1-0"); in TEST_F() 316 EXPECT_EQ("ack-0-1", ack_id); in TEST_F() 320 EXPECT_EQ("ack-0-3", ack_id); in TEST_F() 324 EXPECT_EQ("ack-1-1", ack_id); in TEST_F() 330 EXPECT_EQ("ack-0-0", ack_id); in TEST_F() 334 EXPECT_EQ("ack-0-2", ack_id); in TEST_F() 338 EXPECT_EQ("ack-0-4", ack_id); in TEST_F() 342 EXPECT_EQ("ack-1-0", ack_id); in TEST_F() [all …]
|
H A D | subscription_concurrency_control.cc | 29 std::string ack_id, std::int32_t delivery_attempt, in AckHandlerImpl() argument 32 ack_id_(std::move(ack_id)), in AckHandlerImpl() 43 std::string ack_id() const override { return ack_id_; } in ack_id() function in google::cloud::pubsub_internal::GOOGLE_CLOUD_CPP_PUBSUB_NS::__anonc34b78750111::AckHandlerImpl 76 void SubscriptionConcurrencyControl::AckMessage(std::string const& ack_id, in AckMessage() argument 78 source_->AckMessage(ack_id, size); in AckMessage() 82 void SubscriptionConcurrencyControl::NackMessage(std::string const& ack_id, in NackMessage() argument 84 source_->NackMessage(ack_id, size); in NackMessage() 113 GCP_LOG(DEBUG) << "calling callback(" << h->ack_id() << ")"; in OnMessage()
|
H A D | ordering_key_publisher_connection_test.cc | 47 auto ack_id = p.message.ordering_key() + "#" + in TEST() local 49 return make_ready_future(make_status_or(ack_id)); in TEST() 60 std::string ack_id = step.ordering_key + "#" + step.data; in TEST() local 66 .then([ack_id](future<StatusOr<std::string>> f) { in TEST() 69 EXPECT_EQ(ack_id, *r); in TEST()
|
H A D | subscription_message_queue.cc | 57 future<Status> SubscriptionMessageQueue::AckMessage(std::string const& ack_id, in AckMessage() argument 59 return source_->AckMessage(ack_id, size); in AckMessage() 62 future<Status> SubscriptionMessageQueue::NackMessage(std::string const& ack_id, in NackMessage() argument 64 return source_->NackMessage(ack_id, size); in NackMessage()
|
H A D | subscription_lease_management.cc | 35 std::string const& ack_id, std::size_t) { in AckMessage() argument 37 leases_.erase(ack_id); in AckMessage() 41 request.add_ack_ids(ack_id); in AckMessage() 47 std::string const& ack_id, std::size_t) { in NackMessage() argument 49 leases_.erase(ack_id); in NackMessage() 53 request.add_ack_ids(ack_id); in NackMessage() 103 leases_.emplace(rm.ack_id(), in OnPull()
|
H A D | subscription_message_queue_test.cc | 33 .WillOnce([](std::string const& ack_id, std::size_t size) { in TEST() argument 34 EXPECT_EQ("ack-m0", ack_id); in TEST() 39 .WillOnce([](std::string const& ack_id, std::size_t size) { in TEST() argument 40 EXPECT_EQ("ack-m1", ack_id); in TEST()
|
H A D | subscription_flow_control.cc | 42 future<Status> SubscriptionFlowControl::AckMessage(std::string const& ack_id, in AckMessage() argument 44 auto result = queue_.AckMessage(ack_id, size); in AckMessage() 49 future<Status> SubscriptionFlowControl::NackMessage(std::string const& ack_id, in NackMessage() argument 51 auto result = queue_.NackMessage(ack_id, size); in NackMessage()
|
H A D | subscription_message_source.h | 62 virtual future<Status> AckMessage(std::string const& ack_id, 74 virtual future<Status> NackMessage(std::string const& ack_id,
|
H A D | subscription_batch_source.h | 56 virtual future<Status> AckMessage(std::string const& ack_id, 68 virtual future<Status> NackMessage(std::string const& ack_id,
|
/dports/devel/google-cloud-cpp/google-cloud-cpp-1.21.0/google/cloud/pubsub/internal/ |
H A D | subscription_message_queue.cc | 47 void SubscriptionMessageQueue::AckMessage(std::string const& ack_id) { in AckMessage() argument 48 HandlerDone(ack_id); in AckMessage() 49 source_->AckMessage(ack_id); in AckMessage() 52 void SubscriptionMessageQueue::NackMessage(std::string const& ack_id) { in NackMessage() argument 53 HandlerDone(ack_id); in NackMessage() 54 source_->NackMessage(ack_id); in NackMessage() 142 ordering_key_by_ack_id_[m.ack_id()] = m.message().ordering_key(); in DrainQueue() 152 void SubscriptionMessageQueue::HandlerDone(std::string const& ack_id) { in HandlerDone() argument 155 auto loc = ordering_key_by_ack_id_.find(ack_id); in HandlerDone()
|
H A D | ordering_key_publisher_connection_test.cc | 45 auto ack_id = p.message.ordering_key() + "#" + in TEST() local 47 return make_ready_future(make_status_or(ack_id)); in TEST() 59 std::string ack_id = step.ordering_key + "#" + step.data; in TEST() local 65 .then([ack_id](future<StatusOr<std::string>> f) { in TEST() 68 EXPECT_EQ(ack_id, *r); in TEST()
|
H A D | subscription_concurrency_control.cc | 28 std::string ack_id, std::int32_t delivery_attempt) in AckHandlerImpl() argument 30 ack_id_(std::move(ack_id)), in AckHandlerImpl() 70 void SubscriptionConcurrencyControl::AckMessage(std::string const& ack_id) { in AckMessage() argument 71 source_->AckMessage(ack_id); in AckMessage() 75 void SubscriptionConcurrencyControl::NackMessage(std::string const& ack_id) { in NackMessage() argument 76 source_->NackMessage(ack_id); in NackMessage()
|
H A D | subscription_lease_management.cc | 44 void SubscriptionLeaseManagement::AckMessage(std::string const& ack_id) { in AckMessage() argument 46 leases_.erase(ack_id); in AckMessage() 48 child_->AckMessage(ack_id); in AckMessage() 51 void SubscriptionLeaseManagement::NackMessage(std::string const& ack_id) { in NackMessage() argument 53 leases_.erase(ack_id); in NackMessage() 55 child_->NackMessage(ack_id); in NackMessage() 85 leases_.emplace(rm.ack_id(), in OnRead()
|
H A D | subscription_message_queue.h | 74 void AckMessage(std::string const& ack_id) override; 75 void NackMessage(std::string const& ack_id) override; 91 void HandlerDone(std::string const& ack_id);
|
H A D | subscription_message_source.h | 60 virtual void AckMessage(std::string const& ack_id) = 0; 69 virtual void NackMessage(std::string const& ack_id) = 0;
|
H A D | subscription_batch_source.h | 60 virtual void AckMessage(std::string const& ack_id) = 0; 69 virtual void NackMessage(std::string const& ack_id) = 0;
|
/dports/net/py-socketio-client/socketIO_client-0.6.7/socketIO_client/ |
H A D | parsers.py | 56 def format_socketIO_packet_data(path=None, ack_id=None, args=None): argument 58 if ack_id is not None: 59 socketIO_packet_data = str(ack_id) + socketIO_packet_data 78 ack_id = int(ack_id_string) 80 ack_id = None 85 return SocketIOData(path=path, ack_id=ack_id, args=args)
|
H A D | __init__.py | 418 ack_id = self._set_ack_callback(callback) if callback else None 421 socketIO_packet_data = format_socketIO_packet_data(path, ack_id, args) 431 def _ack(self, path, ack_id, *args): argument 433 socketIO_packet_data = format_socketIO_packet_data(path, ack_id, args) 494 if data_parsed.ack_id is not None: 496 data_parsed.path, data_parsed.ack_id)) 502 ack_callback = self._get_ack_callback(data_parsed.ack_id) 516 def _prepare_to_send_ack(self, path, ack_id): argument 518 return lambda *args: self._ack(path, ack_id, *args) 525 def _get_ack_callback(self, ack_id): argument [all …]
|
/dports/devel/google-cloud-cpp117/google-cloud-cpp-1.17.0/google/cloud/pubsub/ |
H A D | ack_handler.h | 56 std::string ack_id() const { return impl_->ack_id(); } in ack_id() function 71 virtual std::string ack_id() const = 0;
|
/dports/net/py-stomp.py/stomp.py-4.1.17/stomp/test/ |
H A D | s12_test.py | 52 ack_id = headers['ack'] 54 self.conn.ack(ack_id) 66 ack_id = headers['ack'] 68 self.conn.nack(ack_id)
|
/dports/devel/google-cloud-cpp/google-cloud-cpp-1.21.0/google/cloud/pubsub/testing/ |
H A D | mock_subscription_message_source.h | 33 MOCK_METHOD1(AckMessage, void(std::string const& ack_id)); 34 MOCK_METHOD1(NackMessage, void(std::string const& ack_id));
|
H A D | mock_subscription_batch_source.h | 32 MOCK_METHOD1(AckMessage, void(std::string const& ack_id)); 33 MOCK_METHOD1(NackMessage, void(std::string const& ack_id));
|
/dports/devel/google-cloud-cpp117/google-cloud-cpp-1.17.0/google/cloud/pubsub/testing/ |
H A D | mock_subscription_message_source.h | 34 future<Status>(std::string const& ack_id, std::size_t size)); 36 future<Status>(std::string const& ack_id, std::size_t size));
|
H A D | mock_subscription_batch_source.h | 32 future<Status>(std::string const& ack_id, std::size_t size)); 34 future<Status>(std::string const& ack_id, std::size_t size));
|
/dports/emulators/qemu42/qemu-4.2.1/roms/skiboot/hw/fsp/ |
H A D | fsp-elog-read.c | 396 static int64_t fsp_opal_elog_ack(uint64_t ack_id) in fsp_opal_elog_ack() argument 401 if (opal_elog_ack(ack_id)) in fsp_opal_elog_ack() 405 rc = fsp_send_elog_ack(ack_id); in fsp_opal_elog_ack() 413 if (record->log_id != ack_id) in fsp_opal_elog_ack() 423 if (record->log_id != ack_id) in fsp_opal_elog_ack()
|