peer.cpp

/* SPDX-License-Identifier: MPL-2.0 */

#include "precompiled.hpp"
#include "macros.hpp"
#include "peer.hpp"
#include "pipe.hpp"
#include "wire.hpp"
#include "random.hpp"
#include "likely.hpp"
#include "err.hpp"

zmq::peer_t::peer_t (class ctx_t *parent_, uint32_t tid_, int sid_) :
    server_t (parent_, tid_, sid_)
{
    options.type = ZMQ_PEER;
    options.can_send_hello_msg = true;
    options.can_recv_disconnect_msg = true;
    options.can_recv_hiccup_msg = true;
}

uint32_t zmq::peer_t::connect_peer (const char *endpoint_uri_)
{
    scoped_optional_lock_t sync_lock (&_sync);

    // connect_peer cannot work with immediate enabled
    if (options.immediate == 1) {
        errno = EFAULT;
        return 0;
    }

    int rc = socket_base_t::connect_internal (endpoint_uri_);
    if (rc != 0)
        return 0;

    return _peer_last_routing_id;
}

void zmq::peer_t::xattach_pipe (pipe_t *pipe_,
                                bool subscribe_to_all_,
                                bool locally_initiated_)
{
    server_t::xattach_pipe (pipe_, subscribe_to_all_, locally_initiated_);
    _peer_last_routing_id = pipe_->get_server_socket_routing_id ();
}