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
|
#ifndef _APP_STREAM_ENTRY_H_
#define _APP_STREAM_ENTRY_H_
#define STREAM_ENTRY_H_VERSION (20190818)
/*
CHN : ҵ�����ý�����ʱsession_state״̬;
*/
#define SESSION_STATE_PENDING 0x01
#define SESSION_STATE_DATA 0x02
#define SESSION_STATE_CLOSE 0x04
//���������ҵ���ʱ�ķ���ֵ��
#define PROT_STATE_GIVEME 0x01
#define PROT_STATE_DROPME 0x02
#define PROT_STATE_DROPPKT 0x04
//������������ҵ�����ʱ�������
typedef struct _plugin_session_info
{
unsigned short plugid; //plugid��ƽ̨����
char session_state; //�Ự״̬��PENDING,DATA,CLOSE
char _pad_; //����
int buflen; //��ǰ�ֶγ���
long long prot_flag; //��ǰ�ֶε�flagֵ
void *buf; //��ǰ�ֶ�
void* app_info; //��������������Ϣ
}stSessionInfo;
#ifdef __cplusplus
extern "C" {
#endif
typedef char (*STREAM_CB_FUN_T)(const struct streaminfo *pstream,void **pme, int thread_seq,const void *ip_hdr);
typedef char (*IPv4_CB_FUN_T)(const struct streaminfo *pstream,unsigned char routedir,int thread_seq, const void *ipv4_hdr);
typedef char (*IPv6_CB_FUN_T)(const struct streaminfo *pstream,unsigned char routedir,int thread_seq, const void *ipv6_hdr);
typedef char (*SAPP_PKT_CB_FUN_T)(const struct streaminfo *pstream, const void *this_hdr, const void *raw_pkt);
typedef char (*SAPP_STREAM_FUN_T)(const struct streaminfo *pstream, const void *this_hdr, const void *raw_pkt, void **pme);
/*����������
a_*, pstream: ������������Ϣ;
raw_pkt: ԭʼ��ָ��,��ȡ�����Ϣʹ��get_opt_from_rawpkt()�ӿ�;
pme: ˽������ָ��;
thread_seq���߳����;
��������ֵ������Ϊ�����ĸ�ֵ������
APP_STATE_GIVEME�����������Ͱ���
APP_STATE_DROPME�����������Ͱ���
APP_STATE_FAWPKT����ע�����ݰ�
APP_STATE_DROPPKT������ע�����ݰ�
*/
char IPv4_ENTRY_EXAMPLE(const struct streaminfo *pstream,unsigned char routedir,int thread_seq, const void *ipv4_hdr);
char IPv6_ENTRY_EXAMPLE(const struct streaminfo *pstream,unsigned char routedir,int thread_seq,const void *ipv6_hdr);
char TCP_ENTRY_EXAMPLE(const struct streaminfo *a_tcp, void **pme, int thread_seq,const void *ip_hdr);
char UDP_ENTRY_EXAMPLE(const struct streaminfo *a_udp, void **pme, int thread_seq,const void *ip_hdr);
char SAPP_PKT_EXAMPLE(const struct streaminfo *pstream, const void *this_hdr, const void *raw_pkt);
char SAPP_STREAM_EXAMPLE(const struct streaminfo *pstream, const void *this_hdr, const void *raw_pkt, void **pme);
#define POLLING_STATE_WORK 0x80
#define POLLING_STATE_IDLE 0x40
/*
ÿ��һ��ʱ��, ƽ̨����õ�ǰ�ӿ�, �����������Ƿ������ݰ�.
stream, pme, a_packet�̶�����NULL, thread_seq���հ��̵߳����.
����ֵ:
POLLING_STATE_WORK: �˴λص�����������������������;
POLLING_STATE_IDLE: �˴λص����ʲô��û��, ����������û����, ���������ģʽ�հ�, ��ʵ��û���յ���;
*/
char POLLING_ENTRY(struct streaminfo *stream, void **pme, int thread_seq,void *a_packet);
/*
CHN : ҵ���ص��ӿ� ;
ENG : business plug API ;
*/
char PROT_PROCESS(stSessionInfo* session_info, void **pme, int thread_seq,struct streaminfo *a_stream,const void *a_packet);
int libsapp_setup_env(int argc, char *argv[]);
void libsapp_destroy_env(void);
#ifdef __cplusplus
}
#endif
#endif
|
