static void ast_read_h ( int  conn_id, int  status, int  size  )

static

Definition at line 134 of file dna.c.

References buff, DNA_CONNECTION::buffer, DNA_CONNECTION::curr_buffer, DNA_CONNECTION::curr_size, DIM_ERROR, DIMTCPRDERR, Dna_conns, dna_report_error(), dna_start_read(), is_header(), RD_DATA, RD_HDR, DNA_CONNECTION::read_ast, read_data(), READ_HEADER_SIZE, size, STA_DISC, DNA_CONNECTION::state, tcpip_failure(), Tcpip_max_io_data_read, and tcpip_start_read().

{
        register DNA_CONNECTION *dna_connp = &Dna_conns[conn_id];
        int tcpip_code;
        register int read_size, next_size;
        register char *buff;
        int max_io_data;

        if(!dna_connp->buffer) /* The connection has already been closed */
        {
                return;
        }
        if(status == 1)
        {
                next_size = dna_connp->curr_size;
                buff = (char *) dna_connp->curr_buffer;
                if(size < next_size) 
                {
/*
                        Prev_conn_id = conn_id;
                        Prev_packet[0] = ((int *)dna_connp->curr_buffer)[0];
                        Prev_packet[1] = ((int *)dna_connp->curr_buffer)[1];
                        Prev_packet[2] = ((int *)dna_connp->curr_buffer)[2];
                        Prev_buffer[0] = dna_connp->buffer[0];
                        Prev_buffer[1] = dna_connp->buffer[1];
                        Prev_buffer[2] = dna_connp->buffer[2];
*/
                        max_io_data = Tcpip_max_io_data_read;
                        read_size = ((next_size - size) > max_io_data) ?
                                max_io_data : next_size - size;
                        dna_connp->curr_size -= size;
                        dna_connp->curr_buffer += size;
                        tcpip_code = tcpip_start_read(conn_id, buff + size, 
                                read_size, ast_read_h);
                        if(tcpip_failure(tcpip_code)) 
                        {
#ifndef WIN32
                          if(errno == ENOTSOCK)
                          {
                                  if(dna_connp->read_ast)
                                        dna_connp->read_ast(conn_id, NULL, 0, STA_DISC);
                          }
                          else
#endif
                          {
                                dna_report_error(conn_id, tcpip_code,
                                        "Reading from", DIM_ERROR, DIMTCPRDERR);
                          }
                        }
                        return;
                }
                switch(dna_connp->state)
                {
                        case RD_HDR :
                                if(is_header(conn_id))
                                {
                                        if( dna_connp->state == RD_DATA )
                                        {
                                                next_size = vtohl(dna_connp->buffer[1]);
                                                dna_start_read(conn_id, next_size);
                                        }
                                        else
                                        {
                                                dna_connp->state = RD_HDR;
                                                dna_start_read(conn_id, READ_HEADER_SIZE);
                                        }
                                }
                                break;
                        case RD_DATA :
                                read_data(conn_id);
                                dna_connp->state = RD_HDR;
                                dna_start_read(conn_id, READ_HEADER_SIZE);
                                break;
                        default:
                                break;
                }
/*
                if(dna_connp->buffer)
                {
                        Prev_conn_id = conn_id;
                        Prev_packet[0] = ((int *)dna_connp->curr_buffer)[0];
                        Prev_packet[1] = ((int *)dna_connp->curr_buffer)[1];
                        Prev_packet[2] = ((int *)dna_connp->curr_buffer)[2];
                        Prev_buffer[0] = dna_connp->buffer[0];
                        Prev_buffer[1] = dna_connp->buffer[1];
                        Prev_buffer[2] = dna_connp->buffer[2];
                }
*/
        } 
        else 
        {
          /*
          printf("Connection lost. Signal upper layer\n");
          */
                if(dna_connp->read_ast)
                        dna_connp->read_ast(conn_id, NULL, 0, STA_DISC);
        }
}

Here is the call graph for this function: