aboutsummaryrefslogtreecommitdiff
path: root/src/process_image.c
diff options
context:
space:
mode:
authorThomas White <taw@physics.org>2023-04-12 17:12:48 +0200
committerThomas White <taw@physics.org>2023-06-01 15:31:50 +0200
commit6730fa1c86654ccf84b4ad694f74cc1564cd2cee (patch)
tree1fc974d0853bfcc84c446e246ad2d772aa2aaf1b /src/process_image.c
parente922cc649959d2f05dc4df44b0d5889b0fcdb32c (diff)
indexamajig: Add --asapo-output-stream (hits only)
Diffstat (limited to 'src/process_image.c')
-rw-r--r--src/process_image.c5
1 files changed, 4 insertions, 1 deletions
diff --git a/src/process_image.c b/src/process_image.c
index 5bc527a1..8acd3e86 100644
--- a/src/process_image.c
+++ b/src/process_image.c
@@ -56,6 +56,7 @@
#include "predict-refine.h"
#include "im-sandbox.h"
#include "im-zmq.h"
+#include "im-asapo.h"
static float **backup_image_data(float **dp, struct detgeom *det)
{
@@ -177,7 +178,7 @@ static struct image *file_wait_open_read(const char *filename,
void process_image(const struct index_args *iargs, struct pattern_args *pargs,
Stream *st, int cookie, const char *tmpdir,
int serial, struct sb_shm *sb_shared,
- char *last_task)
+ char *last_task, struct im_asapo *asapostuff)
{
struct image *image;
int i;
@@ -480,6 +481,8 @@ streamwrite:
"%s\n", n, n>1?"s":"", image->filename, image->ev);
}
+ im_asapo_send(asapostuff, image, image->hit);
+
out:
/* Count crystals which are still good */
set_last_task(last_task, "process_image finalisation");