int tcpip_write_nowait	(	int	conn_id,
		char *	buffer,
		int	size
	)

Definition at line 1435 of file tcpip.c.

References NET_CONNECTION::channel, DIM_ERROR, DIMTCPWRRTY, dna_report_error(), Net_conns, set_blocking(), set_non_blocking(), size, tcpip_would_block(), NET_CONNECTION::write_timedout, Write_timeout, and writesock.

Referenced by dna_write_bytes().

{
        /* Do a (asynchronous) write to conn_id.
         */
        int     wrote, ret, selret;
        int tcpip_would_block();
#ifdef __linux__
        struct pollfd pollitem;
#else
        struct timeval  timeout;
        fd_set wfds;
#endif
        
        set_non_blocking(Net_conns[conn_id].channel);
/*
#ifdef __linux__
        tcpip_get_send_space(conn_id);
#endif
*/
        wrote = (int)writesock( Net_conns[conn_id].channel, buffer, (size_t)size, 0 );
#ifndef WIN32
        ret = errno;
#else
        ret = WSAGetLastError();
#endif
/*
        if((wrote == -1) && (!tcpip_would_block(ret)))
        {
        dna_report_error(conn_id, 0,
                        "Writing (non-blocking) to", DIM_ERROR, DIMTCPWRRTY);
printf("Writing %d, ret = %d\n", size, ret);
        }
*/
        set_blocking(Net_conns[conn_id].channel);
        if(wrote == -1)
        {
                if(tcpip_would_block(ret))
                {
#ifdef __linux__
                  pollitem.fd = Net_conns[conn_id].channel;
                  pollitem.events = POLLOUT;
                  pollitem.revents = 0;
                  selret = poll(&pollitem, 1, Write_timeout*1000);
#else
                        timeout.tv_sec = Write_timeout;
                        timeout.tv_usec = 0;
                        FD_ZERO(&wfds);
                        FD_SET( Net_conns[conn_id].channel, &wfds);
                        selret = select(FD_SETSIZE, NULL, &wfds, NULL, &timeout);
#endif
                        if(selret > 0)
                        {
                                wrote = (int)writesock( Net_conns[conn_id].channel, buffer, (size_t)size, 0 );
                                if( wrote == -1 ) 
                                {
                                        dna_report_error(conn_id, 0,
                                                "Writing to", DIM_ERROR, DIMTCPWRRTY);
                                        return(0);
                                }
                        }
                }
                else
                {
                        dna_report_error(conn_id, 0,
                                "Writing (non-blocking) to", DIM_ERROR, DIMTCPWRRTY);
                        return(0);
                }
        }
        if(wrote == -1)
        {
                Net_conns[conn_id].write_timedout = 1;
        }
        return(wrote);
}

Here is the call graph for this function:

Here is the caller graph for this function: