Как можно установить время неответа на CURLOPT_WRITEFUNCTION?

Question

[accountnujen]

Есть ip, который постоянно (каждые 5 секунд), отвечает в виде потока. Это камера, которая информирует о новых видео. Функция writer поддерживает эти ответы, а handler обрабатывает ответ. Мне нужно, чтобы этот запрос выполнялся вечно, однако в какой-то момент, как, к примеру, сейчас, камера может перестать вообще отвечать. Свет выключили либо ещё что-то случилось, но сейчас я не могу обратиться по ip. В обычном состоянии камера постоянно отвечает:

--myboundary
Content-Type: text/plain
Content-Length: 9
Heartbeat

Что означает, что новых видео нет. На данных момент логах у меня зафиксировано последнее время и ответ, когда запустился writer и всё.

Как мне можно установить какой-нибудь ограничитель, чтобы он срабатывал в случае если ответа нет в течении условных 20 секунд? По сути, за это отвечает TIMEOUT, однако скрипт перестанет выполняться через 20 секунд, даже если ответы во writer были, поэтому сейчас установлен 0. Нужен другой ограничитель.

function writer($ch, $data) {
  handler($data);
  return strlen($data);
}

$ch = curl_init("$urlcam/cgi-bin/eventManager.cgi?action=attach&codes=[NewFile]&heartbeat=5");
curl_setopt_array($ch, [
        CURLOPT_USERPWD => "$user:$pass",
        CURLOPT_CONNECTTIMEOUT => 20,
        CURLOPT_TIMEOUT => 0,
        CURLOPT_RETURNTRANSFER => 1,
        CURLOPT_HTTPAUTH=>CURLAUTH_DIGEST,
        CURLOPT_CUSTOMREQUEST => "GET",
        CURLOPT_WRITEFUNCTION => 'writer'
    ]);

$result = curl_exec($ch);
curl_close($ch);

Comments

[AUser0]

То есть работу в цикле, запрос за запросом, вы возложили на curl?
При этом ещё и из writer() возвращаете не реально переданное количество байт, а просто размер входящей строки, всегда, перманентно.

[Алексей Уколов]

При чём тут git?

[accountnujen]

AUser0,

То есть работу в цикле, запрос за запросом, вы возложили на curl?
При этом ещё и из writer() возвращаете не реально переданное количество байт, а просто размер входящей строки, всегда, перманентно.

оно работает, если к камере есть доступ.

При чём тут git?

был тег? Я хотел задать другой вопрос про гит, затем передумал и на этой же странице переписал вопрос. вероятно забыл убрать тег. приношу извинения.

Answer 1

[alexalexes]

У вас callback в виде функции writer скорее всего не срабатывает, в случае ошибки по curl.
Попробуйте проанализировать curl после посылки запроса:

$result = curl_exec($ch);
$info = curl_getinfo($ch);
if($info['http_code'] != 200)
{
  // по http не получили статус 200, значит, пишем репорт об этом
}
curl_close($ch);

Вариант 2:

$result = curl_exec($ch);
$curl_error_number = curl_errno($ch);
if($curl_error_number)
{
   $info = curl_getinfo($ch);
  // что-то случилось с соединением в целом, пишем репорт об этом со сведениями $info
}
curl_close($ch);

Comments

[accountnujen]

здесь тоже либо я вас не понимаю, либо вы меня не поняли. хотя здесь больше ко второму склоняюсь. Вы уверены, что я могу дойти до $curl_error_number = curl_errno($ch);? Я не покидаю exec. И в данный момент у меня висит скрипт, который находится в exec, потому что в случае если бы я его покинул, то я бы в логах увидел echo "end script", который находится в конце всего php файла. Я его не вижу, следовательно я не покинул writer.

Answer 2

[Григорий Васильков]

Вы решаете задачу потокового получения данных разовым запросом к камере.

Потоковое получение данных это когда ты используешь fsockopen() или socket_create() в этом случае ты "подписываешься" на камеру и ловишь весь траффик, который оттуда приходит. И это соединение само по себе сломается, если камера перестала отвечать.

Под капотом оно работает как опросник на уровне операционной системы, который с некой частотой проверяет информацию в ячейке памяти.

Так как вы делаете тоже можно, но ваш вызов надо заворачивать в

while (true) {
  // > запрос (сам по себе займет несколько секунд, если повезет - меньше секунды, таймауты в этом случае нужны чтобы при проблемах сети, но когда все устройства работают - немножко подождать, секунду-полторы, а не 20)

  // где-то тут брать значение счетчика microtime(true) и писать функцию считающую разницу по вашим критериям, будь это 20 сек с последнего запроса или 20 сек с последних полученных данных

  usleep(1); // подождать минимум 1 микросекунду (1 кадр), позволив этому ядру проверить другие ожидающие задачи операционной системы, чтобы процессор не задымился от 100% нагрузки в случае если запрос перестанет происходить
  // usleep можно ставить и больше, например 1*1E5 или 100 000, это 100 мс, но в принципе операционке достаточно 1 кадр, она все равно вернется только после того как закончит проверку всех устройств, т.е. по факту пройдет не 1 мкс, а "минимум 1 мкс".
}

