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
|
#include <string.h>
#include <stdlib.h>
#include <stdio.h>
#include <errno.h>
#include <unistd.h>
#include <netinet/in.h>
#include "events.h"
#include "triton.h"
#include "log.h"
#include "ap_session.h"
#include "backup.h"
#include "ap_session_backup.h"
#include "ipdb.h"
#include "memdebug.h"
#ifdef USE_BACKUP
#define add_tag(id, data, size) if (!backup_add_tag(m, id, 0, data, size)) return -1;
#define add_tag_int(id, data, size) if (!backup_add_tag(m, id, 1, data, size)) return -1;
static int session_save(struct ap_session *ses, struct backup_mod *m)
{
struct ipv6db_addr_t *a;
struct ses_tag_ipv6 ipv6;
add_tag(SES_TAG_USERNAME, ses->username, strlen(ses->username));
add_tag(SES_TAG_SESSIONID, ses->sessionid, AP_SESSIONID_LEN);
add_tag(SES_TAG_START_TIME, &ses->start_time, sizeof(time_t));
add_tag(SES_TAG_IFNAME, ses->ifname, strlen(ses->ifname));
add_tag_int(SES_TAG_IFINDEX, &ses->ifindex, 4);
if (ses->ipv4) {
add_tag(SES_TAG_IPV4_ADDR, &ses->ipv4->addr, 4);
add_tag(SES_TAG_IPV4_PEER_ADDR, &ses->ipv4->peer_addr, 4);
}
if (ses->ipv6) {
add_tag(SES_TAG_IPV6_INTFID, &ses->ipv6->intf_id, 8);
add_tag(SES_TAG_IPV6_PEER_INTFID, &ses->ipv6->peer_intf_id, 8);
list_for_each_entry(a, &ses->ipv6->addr_list, entry) {
ipv6.addr = a->addr;
ipv6.prefix_len = a->prefix_len;
add_tag(SES_TAG_IPV6_ADDR, &ipv6, sizeof(ipv6));
}
}
//add_tag_int(PPP_TAG_FD, &ses->fd, sizeof(ses->fd));
//add_tag_int(PPP_TAG_CHAN_FD, &ses->chan_fd, sizeof(ses->chan_fd));
//add_tag_int(PPP_TAG_UNIT_FD, &ses->unit_fd, sizeof(ses->unit_fd));
//add_tag_int(PPP_TAG_UNIT, &ses->unit_idx, sizeof(ses->unit_idx));
//triton_event_fire(EV_PPP_SESSION_SAVE, &ev);
return 0;
}
static int session_restore(struct ap_session *ses, struct backup_mod *m)
{
struct backup_tag *t;
list_for_each_entry(t, &m->tag_list, entry) {
switch(t->id) {
case SES_TAG_USERNAME:
ses->username = _malloc(t->size + 1);
if (!ses->username) {
log_emerg("out of memory");
return -1;
}
memcpy(ses->username, t->data, t->size);
ses->username[t->size] = 0;
break;
case SES_TAG_SESSIONID:
memcpy(ses->sessionid, t->data, AP_SESSIONID_LEN);
break;
case SES_TAG_IFNAME:
memcpy(ses->ifname, t->data, t->size);
ses->ifname[t->size] = 0;
break;
case SES_TAG_START_TIME:
ses->start_time = *(time_t *)t->data;
break;
case SES_TAG_IFINDEX:
if (ses->backup->internal)
ses->ifindex = *(uint32_t *)t->data;
break;
/*case PPP_TAG_FD:
ses->fd = *(int *)t->data;
break;
case PPP_TAG_CHAN_FD:
ses->chan_fd = *(int *)t->data;
break;
case PPP_TAG_UNIT_FD:
ses->chan_fd = *(int *)t->data;
break;
case PPP_TAG_UNIT:
ses->unit_idx = *(int *)t->data;
break;
case PPP_TAG_IPV4_ADDR:
if (!ses->ipv4) {
ses->ipv4 = _malloc(sizeof(*ses->ipv4));
memset(ses->ipv4, 0, sizeof(*ses->ipv4));
ses->ipv4->owner = &ipdb;
}
ses->ipv4->addr = *(in_addr_t *)t->data;
break;
case PPP_TAG_IPV4_PEER_ADDR:
if (!ses->ipv4) {
ses->ipv4 = _malloc(sizeof(*ses->ipv4));
memset(ses->ipv4, 0, sizeof(*ses->ipv4));
ses->ipv4->owner = &ipdb;
}
ses->ipv4->peer_addr = *(in_addr_t *)t->data;
break;*/
}
}
return 0;
//return establish_ses(ses);
}
static struct backup_module mod = {
.id = MODID_COMMON,
.save = session_save,
.restore = session_restore,
};
static void init(void)
{
backup_register_module(&mod);
}
DEFINE_INIT(101, init);
#endif
|
