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
|
/*
* Copyright (c) 2015, 2016 VMware, Inc.
*
* 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 "Conntrack.h"
#include <stddef.h>
enum other_state {
OTHERS_FIRST,
OTHERS_MULTIPLE,
OTHERS_BIDIR,
};
struct conn_other {
struct OVS_CT_ENTRY up;
enum other_state state;
};
C_ASSERT(offsetof(struct conn_other, up) == 0);
static const long long other_timeouts[] = {
[OTHERS_FIRST] = 60 * CT_INTERVAL_SEC,
[OTHERS_MULTIPLE] = 60 * CT_INTERVAL_SEC,
[OTHERS_BIDIR] = 30 * CT_INTERVAL_SEC,
};
static __inline struct conn_other*
OvsCastConntrackEntryToOtherEntry(OVS_CT_ENTRY *conn)
{
ASSERT(conn);
return CONTAINER_OF(conn, struct conn_other, up);
}
enum CT_UPDATE_RES
OvsConntrackUpdateOtherEntry(OVS_CT_ENTRY *conn_,
BOOLEAN reply,
UINT64 now)
{
ASSERT(conn_);
struct conn_other *conn = OvsCastConntrackEntryToOtherEntry(conn_);
enum CT_UPDATE_RES ret = CT_UPDATE_VALID;
if (reply && conn->state != OTHERS_BIDIR) {
conn->state = OTHERS_BIDIR;
} else if (conn->state == OTHERS_FIRST) {
conn->state = OTHERS_MULTIPLE;
ret = CT_UPDATE_VALID_NEW;
}
OvsConntrackUpdateExpiration(&conn->up, now,
other_timeouts[conn->state]);
return ret;
}
OVS_CT_ENTRY *
OvsConntrackCreateOtherEntry(UINT64 now)
{
struct conn_other *conn;
conn = OvsAllocateMemoryWithTag(sizeof(struct conn_other),
OVS_CT_POOL_TAG);
if (!conn) {
return NULL;
}
conn->up = (OVS_CT_ENTRY) {0};
conn->state = OTHERS_FIRST;
OvsConntrackUpdateExpiration(&conn->up, now,
other_timeouts[conn->state]);
return &conn->up;
}
|
