-
Notifications
You must be signed in to change notification settings - Fork 171
/
vr_message.h
94 lines (79 loc) · 2.93 KB
/
vr_message.h
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
/*
* vr_message.h -- messaging
*
* Copyright (c) 2013 Juniper Networks, Inc. All rights reserved.
*/
#ifndef __VR_MESSAGE_H__
#define __VR_MESSAGE_H__
#include "vr_queue.h"
#define VR_MESSAGE_DUMP_INCOMPLETE (0x1 << 30)
#define VR_MPROTO_SANDESH 1
#define VR_MPROTO_DIET 2
#define VR_MESSAGE_TYPE_REQUEST 0
#define VR_MESSAGE_TYPE_RESPONSE 1
#define VR_NULL_OBJECT_ID 0
#define VR_INTERFACE_OBJECT_ID 1
#define VR_NEXTHOP_OBJECT_ID 2
#define VR_ROUTE_OBJECT_ID 3
#define VR_MPLS_OBJECT_ID 4
#define VR_MIRROR_OBJECT_ID 5
#define VR_FLOW_OBJECT_ID 6
#define VR_RESPONSE_OBJECT_ID 7
#define VR_VRF_ASSIGN_OBJECT_ID 8
#define VR_VRF_STATS_OBJECT_ID 9
#define VR_DROP_STATS_OBJECT_ID 10
#define VR_VXLAN_OBJECT_ID 11
#define VR_VROUTER_OPS_OBJECT_ID 12
#define VR_FLOW_INFO_OBJECT_ID 13
#define VR_MESSAGE_PAGE_SIZE (4096 - 128)
struct vr_mproto {
unsigned int mproto_type;
unsigned int (*mproto_buf_len)(unsigned int, void *);
int (*mproto_encode)(char *, unsigned int,
unsigned int, void *, unsigned int);
int (*mproto_encode_response)(char *, unsigned int, unsigned int,
void *, int);
int (*mproto_decode)(char *, unsigned int,
int (*)(void *, unsigned int, void *), void *);
};
struct vr_mtransport {
char *(*mtrans_alloc)(unsigned int);
void (*mtrans_free)(char *);
};
struct vr_message {
char *vr_message_buf;
unsigned int vr_message_len;
struct vr_qelem vr_message_queue;
};
struct vr_message_handler {
struct vr_mproto *vm_proto;
struct vr_mtransport *vm_trans;
struct vr_qhead vm_response_queue;
};
struct vr_message_dumper {
void *dump_req;
unsigned int dump_been_to_marker;
unsigned int dump_num_dumps;
unsigned int dump_num_dumped;
char *dump_buffer;
unsigned int dump_buf_len;
unsigned int dump_resp_len;
unsigned int dump_offset;
};
int vr_message_transport_register(struct vr_mtransport *);
void vr_message_transport_unregister(struct vr_mtransport *);
int vr_message_proto_register(struct vr_mproto *);
void vr_message_proto_unregister(struct vr_mproto *);
struct vr_message_dumper *vr_message_dump_init(void *);
void vr_message_dump_exit(void *, int);
int vr_message_request(struct vr_message *);
int vr_message_response(unsigned int, void *, int);
int vr_message_make_request(unsigned int, void *);
int vr_message_process_response(int (*)(void *, unsigned int, void *), void *);
int vr_message_dump_object(void *, unsigned int, void *);
void *vr_mtrans_alloc(unsigned int);
void vr_mtrans_free(void *);
struct vr_message *vr_message_dequeue_response(void);
void vr_message_free(struct vr_message *message);
bool vr_response_queue_empty(void);
#endif /* __VR_MESSAGE_H__ */