diff options
| author | Thomas White <taw@physics.org> | 2024-04-29 18:55:26 +0200 |
|---|---|---|
| committer | Thomas White <taw@physics.org> | 2024-04-29 18:55:26 +0200 |
| commit | 58b495b0cf99a2908cf22de62a0f6b986886246e (patch) | |
| tree | 6fb5980e597fc90fa80d748247fbbf53066fa5a7 | |
| parent | b62a4d1ff2e7ae19591a0501e35aadbd6eaaf472 (diff) | |
indexamajig: Send ASAP::O acknowledgement only after process_image
Otherwise, we end up acknowledging the previous message ID after
receiving something like kEndOfStream.
| -rw-r--r-- | src/im-sandbox.c | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/src/im-sandbox.c b/src/im-sandbox.c index 9c970cc1..2fa19820 100644 --- a/src/im-sandbox.c +++ b/src/im-sandbox.c @@ -533,10 +533,11 @@ static int run_work(const struct index_args *iargs, Stream *st, sb->shared, sb->shared->last_task[cookie], asapostuff, mille, ida); profile_end("process-image"); - } - if ( sb->asapo_params != NULL ) { - im_asapo_finalise(asapostuff, ser); + if ( sb->asapo_params != NULL ) { + im_asapo_finalise(asapostuff, ser); + } + } /* NB pargs.zmq_data, pargs.asapo_data and pargs.asapo_meta |