aboutsummaryrefslogtreecommitdiff
path: root/src/im-asapo.h
diff options
context:
space:
mode:
authorThomas White <taw@physics.org>2022-05-04 12:14:27 +0200
committerThomas White <taw@physics.org>2022-06-02 12:15:38 +0200
commitffd98b770d6dfa7c1bef4b2ae54e0b637f2e7ac3 (patch)
treec4a21baa21da4617b7da671604c51ef2084d7943 /src/im-asapo.h
parent8e601d452a8b3d022b89e904c0cecee812f2b636 (diff)
indexamajig: Add --asapo-stream
Diffstat (limited to 'src/im-asapo.h')
-rw-r--r--src/im-asapo.h13
1 files changed, 9 insertions, 4 deletions
diff --git a/src/im-asapo.h b/src/im-asapo.h
index 5fd7665c..ab68e1c2 100644
--- a/src/im-asapo.h
+++ b/src/im-asapo.h
@@ -40,12 +40,14 @@ extern struct im_asapo *im_asapo_connect(const char *endpoint,
const char *token,
const char *beamtime,
const char *group_id,
- const char *data_source);
+ const char *data_source,
+ const char *stream);
extern void im_asapo_shutdown(struct im_asapo *a);
extern void *im_asapo_fetch(struct im_asapo *a, size_t *pdata_size,
- char **pmeta, char **pfilename, char **pevent);
+ char **pmeta, char **pfilename, char **pevent,
+ int *pfinished);
extern char *im_asapo_make_unique_group_id(const char *endpoint,
const char *token);
@@ -56,7 +58,8 @@ static UNUSED struct im_asapo *im_asapo_connect(const char *endpoint,
const char *token,
const char *beamtime,
const char *group_id,
- const char *data_source)
+ const char *data_source,
+ const char *stream)
{
return NULL;
}
@@ -66,12 +69,14 @@ static UNUSED void im_asapo_shutdown(struct im_asapo *a)
}
static UNUSED void *im_asapo_fetch(struct im_asapo *a, size_t *psize,
- char **pmeta, char **pfilename, char **pevent)
+ char **pmeta, char **pfilename, char **pevent,
+ int *pfinished)
{
*psize = 0;
*pmeta = NULL;
*pfilename = NULL;
*pevent = NULL;
+ *pfinished = 1;
return NULL;
}