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
|
#include "common.h"
bool CToxProto::IsOnline()
{
return isConnected && m_iStatus > ID_STATUS_OFFLINE;
}
void CToxProto::BootstrapNode(int index)
{
bool isIPv4 = getBool("DisableIPv6", 0);
int nodeCount = db_get_w(NULL, "TOX", TOX_SETTINGS_NODE_COUNT, 0);
if (!nodeCount)
{
tox_bootstrap_from_address(
tox, isIPv4 ? "192.254.75.102" : "2607:5600:284::2", 33445,
ToxBinAddress("951C88B7E75C867418ACDB5D273821372BB5BD652740BCDF623A4FA293E75D2F"));
tox_bootstrap_from_address(
tox, "104.219.184.206", 443,
ToxBinAddress("8CD087E31C67568103E8C2A28653337E90E6B8EDA0D765D57C6B5172B4F1F04C"));
return;
}
int i = index % nodeCount;
char setting[MAX_PATH];
mir_snprintf(setting, SIZEOF(setting), isIPv4 ? TOX_SETTINGS_NODE_IPV4 : TOX_SETTINGS_NODE_IPV6, i);
ptrA address(db_get_sa(NULL, "TOX", setting));
if (address == NULL && !isIPv4)
{
mir_snprintf(setting, SIZEOF(setting), TOX_SETTINGS_NODE_IPV4, i);
address = db_get_sa(NULL, "TOX", setting);
}
mir_snprintf(setting, SIZEOF(setting), TOX_SETTINGS_NODE_PORT, i);
int port = db_get_w(NULL, "TOX", setting, 0);
mir_snprintf(setting, SIZEOF(setting), TOX_SETTINGS_NODE_PKEY, i);
ptrA pubKey(db_get_sa(NULL, "TOX", setting));
tox_bootstrap_from_address(tox, address, port, ToxBinAddress(pubKey));
}
void CToxProto::TryConnect()
{
if (tox_isconnected(tox))
{
isConnected = true;
debugLogA("CToxProto::PollingThread: successfuly connected to DHT");
m_iStatus = m_iDesiredStatus;
ProtoBroadcastAck(NULL, ACKTYPE_STATUS, ACKRESULT_SUCCESS, (HANDLE)ID_STATUS_CONNECTING, m_iStatus);
tox_set_user_status(tox, MirandaToToxStatus(m_iStatus));
debugLogA("CToxProto::PollingThread: changing status from %i to %i", ID_STATUS_CONNECTING, m_iDesiredStatus);
}
else
{
BootstrapNode(m_iStatus);
if (m_iStatus++ > MAX_CONNECT_RETRIES)
{
SetStatus(ID_STATUS_OFFLINE);
ProtoBroadcastAck(NULL, ACKTYPE_LOGIN, ACKRESULT_FAILED, (HANDLE)NULL, LOGINERR_NONETWORK);
debugLogA("CToxProto::PollingThread: failed to connect to DHT");
}
}
}
void CToxProto::CheckConnection(int &retriesCount)
{
if (!isConnected)
{
TryConnect();
}
else
{
if (tox_isconnected(tox))
{
retriesCount = TOX_MAX_DISCONNECT_RETRIES;
}
else if (!(--retriesCount))
{
isConnected = false;
debugLogA("CToxProto::PollingThread: disconnected from DHT");
SetStatus(ID_STATUS_OFFLINE);
}
}
}
void CToxProto::DoTox()
{
{
mir_cslock lock(toxLock);
tox_do(tox);
}
uint32_t interval = tox_do_interval(tox);
Sleep(interval);
}
void CToxProto::PollingThread(void*)
{
debugLogA("CToxProto::PollingThread: entering");
if (!InitToxCore())
{
SetStatus(ID_STATUS_OFFLINE);
ProtoBroadcastAck(NULL, ACKTYPE_LOGIN, ACKRESULT_FAILED, (HANDLE)NULL, LOGINERR_WRONGPASSWORD);
debugLogA("CToxProto::PollingThread: leaving");
return;
}
int retriesCount = TOX_MAX_DISCONNECT_RETRIES;
isConnected = false;
while (!isTerminated)
{
CheckConnection(retriesCount);
DoTox();
}
UninitToxCore();
isConnected = false;
debugLogA("CToxProto::PollingThread: leaving");
}
|
