void tcpip_task

(

void *

dummy

)

Definition at line 859 of file tcpip.c.

References count, data, DIM_IO_Done, DIM_IO_path, DIM_IO_valid, dim_usleep(), do_accept(), do_read(), fds_get_entry(), get_bytes_to_read(), list_to_fds(), MY_FD_CLR, MY_FD_ISSET, MY_FD_SET, MY_FD_ZERO, and Net_conns.

Referenced by dim_signal_cond(), and dim_tcpip_thread().

{
        /* wait for an IO signal, find out what is happening and
         * call the right routine to handle the situation.
         */
        fd_set  rfds, *pfds;
#ifndef __linux__
        fd_set efds;
#endif
        int     conn_id, ret, count;
#ifndef WIN32
        int data;
#endif
        if(dummy){}
        while(1)
        {
                while(!DIM_IO_valid)
                        dim_usleep(1000);

                list_to_fds( &rfds );
                MY_FD_ZERO(&efds);
#ifdef WIN32
                pfds = &efds;
#else
                pfds = &rfds;
#endif
                MY_FD_SET( DIM_IO_path[0], pfds );
#ifdef __linux__
                ret = poll(Pollfds, Pollfd_size, -1);
#else
                ret = select(FD_SETSIZE, &rfds, NULL, &efds, NULL);
#endif
                if(ret <= 0)
                  {
                    printf("poll returned %d, errno %d\n", ret, errno);
                  }
                if(ret > 0)
                {
                        if(MY_FD_ISSET(DIM_IO_path[0], pfds) )
                        {
#ifndef WIN32
                                read(DIM_IO_path[0], &data, 4);
                                DIM_IO_Done = 0;
#endif
                                MY_FD_CLR( (unsigned)DIM_IO_path[0], pfds );
                        }
/*
                        {
                        DISABLE_AST
*/
                        conn_id = 0;
                        while( (ret = fds_get_entry( &rfds, &conn_id )) > 0 ) 
                        {
                                if( Net_conns[conn_id].reading )
                                {
                                        count = 0;
                                        do
                                        {
                                                DISABLE_AST
                                                if(Net_conns[conn_id].channel)
                                                {
                                                        do_read( conn_id );
                                                        count = get_bytes_to_read(conn_id);
                                                }
                                                else
                                                {
                                                        count = 0;
                                                }
                                                ENABLE_AST
                                        }while(count > 0 );
                                }
                                else
                                {
                                        DISABLE_AST
                                        do_accept( conn_id );
                                        ENABLE_AST
                                }
                                MY_FD_CLR( (unsigned)Net_conns[conn_id].channel, &rfds );
                        }
/*
                        ENABLE_AST
                        }
*/
#ifndef WIN32
                        return;
#endif
                }
        }
}

Here is the call graph for this function:

Here is the caller graph for this function: