diff options
| author | Thomas White <taw@physics.org> | 2024-04-29 16:04:29 +0200 |
|---|---|---|
| committer | Thomas White <taw@physics.org> | 2024-04-29 16:04:29 +0200 |
| commit | b62a4d1ff2e7ae19591a0501e35aadbd6eaaf472 (patch) | |
| tree | 60103ab6e73449718f8a254942b8271b5c2d6be6 | |
| parent | aecd2dcd9af71911ce0b2be0ac74c1820c02f3f7 (diff) | |
indexamajig: Report ASAP::O message ID for acknowledgement
Something strange is going on here, need to debug.
| -rw-r--r-- | src/im-asapo.c | 1 | ||||
| -rw-r--r-- | src/im-sandbox.c | 4 |
2 files changed, 3 insertions, 2 deletions
diff --git a/src/im-asapo.c b/src/im-asapo.c index 6df14e93..014c4774 100644 --- a/src/im-asapo.c +++ b/src/im-asapo.c @@ -278,6 +278,7 @@ void im_asapo_finalise(struct im_asapo *a, uint64_t message_id) AsapoErrorHandle err = asapo_new_handle(); asapo_consumer_acknowledge(a->consumer, a->group_id, message_id, a->stream, &err); + STATUS("Acknowledging ASAP::O message %lli\n", (long long int)message_id); if ( asapo_is_error(err) ) { show_asapo_error("Couldn't acknowledge ASAP::O message", err); } diff --git a/src/im-sandbox.c b/src/im-sandbox.c index 3d9f1f96..9c970cc1 100644 --- a/src/im-sandbox.c +++ b/src/im-sandbox.c @@ -343,7 +343,6 @@ static int run_work(const struct index_args *iargs, Stream *st, struct im_asapo *asapostuff = NULL; Mille *mille; ImageDataArrays *ida; - int asapo_message_id; if ( sb->profile ) { profile_init(); @@ -491,6 +490,7 @@ static int run_work(const struct index_args *iargs, Stream *st, char *filename; char *event; int finished = 0; + int asapo_message_id; profile_start("asapo-fetch"); set_last_task(sb->shared->last_task[cookie], "ASAPO fetch"); @@ -536,7 +536,7 @@ static int run_work(const struct index_args *iargs, Stream *st, } if ( sb->asapo_params != NULL ) { - im_asapo_finalise(asapostuff, asapo_message_id); + im_asapo_finalise(asapostuff, ser); } /* NB pargs.zmq_data, pargs.asapo_data and pargs.asapo_meta |