boost :: asio :: tcp :: socket Zamknij i anuluj bez funkcji obsługi o nazwie

Question

Piszę serwer z biblioteką asio doładowania. Serwer obsługuje wiele równoczesnych połączeń za pomocą kolekcji obiektów połączeń (klasa otoki wokół boost :: asio :: tcp :: socket). W klasie Connection gniazdo jest stale odczytywane za pomocą socket.async_read_some (...) i zawsze, gdy wywoływacz zostanie wywołany nowymi danymi, socket.async_read_some() jest natychmiast wywoływany ponownie, aby uzyskać więcej danych do odczytania.

Teraz serwer może z jakiegoś powodu zdecydować o rozłączeniu klienta, więc naturalną rzeczą jest wywołanie metody connection.close(), która z kolei wywołuje socket.close(), co spowoduje, że wszystkie operacje asynchronizacji będą w toku. być anulowane. Powoduje to wywołanie procedury odczytu (powiązanej z metodą w klasie Connection) za pomocą instrukcji boost :: asio :: error :: operation_aborted. A moim problemem jest: nie chcę tego.

Po socket.close(), chciałbym zniszczyć gniazdo i połączenie, a następnie usunąć jego wskaźnik z listy aktywnych klientów serwera. Jednak program obsługi odczytu nie zostanie wywołany do następnej iteracji io_service.run(), co oznacza, że ​​nie mogę natychmiast zniszczyć gniazda lub czytnika obsługi, który przekazałem do socket.async_read_some(), dopóki program obsługi nie zostanie wywołany błąd. Więc muszę jakoś opóźnić zniszczenie tych obiektów; To irytujące.

Czy istnieje bezpieczny sposób zarówno

• Anuluj toku operacji async bez dowolnego modułu obsługi powoływać, więc mogę bezpiecznie natychmiast zniszczyć gniazdo po socket.close(), lub do
• bezpiecznie wiesz, kiedy nie więcej osób może być potencjalnie nazwanych

Czy podchodzę do tego całkowicie w niewłaściwy sposób?

Answer 1

Po zakończeniu operacji async.operation - z powodzeniem lub z błędem - wywoływana jest procedura obsługi zakończenia. Jest to ważna gwarancja i nie sądzę, że dobrym pomysłem jest "zhakowanie" tego zachowania. Problem napotkany w przypadku użycia jest zwykle wywoływany za pomocą metody shared_ptr (shared_from_this idiom): bind shared_ptr<Connection> do procedur obsługi, nie wysyłaj kolejnego async_read po uzyskaniu operation_aborted (lub innego błędu), tak aby po wszystkich procedur obsługi są wykonywane obiekt połączenia jest niszczony za pomocą gniazda.