@@ -27,7 +27,7 @@ BanMan::~BanMan()
27
27
28
28
void BanMan::LoadBanlist ()
29
29
{
30
- LOCK (m_cs_banned );
30
+ LOCK (m_banned_mutex );
31
31
32
32
if (m_client_interface) m_client_interface->InitMessage (_ (" Loading banlist…" ).translated );
33
33
@@ -51,7 +51,7 @@ void BanMan::DumpBanlist()
51
51
52
52
banmap_t banmap;
53
53
{
54
- LOCK (m_cs_banned );
54
+ LOCK (m_banned_mutex );
55
55
SweepBanned ();
56
56
if (!m_is_dirty) return ;
57
57
banmap = m_banned;
@@ -60,7 +60,7 @@ void BanMan::DumpBanlist()
60
60
61
61
int64_t n_start = GetTimeMillis ();
62
62
if (!m_ban_db.Write (banmap)) {
63
- LOCK (m_cs_banned );
63
+ LOCK (m_banned_mutex );
64
64
m_is_dirty = true ;
65
65
}
66
66
@@ -71,7 +71,7 @@ void BanMan::DumpBanlist()
71
71
void BanMan::ClearBanned ()
72
72
{
73
73
{
74
- LOCK (m_cs_banned );
74
+ LOCK (m_banned_mutex );
75
75
m_banned.clear ();
76
76
m_is_dirty = true ;
77
77
}
@@ -81,14 +81,14 @@ void BanMan::ClearBanned()
81
81
82
82
bool BanMan::IsDiscouraged (const CNetAddr& net_addr)
83
83
{
84
- LOCK (m_cs_banned );
84
+ LOCK (m_banned_mutex );
85
85
return m_discouraged.contains (net_addr.GetAddrBytes ());
86
86
}
87
87
88
88
bool BanMan::IsBanned (const CNetAddr& net_addr)
89
89
{
90
90
auto current_time = GetTime ();
91
- LOCK (m_cs_banned );
91
+ LOCK (m_banned_mutex );
92
92
for (const auto & it : m_banned) {
93
93
CSubNet sub_net = it.first ;
94
94
CBanEntry ban_entry = it.second ;
@@ -103,7 +103,7 @@ bool BanMan::IsBanned(const CNetAddr& net_addr)
103
103
bool BanMan::IsBanned (const CSubNet& sub_net)
104
104
{
105
105
auto current_time = GetTime ();
106
- LOCK (m_cs_banned );
106
+ LOCK (m_banned_mutex );
107
107
banmap_t ::iterator i = m_banned.find (sub_net);
108
108
if (i != m_banned.end ()) {
109
109
CBanEntry ban_entry = (*i).second ;
@@ -122,7 +122,7 @@ void BanMan::Ban(const CNetAddr& net_addr, int64_t ban_time_offset, bool since_u
122
122
123
123
void BanMan::Discourage (const CNetAddr& net_addr)
124
124
{
125
- LOCK (m_cs_banned );
125
+ LOCK (m_banned_mutex );
126
126
m_discouraged.insert (net_addr.GetAddrBytes ());
127
127
}
128
128
@@ -139,7 +139,7 @@ void BanMan::Ban(const CSubNet& sub_net, int64_t ban_time_offset, bool since_uni
139
139
ban_entry.nBanUntil = (normalized_since_unix_epoch ? 0 : GetTime ()) + normalized_ban_time_offset;
140
140
141
141
{
142
- LOCK (m_cs_banned );
142
+ LOCK (m_banned_mutex );
143
143
if (m_banned[sub_net].nBanUntil < ban_entry.nBanUntil ) {
144
144
m_banned[sub_net] = ban_entry;
145
145
m_is_dirty = true ;
@@ -161,7 +161,7 @@ bool BanMan::Unban(const CNetAddr& net_addr)
161
161
bool BanMan::Unban (const CSubNet& sub_net)
162
162
{
163
163
{
164
- LOCK (m_cs_banned );
164
+ LOCK (m_banned_mutex );
165
165
if (m_banned.erase (sub_net) == 0 ) return false ;
166
166
m_is_dirty = true ;
167
167
}
@@ -172,15 +172,15 @@ bool BanMan::Unban(const CSubNet& sub_net)
172
172
173
173
void BanMan::GetBanned (banmap_t & banmap)
174
174
{
175
- LOCK (m_cs_banned );
175
+ LOCK (m_banned_mutex );
176
176
// Sweep the banlist so expired bans are not returned
177
177
SweepBanned ();
178
178
banmap = m_banned; // create a thread safe copy
179
179
}
180
180
181
181
void BanMan::SweepBanned ()
182
182
{
183
- AssertLockHeld (m_cs_banned );
183
+ AssertLockHeld (m_banned_mutex );
184
184
185
185
int64_t now = GetTime ();
186
186
bool notify_ui = false ;
0 commit comments