1 /* ------------------------------------------------
2 Copyright 2014 AT&T Intellectual Property
3 Licensed under the Apache License, Version 2.0 (the "License");
4 you may not use this file except in compliance with the License.
5 You may obtain a copy of the License at
7 http://www.apache.org/licenses/LICENSE-2.0
9 Unless required by applicable law or agreed to in writing, software
10 distributed under the License is distributed on an "AS IS" BASIS,
11 WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12 See the License for the specific language governing permissions and
13 limitations under the License.
14 ------------------------------------------- */
27 #define FTA_ALLOC_INSTANCE 2
28 #define FTA_ALLOC_PRINT_INSTANCE 3
29 #define FTA_FREE_INSTANCE 4
31 #define FTA_PRODUCER_FAILURE 6
32 #define FTA_HEARTBEAT 7
34 #define GSCP_GET_BUFFER 8
36 #define FTA_REGISTER 9
37 #define FTA_UNREGISTER 10
39 #define PROCESS_CONTROL 11
41 #define RESULT_OPCODE_BASE 128
42 #define STANDARD_RESULT 129
43 #define FTAFIND_RESULT 130
44 #define FTA_RESULT 131
46 /* the following result codes are ignored in standard
47 * processing they are only used when blocking for them
51 #define RESULT_OPCODE_IGNORE 256
58 gs_int32_t buffersize;
64 extern struct processtate curprocess;
74 gs_int8_t name[MAXFTANAME];
78 struct fta_alloc_instance_arg {
82 gs_int8_t name[MAXFTANAME];
83 gs_int8_t schema[MAXSCHEMASZ];
87 gs_int8_t path[MAXPRINTSTRING];
88 gs_int8_t basename[MAXPRINTSTRING];
89 gs_int8_t temporal_field[MAXPRINTSTRING];
90 gs_int8_t split_field[MAXPRINTSTRING];
96 struct fta_free_instance_arg {
100 gs_uint32_t recursive;
103 struct fta_control_arg {
113 struct fta_notify_producer_failure_arg {
119 struct fta_heartbeat_arg {
122 gs_uint64_t trace_id;
127 struct gscp_get_buffer_arg {
132 struct fta_register_arg {
134 gs_uint32_t reusable;
135 gs_int8_t name[MAXFTANAME];
136 gs_int8_t schema[MAXSCHEMASZ];
141 struct fta_unregister_arg {
147 struct tuple_post_arg {
149 gs_int32_t stream_id;
154 struct process_control_arg {
161 struct standard_result {
166 struct wakeup_result {
170 struct timeout_result {
181 struct ftafind_result {
185 gs_int8_t schema[MAXSCHEMASZ];