-/* ------------------------------------------------\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
-#ifndef IPCENCODING_H\r
-#define IPCENCODING_H\r
-#include "gsconfig.h"\r
-#include "gstypes.h"\r
-\r
-#include <fta.h>\r
-#include <systat.h>\r
-#include <gscpipc.h>\r
-#include <fta_stat.h>\r
-\r
-\r
-#define FTA_LOOKUP 1\r
-#define FTA_ALLOC_INSTANCE 2\r
-#define FTA_ALLOC_PRINT_INSTANCE 3\r
-#define FTA_FREE_INSTANCE 4\r
-#define FTA_CONTROL 5\r
-#define FTA_PRODUCER_FAILURE 6\r
-#define FTA_HEARTBEAT 7\r
-\r
-#define GSCP_GET_BUFFER 8\r
-\r
-#define FTA_REGISTER 9\r
-#define FTA_UNREGISTER 10\r
-\r
-#define PROCESS_CONTROL 11\r
-\r
-#define RESULT_OPCODE_BASE 128\r
-#define STANDARD_RESULT 129\r
-#define FTAFIND_RESULT 130\r
-#define FTA_RESULT 131\r
-\r
-/* the following result codes are ignored in standard\r
- * processing they are only used when blocking for them\r
- * directly\r
- */\r
-\r
-#define RESULT_OPCODE_IGNORE 256\r
-#define WAKEUP 266\r
-#define TIMEOUT 267\r
-\r
-struct processtate {\r
- gs_int32_t active;\r
- gs_int32_t type;\r
- gs_int32_t buffersize;\r
- gs_int32_t deviceid;\r
- gs_int32_t mapcnt;\r
- gs_sp_t *map;\r
-};\r
-\r
-extern struct processtate curprocess;\r
-\r
-struct hostcall {\r
- gs_int32_t callid;\r
- gs_int32_t size;\r
-};\r
-\r
-\r
-struct fta_find_arg {\r
- struct hostcall h;\r
- gs_int8_t name[MAXFTANAME];\r
- gs_uint32_t reuse;\r
-};\r
-\r
-struct fta_alloc_instance_arg {\r
- struct hostcall h;\r
- FTAID subscriber;\r
- FTAID f;\r
- gs_int8_t name[MAXFTANAME];\r
- gs_int8_t schema[MAXSCHEMASZ];\r
- gs_uint32_t reusable;\r
- gs_int32_t command;\r
- gs_int32_t sz;\r
- gs_int8_t path[MAXPRINTSTRING];\r
- gs_int8_t basename[MAXPRINTSTRING];\r
- gs_int8_t temporal_field[MAXPRINTSTRING];\r
- gs_int8_t split_field[MAXPRINTSTRING];\r
- gs_uint32_t split;\r
- gs_uint32_t delta;\r
- gs_int8_t data[1];\r
-};\r
-\r
-struct fta_free_instance_arg {\r
- struct hostcall h;\r
- FTAID subscriber;\r
- FTAID f;\r
- gs_uint32_t recursive;\r
-};\r
-\r
-struct fta_control_arg {\r
- struct hostcall h;\r
- FTAID subscriber;\r
- FTAID f;\r
- gs_int32_t command;\r
- gs_int32_t sz;\r
- gs_int8_t data[1];\r
-};\r
-\r
-\r
-struct fta_notify_producer_failure_arg {\r
- struct hostcall h;\r
- FTAID sender;\r
- FTAID producer;\r
-};\r
-\r
-struct fta_heartbeat_arg {\r
- struct hostcall h;\r
- FTAID sender;\r
- gs_uint64_t trace_id;\r
- gs_int32_t sz;\r
- fta_stat data[1];\r
-};\r
-\r
-struct gscp_get_buffer_arg {\r
- struct hostcall h;\r
- gs_int32_t timeout;\r
-};\r
-\r
-struct fta_register_arg {\r
- struct hostcall h;\r
- gs_uint32_t reusable;\r
- gs_int8_t name[MAXFTANAME];\r
- gs_int8_t schema[MAXSCHEMASZ];\r
- FTAID f;\r
- FTAID subscriber;\r
-};\r
-\r
-struct fta_unregister_arg {\r
- struct hostcall h;\r
- FTAID f;\r
- FTAID subscriber;\r
-};\r
-\r
-struct tuple_post_arg {\r
- struct hostcall h;\r
- gs_int32_t stream_id;\r
- gs_int32_t sz;\r
- void * tuple;\r
-};\r
-\r
-struct process_control_arg {\r
- struct hostcall h;\r
- gs_int32_t command;\r
- gs_int32_t sz;\r
- gs_int8_t data[1];\r
-};\r
-\r
-struct standard_result {\r
- struct hostcall h;\r
- gs_int32_t result;\r
-};\r
-\r
-struct wakeup_result {\r
- struct hostcall h;\r
-};\r
-\r
-struct timeout_result {\r
- struct hostcall h;\r
-};\r
-\r
-\r
-struct fta_result {\r
- struct hostcall h;\r
- gs_int32_t result;\r
- FTAID f;\r
-};\r
-\r
-struct ftafind_result {\r
- struct hostcall h;\r
- gs_int32_t result;\r
- FTAID f;\r
- gs_int8_t schema[MAXSCHEMASZ];\r
-};\r
-\r
-#endif\r
+/* ------------------------------------------------
+ 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.
+ ------------------------------------------- */
+#ifndef IPCENCODING_H
+#define IPCENCODING_H
+#include "gsconfig.h"
+#include "gstypes.h"
+
+#include <fta.h>
+#include <systat.h>
+#include <gscpipc.h>
+#include <fta_stat.h>
+
+
+#define FTA_LOOKUP 1
+#define FTA_ALLOC_INSTANCE 2
+#define FTA_ALLOC_PRINT_INSTANCE 3
+#define FTA_FREE_INSTANCE 4
+#define FTA_CONTROL 5
+#define FTA_PRODUCER_FAILURE 6
+#define FTA_HEARTBEAT 7
+
+#define GSCP_GET_BUFFER 8
+
+#define FTA_REGISTER 9
+#define FTA_UNREGISTER 10
+
+#define PROCESS_CONTROL 11
+
+#define RESULT_OPCODE_BASE 128
+#define STANDARD_RESULT 129
+#define FTAFIND_RESULT 130
+#define FTA_RESULT 131
+
+/* the following result codes are ignored in standard
+ * processing they are only used when blocking for them
+ * directly
+ */
+
+#define RESULT_OPCODE_IGNORE 256
+#define WAKEUP 266
+#define TIMEOUT 267
+
+struct processtate {
+ gs_int32_t active;
+ gs_int32_t type;
+ gs_int32_t buffersize;
+ gs_int32_t deviceid;
+ gs_int32_t mapcnt;
+ gs_sp_t *map;
+};
+
+extern struct processtate curprocess;
+
+struct hostcall {
+ gs_int32_t callid;
+ gs_int32_t size;
+};
+
+
+struct fta_find_arg {
+ struct hostcall h;
+ gs_int8_t name[MAXFTANAME];
+ gs_uint32_t reuse;
+};
+
+struct fta_alloc_instance_arg {
+ struct hostcall h;
+ FTAID subscriber;
+ FTAID f;
+ gs_int8_t name[MAXFTANAME];
+ gs_int8_t schema[MAXSCHEMASZ];
+ gs_uint32_t reusable;
+ gs_int32_t command;
+ gs_int32_t sz;
+ gs_int8_t path[MAXPRINTSTRING];
+ gs_int8_t basename[MAXPRINTSTRING];
+ gs_int8_t temporal_field[MAXPRINTSTRING];
+ gs_int8_t split_field[MAXPRINTSTRING];
+ gs_uint32_t split;
+ gs_uint32_t delta;
+ gs_int8_t data[1];
+};
+
+struct fta_free_instance_arg {
+ struct hostcall h;
+ FTAID subscriber;
+ FTAID f;
+ gs_uint32_t recursive;
+};
+
+struct fta_control_arg {
+ struct hostcall h;
+ FTAID subscriber;
+ FTAID f;
+ gs_int32_t command;
+ gs_int32_t sz;
+ gs_int8_t data[1];
+};
+
+
+struct fta_notify_producer_failure_arg {
+ struct hostcall h;
+ FTAID sender;
+ FTAID producer;
+};
+
+struct fta_heartbeat_arg {
+ struct hostcall h;
+ FTAID sender;
+ gs_uint64_t trace_id;
+ gs_int32_t sz;
+ fta_stat data[1];
+};
+
+struct gscp_get_buffer_arg {
+ struct hostcall h;
+ gs_int32_t timeout;
+};
+
+struct fta_register_arg {
+ struct hostcall h;
+ gs_uint32_t reusable;
+ gs_int8_t name[MAXFTANAME];
+ gs_int8_t schema[MAXSCHEMASZ];
+ FTAID f;
+ FTAID subscriber;
+};
+
+struct fta_unregister_arg {
+ struct hostcall h;
+ FTAID f;
+ FTAID subscriber;
+};
+
+struct tuple_post_arg {
+ struct hostcall h;
+ gs_int32_t stream_id;
+ gs_int32_t sz;
+ void * tuple;
+};
+
+struct process_control_arg {
+ struct hostcall h;
+ gs_int32_t command;
+ gs_int32_t sz;
+ gs_int8_t data[1];
+};
+
+struct standard_result {
+ struct hostcall h;
+ gs_int32_t result;
+};
+
+struct wakeup_result {
+ struct hostcall h;
+};
+
+struct timeout_result {
+ struct hostcall h;
+};
+
+
+struct fta_result {
+ struct hostcall h;
+ gs_int32_t result;
+ FTAID f;
+};
+
+struct ftafind_result {
+ struct hostcall h;
+ gs_int32_t result;
+ FTAID f;
+ gs_int8_t schema[MAXSCHEMASZ];
+};
+
+#endif
Code Review / com / gs-lite.git / blobdiff