generic-library/libzmq
1
0
Fork 0
mirror of https://github.com/zeromq/libzmq.git synced 2025-10-22 16:02:31 +02:00
Code Issues Projects Releases Wiki Activity

Scatter-Gather socket types

Browse Source
This commit is contained in:
somdoron
2016-04-21 13:23:44 +03:00
committed by Doron Somech
parent 317499edae
commit e6dae56c6e
13 changed files with 443 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/socket_base.cpp
View File

@@ -96,6 +96,8 @@
#include "client.hpp"
#include "radio.hpp"
#include "dish.hpp"
#include "gather.hpp"
#include "scatter.hpp"
#define ENTER_MUTEX() \
if (thread_safe) \
@@ -163,6 +165,12 @@ zmq::socket_base_t *zmq::socket_base_t::create (int type_, class ctx_t *parent_,
case ZMQ_DISH:
s = new (std::nothrow) dish_t (parent_, tid_, sid_);
break;
case ZMQ_GATHER:
s = new (std::nothrow) gather_t (parent_, tid_, sid_);
break;
case ZMQ_SCATTER:
s = new (std::nothrow) scatter_t (parent_, tid_, sid_);
break;
default:
errno = EINVAL;
return NULL;