aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/im-asapo.c13
1 files changed, 13 insertions, 0 deletions
diff --git a/src/im-asapo.c b/src/im-asapo.c
index a095c82e..2e5ed504 100644
--- a/src/im-asapo.c
+++ b/src/im-asapo.c
@@ -252,23 +252,30 @@ void *im_asapo_fetch(struct im_asapo *a, size_t *pdata_size,
AsapoErrorHandle err;
uint64_t msg_size;
+ profile_start("select-stream");
if ( a->stream == NULL ) {
if ( select_last_stream(a) ) {
+ profile_end("select-stream");
return NULL;
}
skip_to_stream_end(a);
}
+ profile_end("select-stream");
+ profile_start("create-handles");
err = asapo_new_handle();
meta = asapo_new_handle();
data = asapo_new_handle();
+ profile_end("create-handles");
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 ) {
+ profile_start("next-stream");
select_next_stream(a);
+ profile_end("next-stream");
asapo_free_handle(&err);
asapo_free_handle(&meta);
asapo_free_handle(&data);
@@ -283,8 +290,11 @@ void *im_asapo_fetch(struct im_asapo *a, size_t *pdata_size,
return NULL;
}
+ profile_start("get-size");
msg_size = asapo_message_meta_get_size(meta);
+ profile_end("get-size");
+ profile_start("malloc-copy");
data_copy = malloc(msg_size);
if ( data_copy == NULL ) {
ERROR("Failed to copy data block.\n");
@@ -294,10 +304,13 @@ void *im_asapo_fetch(struct im_asapo *a, size_t *pdata_size,
return NULL;
}
memcpy(data_copy, asapo_message_data_get_as_chars(data), msg_size);
+ profile_end("malloc-copy");
+ profile_start("copy-meta");
*pmeta = strdup(asapo_message_meta_get_metadata(meta));
*pfilename = strdup(asapo_message_meta_get_name(meta));
*pevent = strdup("//");
+ profile_end("copy-meta");
asapo_free_handle(&err);
asapo_free_handle(&meta);