aboutsummaryrefslogtreecommitdiff
path: root/src/indexamajig.c
diff options
context:
space:
mode:
authorThomas White <taw@physics.org>2021-09-09 16:30:14 +0200
committerThomas White <taw@physics.org>2022-06-02 12:15:38 +0200
commit151924b7fccde4cb6bdb73128ba27c091037eb4b (patch)
treedfcaca887019e97be5272b02479ad3d9022aac97 /src/indexamajig.c
parent0c566e3bcc918f8f047fd3b2aad866f0e81e582f (diff)
ASAP::O: Expose data source
Diffstat (limited to 'src/indexamajig.c')
-rw-r--r--src/indexamajig.c9
1 files changed, 8 insertions, 1 deletions
diff --git a/src/indexamajig.c b/src/indexamajig.c
index 52e83c57..7fbb3f8f 100644
--- a/src/indexamajig.c
+++ b/src/indexamajig.c
@@ -89,6 +89,7 @@ struct indexamajig_arguments
char *asapo_beamtime;
char *asapo_path;
char *asapo_group_id;
+ char *asapo_source;
int serial_start;
char *temp_location;
int if_refine;
@@ -427,6 +428,10 @@ static error_t parse_arg(int key, char *arg, struct argp_state *state)
args->asapo_group_id = strdup(arg);
break;
+ case 218 :
+ args->asapo_source = strdup(arg);
+ break;
+
case 219 :
args->iargs.data_format = parse_data_format(arg);
if ( args->iargs.data_format == DATA_SOURCE_TYPE_UNKNOWN ) {
@@ -856,6 +861,7 @@ int main(int argc, char *argv[])
args.asapo_beamtime = NULL;
args.asapo_path = NULL;
args.asapo_group_id = NULL;
+ args.asapo_source = NULL;
args.n_zmq_subscriptions = 0;
args.serial_start = 1;
args.if_peaks = 1;
@@ -969,6 +975,7 @@ int main(int argc, char *argv[])
{"asapo-beamtime", 215, "str", OPTION_NO_USAGE, "ASAP::O beamtime ID"},
{"asapo-path", 216, "str", OPTION_NO_USAGE, "ASAP::O path to files"},
{"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"},
{NULL, 0, 0, OPTION_DOC, "Peak search options:", 3},
@@ -1332,7 +1339,7 @@ int main(int argc, char *argv[])
args.n_zmq_subscriptions, args.zmq_request,
args.asapo_endpoint, args.asapo_token,
args.asapo_beamtime, args.asapo_path,
- args.asapo_group_id,
+ args.asapo_group_id, args.asapo_source,
timeout, args.profile);
cell_free(args.iargs.cell);