From b5550e4399415fe4863057d6cbd406faf3f2df31 Mon Sep 17 00:00:00 2001 From: Thomas White Date: Sat, 3 Jun 2023 20:27:49 +0200 Subject: ASAP::O: Add verbose logging for hits-only stream Caution: extreme console spam --- src/im-asapo.c | 11 +++++++++++ 1 file changed, 11 insertions(+) (limited to 'src') diff --git a/src/im-asapo.c b/src/im-asapo.c index 7cc155bc..c34954e2 100644 --- a/src/im-asapo.c +++ b/src/im-asapo.c @@ -35,6 +35,7 @@ #include #include #include +#include #include #include @@ -113,6 +114,8 @@ static int create_producer(struct im_asapo *a, struct im_asapo_params *params) return 1; } + asapo_producer_set_log_level(a->producer, Debug); + asapo_free_handle(&err); return 0; } @@ -294,6 +297,10 @@ static void send_real(struct im_asapo *a, struct image *image) 0, 0); /* Auto ID */ + struct timeval tv; + gettimeofday(&tv,NULL); + STATUS("sent %s at %lli . %lli\n", filename, tv.tv_sec, tv.tv_usec); + err = asapo_new_handle(); asapo_producer_send(a->producer, header, image->data_block, kDefaultIngestMode, a->stream, @@ -319,6 +326,10 @@ static void send_placeholder(struct im_asapo *a, struct image *image) snprintf(filename, 1024, "processed/%s_hits/%s-%i.placeholder", a->stream, a->stream, image->serial); + struct timeval tv; + gettimeofday(&tv,NULL); + STATUS("sent %s at %lli . %lli\n", filename, tv.tv_sec, tv.tv_usec); + header = asapo_create_message_header(image->serial, 8, /* strlen("SKIPPED"+\0) */ filename, -- cgit v1.2.3