aboutsummaryrefslogtreecommitdiff
path: root/src/im-sandbox.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/im-sandbox.c')
-rw-r--r--src/im-sandbox.c18
1 files changed, 13 insertions, 5 deletions
diff --git a/src/im-sandbox.c b/src/im-sandbox.c
index 3da205f1..512a12df 100644
--- a/src/im-sandbox.c
+++ b/src/im-sandbox.c
@@ -454,6 +454,7 @@ static int run_work(const struct index_args *iargs, Stream *st,
pargs.event = safe_strdup(event_str);
free(line);
+ ok = 0;
if ( sb->zmq ) {
@@ -461,6 +462,7 @@ static int run_work(const struct index_args *iargs, Stream *st,
pargs.zmq_data = im_zmq_fetch(zmqstuff,
&pargs.zmq_data_size);
} while ( pargs.zmq_data_size < 15 );
+ ok = 1;
/* The filename/event, which will be 'fake' values in
* this case, still came via the event queue. More
@@ -473,17 +475,23 @@ static int run_work(const struct index_args *iargs, Stream *st,
* data comes via ASAP::O */
pargs.zmq_data = im_asapo_fetch(asapostuff,
&pargs.zmq_data_size);
+ if ( pargs.zmq_data != NULL ) {
+ ok = 1;
+ }
} else {
pargs.zmq_data = NULL;
pargs.zmq_data_size = 0;
+ ok = 1;
}
- sb->shared->time_last_start[cookie] = get_monotonic_seconds();
- profile_start("process-image");
- process_image(iargs, &pargs, st, cookie, tmpdir, ser,
- sb->shared, sb->shared->last_task[cookie]);
- profile_end("process-image");
+ if ( ok ) {
+ sb->shared->time_last_start[cookie] = get_monotonic_seconds();
+ profile_start("process-image");
+ process_image(iargs, &pargs, st, cookie, tmpdir, ser,
+ sb->shared, sb->shared->last_task[cookie]);
+ profile_end("process-image");
+ }
/* pargs.zmq_data will be copied into the image structure, so
* that it can be queried for "header" values etc. It will