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 /doc/articles | |
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 'doc/articles')
-rw-r--r-- | doc/articles/online.rst | 27 |
1 files changed, 22 insertions, 5 deletions
diff --git a/doc/articles/online.rst b/doc/articles/online.rst index 84e037ca..6183d7eb 100644 --- a/doc/articles/online.rst +++ b/doc/articles/online.rst @@ -7,9 +7,10 @@ socket. Use ``--zmq-input`` instead of ``--input`` or ``-i``. An error will be generated if you use ``--zmq-input`` and ``--input`` or ``-i`` simultaneously. -Indexamajig assumes that the socket is a *pub/sub* socket. You will also need -to specify which message prefixes to subscribe to. Use ``--zmq-subscribe`` for -this:: +Indexamajig can use either a SUB (subscriber) or a REQ (request) socket. The +SUB socket type can be used for receiving data from OnDA/OM via the same +mechanism that the OnDA/OM GUI uses. In this case, you will also need to +specify which message prefixes to subscribe to using ``--zmq-subscribe``:: indexamajig --zmq-input=tcp://127.0.0.1:5002 \ --zmq-subscribe=ondaframedata \ @@ -18,8 +19,24 @@ this:: You can use ``--zmq-subscribe`` multiple times to subscribe to multiple message prefixes. -The option ``--no-image-data`` will be honoured, if given. This makes it -possible to quickly check streaming data for "indexability". +Note that this mode of operation does not combine well with multi-threading +in inddxamajig - all worker processes will receive the same data! For anything +more than "taking a peek" at the data, use the REQ socket instead by using +``--zmq-request`` instead of ``--zmq-subscribe``. The argument to this option +is the string which should be sent in the request message:: + + indexamajig --zmq-input=tcp://127.0.0.1:5002 \ + --zmq-request=next \ + -o output.stream -g Eiger.geom ... + +Because they represent completely different modes of operation, the two options +``--zmq-request`` and ``--zmq-subscribe`` are mutually exclusive. + +In both cases, the option ``--no-image-data`` will be honoured, if given. This +makes it possible to quickly check streaming data for "indexability". You will +be able to do almost all of the usual downstream analysis operations on the +resulting stream, except that attempting to merge it using partialator or +process_hkl will result in zeroes everywhere. Data format |