diff options
| author | Thomas White <taw@physics.org> | 2020-06-08 17:36:49 +0200 |
|---|---|---|
| committer | Thomas White <taw@physics.org> | 2020-07-29 18:53:44 +0200 |
| commit | 11f2f894db82b35e9beb83d30a70ee26ae53b78b (patch) | |
| tree | 645803a6bc57065631bf7c85f63435fb5bde04dc /src | |
| parent | 9eec5930bbb8121c6ac1239fc48cc7c9852c78ff (diff) | |
Convert whirligig to new Stream API
Diffstat (limited to 'src')
| -rw-r--r-- | src/whirligig.c | 27 |
1 files changed, 12 insertions, 15 deletions
diff --git a/src/whirligig.c b/src/whirligig.c index 9a8dd07f..6c007f0b 100644 --- a/src/whirligig.c +++ b/src/whirligig.c @@ -7,7 +7,7 @@ * a research centre of the Helmholtz Association. * * Authors: - * 2012-2014 Thomas White <taw@physics.org> + * 2012-2020 Thomas White <taw@physics.org> * * This file is part of CrystFEL. * @@ -670,7 +670,7 @@ int main(int argc, char *argv[]) return 1; } - st = open_stream_for_read(argv[optind++]); + st = stream_open_for_read(argv[optind++]); if ( st == NULL ) { ERROR("Failed to open input stream '%s'\n", argv[optind-1]); return 1; @@ -714,29 +714,26 @@ int main(int argc, char *argv[]) win.join_ptr = 0; do { - struct image cur; + struct image *image; - cur.div = NAN; - cur.bw = NAN; - if ( read_chunk(st, &cur, NULL, - STREAM_READ_REFLECTIONS | STREAM_READ_UNITCELL) != 0 ) - { - break; - } + image = stream_read_chunk(st, NULL, STREAM_REFLECTIONS + | STREAM_UNITCELL); + + if ( image == NULL ) break; - if ( verbose ) printf("\n\nIncoming serial %i\n", cur.serial); + if ( verbose ) printf("\n\nIncoming serial %i\n", image->serial); - if ( isnan(cur.div) || isnan(cur.bw) ) { + if ( isnan(image->div) || isnan(image->bw) ) { ERROR("Chunk doesn't contain beam parameters.\n"); return 1; } - if ( cur.serial < 1 ) { + if ( image->serial < 1 ) { ERROR("Serial numbers must be greater than zero.\n"); return 1; } - add_to_window(&cur, &win, &ss); + add_to_window(image, &win, &ss); connect_series(&win); if ( verbose ) { @@ -764,7 +761,7 @@ int main(int argc, char *argv[]) display_progress(n_images); printf("\n"); - close_stream(st); + stream_close(st); find_and_process_series(&win, 1, &ss, outdir); |