Home
last modified time | relevance | path

Searched refs:ack_id (Results 1 – 25 of 94) sorted by relevance

1234

/dports/devel/google-cloud-cpp117/google-cloud-cpp-1.17.0/google/cloud/pubsub/internal/
H A Dsubscription_flow_control_test.cc88 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 Dsubscription_concurrency_control.cc29 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 Dordering_key_publisher_connection_test.cc47 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 Dsubscription_message_queue.cc57 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 Dsubscription_lease_management.cc35 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 Dsubscription_message_queue_test.cc33 .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 Dsubscription_flow_control.cc42 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 Dsubscription_message_source.h62 virtual future<Status> AckMessage(std::string const& ack_id,
74 virtual future<Status> NackMessage(std::string const& ack_id,
H A Dsubscription_batch_source.h56 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 Dsubscription_message_queue.cc47 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 Dordering_key_publisher_connection_test.cc45 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 Dsubscription_concurrency_control.cc28 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 Dsubscription_lease_management.cc44 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 Dsubscription_message_queue.h74 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 Dsubscription_message_source.h60 virtual void AckMessage(std::string const& ack_id) = 0;
69 virtual void NackMessage(std::string const& ack_id) = 0;
H A Dsubscription_batch_source.h60 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 Dparsers.py56 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__.py418 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 Dack_handler.h56 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 Ds12_test.py52 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 Dmock_subscription_message_source.h33 MOCK_METHOD1(AckMessage, void(std::string const& ack_id));
34 MOCK_METHOD1(NackMessage, void(std::string const& ack_id));
H A Dmock_subscription_batch_source.h32 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 Dmock_subscription_message_source.h34 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 Dmock_subscription_batch_source.h32 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 Dfsp-elog-read.c396 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()

1234