AK
Если десериализатора такого нет - ну, сорри, по таймеру выжигаем задачу калёным железом и пишем в лог
Size: a a a
2020 April 08
VG
Может, раскидывать задания десериализаторам через MQ? Т.е. главный процесс ничего не делает, а просто публикует задачи
ну, пока что это второй такой случай за год, хотелось обкостылять не так радикально
VG
так не читай дальше их этого сокета?
а как, если мы продолжим крутиться на любом кондваре?
AK
ну, пока что это второй такой случай за год, хотелось обкостылять не так радикально
Зато ж паттерн отработаешь, а дальше переиспользуешь многократно
VG
собственно, нужда в другом процессе только затем, что десериализуем мы в набор классов, и загрузить набор классов того же нэймспэйса тоже в основной процесс как-то затруднительно :)
VG
Зато ж паттерн отработаешь, а дальше переиспользуешь многократно
это клиентское приложение для (в идеале) конечного пользователя, как-то оверкилл штоль :)
b
а как, если мы продолжим крутиться на любом кондваре?
по идее ты ж
$handle->push_read должен делать, чтобы новые данные подкачать. Не делай, пока не удостоверишься, что они тебе действительно нужны.VG
по идее ты ж
$handle->push_read должен делать, чтобы новые данные подкачать. Не делай, пока не удостоверишься, что они тебе действительно нужны.да? в этом коде вообще нет push_read :)
AP
> предполагается вместо warn/die в этом месте воткнуть RPC-вызов в специально поднимаемые соседние процессы с другими версиями схемы
для телеграмма что ли? :)
для телеграмма что ли? :)
VG
как ты догадался?!
AP
как ты догадался?!
хабрастатью помню
b
да? в этом коде вообще нет push_read :)
ну я ж не знаю что там у тебя за код. Обычно из сокета явным образом просят. А как ты вообще читаешь из сокета с помощью AE?
AK
это клиентское приложение для (в идеале) конечного пользователя, как-то оверкилл штоль :)
Можно лайток ZMQ. Плюс ещё в параллельной обработке . Можно один тип сериализации несколькими процессами молоть, чтобы ядра получше нагружать
AP
Можно лайток ZMQ. Плюс ещё в параллельной обработке . Можно один тип сериализации несколькими процессами молоть, чтобы ядра получше нагружать
ты мастер побредить
AK
ты мастер побредить
А чего?
AP
А чего?
ты задачу понимаешь?
VG
ну я ж не знаю что там у тебя за код. Обычно из сокета явным образом просят. А как ты вообще читаешь из сокета с помощью AE?
ну там в new() класса делается
внутри этого cb делаются unshift_read в зависимости от текущего состояния
$aeh->on_read( $self->_get_read_cb )
внутри этого cb делаются unshift_read в зависимости от текущего состояния
AK
В рамках того, что сформулировано вроде да
AP
В рамках того, что сформулировано вроде да
нет. схема данных может оказаться не совместимой с той, что крутится в процессе
AP
но это крайне маловероятно