cpp/libzmq
1
0
Fork 0
mirror of https://github.com/zeromq/libzmq synced 2025-03-28 21:13:24 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge e7ff60ff6e5cc9b464d15ab76c417f24bacd0c48 into 34f7fa22022bed9e0e390ed3580a1c83ac4a2834

Browse Source
This commit is contained in:
ZhuXxxx 2025-01-02 16:10:19 +01:00 committed by GitHub
commit 1f38f67bdd
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
3 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/pipe.cpp
View File

@ -537,6 +537,11 @@ bool zmq::pipe_t::check_hwm () const
return !full;
}
bool zmq::pipe_t::is_active () const
{
return active == _state;
}
void zmq::pipe_t::send_hwms_to_peer (int inhwm_, int outhwm_)
{
if (_state == active)

2
src/pipe.hpp
View File

@ -115,6 +115,8 @@ class pipe_t ZMQ_FINAL : public object_t,
// Returns true if HWM is not reached
bool check_hwm () const;
bool is_active () const;
void set_endpoint_pair (endpoint_uri_pair_t endpoint_pair_);
const endpoint_uri_pair_t &get_endpoint_pair () const;

3
src/router.cpp
View File

@ -185,12 +185,13 @@ int zmq::router_t::xsend (msg_t *msg_)
if (!_current_out->check_write ()) {
// Check whether pipe is full or not
const bool pipe_full = !_current_out->check_hwm ();
const bool pipe_active = _current_out->is_active ();
out_pipe->active = false;
_current_out = NULL;
if (_mandatory) {
_more_out = false;
if (pipe_full)
if (pipe_full && pipe_active)
errno = EAGAIN;
else
errno = EHOSTUNREACH;