int tcpip_open_server	(	int	conn_id,
		char *	task,
		int *	port
	)

Definition at line 1182 of file tcpip.c.

References NET_CONNECTION::channel, closesock, dim_tcpip_init(), NET_CONNECTION::last_used, Listen_backlog, Net_conns, NET_CONNECTION::port, Read_buffer_size, NET_CONNECTION::reading, SEEK_PORT, START_PORT_RANGE, STOP_PORT_RANGE, time, NET_CONNECTION::timr_ent, ushort, Write_buffer_size, and NET_CONNECTION::write_timedout.

Referenced by dna_open_server(), and web_open_server().

{
        /* Create connection: create and initialize socket stuff,
         * find a free port on this node.
         */
        struct sockaddr_in sockname;
        int path, val, ret_code, ret;

    dim_tcpip_init(0);
        if( (path = (int)socket(AF_INET, SOCK_STREAM, 0)) == -1 ) 
        {
                return(0);
        }

        val = 1;
        if ((ret_code = setsockopt(path, IPPROTO_TCP, TCP_NODELAY, 
                        (char*)&val, sizeof(val))) == -1 ) 

        {
#ifdef DEBUG
                printf("Couln't set TCP_NODELAY\n");
#endif
                closesock(path); 
                return(0);
        }

        val = Write_buffer_size;
        if ((ret_code = setsockopt(path, SOL_SOCKET, SO_SNDBUF, 
                        (void *)&val, sizeof(val))) == -1 ) 
        {
#ifdef DEBUG
                printf("Couln't set SO_SNDBUF\n");
#endif
                closesock(path); 
                return(0);
        }
/*
        sval1 = sizeof(val1);
        if ((ret_code = getsockopt(path, SOL_SOCKET, SO_SNDBUF, 
                        (void *)&val1, &sval1)) == -1 ) 
        {
#ifdef DEBUG
                printf("Couln't set SO_SNDBUF\n");
#endif
                closesock(path); 
                return(0);
        }
printf("Set size to %d, got size %d\n", val, val1);
*/
        val = Read_buffer_size;
        if ((ret_code = setsockopt(path, SOL_SOCKET, SO_RCVBUF, 
                        (void *)&val, sizeof(val))) == -1 ) 
        {
#ifdef DEBUG
                printf("Couln't set SO_RCVBUF\n");
#endif
                closesock(path); 
                return(0);
        }

        if( *port == SEEK_PORT ) 
        {       /* Search a free one. */
                *port = START_PORT_RANGE - 1;
                do 
                {
                        (*port)++;
                        sockname.sin_family = AF_INET;
                        sockname.sin_addr.s_addr = INADDR_ANY;
                        sockname.sin_port = htons((ushort) *port);
                        if( *port > STOP_PORT_RANGE ) {
                                errno = EADDRNOTAVAIL;  /* fake an error code */
                                closesock(path);
#ifdef WIN32
                                WSASetLastError(errno);
#endif
                                return(0);
                        }
                        ret = bind(path, (struct sockaddr*)&sockname, sizeof(sockname));
/*
printf("Trying port %d, ret = %d\n", *port, ret);
*/
                } while( ret == -1 );
/*
                } while( bind(path, (struct sockaddr*)&sockname, sizeof(sockname)) == -1 );
*/
        } else {
#ifndef WIN32
                val = 1;
                if( setsockopt(path, SOL_SOCKET, SO_REUSEADDR, (char*)&val, 
                        sizeof(val)) == -1 )
                {
#ifdef DEBUG
                        printf("Couln't set SO_REUSEADDR\n");
#endif
                        closesock(path); 
                        return(0);
                }
#endif
                sockname.sin_family = AF_INET;
                sockname.sin_addr.s_addr = INADDR_ANY;
                sockname.sin_port = htons((ushort) *port);
                if( (ret = bind(path, (struct sockaddr*) &sockname, sizeof(sockname))) == -1 )
                {
                        closesock(path);
                        return(0);
                }
        }

        if( (ret = listen(path, Listen_backlog)) == -1 )
        {
                closesock(path);
                return(0);
        }

        strcpy( Net_conns[conn_id].node, "MYNODE" );
        strcpy( Net_conns[conn_id].task, task );
        Net_conns[conn_id].channel = path;
        Net_conns[conn_id].port = *port;
        Net_conns[conn_id].last_used = time(NULL);
        Net_conns[conn_id].reading = -1;
        Net_conns[conn_id].timr_ent = NULL;
        Net_conns[conn_id].write_timedout = 0;
        return(1);
}

Here is the call graph for this function:

Here is the caller graph for this function: