test (49288cfc) · Commits · tuxist / libparitypp

src/client.cpp

+4 −4

Original line number	Diff line number	Diff line
		@@ -58,7 +58,7 @@ void client::connect_to_node(size_t node_index) {
		nc.socket->connect(nodes_[node_index].address, nodes_[node_index].port, false);

		// Wait for handshake using event-driven wait (epoll/kqueue/IOCP/poll)
		auto hs_deadline = std::chrono::steady_clock::now() + std::chrono::seconds(5);
		auto hs_deadline = std::chrono::steady_clock::now() + std::chrono::seconds(2);
		while (int poll_ms = ms_left(hs_deadline)) {
		if (nc.socket->hasPendingWrite()) {
		if (!wait_.waitWrite(*nc.socket, poll_ms)) continue;
		@@ -147,7 +147,7 @@ std::vector<uint8_t> client::send_recv(size_t node_index,
		uint64_t stream = conn.openStream(true);
		auto msg = protocol::encode_message(type, payload);

		auto sr_deadline = std::chrono::steady_clock::now() + std::chrono::seconds(15);
		auto sr_deadline = std::chrono::steady_clock::now() + std::chrono::seconds(5);

		// Non-blocking send: wait for writable, then send
		while (int poll_ms = ms_left(sr_deadline)) {
		@@ -283,7 +283,7 @@ void client::store_stripe(uint64_t group_id, uint32_t stripe_index,

		size_t n = k_ + m_;

		auto stripe_deadline = std::chrono::steady_clock::now() + std::chrono::seconds(15);
		auto stripe_deadline = std::chrono::steady_clock::now() + std::chrono::seconds(5);

		// Pending stream info per node-slot
		struct Pending {
		@@ -528,7 +528,7 @@ bool client::retrieve_stripe(uint64_t group_id, uint32_t stripe_index,
		std::vector<uint8_t>& out) {
		size_t n = k_ + m_;

		auto retr_deadline = std::chrono::steady_clock::now() + std::chrono::seconds(15);
		auto retr_deadline = std::chrono::steady_clock::now() + std::chrono::seconds(5);

		// Pipelined fetch: send requests to all nodes in parallel,
		// then collect responses using waitReadMulti.