diff options
Diffstat (limited to 'src/im-sandbox.c')
| -rw-r--r-- | src/im-sandbox.c | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/src/im-sandbox.c b/src/im-sandbox.c index ae1fe92a..4d40c461 100644 --- a/src/im-sandbox.c +++ b/src/im-sandbox.c @@ -102,6 +102,7 @@ struct sandbox const char *zmq_address; char **zmq_subscriptions; int n_zmq_subscriptions; + const char *zmq_request; /* Final output */ Stream *stream; @@ -335,7 +336,8 @@ static int run_work(const struct index_args *iargs, Stream *st, if ( sb->zmq ) { zmqstuff = im_zmq_connect(sb->zmq_address, sb->zmq_subscriptions, - sb->n_zmq_subscriptions); + sb->n_zmq_subscriptions, + sb->zmq_request); if ( zmqstuff == NULL ) { ERROR("ZMQ setup failed.\n"); return 1; @@ -1025,7 +1027,8 @@ int create_sandbox(struct index_args *iargs, int n_proc, char *prefix, int config_basename, FILE *fh, Stream *stream, const char *tmpdir, int serial_start, const char *zmq_address, char **zmq_subscriptions, - int n_zmq_subscriptions, int timeout, int profile) + int n_zmq_subscriptions, const char *zmq_request, + int timeout, int profile) { int i; struct sandbox *sb; @@ -1061,6 +1064,7 @@ int create_sandbox(struct index_args *iargs, int n_proc, char *prefix, sb->zmq_address = zmq_address; sb->zmq_subscriptions = zmq_subscriptions; sb->n_zmq_subscriptions = n_zmq_subscriptions; + sb->zmq_request = zmq_request; } else { sb->zmq = 0; } |