Skip to content

Commit abd28e4

Browse files
authored
Merge pull request #867 from redboltz/post_acceptor_reset
Added acceptor_.reset() posting.
2 parents 6c25c7a + 6c76ccb commit abd28e4

File tree

1 file changed

+24
-4
lines changed

1 file changed

+24
-4
lines changed

include/mqtt/server.hpp

+24-4
Original file line numberDiff line numberDiff line change
@@ -134,7 +134,12 @@ class server {
134134

135135
void close() {
136136
close_request_ = true;
137-
acceptor_.reset();
137+
as::post(
138+
ioc_accept_,
139+
[this] {
140+
acceptor_.reset();
141+
}
142+
);
138143
}
139144

140145
void set_accept_handler(accept_handler h = accept_handler()) {
@@ -300,7 +305,12 @@ class server_tls {
300305

301306
void close() {
302307
close_request_ = true;
303-
acceptor_.reset();
308+
as::post(
309+
ioc_accept_,
310+
[this] {
311+
acceptor_.reset();
312+
}
313+
);
304314
}
305315

306316
void set_accept_handler(accept_handler h = accept_handler()) {
@@ -519,7 +529,12 @@ class server_ws {
519529

520530
void close() {
521531
close_request_ = true;
522-
acceptor_.reset();
532+
as::post(
533+
ioc_accept_,
534+
[this] {
535+
acceptor_.reset();
536+
}
537+
);
523538
}
524539

525540
void set_accept_handler(accept_handler h = accept_handler()) {
@@ -792,7 +807,12 @@ class server_tls_ws {
792807

793808
void close() {
794809
close_request_ = true;
795-
acceptor_.reset();
810+
as::post(
811+
ioc_accept_,
812+
[this] {
813+
acceptor_.reset();
814+
}
815+
);
796816
}
797817

798818
void set_accept_handler(accept_handler h = accept_handler()) {

0 commit comments

Comments
 (0)