diff options
| author | Thomas White <taw@physics.org> | 2021-05-05 17:07:13 +0200 |
|---|---|---|
| committer | Thomas White <taw@physics.org> | 2021-05-05 17:14:04 +0200 |
| commit | ce270ad7d8136aac47a802a9a72c011344f90527 (patch) | |
| tree | 1df70574efad2ceb31edb43582ba7ff2c8a2c8ea /src/im-sandbox.c | |
| parent | e11394ce9133333af01afd88a0f484d6ea70665d (diff) | |
indexamajig: Add --zmq-request
This (re-)adds the ability to get data via a request/reply socket.
See afcb7b568947c for when it was removed.
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; } |