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
|
/*
* Copyright (c) 2017, The Linux Foundation. All rights reserved.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions are
* met:
* * Redistributions of source code must retain the above copyright
* notice, this list of conditions and the following disclaimer.
* * Redistributions in binary form must reproduce the above
* copyright notice, this list of conditions and the following
* disclaimer in the documentation and/or other materials provided
* with the distribution.
* * Neither the name of The Linux Foundation nor the names of its
* contributors may be used to endorse or promote products derived
* from this software without specific prior written permission.
*
* THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESS OR IMPLIED
* WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
* MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NON-INFRINGEMENT
* ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS
* BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
* CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
* SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR
* BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
* WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE
* OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN
* IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
*/
#ifndef DBG
#define DBG false
#endif /* DBG */
#define LOG_TAG "IPAHALService/CtUpdateAmbassador"
/* External Includes */
#include <arpa/inet.h>
#include <cutils/log.h>
/* HIDL Includes */
#include <android/hardware/tetheroffload/control/1.0/ITetheringOffloadCallback.h>
/* Internal Includes */
#include "CtUpdateAmbassador.h"
/* Namespace pollution avoidance */
using ::android::hardware::tetheroffload::control::V1_0::ITetheringOffloadCallback;
using ::android::hardware::tetheroffload::control::V1_0::NetworkProtocol;
using HALIpAddrPortPair = ::android::hardware::tetheroffload::control::V1_0::IPv4AddrPortPair;
using HALNatTimeoutUpdate = ::android::hardware::tetheroffload::control::V1_0::NatTimeoutUpdate;
using IpaIpAddrPortPair = ::IOffloadManager::ConntrackTimeoutUpdater::IpAddrPortPair;
using IpaNatTimeoutUpdate = ::IOffloadManager::ConntrackTimeoutUpdater::NatTimeoutUpdate;
using IpaL4Protocol = ::IOffloadManager::ConntrackTimeoutUpdater::L4Protocol;
CtUpdateAmbassador::CtUpdateAmbassador(
const ::android::sp<ITetheringOffloadCallback>& cb) : mFramework(cb) {
} /* CtUpdateAmbassador */
void CtUpdateAmbassador::updateTimeout(IpaNatTimeoutUpdate in) {
if (DBG) {
ALOGD("updateTimeout(src={%#010X, %#04X}, dest={%#010X, %#04X}, Proto=%d)",
in.src.ipAddr, in.src.port, in.dst.ipAddr, in.dst.port,
in.proto);
}
HALNatTimeoutUpdate out;
if (!translate(in, out)) {
/* Cannot log the input outside of DBG flag because it contains sensitive
* information. This will lead to a two step debug if the information
* cannot be gleaned from IPACM logs. The other option is to improve this
* with the use of our local log. That would likely still be hard to
* instruct testers to collect logs, because, assuming timeout updates
* are numerous, it will overrun the ring quickly. Therefore, the tester
* would have to know the exact moment as issue occurred. Or we make the
* ring massive. This would lead to a significant memory overhead.
* Because of this overhead, we would likely not want to check in a change
* with it and once we provide a debug build for increasing buffer size,
* why not just define the DBG flag?
*/
ALOGE("Failed to translate timeout event :(");
} else {
mFramework->updateTimeout(out);
}
} /* updateTimeout */
bool CtUpdateAmbassador::translate(IpaNatTimeoutUpdate in, HALNatTimeoutUpdate &out) {
return translate(in.src, out.src)
&& translate(in.dst, out.dst)
&& L4ToNetwork(in.proto, out.proto);
} /* translate */
bool CtUpdateAmbassador::translate(IpaIpAddrPortPair in, HALIpAddrPortPair& out) {
char ipAddrStr[INET_ADDRSTRLEN];
if (inet_ntop(AF_INET, &(in.ipAddr), ipAddrStr, INET_ADDRSTRLEN) == nullptr) {
/* errno would be valid here with EAFNOSUPPORT or ENOSPC, neither should really
* be possible in our scenario though.
*/
return false;
}
out.addr = ipAddrStr;
out.port = in.port;
return true;
} /* translate */
bool CtUpdateAmbassador::L4ToNetwork(IpaL4Protocol in, NetworkProtocol &out) {
bool ret = false;
switch(in) {
case IpaL4Protocol::TCP:
ret = true;
out = NetworkProtocol::TCP;
break;
case IpaL4Protocol::UDP:
ret = true;
out = NetworkProtocol::UDP;
break;
default:
ret = false;
break;
}
return ret;
} /* L4ToNetwork */
|
