Skip to content

Commit c6764ba

Browse files
authored
Merge pull request #700 from redboltz/session_expire_fix
Fiexed session expire.
2 parents 16ae098 + d51cf77 commit c6764ba

File tree

1 file changed

+7
-2
lines changed

1 file changed

+7
-2
lines changed

test/test_broker.hpp

+7-2
Original file line numberDiff line numberDiff line change
@@ -1350,8 +1350,13 @@ class test_broker {
13501350
(MQTT_NS::error_code ec) {
13511351
auto sp = wp.lock();
13521352
if (!ec) {
1353-
auto& idx = sessions_offline_.get<tag_tim>();
1354-
idx.erase(sp);
1353+
auto& idx_sess = sessions_offline_.get<tag_tim>();
1354+
auto it = idx_sess.find(sp);
1355+
if (it != idx_sess.end()) {
1356+
auto& idx_sub = subs_offline_.get<tag_cid>();
1357+
idx_sub.erase(it->client_id);
1358+
idx_sess.erase(it);
1359+
}
13551360
}
13561361
}
13571362
);

0 commit comments

Comments
 (0)