From 651c1adc80ddc724877f2ebedf07d18e21e363f6 Mon Sep 17 00:00:00 2001 From: Martin Sustrik Date: Wed, 1 Sep 2010 15:24:46 +0200 Subject: sys transport introdced; inproc://log moved to sys://log --- src/socket_base.cpp | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) (limited to 'src/socket_base.cpp') diff --git a/src/socket_base.cpp b/src/socket_base.cpp index e3b956a..4a0ed24 100644 --- a/src/socket_base.cpp +++ b/src/socket_base.cpp @@ -143,7 +143,7 @@ int zmq::socket_base_t::check_protocol (const std::string &protocol_) { // First check out whether the protcol is something we are aware of. if (protocol_ != "inproc" && protocol_ != "ipc" && protocol_ != "tcp" && - protocol_ != "pgm" && protocol_ != "epgm") { + protocol_ != "pgm" && protocol_ != "epgm" && protocol_ != "sys") { errno = EPROTONOSUPPORT; return -1; } @@ -282,8 +282,8 @@ int zmq::socket_base_t::bind (const char *addr_) if (rc != 0) return -1; - if (protocol == "inproc") - return register_endpoint (address.c_str (), this); + if (protocol == "inproc" || protocol == "sys") + return register_endpoint (addr_, this); if (protocol == "tcp" || protocol == "ipc") { zmq_listener_t *listener = new (std::nothrow) zmq_listener_t ( @@ -335,14 +335,14 @@ int zmq::socket_base_t::connect (const char *addr_) if (rc != 0) return -1; - if (protocol == "inproc") { + if (protocol == "inproc" || protocol == "sys") { // TODO: inproc connect is specific with respect to creating pipes // as there's no 'reconnect' functionality implemented. Once that // is in place we should follow generic pipe creation algorithm. // Find the peer socket. - socket_base_t *peer = find_endpoint (address.c_str ()); + socket_base_t *peer = find_endpoint (addr_); if (!peer) return -1; -- cgit v1.2.3