Asyncio.StreamWriter перестает отсылать запросы, что делать?

Question

[datareset]

Приветствую!
Пишу приложение, используя сокеты asyncio, и после циклических запросов перестают отправлять другие

while request_screen:
     writer.write(b'screenshare')
     await writer.drain()

Я заметил, что до выполнения циклических запросов writer при выводе выглядит так:

<StreamWriter transport=<_ProactorSocketTransport fd=1168 read=<_OverlappedFuture pending overlapped=<pending, 0x1bc7ca13a30> cb=[_ProactorReadPipeTransport._loop_reading()]> write=<_OverlappedFuture finished result=3>> reader=<StreamReader waiter=<Future pending cb=[Task.task_wakeup()]> transport=<_ProactorSocketTransport fd=1168 read=<_OverlappedFuture pending overlapped=<pending, 0x1bc7ca13a30> cb=[_ProactorReadPipeTransport._loop_reading()]> write=<_OverlappedFuture finished result=3>>>>

Но после так:

<StreamWriter transport=<_ProactorSocketTransport fd=1168 write=<_OverlappedFuture finished result=3>> reader=<StreamReader 173203 bytes transport=<_ProactorSocketTransport fd=1168 write=<_OverlappedFuture finished result=3>> paused>>

Подскажите как исправить..
Буду благодарен!

Answer 1

[datareset]

Указав паузу начало нормально функционировать

while request_screen:
                    writer.write(b'screenshare')
                    await writer.drain()
                    await asyncio.sleep(0.1)

Answer 2

[whoiam_frontend]

Проблема может быть связана с тем, что буфер записи (write buffer) StreamWriter переполнен, и поэтому запись заблокирована. Чтобы решить эту проблему, можно увеличить размер буфера записи StreamWriter с помощью параметра `high_water`:

writer = await asyncio.open_connection(host, port)
writer = asyncio.StreamWriter(writer, {'high_water': 256*1024}) # устанавливаем размер буфера в 256 КБ

Также может быть полезно использовать метод `can_write()` для проверки, можно ли записать данные в настоящий момент:

while request_screen:
     if writer.can_write():
         writer.write(b'screenshare')
         await writer.drain()
     else:
         await asyncio.sleep(0.1) # ждем некоторое время, пока буфер записи не освободится

Это заставит цикл ожидать некоторое время, пока буфер записи не освободится, прежде чем продолжать отправку данных.

Comments

[datareset]

а можно ли его освободить вручную?

[datareset]

и как происходит процесс освобождения?

[whoiam_frontend]

datareset, освободить вручную вряд ли получится, это занудный процесс. Буфер умножает кбайты - 256*1024, до тех пор, пока у буфера не будет достаточно свободного места. Далее он сам очищается - программа считает первые данные временным мусором

[whoiam_frontend]

GNUBack, кавычки ` не означают ответ от чатгпт

[datareset]

whoiam_frontend, а почему он сейчас не очищается, а стопится?

[whoiam_frontend]

datareset, мало свободного места. Это автоматизированный код, можешь просто поставить его

[datareset]

whoiam_frontend,

writer = asyncio.StreamWriter(writer, {'high_water': 256*1024})
TypeError: StreamWriter.__init__() missing 2 required positional arguments: 'reader' and 'loop'

[whoiam_frontend]

datareset, есть файл __init__? Ошибка пишет, что в init используется 2 аргумента при максимуме 1

[datareset]

whoiam_frontend,

def __init__(self, transport, protocol, reader, loop):
        self._transport = transport
        self._protocol = protocol
        # drain() expects that the reader has a exception() method
        assert reader is None or isinstance(reader, StreamReader)
        self._reader = reader
        self._loop = loop

[whoiam_frontend]

datareset, используй как аргумент только loop либо reader. Либо добавь функцию .sys.argv[2]

[datareset]

whoiam_frontend, он требует их всех

[whoiam_frontend]

datareset, __init__ = sys.argv[2]

[datareset]

whoiam_frontend, не понял причем тут sys

[whoiam_frontend]

datareset, указывает кол-во аргументов в __init__

[datareset]

whoiam_frontend, так в самом методе класса нет параметров отвечающих за лимиты

[Алан Гибизов]

datareset, я бы рекомендовал вам не слушать бред, который транслируют от ChatGPT. Он постоянно теряет контекст и путает педали. И смешно и грустно.

[datareset]

Алан Гибизов, что можете посоветовать в моей ситуации?

[Алан Гибизов]

datareset, я бы посоветовал не пытаться создавать и настраивать экземпляры класса asyncio.StreamWriter напрямую, а попытаться использовать функцию asyncio.open_connection(), изучить его параметры, среди них кстати есть параметр limit, он заведует размером буфера.
Параметра «high_water» согласно документации у него нет, и передача его в конструктор класса сомнительна. Впрочем, надо покопаться в исходниках asyncio, кто знает, что там…

Кстати, согласно документации у класса asyncio.StreamWriter нет метода .can_write() (есть .can_write_eof(), но это не то же), поэтому и второй совет бота сомнителен.

[datareset]

Алан Гибизов, я попробовал покрутить лимит, но к сожалению ничего не изменилось

[Алан Гибизов]

datareset, ну, наличие лимита не означает, что он выполняет то, что вам нужно.

Вообще, тут надо понять, для чего весь этот танец с саблями исполняется? Вы изучаете сокеты? Вы пилите пет-проект? Это как-то потом будет использоваться? Кем? Зачем?

[datareset]

Алан Гибизов, в целях обучения делаю приложение с интерфейсом для удалённого управления компьютерами, используя для передачи данных между ними сокеты

[datareset]

Алан Гибизов, не знаю насколько это является решением, но сделав паузу в 0.1 сек все заработало
await asyncio.sleep(0.1)