Subversion Repositories tpanel

Rev

Rev 97 | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 97 Rev 112
Line 304... Line 304...
304 
    }
 304 
    }
305 
 
 305 
 
306 
    return false;
 306 
    return false;
307 
}
 307 
}
308 
 
 308 
 
309 
size_t TSocket::receive(char* buffer, size_t size)
 309 
size_t TSocket::receive(char* buffer, size_t size, bool doPoll)
310 
{
 310 
{
311 
    DECL_TRACER("TSocket::receive(char* buffer, size_t size)");
 311 
    DECL_TRACER("TSocket::receive(char* buffer, size_t size)");
312 
 
 312 
 
313 
    int proto = 0;
 313 
    int proto = 0;
314 
    bool retry = false;
 314 
    bool retry = false;
Line 330... Line 330...
330 
 
 330 
 
331 
    int s = 0;
 331 
    int s = 0;
332 
 
 332 
 
333 
    do
 333 
    do
334 
    {
 334 
    {
- 
 
 335 
        if (doPoll)
335 
        s = poll(&pfd, nfds, 10000);    // FIXME: Make the timeout configurable.
 336 
            s = poll(&pfd, nfds, 10000);    // FIXME: Make the timeout configurable.
- 
 
 337 
        else
- 
 
 338 
            s = 1;
336 
 
 339 
 
337 
        if (s < 0)
 340 
        if (s < 0)
338 
        {
 341 
        {
339 
            close();
 342 
            close();
340 
            XCEPTNETWORK("[" + mHost + "] Poll error on read: " + strerror(errno));
 343 
            XCEPTNETWORK("[" + mHost + "] Poll error on read: " + strerror(errno));