2012-03-12 4 views
4

У меня есть простое приложение для передачи файлов, которое передает клиенту 4096 байт на запись. В конце сервера я использую следующий вызов:Почему boost :: asio :: read размер данных буфера меньше размера чтения?

tempLen = boost :: asio :: read (l_Socket, boost :: asio :: buffer (buf, bufSize), boost :: asio :: transfer_all() , ошибка);

Templen - 1440 байт, но когда я читаю buf, это всего лишь 11 байт. Скопируйте код сервера ниже. Я попробовал как socket.read_some, так и asio :: read - оба конца в том же самом результате. Может кто-нибудь объяснить, что я делаю неправильно здесь?

//boost::array<char, 4096> buf; 
char* buf = new char[4096]; 
char* bigBuffer = new char[2097152]; 
std::string strBuffer; 

strBuffer.clear(); 

for (;;) // Loop for the whole file length 
{ 

    boost::asio::read_until(l_Socket, request_buf, "\n\n"); 
    std::istream request_stream(&request_buf); 
    request_stream >> bufSize; 
    std::cout<< "Size of the Compressed data transfer:" << bufSize << "\n"; 

    // Clear the stream 
    request_stream.clear(); 
    memset(bigBuffer, 0, 2097152); 
    memset(buf, 0, 4096); 

    if(bufSize == 0) 
     break; 

    size_t len = 0, prevLen = 0, tempLen = 0; 

    try{ 

     //tempLen = l_Socket.read_some(boost::asio::buffer(buf, bufSize), error); 
     tempLen = boost::asio::read(l_Socket, boost::asio::buffer(buf, bufSize), boost::asio::transfer_all(), error); 
     std::cout << "Length from read: " << tempLen << " Buffer Size: " << bufSize << std::endl; 
     prevLen = len; 

     len += tempLen; 

    } 
    catch (boost::exception& e) 
    { 
     std::cerr << diagnostic_information(e); 
    }.....} 

Edit:

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

std::string CClient::Compress(const char* data, unsigned int* dataLen) 
{ 
    std::stringstream compressed; 
    std::stringstream decompressed; 
    std::cout << "From Compress Function: " << " Size of Decompressed Data: " << strlen(data) << std::endl; 
    decompressed << data; 
    boost::iostreams::filtering_streambuf<boost::iostreams::input> out; 
    out.push(boost::iostreams::zlib_compressor()); 
    out.push(decompressed); 
    boost::iostreams::copy(out, compressed); 
    *dataLen = compressed.str().size(); 
    return compressed.str(); 
} 

std::string CClient::DeCompress(const std::string& data) 
{ 
    std::stringstream compressed; 
    std::stringstream decompressed; 
    compressed << data; 
    boost::iostreams::filtering_streambuf<boost::iostreams::input> in; 
    in.push(boost::iostreams::zlib_decompressor()); 
    in.push(compressed); 
    boost::iostreams::copy(in, decompressed); 
    std::cout << "Decompressed Data: " << decompressed.str().c_str() << std::endl; 
    return decompressed.str(); 
} 

Когда я декомпрессию данных у самого «клиента» после сжатия (перед отправкой), данные печатаются должным образом. Но когда я читаю данные после получения на сервере, я столкнулся с этой проблемой.

+0

Вы получите больше внимания, пометив свои вопросы языком, который вы используете. –

+0

J.N - Спасибо за совет. Это будет иметь в виду. –

ответ

1

Проблема, кажется, в функции сжатия. Строка, которая возвращается из функции сжатия, когда я конвертирую ее в строку c, завершает 11 байтов. Я решил проблему, реализовав функцию сжатия, чтобы напрямую вызвать функции zlib и обрабатывать данные как строковые символы, а не std :: string.

+0

вы можете принять свой собственный ответ –

Смежные вопросы