-/* ------------------------------------------------
-Copyright 2014 AT&T Intellectual Property
- Licensed under the Apache License, Version 2.0 (the "License");
- you may not use this file except in compliance with the License.
- You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
- Unless required by applicable law or agreed to in writing, software
- distributed under the License is distributed on an "AS IS" BASIS,
- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- See the License for the specific language governing permissions and
- limitations under the License.
- ------------------------------------------- */
-
- /*
- * gshub.h: interface to GSHUB to announce and discover gs instances, sources and sinks
- */
-
-#ifndef GSHUB_H
-#define GSHUB_H
-
-#include "gstypes.h"
-#include "fta.h"
-#include "fta_stat.h"
-
-#define DISCOVER_INSTANCE_URL "/v1/discover-instance"
-#define DISCOVER_INITINSTANCE_URL "/v1/discover-initialized-instance"
-#define DISCOVER_SOURCE_URL "/v1/discover-source"
-#define DISCOVER_SINK_URL "/v1/discover-sink"
-#define DISCOVER_STARTPROCESSING_URL "/v1/discover-start-processing"
-#define ANNOUNCE_INSTANCE_URL "/v1/announce-instance"
-#define ANNOUNCE_INITINSTANCE_URL "/v1/announce-initialized-instance"
-#define ANNOUNCE_SOURCE_URL "/v1/announce-source"
-#define ANNOUNCE_SINK_URL "/v1/announce-sink"
-#define ANNOUNCE_STARTPROCESSING_URL "/v1/announce-start-processing"
-#define ANNOUNCE_STREAM_SUBSCRIPTION "/v1/announce-stream-subscription"
-#define ANNOUNCE_FTA_INSTANCE "/v1/announce-fta-instance"
-#define ANNOUNCE_METRICS "/v1/log-metrics"
-
-typedef struct {
- gs_uint32_t ip;
- gs_uint16_t port;
-} endpoint;
-
-
-#ifdef __cplusplus
-extern "C" {
-#endif
-
-/* saving and retrival of gshub endpoint */
-gs_retval_t set_hub(endpoint gshub);
-gs_retval_t get_hub(endpoint* gshub);
-
-/* savinf and retrieving instance name */
-gs_retval_t set_instance_name(gs_sp_t instancename);
-gs_sp_t get_instance_name();
-
-/* Discover gs instance endpoint by name.
- * Return value of 0 indicates success. If blocking mode is used return value > 0 indicates that retry is needed. Return value < 0 indicates an error. */
-gs_retval_t get_instance(endpoint gshub, gs_sp_t instance_name, endpoint* instance, gs_bool_t block);
-
-/* Discover initialized gs instance endpoint by name.
- * Return value of 0 indicates success. If blocking mode is used return value > 0 indicates that retry is needed. Return value < 0 indicates an error. */
-gs_retval_t get_initinstance(endpoint gshub, gs_sp_t instance_name, endpoint* instance, gs_bool_t block);
-
-/* Discover stream source endpoint by name.
- * Return value of 0 indicates success. If blocking mode is used return value > 0 indicates that retry is needed. Return value < 0 indicates an error. */
-gs_retval_t get_streamsource(endpoint gshub, gs_sp_t source_name, endpoint* source, gs_bool_t block);
-
-/* Discover stream sink endpoint by name.
- * Return value of 0 indicates success. If blocking mode is used return value > 0 indicates that retry is needed. Return value < 0 indicates an error. */
-gs_retval_t get_streamsink(endpoint gshub, gs_sp_t sink_name, endpoint* sink, gs_bool_t block);
-
-/* Discover if an isntance should start processing
- * Return value of 0 indicates success. If blocking mode is used return value > 0 indicates that retry is needed. Return value < 0 indicates an error. */
-gs_retval_t get_startprocessing(endpoint gshub, gs_sp_t instance_name, gs_bool_t block);
-
-/* Announce gs instance endpoint to gshub. Return value of 0 indicates success. */
-gs_retval_t set_instance(endpoint gshub, gs_sp_t instance_name, endpoint instance);
-
-/* Announce initialized gs instance endpoint to gshub. Return value of 0 indicates success. */
-gs_retval_t set_initinstance(endpoint gshub, gs_sp_t instance_name);
-
-/* Announce stream source endpoint to gshub. Return value of 0 indicates success. */
-gs_retval_t set_streamsource(endpoint gshub, gs_sp_t source_name, endpoint source);
-
-/* Announce stream source endpoint to gshub. Return value of 0 indicates success. */
-gs_retval_t set_streamsink(endpoint gshub, gs_sp_t sink_name, endpoint sink);
-
-/* Announce to gshub that an instance can start processin. Return value of 0 indicates success. */
-gs_retval_t set_startprocessing(endpoint gshub, gs_sp_t instance_name);
-
-/* Announce stream subscription to gshub. Return value of 0 indicates success. */
-gs_retval_t set_streamsubscription(endpoint gshub, gs_sp_t instance_name, gs_sp_t sink_name);
-
-/* Announce new fta instantiation to gshub. Return value of 0 indicates success. */
-gs_retval_t set_ftainstance(endpoint gshub, gs_sp_t instance_name, gs_sp_t ftainstance_name, FTAID* id);
-
-/* Announce fta instance stats to gshub. Return value of 0 indicates success. */
-gs_retval_t set_instancestats(endpoint gshub, gs_sp_t instance_name, fta_stat* stats);
-
-#ifdef __cplusplus
-}
-#endif
-
-#endif /* GSHUB_H */
+/* ------------------------------------------------\r
+Copyright 2014 AT&T Intellectual Property\r
+ Licensed under the Apache License, Version 2.0 (the "License");\r
+ you may not use this file except in compliance with the License.\r
+ You may obtain a copy of the License at\r
+\r
+ http://www.apache.org/licenses/LICENSE-2.0\r
+\r
+ Unless required by applicable law or agreed to in writing, software\r
+ distributed under the License is distributed on an "AS IS" BASIS,\r
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
+ See the License for the specific language governing permissions and\r
+ limitations under the License.\r
+ ------------------------------------------- */\r
+\r
+ /*\r
+ * gshub.h: interface to GSHUB to announce and discover gs instances, sources and sinks\r
+ */\r
+\r
+#ifndef GSHUB_H\r
+#define GSHUB_H\r
+\r
+#include "gstypes.h"\r
+#include "fta.h"\r
+#include "fta_stat.h"\r
+\r
+#define DISCOVER_INSTANCE_URL "/v1/discover-instance"\r
+#define DISCOVER_INITINSTANCE_URL "/v1/discover-initialized-instance"\r
+#define DISCOVER_SOURCE_URL "/v1/discover-source"\r
+#define DISCOVER_SINK_URL "/v1/discover-sink"\r
+#define DISCOVER_STARTPROCESSING_URL "/v1/discover-start-processing"\r
+#define ANNOUNCE_INSTANCE_URL "/v1/announce-instance"\r
+#define ANNOUNCE_INITINSTANCE_URL "/v1/announce-initialized-instance"\r
+#define ANNOUNCE_SOURCE_URL "/v1/announce-source"\r
+#define ANNOUNCE_SINK_URL "/v1/announce-sink"\r
+#define ANNOUNCE_STARTPROCESSING_URL "/v1/announce-start-processing"\r
+#define ANNOUNCE_STREAM_SUBSCRIPTION "/v1/announce-stream-subscription"\r
+#define ANNOUNCE_FTA_INSTANCE "/v1/announce-fta-instance"\r
+#define ANNOUNCE_METRICS "/v1/log-metrics"\r
+\r
+typedef struct {\r
+ gs_uint32_t ip;\r
+ gs_uint16_t port;\r
+} endpoint;\r
+\r
+\r
+#ifdef __cplusplus\r
+extern "C" {\r
+#endif\r
+\r
+/* saving and retrival of gshub endpoint */\r
+gs_retval_t set_hub(endpoint gshub);\r
+gs_retval_t get_hub(endpoint* gshub);\r
+\r
+/* savinf and retrieving instance name */\r
+gs_retval_t set_instance_name(gs_sp_t instancename);\r
+gs_sp_t get_instance_name();\r
+\r
+/* Discover gs instance endpoint by name.\r
+ * Return value of 0 indicates success. If blocking mode is used return value > 0 indicates that retry is needed. Return value < 0 indicates an error. */\r
+gs_retval_t get_instance(endpoint gshub, gs_sp_t instance_name, endpoint* instance, gs_bool_t block);\r
+\r
+/* Discover initialized gs instance endpoint by name.\r
+ * Return value of 0 indicates success. If blocking mode is used return value > 0 indicates that retry is needed. Return value < 0 indicates an error. */\r
+gs_retval_t get_initinstance(endpoint gshub, gs_sp_t instance_name, endpoint* instance, gs_bool_t block);\r
+\r
+/* Discover stream source endpoint by name.\r
+ * Return value of 0 indicates success. If blocking mode is used return value > 0 indicates that retry is needed. Return value < 0 indicates an error. */\r
+gs_retval_t get_streamsource(endpoint gshub, gs_sp_t source_name, endpoint* source, gs_bool_t block);\r
+\r
+/* Discover stream sink endpoint by name.\r
+ * Return value of 0 indicates success. If blocking mode is used return value > 0 indicates that retry is needed. Return value < 0 indicates an error. */\r
+gs_retval_t get_streamsink(endpoint gshub, gs_sp_t sink_name, endpoint* sink, gs_bool_t block);\r
+\r
+/* Discover if an isntance should start processing\r
+ * Return value of 0 indicates success. If blocking mode is used return value > 0 indicates that retry is needed. Return value < 0 indicates an error. */\r
+gs_retval_t get_startprocessing(endpoint gshub, gs_sp_t instance_name, gs_bool_t block);\r
+\r
+/* Announce gs instance endpoint to gshub. Return value of 0 indicates success. */\r
+gs_retval_t set_instance(endpoint gshub, gs_sp_t instance_name, endpoint instance);\r
+\r
+/* Announce initialized gs instance endpoint to gshub. Return value of 0 indicates success. */\r
+gs_retval_t set_initinstance(endpoint gshub, gs_sp_t instance_name);\r
+\r
+/* Announce stream source endpoint to gshub. Return value of 0 indicates success. */\r
+gs_retval_t set_streamsource(endpoint gshub, gs_sp_t source_name, endpoint source);\r
+\r
+/* Announce stream source endpoint to gshub. Return value of 0 indicates success. */\r
+gs_retval_t set_streamsink(endpoint gshub, gs_sp_t sink_name, endpoint sink);\r
+\r
+/* Announce to gshub that an instance can start processin. Return value of 0 indicates success. */\r
+gs_retval_t set_startprocessing(endpoint gshub, gs_sp_t instance_name);\r
+\r
+/* Announce stream subscription to gshub. Return value of 0 indicates success. */\r
+gs_retval_t set_streamsubscription(endpoint gshub, gs_sp_t instance_name, gs_sp_t sink_name);\r
+\r
+/* Announce new fta instantiation to gshub. Return value of 0 indicates success. */\r
+gs_retval_t set_ftainstance(endpoint gshub, gs_sp_t instance_name, gs_sp_t ftainstance_name, FTAID* id);\r
+\r
+/* Announce fta instance stats to gshub. Return value of 0 indicates success. */\r
+gs_retval_t set_instancestats(endpoint gshub, gs_sp_t instance_name, fta_stat* stats);\r
+\r
+#ifdef __cplusplus\r
+}\r
+#endif\r
+\r
+#endif /* GSHUB_H */\r
Code Review / com / gs-lite.git / blobdiff