static int dna_write_bytes ( int  conn_id, void *  buffer, int  size, int  nowait  )

static

Definition at line 270 of file dna.c.

References DIM_WARNING, DIMTCPWRRTY, DIMTCPWRTMO, dna_report_error(), size, tcpip_failure(), Tcpip_max_io_data_write, tcpip_would_block(), tcpip_write(), and tcpip_write_nowait().

Referenced by dna_test_write(), dna_write_nowait(), and do_dna_write().

{
        register int size_left, wrote;
        register char *p;
        int max_io_data;
#ifdef VMS
        int retries = WRITE_RETRIES, retrying = 0;
        float wait_time = 0.01;
#endif
        extern int tcpip_write_nowait(int, char *, int);

        max_io_data = Tcpip_max_io_data_write;
        p = (char *) buffer;
        size_left = size;
        do {
                size = (size_left > max_io_data) ? max_io_data : size_left ;
#ifdef VMS
                if(nowait)
                {
                        while(--retries)
                        {
                                if((wrote = tcpip_write_nowait(conn_id, p, size)) > 0)
                                        break;
                                if(!tcpip_would_block(wrote))
                                        return(0);
                                if(retries == WRITE_RETRIES_WNG)
                                {
                                        dna_report_error(conn_id, tcpip_code,
                                                "Writing to (retrying)", DIM_WARNING, DIMTCPWRRTY);
                                        retrying = 1;
                                }
                                lib$wait(&wait_time);
                        }
                        if(!retries)
                        {
                                return(0);
                        }
                }
                else
                        wrote = tcpip_write(conn_id, p, size);
#else
                if(nowait)
                {
                  wrote = tcpip_write_nowait(conn_id, p, size);
                  if(wrote == -1)
                  {
                    dna_report_error(conn_id, -1,
                                     "Write timeout, writing to", DIM_WARNING, DIMTCPWRTMO);
                    wrote = 0;
                  }
                }
                else
                {
                        wrote = tcpip_write(conn_id, p, size);
                }
#endif
                
                if( tcpip_failure(wrote) )
                        return(0);
                p += wrote;
                size_left -= wrote;
        } while(size_left > 0);
        return(1);
}

Here is the call graph for this function:

Here is the caller graph for this function: