diff options
| -rw-r--r-- | src/im-asapo.c | 13 |
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); |