Реализовать таймаут

bool some_class::some_method(std::string msg, std::string& result)
{
  // код отправки msg
    if( ! Ok )  return false;
 
  // код приема в result , и если не удалось принять Ok = 0;
  if( ! Ok )  return false;
 
  return true; 
}

       bool wait_for_read( DWORD timeout = INFINITE ) const {
 
            fd_set recv_set = {0};
 
            timeval tv = {0};
            timeval *tvp;
 
            if (timeout == INFINITE) {
                tvp = NULL;
            } else {
                tv.tv_sec = timeout / 1000;
                tv.tv_usec = (timeout % 1000) * 1000;
                tvp = &tv;
            }
            FD_SET(sock, &recv_set);
            int res = 0;
            res = ::select(sock + 1, // useless in windows
                            &recv_set, NULL, NULL, tvp);
            // res == -1 -- throw ... 
            return (res != 0);
        }

DWORD interval = 1000; // мс
int size = sizeof (DWORD);
//....
ListenSocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
//...
iResult = setsockopt(ListenSocket, SOL_SOCKET, SO_RCVTIMEO,  (char *)&interval,size);
 
if (iResult == SOCKET_ERROR)   
   {
       wprintf(L"setsockopt for SO_KEEPALIVE failed with error: %u\n", WSAGetLastError());
   } 
else
      wprintf(L"SO_RCVTIMEO: ON\n");
 
 
iResult = setsockopt(ListenSocket, SOL_SOCKET, SO_SNDTIMEO,  (char *)&interval, size);
 
if (iResult == SOCKET_ERROR)   
   {
       wprintf(L"setsockopt for SO_SNDTIMEO failed with error: %u\n", WSAGetLastError());
   } 
else
      wprintf(L"SO_SNDTIMEO: ON\n");

//---------------------------------------------------------------------------
bool client_t::connect()
{
    _socket= ::socket(AF_INET,SOCK_STREAM,0);
    if(_socket==INVALID_SOCKET) return false;
 
    if( ::connect(_socket, (sockaddr*)&_addr, sizeof(_addr) ) ) return false;
    else
        {
            #ifdef MyDebug
                std::cerr<<"[Debug] "<<"Соединение установлено."<<std::endl;
            #endif
        }
     /*
    if(setsockopt( _socket, SOL_SOCKET,
                                 SO_RCVTIMEO,
                                 (char *)&_timeout,
                                 sizeof(_timeout) ) == SOCKET_ERROR) return false;
 
    if(setsockopt( _socket, SOL_SOCKET,
                                 SO_SNDTIMEO,
                                 (char *)&_timeout,
                                 sizeof(_timeout) ) == SOCKET_ERROR) return false;
     */
return true;
}
//---------------------------------------------------------------------------
bool client_t::send(std::string cmd)
{
    int length = ::send(_socket, cmd.c_str(), cmd.length(), NULL);
    return length != SOCKET_ERROR;
}
//---------------------------------------------------------------------------
bool client_t::receive(std::string& response)
{
response.clear();
int length= 0;
 
do
    {
        //memset(_buff,'\0',MAX_LENGTH);
        length= ::recv( _socket, _buff, MAX_LENGTH, NULL);
        if(length == SOCKET_ERROR)
            {
             #ifdef MyDebug
                    std::cerr<<"[Debug] "<<"Ошибка чтения."<<std::endl;
             #endif
             return false;
            }
        #ifdef MyDebug
                    std::cerr<<"[Debug] "<<"Принято "<<length<<" Байт"<<std::endl;
        #endif
        response+= std::string(_buff, length) ;
    }
while( length!=0 );
 
return true;
}
//---------------------------------------------------------------------------

//---------------------------------------------------------------------------
int main(int argc, char* argv[])
{
system("chcp 1251");
system("color 0a");
 
using namespace std;
 
my::client_t client1;
 
client1.set_port(110);
if(! client1.set_addr("pop.yandex.ru") ) client1.get_error();
 
if(! client1.connect() ) client1.get_error();
 
std::string response;
if( ! client1.receive(response) ) client1.get_error();
cout<< response;
 
 
system("pause");
return 0;
}
//---------------------------------------------------------------------------