но правильно, это все таки подключится сокет соединением на порт камеры.

И нет, этот скрипт не нужно потом запускать из браузера. Он запускается из командой строки/total_commander вызовом "php index.php", что приведет к запуску окошка в котором он работает. Из браузера что-то с while (true) запустишь и оно рано или поздно сляжет по php execution time.

Comments

[accountnujen]

где-то тут брать значение счетчика microtime(true) и писать функцию считающую разницу по вашим критериям, будь это 20 сек с последнего запроса или 20 сек с последних полученных данных
usleep(1); // подождать минимум 1 микросекунду (1 кадр), позволив этому ядру проверить другие ожидающие задачи операционной системы, чтобы процессор не задымился от 100% нагрузки в случае если запрос перестанет происходить

либо я вас не понимаю, либо я не могу себе это позволить, потому что в моём случае нет разрывов между запросами. А в вашем случае, если правильно понял, находясь на 7 секунде, после получения данных с 0 по 5 секунду, я не смогу получить данные с 5 по 10 секунду. Мне тогда доступно только с 7 по 12. С 5 по 7 могло произойти событие, о котором я не уже не узнаю. я сейчас специально утрирую, чтобы было нагляднее понятно, но сути это не меняет

[accountnujen]

И нет, этот скрипт не нужно потом запускать из браузера. Он запускается из командой строки/total_commander вызовом "php index.php", что приведет к запуску окошка в котором он работает. Из браузера что-то с while (true) запустишь и оно рано или поздно сляжет по php execution time.

так оно у меня так и работает. откуда вы вообще взяли браузер?

[Григорий Васильков]

accountnujen, хорошо, что так и работает. На всякий случай убедился, что все работает как должно.

Напишите в телегу вечером https___t_me_gzhegow, посмотрю что там у вас по скрипту. Попытаюсь пояснить на пальцах. Для меня курл это штука которая в основном используется по принципу "подключился, отправил данные, получил ответ, забыл". Возможно вы пытаетесь сделать постоянное соединение, открыв его curl-ом. Может такой функционал там и есть, в этом случае в нем я не шарю, но я бы делал это несколько иначе, и могу попробовать сделать.

[accountnujen]

Григорий Васильков, если предложение сделать через fopen, то у меня так оно и было. Мне не нравился колхоз с digest подключением, которое я должен делать в ручную, так как fopen его не поддерживал. Поэтому я бы хотел реализовать это именно средствами curl, но текущее положение больше походит на баг PHP+Curl, так как я не могу найти никаких способов выхода из CURLOPT_WRITEFUNCTION

[Григорий Васильков]

ну fopen() это несколько более логично конечно, а в том что у вас есть низкоуровневый доступ это по-моему даже лучше, пусть и приходится колхозить. По крайней мере вы уверены, что вы отсылаете голый текст и он долетает в исходном виде, а не поверх какой-нибудь фреймОворк что-то там присобачивает сам себе.

ну fopen/fsockopen почти то же самое.

пожалуй я тогда пас, тут надо GPT долбить пока он не расскажет можно ли в пыхе через курл открыть постоянное соединение. я так не делал и предпочитаю если надо обмен данными - поменьше наворотов подключать, чтобы скрипт был максимально близок к голому PHP и отрабатывал максимально быстро, не делая никакой магии.

[AUser0]

Григорий Васильков,

можно ли в пыхе через курл открыть постоянное соединение

Эммм, HTTP2.0, не?
Ведь явно cURL должен его поддерживать, а значит и все его плюшки...

[Григорий Васильков]

AUser0, я пердало старое, я про такое и не слышал и не хочу. я уже видел к чему приводит избыток новых штук, и с тех самых пор всегда делаю лучше вручную и лучше без них. Про новинки тысячу споров, много хайпа и в них никогда не найдешь того, кто "уже понял как". Даже в старом не всегда такие есть, но в старом хотя бы хелпа больше. А натыкать технологий и потом создавать топы "как ускорить запрос по вычитке 20млн записей потому шо у меня тут инфра и рэббит и вообще", а там задача "сумматор на записи прилепи" - ну короче ты понял

самая печальная трабла с новыми штуками, которые называются так же как старые - это то, что они путаются по теории и описаниям терминов так, что потом ни ты разобраться не можешь, ни коллеги твои, говорите про хттп, одни про сани другие про коней, а говорить никто ни с кем не желает, хотят чтобы за секунду решалось, а становится невозможно