3

カメラからビデオを取得するために、HTTP経由でRTSPを使用してIPカメラと通信するソケットクライアントを実装しました。

カメラとの通信を安定させるには、まず HTTP-GET トンネルを設定し、次に RTSP コマンドを送信する必要があります。カメラが接続を失うと、プログラムはトンネル ハンドラーを閉じてスレッドを終了し、プロセスがメイン関数に戻ると通信を開始する必要があります (トレッドの開始など)。

再接続時: http-get トンネルは正常に設定されています。つまり、ソケットが接続して "HTTP OK" を受信するため、プログラムは RTSP "DESCRIBE" を送信しますが、recv は常に EAGAIN エラーを返します。カメラから DESCRIBE OK 応答が送信されていることを確認しますが、recv はそれを取得しません。

コードは次のとおりです。

   struct sockaddr_in aServer;
  // string myData;
  char *myData=new char [256];
  connection *c=(connection*)vargp;


   memset(&aServer, 0, sizeof aServer);
   aServer.sin_family = AF_INET;

   aServer.sin_addr.s_addr = inet_addr(c->theServer.c_str());
   if (aServer.sin_addr.s_addr == INADDR_NONE)
   {
     struct hostent *hp;

     hp = gethostbyname(c->theServer.c_str());
     if (hp != NULL)
     {
       memcpy(&aServer.sin_addr, hp->h_addr, hp->h_length);
       aServer.sin_family = hp->h_addrtype;    //Protocol family
     }
     else
           cout << "Failed to resolve " << c->theServer.c_str()  << ": " << hstrerror(h_errno) << endl;
   }

   aServer.sin_port = htons(c->thePort);
   c->fd_get = socket(AF_INET, SOCK_STREAM, 0);

   struct timeval timeout;

   timeout.tv_sec = 5;
   timeout.tv_usec = 0;

  setsockopt(c->fd_get, SOL_SOCKET, SO_RCVTIMEO, &timeout, sizeof(timeout));

   if (c->fd_get < 0){
    cout << "fd_get < 0"  << endl;
      c->bFin=true;
      c->WakeUP();
      }
   if (connect(c->fd_get, (struct sockaddr *) &aServer, sizeof aServer) < 0){
    cout << "connect fd_get < 0"  << endl;
    c->bFin=true;
    c->WakeUP();
   }
   if(!c->bFin){

    sprintf(myData, "GET %s HTTP/1.1\r\n", c->theURI.c_str());
    sprintf(myData, "%sx-sessioncookie: %s\r\nAccept: application/x-rtsp-tunnelled\r\nAuthorization: %s\r\n\r\n", myData,c->theHTTPSessionId.c_str(), c->addAuthorization(c->aGlobalUsername, c->aGlobalPassword).c_str() );

    cout << myData << endl;
    write(c->fd_get, myData, strlen(myData));

    //LISTENING...
    int theLen=1500; //3000;
    int ret=0;
    unsigned char datosRecibidos[3000];

    int flags =fctl(c->fd_get, F_GETFD;
    if((flags & O_NONBLOCK) == O_NONBLOCK){
        fprint(stderr, "yup, its nonblocking");
    }
    else{
        fprint(stderr, "nope, its blocking");
    }


    while (c->bFin==false){

     ret = read(c->fd_get, ReceivedData, theLen);
    // ret= recvfrom(c->fd_get, ReceivedData, theLen, 0,  (struct sockaddr *) 0, (socklen_t*)0);
     if (ret == 0)
     {
      cout << "Server closed connection: 0" << endl;

    }
      else
      if (ret == -1){
     fprintf (stderr, "\n[%d]: %s %d\n", __LINE__, strerror (errno), errno);

     if(errno==107 ||errno==EAGAIN){
      cout << "errno" << endl;
      c->bFin=true;
      c->WakeUP();
      cout << "vuelta wakeUP" << endl;
      break;// empezar de nuevo
     }else{
      cout << "errno" << endl;

     }

    }
    else{
     //cout << (string)ReceivedData[0]<< endl;
     c->ProcessReceivedData(ReceivedData, ret);
     usleep(10);
    }
   }

   close(c->fd_get);
   c->fd_get = -1;

   }

タイムアウトの問題でしょうか？またはスタックの問題？どうすれば解決できますか？

よろしくお願いします。よろしくお願いします。

クリスティーナ

4

3 に答える 3

4

EAGAINは、非ブロッキングソケットで読み取るために使用できるデータがないことを意味します。したがって、recv呼び出しを再度実行する必要があります。

プログラミング障害があることを示唆するのに十分なコードを実際に投稿していませんが、接続が閉じられたことを検出したときに、すべてを再確立する前に端も閉じるかどうかを尋ねることはできますか？

于 2011-01-24T01:29:45.040 に答える
1

ソケットはO_NONBLOCKモードで開いていますか？次のように確認できます。

int flags = fcntl(fd, F_GETFD);
if ((flags & O_NONBLOCK) == O_NONBLOCK) {
  fprintf(stderr, "Yup, it's nonblocking");
}
else {
  fprintf(stderr, "Nope, it's blocking.");
}

非ブロッキングモードでは、受信するものがまだない場合、recvはerrnoをEAGAINに設定してすぐに戻ります。

于 2011-01-24T01:28:45.607 に答える