aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/im-asapo.c3
-rw-r--r--src/im-sandbox.c2
2 files changed, 5 insertions, 0 deletions
diff --git a/src/im-asapo.c b/src/im-asapo.c
index f336a735..48a32ee4 100644
--- a/src/im-asapo.c
+++ b/src/im-asapo.c
@@ -39,6 +39,7 @@
#include <image.h>
#include <utils.h>
+#include <profile.h>
#include "im-asapo.h"
@@ -262,8 +263,10 @@ void *im_asapo_fetch(struct im_asapo *a, size_t *pdata_size,
meta = asapo_new_handle();
data = asapo_new_handle();
+ profile_start("asapo-get-next");
asapo_consumer_get_next(a->consumer, a->group_id, &meta, &data,
a->stream, &err);
+ profile_end("asapo-get-next");
if ( asapo_error_get_type(err) == kEndOfStream ) {
select_next_stream(a);
asapo_free_handle(&err);
diff --git a/src/im-sandbox.c b/src/im-sandbox.c
index 158da59b..6e4b7fcd 100644
--- a/src/im-sandbox.c
+++ b/src/im-sandbox.c
@@ -476,10 +476,12 @@ static int run_work(const struct index_args *iargs, Stream *st,
/* Temporary (?) abuse of "zmq_data", even though
* data comes via ASAP::O */
+ profile_start("asapo-fetch");
pargs.zmq_data = im_asapo_fetch(asapostuff,
&pargs.zmq_data_size,
&filename,
&event);
+ profile_end("asapo-fetch");
if ( pargs.zmq_data != NULL ) {
ok = 1;