LINUX.ORG.RU

When Socket Die

 ,


0

1

Работает у меня в отдельном потоке вот такой кусок кода:

while self._running.is_set():
    line = self._sock.readline()
    self._message_queue.put(line)
, где
_sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
_sock.connect((host, port))
self._sock = _sock.makefile()
Хорошо работает, однако, если удаленный сервер внезапно вырубается, то моя наколенная поделка лочится намертво и жрет ресурсы.

В документации сие описано следующим образом:

When Sockets Die

Probably the worst thing about using blocking sockets is what happens when the other side comes down hard (without doing a close). Your socket is likely to hang. SOCKSTREAM is a reliable protocol, and it will wait a long, long time before giving up on a connection. If you’re using threads, the entire thread is essentially dead. There’s not much you can do about it. As long as you aren’t doing something dumb, like holding a lock while doing a blocking read, the thread isn’t really consuming much in the way of resources. Do not try to kill the thread - part of the reason that threads are more efficient than processes is that they avoid the overhead associated with the automatic recycling of resources. In other words, if you do manage to kill the thread, your whole process is likely to be screwed up.

Вопрос: что делать-то? Как перехватить смерть удаленной стороны?

то моя наколенная поделка лочится намертво и жрет ресурсы.

Очень похоже на взаимоисключающие параграфы.

Можешь скопипастить минимальный сервер и клиент?

baverman ★★★
()

если удаленный сервер внезапно вырубается

Питанием?

tailgunner ★★★★★
()
Ответ на: комментарий от val-amart

Дефолтный таймаут очень большой (порядка 2 часов).

Универсального кроссплатформенного и при этом бескостыльного способа задать таймер TCP Keepalive не существует. В Linux нужно править опции TCP_KEEPCNT, TCP_KEEPINTVL и TCP_KEEPIDLE на сокете.

В оффтопике SIO_KEEPALIVE_VALS меняется вызовом WSAIoctl.

Более-менее претендующий на переносимость способ - использовать таймеры на операции чтения/записи.

Алсо есть книжка «Эффективное программирование TCP/IP», там есть описание решения проблемы зависших соединений. В целом, описанный там метод сводится к своей самопальной реализации keep-alive, но уже на уровне приложения.

H3
()
Ответ на: комментарий от baverman

Сервер - это Asterisk Manager Interface, а минимальный клиент - 2000 строк быдлокода.

Повтыкав в trace разобрался: при разрыве соединения socket.socket.readline() возвращает пустую строку, что невозможно при нормальной работе, поэтому можно возбуждать исключение, останавливать треды и т.д.

kernelpanic ★★★★★
() автор топика
Ответ на: комментарий от kernelpanic

при разрыве соединения socket.socket.readline() возвращает пустую строку

ЧТД.

baverman ★★★
()
Вы не можете добавлять комментарии в эту тему. Тема перемещена в архив.