diff options
Diffstat (limited to 'src/pair.cpp')
-rw-r--r-- | src/pair.cpp | 33 |
1 files changed, 33 insertions, 0 deletions
diff --git a/src/pair.cpp b/src/pair.cpp index b4cb0b4..d4f699e 100644 --- a/src/pair.cpp +++ b/src/pair.cpp @@ -23,12 +23,17 @@ #include "err.hpp" #include "pipe.hpp" #include "msg.hpp" +#include "wire.hpp" xs::pair_t::pair_t (class ctx_t *parent_, uint32_t tid_, int sid_) : socket_base_t (parent_, tid_, sid_), pipe (NULL) { options.type = XS_PAIR; + options.sp_pattern = SP_PAIR; + options.sp_role = SP_PAIR_PAIR; + options.sp_version = 2; + options.sp_complement = SP_PAIR_PAIR; } xs::pair_t::~pair_t () @@ -36,6 +41,34 @@ xs::pair_t::~pair_t () xs_assert (!pipe); } +int xs::pair_t::xsetsockopt (int option_, const void *optval_, + size_t optvallen_) +{ + if (option_ != XS_PROTOCOL) { + errno = EINVAL; + return -1; + } + + if (optvallen_ != sizeof (int)) { + errno = EINVAL; + return -1; + } + + if (!optval_) { + errno = EFAULT; + return -1; + } + + int version = *(int *) optval_; + if (version != 2) { + errno = EINVAL; + return -1; + } + + options.sp_version = version; + return 0; +} + void xs::pair_t::xattach_pipe (pipe_t *pipe_, bool icanhasall_) { xs_assert (!pipe); |