1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
|
/*
*
* Copyright (c) 2018 Huawei Technologies Co.,Ltd.
* 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.
*/
/*==============================================*
* include header files *
*----------------------------------------------*/
#ifndef _NSFW_MGRCOM_API_H
#define _NSFW_MGRCOM_API_H
#ifdef __cplusplus
/* *INDENT-OFF* */
extern "C"{
/* *INDENT-ON* */
#endif /* __cplusplus */
#define NSFW_MGR_COM_MODULE "nsfw_mgr_com"
#define MRG_RSP(_req_msg) (_req_msg + MGR_MSG_RSP_BASE)
typedef enum _mgr_msg_type
{
MGR_MSG_NULL = 0,
/*#############common msg type################# */
MGR_MSG_CHK_INIT_REQ = 1,
MGR_MSG_INIT_NTY_REQ,
MGR_MSG_CHK_HBT_REQ,
MGR_MSG_APP_EXIT_REQ,
MGR_MSG_SRV_CTL_REQ,
MGR_MSG_VER_MGR_REQ,
MGR_MSG_SOF_PAR_REQ,
/*############################################# */
MGR_MSG_MEM_ALLOC_REQ = 64, /* memory msg type */
/*############################################# */
MGR_MSG_DFX_QRY_REQ = 96, /* nStackCtrl maintain msg */
MGR_MSG_SET_LOG_REQ,
/*############################################# */
MGR_MSG_RCC_END_REQ = 128, /* service msg type */
/*############################################# */
MGR_MSG_TOOL_TCPDUMP_REQ = 256, /* for tools */
MGR_MSG_TOOL_HEART_BEAT,
/*###query message with large rsp message begin## */
MGR_MSG_LARGE_QRY_REQ_BEGIN = 384,
MGR_MSG_LARGE_STA_QRY_REQ = MGR_MSG_LARGE_QRY_REQ_BEGIN,
MGR_MSG_LARGE_MT_QRY_REQ, /* nStackCtrl maintain msg */
/*############################################# */
MGR_MSG_LARGE_ALARM_REQ = 500, /* alarm msg type */
MGR_MSG_RSP_BASE = 512,
/*#############common msg type################# */
MGR_MSG_CHK_INIT_RSP = MRG_RSP (MGR_MSG_CHK_INIT_REQ),
MGR_MSG_INIT_NTY_RSP = MRG_RSP (MGR_MSG_INIT_NTY_REQ),
MGR_MSG_CHK_HBT_RSP = MRG_RSP (MGR_MSG_CHK_HBT_REQ),
MGR_MSG_APP_EXIT_RSP = MRG_RSP (MGR_MSG_APP_EXIT_REQ),
MGR_MSG_SRV_CTL_RSP = MRG_RSP (MGR_MSG_SRV_CTL_REQ),
MGR_MSG_VER_MGR_RSP = MRG_RSP (MGR_MSG_VER_MGR_REQ),
MGR_MSG_SOF_PAR_RSP = MRG_RSP (MGR_MSG_SOF_PAR_REQ),
/*############################################# */
MGR_MSG_MEM_ALLOC_RSP = MRG_RSP (MGR_MSG_MEM_ALLOC_REQ),
MGR_MSG_DFX_QRY_RSP = MRG_RSP (MGR_MSG_DFX_QRY_REQ),
MGR_MSG_SET_LOG_RSP = MRG_RSP (MGR_MSG_SET_LOG_REQ),
MGR_MSG_RCC_END_RSP = MRG_RSP (MGR_MSG_RCC_END_REQ),
/*############################################# */
MGR_MSG_TOOL_TCPDUMP_RSP = MRG_RSP (MGR_MSG_TOOL_TCPDUMP_REQ),
MGR_MSG_TOOL_HEART_BEAT_RSP = MRG_RSP (MGR_MSG_TOOL_HEART_BEAT),
/*##############LARGE RSP MESSAGE################## */
MGR_MSG_LAG_QRY_RSP_BEGIN = MRG_RSP (MGR_MSG_LARGE_QRY_REQ_BEGIN),
MGR_MSG_LAG_STA_QRY_RSP = MRG_RSP (MGR_MSG_LARGE_STA_QRY_REQ),
MGR_MSG_LAG_MT_QRY_RSP = MRG_RSP (MGR_MSG_LARGE_MT_QRY_REQ),
MGR_MSG_LARGE_ALARM_RSP = MRG_RSP (MGR_MSG_LARGE_ALARM_REQ),
MGR_MSG_MAX = 1024
} mgr_msg_type;
typedef enum _fw_poc_type
{
NSFW_PROC_NULL = 0,
NSFW_PROC_MAIN,
NSFW_PROC_MASTER,
NSFW_PROC_APP,
NSFW_PROC_CTRL,
NSFW_PROC_TOOLS,
NSFW_PROC_ALARM,
NSFW_PROC_MAX = 16
} fw_poc_type;
#define NSFW_DOMAIN_DIR "/var/log/nStack/ip_module/"
#define NSTACK_MAX_PROC_NAME_LEN 20
typedef enum _nsfw_mgr_msg_rsp_code
{
NSFW_MGR_SUCCESS,
NSFW_MGR_MSG_TYPE_ERROR,
} mgr_msg_rsp_code;
extern char *nsfw_get_proc_name (u8 proc_type);
#define GET_USER_MSG(_stu, _msg) ((_stu *)(&(_msg)->msg_body[0]))
/*for log print*/
#define MSGINFO "msg=%p,len=%d,t=%d,sq=%d,st=%d,sp=%d,dt=%d,dp=%d"
#define PRTMSG(msg) (msg), (msg)->msg_len,(msg)->msg_type,(msg)->seq, (msg)->src_proc_type,(msg)->src_pid,(msg)->dst_proc_type,(msg)->dst_pid
#define NSFW_MGR_MSG_LEN 512
#define NSFW_MGR_MSG_HDR_LEN 32
#define NSFW_MGR_MSG_BODY_LEN (NSFW_MGR_MSG_LEN - NSFW_MGR_MSG_HDR_LEN)
#define NSFW_MGR_LARGE_MSG_LEN (256*1024)
#define NSFW_MGR_LARGE_MSG_BODY_LEN (NSFW_MGR_LARGE_MSG_LEN - NSFW_MGR_MSG_HDR_LEN)
typedef struct _nsfw_mgr_msg
{
u16 msg_type; /* mgr_msg_type */
u16 u16Reserve;
u32 msg_len;
u8 alloc_flag:1;
u8 fw_flag:1;
u8 from_mem:1;
u8 more_msg_flag:1;
u8 reserve_flag:4;
u8 resp_code;
u8 src_proc_type; /* fw_poc_type */
u8 dst_proc_type;
i32 seq;
u32 src_pid;
u32 dst_pid;
u8 msg_body[NSFW_MGR_MSG_BODY_LEN];
} nsfw_mgr_msg;
extern nsfw_mgr_msg *nsfw_mgr_msg_alloc (u16 msg_type, u8 dst_proc_type);
extern void nsfw_mgr_msg_free (nsfw_mgr_msg * msg);
/* for rsp msg alloc*/
extern nsfw_mgr_msg *nsfw_mgr_null_rspmsg_alloc ();
extern nsfw_mgr_msg *nsfw_mgr_rsp_msg_alloc (nsfw_mgr_msg * req_msg);
/* for msg proc fun reg*/
typedef int (*nsfw_mgr_msg_fun) (nsfw_mgr_msg * msg);
extern u8 nsfw_mgr_reg_msg_fun (u16 msg_type, nsfw_mgr_msg_fun fun);
extern u8 nsfw_mgr_send_msg (nsfw_mgr_msg * msg);
extern u8 nsfw_mgr_send_req_wait_rsp (nsfw_mgr_msg * req_msg,
nsfw_mgr_msg * rsp_msg);
/* for fork clear parent resource*/
extern void nsfw_mgr_close_dst_proc (u8 proc_type, u32 dst_pid);
extern u8 nsfw_mgr_clr_fd_lock ();
/* for epoll thread reg other sock proc fun*/
typedef int (*nsfw_mgr_sock_fun) (i32 epfd, i32 socket, u32 events);
extern u8 nsfw_mgr_reg_sock_fun (i32 socket, nsfw_mgr_sock_fun fun);
extern void nsfw_mgr_unreg_sock_fun (i32 socket);
extern int nsfw_mgr_com_socket_error (i32 fd, nsfw_mgr_sock_fun fun,
i32 timer);
extern u8 nsfw_mgr_ep_start ();
extern int nsfw_mgr_com_module_init (void *param);
extern int nsfw_mgr_run_script (const char *cmd, char *result,
int result_buf_len);
extern int nsfw_mgr_com_chk_hbt (int v_add);
extern i32 nsfw_set_close_on_exec (i32 sock);
extern int nsfw_mgr_comm_fd_init (u32 proc_type);
#ifdef __cplusplus
/* *INDENT-OFF* */
}
/* *INDENT-ON* */
#endif /* __cplusplus */
#endif /* _NSFW_MGRCOM_API_H */
|
