2

Приложение работает с тремя сокетами, отправляющими данные на один php-скрипт HTTP-сервера:

  1. управляющий сокет - постит присутствие клиента, получает ответы с запросами на активацию/деактивацию остальных двух сокетов. Есть команды send и recv

  2. сокет вебкамеры - стримит кадры с вебки по запросу. Только send

  3. сокет рабочего стола - стримит скриншоты по запросу. Только send

С 1-м проблем нет вообще - если не отправил или не получил - без каких либо ожиданий пересоздаёт подключение и работает дальше. Проблема со 2-м:

DWORD WINAPI NetExCamera(LPVOID){
    unsigned short StreamRate = 50;
    unsigned int OperationStartTime;
    string Header = "POST " + STREAM_URI + " HTTP/1.1\r\nHost: " + STREAM_Host + /*другие параметры*/"\r\nContent-Type: image/jpeg\r\nContent-Transfer-Encoding: binary\r\nContent-Length: ";
    CAMERA.Socket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    if (connect(CAMERA.Socket, (SOCKADDR*)(&Target), sizeof(Target)) == 0){
        cout << "Camera socket connected!\n";
    }
    while(CAMERA.Stream){
        OperationStartTime = GetTickCount();
        CameraFrameSize = WebCam->GetFrameSize();
        CameraFrameBuffer = (unsigned char *)realloc(CameraFrameBuffer, CameraFrameSize);
        compress_image_to_jpeg_file_in_memory(CameraFrameBuffer, CameraFrameSize, RES_X ,RES_Y, 3, WebCam->CaptureFrame(), CameraCompressor);
        CameraFrame = string(reinterpret_cast<char*>(CameraFrameBuffer), CameraFrameSize);
        stringstream SendBuffer;
        SendBuffer << Header << CameraFrame.size() << "\r\n\r\n" << CameraFrame;
        // Sending data...
        cout << "Sending data...\n";
        if (send(CAMERA.Socket, &SendBuffer.str()[0], SendBuffer.str().size(), 0) < 0){
            cout << "Camera socket send error: " << WSAGetLastError() << endl;
            CameraFrame = "";
            closesocket(CAMERA.Socket);
            CAMERA.Socket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
            if (connect(CAMERA.Socket, (SOCKADDR*)(&Target), sizeof(Target)) == 0){
                cout << "Camera socket connected!\n";
            }
        }
        cout << "Send OK!\n";
        while(OperationStartTime + StreamRate > GetTickCount()){
            if (!CAMERA.Stream){break;}
            Sleep(1);
        }
    }
    closesocket(CAMERA.Socket);
    cout << "Camera socket disconnected!\n";
    return 0;
}

Как видно из кода, сокет работает в своём потоке, более того send вроде по умолчанию не блокирующий, но в один момент, спустя 8-11 секунд с начала передачи данных, консольный вывод замирает на строчке cout << "Sending data...\n";, потом секунд через 15-20 "оттаивает", естественно сервер его уже откинул (на apache KeepAliveTimeout 5), и после этой задержки уже выходит cout << "Camera socket send error: " << WSAGetLastError() << endl; с кодом ошибки WSA 10054.

Такое ощущение, что у send есть какой-то невидимый буфер, который переполняется и отправка замирает. Размеры кадров с камеры 6-10 кб. Третий сокет работает по той же схеме, только частота у него не 20 кадров в секунду, а 2 - с ним никаких зависаний не происходит.

Проблема по какой-то причине не возникает на Windows 8.1 x64 на localhost-е, а на 7-ке вот такая беда.

В чём реально может быть причина и как это исправить?

20
  • send по умолчанию блокирующий. Более того, он не гарантирует отправку всех данных.
    – KoVadim
    28 фев 2017 в 8:57
  • Но при send на главном сокете ведь такого не происходит - если что-то не удалось отправить, он сразу реагирует, а этот виснет
    – Iceman
    28 фев 2017 в 9:00
  • 1
    Хорошо бы посмотреть на код другой стороны... Вы уверены, что по ходу дела в ответ вам ничего не шлют? Это (в отсутствии чтения у вас) могло бы объяснить возникшую ситуацию (вы не читаете, буфер (он в самом деле есть) переполняется и та сторона висит на своем send (безуспешно ожидая, пока recv с вашей стороны не разгрузит буфер)). Так оба на своих send и висят.
    – avp
    28 фев 2017 в 9:41
  • Вполне возможно, что скорость заливки маленькая и оно просто не успевает за 8-11 секунд залить.
    – KoVadim
    28 фев 2017 в 9:42
  • 1
    А это последствия. И логично, что сервер его отключает (и это ещё хорошее поведение. А мог и упасть).
    – KoVadim
    28 фев 2017 в 10:01

1 ответ 1

4

В ответ на каждый HTTP POST запрос, которым вы шлете кадр с камеры, сервер шлет ответ.

Эти ответы надо читать (они переполняют буфер и http сервер, подвисая на очередном send, не в состоянии прочесть ваш очередной запрос).

Вот так обе стороны и висят, каждая на своем send.

Кроме того, возможна ситуация, когда ваш send отошлет не все данные. Поэтому его нужно выполнять в цикле, пока все SendBuffer.str().size() байт не будут отосланы.

1
  • Сделал if (send(CAMERA.Socket, &SendBuffer.str()[0], SendBuffer.str().size(), 0) == SendBuffer.str().size()){ RecvBuffer.resize(512); if (recv(CAMERA.Socket, &RecvBuffer[0], RecvBuffer.size(), 0) < 0){ CAMERA.Stream = false;} }. А управляющий сокет пусть уже регулирует потоки. Всё работает. Спасибо!
    – Iceman
    28 фев 2017 в 10:42

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.