@override
| 373 | protected: |
| 374 | // @override |
| 375 | bool accept_callback(acl::aio_socket_stream* conn) { |
| 376 | printf("connect from %s, fd=%d\r\n", conn->get_peer(true), |
| 377 | conn->sock_handle()); |
| 378 | |
| 379 | acl::mqtt_aclient* client = new mqtt_client(handle_, manager_); |
| 380 | if (client->open(conn)) { |
| 381 | return true; |
| 382 | } |
| 383 | |
| 384 | printf("open one mqtt client failed\r\n"); |
| 385 | client->destroy(); |
| 386 | conn->close(); |
| 387 | return true; |
| 388 | } |
| 389 | |
| 390 | private: |
| 391 | acl::aio_handle& handle_; |
nothing calls this directly
no test coverage detected