Форум программистов [Powered by Invision Power Board]

Версия для печати темы
Нажмите сюда для просмотра этой темы в оригинальном формате

Форум программистов > C/C++: Сети > Сокеты Беркли, recv

Автор: mad_lollipop 16.11.2008, 15:13

Недавно начал работать с сокетами, использую их в чистом виде, т.е. Сокеты Беркли+AF_INET, SOCK_STREAM, IPPROTO_TCP, потоковые, TCP. Возник вопрос, связанный с функцией recv. Если наш сокет не асинхронный, тогда при вызове этой функции мы ждем, пока во входном буфере сокета не появятся данные присланного пакета. При появлении данных в буфере мы можем обрабатывать полученное. Но вот что интересует больше всего: гарантируется ли полнота присланных данных, т.е. если нам послали 50 байт, то нам их столько и прийдет, или может возникнуть ситуация, когда нам эти 50 байт придут по частям, причем после получения первой части байтов наша программа получит возможность работы не дожидаясь получения следующих частей??? Возможно, все это реализуется на уровне TCP? Или как?

Автор: jonie 16.11.2008, 18:28

описанная ситуация вполне возможна, и зависит не только от настроек ОС, но и от устройства стека TCP\IP в системе...
а почему это вам должны давать сразу все присланные данные? может их там будет 20 мегабайт...

Автор: J0ker 16.11.2008, 19:47

для UDP пакет приходит целиком, если на recv запрошено меньше, то остаток теряется
для TCP возможна фрагментация пакетов (т.к. фактически пакетов нет - это потоковый протокол), при этом данный не теряются, даже когда в recv запрошено меньше имеющегося

Автор: MAKCim 16.11.2008, 22:26

Цитата(mad_lollipop @ 16.11.2008, 15:13

)

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

ну вообще говоря клиент/сервер обязан сам следить за целостностью данных в рамках протокола
т. е нужно читать столько, сколько надо (подразумевает протокол)

Автор: SVN74 17.11.2008, 00:20

Я был столкнулся с подобной проблемой при пересылке больших размеров данных (в МАССИВАХ),
так как массив надо заполнить за один присест, пришлось смастерить свою функцию для полного заполнения массива:
Где:
RecivedData - Массив данных
SizeOfData - Размер массива
SizeDataForSpeed - Можно устанавливать любую скорость но не больше размера массива

///////////////////////////////////////////////////////////

Код


// Функция получения больших размеров данных через сеть
int  BigRecieve(SOCKET sck, char *RecivedData, int SizeOfData, int SizeDataForSpeed)
{
 int c,x=0; void *Ptr;
 try
 {
  char *TempAccp = new char[SizeDataForSpeed];
  do {
    c=recv(sck,&TempAccp[0],SizeDataForSpeed,0);
   if(c<0)
   {
   delete [] TempAccp;
   return -1;
   }
    Ptr = RecivedData+x;
    if(Ptr)
    x=x+c;
     if((c<0) || (SizeOfData < x) || (!Ptr))
    {
     delete [] TempAccp;
     return -1;
    }
     memcpy(Ptr,(void*)&TempAccp[0],c);
     } while(SizeOfData > x);
   delete [] TempAccp;
  }
  catch(...)
  {
   return -1;
  }
 return x;
}

Да... При ошибках будет возвращать -1

Автор: jonie 19.11.2008, 01:22

вспоминается тот незабываемый код, что когда-то писал наш офис в тайланде....
опишу пошагово (без обид, с юмором):

Цитата

Код


int  BigRecieve(SOCKET sck, char *RecivedData, int SizeOfData, int SizeDataForSpeed)
{
 int c,x=0; void *Ptr;
 try
 {
  char *TempAccp = new char[SizeDataForSpeed];  //завели буферок для скачивания (размер его скорость не даст 99%)

  do {
    c=recv(sck,&TempAccp[0],SizeDataForSpeed,0);  //начнем качать, неважно, что RecivedData может быть равен NULL -- хитроумно проверим дальше, а данные потеряем

   if(c<0)
   {
   delete [] TempAccp;
   return -1;
   }

//заведем магическую Х. Просто, нам лень делать было 
//"Ptr = RecivedData; Ptr += c;" - так могут все.
    Ptr = RecivedData+x;   

    if(Ptr)  //проверим на всякий случай (вдруг в первый раз RecivedData==NULL был?)
      x=x+c;

//
//и еще на всякий случай проверим Ptr (а вдруг RecivedData всеже был NULL?) 
//заодно проверим предоставленный размер буфера (про уже скаченные данные тупо забудем - они никому не нужны)
//на всякий случай перепроверим что C<0 (ведь "семь раз проверь - один отрежь")
     if((c<0) || (SizeOfData < x) || (!Ptr)) 
    {
     delete [] TempAccp;
     return -1;
    }
     memcpy(Ptr,(void*)&TempAccp[0],c); //пишем мы не зная что приводить к void* нет нужды...
     } while(SizeOfData > x);
   delete [] TempAccp;
  }
  catch(...)
  {
   return -1;  //а тут отчищать память от TempAccp не надо. "пусть всегда будет Солнце".
  }
 return x;

}

Автор: SVN74 19.11.2008, 23:34