diff options
| author | Thomas White <taw@physics.org> | 2022-05-04 12:14:27 +0200 |
|---|---|---|
| committer | Thomas White <taw@physics.org> | 2022-06-02 12:15:38 +0200 |
| commit | ffd98b770d6dfa7c1bef4b2ae54e0b637f2e7ac3 (patch) | |
| tree | c4a21baa21da4617b7da671604c51ef2084d7943 /src/indexamajig.c | |
| parent | 8e601d452a8b3d022b89e904c0cecee812f2b636 (diff) | |
indexamajig: Add --asapo-stream
Diffstat (limited to 'src/indexamajig.c')
| -rw-r--r-- | src/indexamajig.c | 11 |
1 files changed, 9 insertions, 2 deletions
diff --git a/src/indexamajig.c b/src/indexamajig.c index dbea7261..6787f903 100644 --- a/src/indexamajig.c +++ b/src/indexamajig.c @@ -89,6 +89,7 @@ struct indexamajig_arguments char *asapo_beamtime; char *asapo_group_id; char *asapo_source; + char *asapo_stream; int serial_start; char *temp_location; int if_refine; @@ -436,6 +437,10 @@ static error_t parse_arg(int key, char *arg, struct argp_state *state) } break; + case 220 : + args->asapo_stream = strdup(arg); + break; + /* ---------- Peak search ---------- */ case 't' : @@ -857,6 +862,7 @@ int main(int argc, char *argv[]) args.asapo_beamtime = NULL; args.asapo_group_id = NULL; args.asapo_source = NULL; + args.asapo_stream = NULL; args.n_zmq_subscriptions = 0; args.serial_start = 1; args.if_peaks = 1; @@ -971,6 +977,7 @@ int main(int argc, char *argv[]) {"asapo-group", 217, "str", OPTION_NO_USAGE, "ASAP::O group ID"}, {"asapo-source", 218, "str", OPTION_NO_USAGE, "ASAP::O data source"}, {"data-format", 219, "str", OPTION_NO_USAGE, "Streamed data format"}, + {"asapo-stream", 220, "str", OPTION_NO_USAGE, "ASAP::O stream name"}, {NULL, 0, 0, OPTION_DOC, "Peak search options:", 3}, {"peaks", 301, "method", 0, "Peak search method. Default: zaef"}, @@ -1332,8 +1339,8 @@ int main(int argc, char *argv[]) args.zmq_addr, args.zmq_subscriptions, args.n_zmq_subscriptions, args.zmq_request, args.asapo_endpoint, args.asapo_token, - args.asapo_beamtime, - args.asapo_group_id, args.asapo_source, + args.asapo_beamtime, args.asapo_group_id, + args.asapo_source, args.asapo_stream, timeout, args.profile); cell_free(args.iargs.cell); |