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

static

Definition at line 70 of file webTcpip.c.

References DNA_CONNECTION::buffer, Dna_conns, dna_start_read(), DNA_CONNECTION::full_size, DNA_CONNECTION::read_ast, read_data(), size, STA_DISC, and TCP_RCV_BUF_SIZE.

Referenced by web_start_read().

{
        register DNA_CONNECTION *dna_connp = &Dna_conns[conn_id];

        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) 
                {
                        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;
                }
*/
                dna_connp->full_size = size;
                read_data(conn_id);
                dna_start_read(conn_id, TCP_RCV_BUF_SIZE);
        } 
        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:

Here is the caller graph for this function: