static int do_read ( int  conn_id )

static

Definition at line 705 of file tcpip.c.

References NET_CONNECTION::buffer, count, get_bytes_to_read(), NET_CONNECTION::last_used, Net_conns, NET_CONNECTION::read_rout, readsock, size, NET_CONNECTION::size, and time.

Referenced by io_sig_handler(), and tcpip_task().

{
        /* There is 'data' pending, read it.
         */
        int     len, totlen, size, count;
        char    *p;

        count = get_bytes_to_read(conn_id);
        if(!count)
        {
/*
                dna_report_error(conn_id, -1,
                        "Connection closed by remote peer", DIM_ERROR, DIMTCPRDERR);
                printf("conn_id %d\n", conn_id);
*/
                Net_conns[conn_id].read_rout( conn_id, -1, 0 );
                return 0;
        }

        size = Net_conns[conn_id].size;
        p = Net_conns[conn_id].buffer;
        totlen = 0;
/*
        count = 1;
*/
        while( size > 0 && count > 0 )
        {
/*
                would this be better? not sure afterwards...
                nbytes = (size < count) ? size : count;
                if( (len = readsock(Net_conns[conn_id].channel, p, (size_t)nbytes, 0)) <= 0 ) 
*/
                if( (len = (int)readsock(Net_conns[conn_id].channel, p, (size_t)size, 0)) <= 0 ) 
                {       /* Connection closed by other side. */
                        Net_conns[conn_id].read_rout( conn_id, -1, 0 );
                        return 0;
                } 
                else 
                {
                        
                        /*
                        printf("tcpip: read %d bytes:\n",len); 
                        printf( "buffer[0]=%d\n", vtohl((int *)p[0]));
                        printf( "buffer[1]=%d\n", vtohl((int *)p[1]));
                        printf( "buffer[2]=%x\n", vtohl((int *)p[2]));
                        */
                        totlen += len;
                        size -= len;
                        p += len;
                }
                if(size)
                        count = get_bytes_to_read(conn_id);
        }

        Net_conns[conn_id].last_used = time(NULL);
        Net_conns[conn_id].read_rout( conn_id, 1, totlen );
        return 1;
}

Here is the call graph for this function:

Here is the caller graph for this function: