int tcpip_open_client	(	int	conn_id,
		char *	node,
		char *	task,
		int	port
	)

Definition at line 1014 of file tcpip.c.

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

Referenced by dna_open_client().

{
        /* Create connection: create and initialize socket stuff. Try
         * and make a connection with the server.
         */
        struct sockaddr_in sockname;
#ifndef VxWorks
        struct hostent *host = 0;
#else
        int host_addr;
#endif
        int path, val, ret_code, ret;
        int a,b,c,d;
/* Fix for gcc 4.6 "dereferencing type-punned pointer will break strict-aliasing rules"?!*/
        unsigned char ipaddr_buff[4];
        unsigned char *ipaddr = ipaddr_buff;
        int host_number = 0;

    dim_tcpip_init(0);
        if(isdigit(node[0]))
        {
                sscanf(node,"%d.%d.%d.%d",&a, &b, &c, &d);
            ipaddr[0] = (unsigned char)a;
            ipaddr[1] = (unsigned char)b;
            ipaddr[2] = (unsigned char)c;
            ipaddr[3] = (unsigned char)d;
            host_number = 1;
/*
#ifndef VxWorks
                if( gethostbyaddr(ipaddr, sizeof(ipaddr), AF_INET) == (struct hostent *)0 )
                {
#ifndef WIN32
                        ret = h_errno;
#else
                        ret = WSAGetLastError();
#endif
//                      if((ret == HOST_NOT_FOUND) || (ret == NO_DATA))
//                      {
//                              if(!check_node_addr(node, ipaddr))
//                                      return(0);
//                      }
                }
#endif
*/
        }
#ifndef VxWorks
        else if( (host = gethostbyname(node)) == (struct hostent *)0 ) 
        {
                if(!check_node_addr(node, ipaddr))
                        return(0);
                host_number = 1;
/*
          ptr = (unsigned char *)node+(int)strlen(node)+1;
          ipaddr[0] = *ptr++;
          ipaddr[1] = *ptr++;
          ipaddr[2] = *ptr++;
          ipaddr[3] = *ptr++;
          host_number = 1;
                  if( (ipaddr[0] == 0xff) &&
                          (ipaddr[1] == 0xff) &&
                          (ipaddr[2] == 0xff) &&
                          (ipaddr[3] == 0xff) )
                  {
                          errno = ECONNREFUSED;
#ifdef WIN32
                          WSASetLastError(errno);
#endif
                          return(0);
                  }
                  if( gethostbyaddr(ipaddr, sizeof(ipaddr), AF_INET) == (struct hostent *)0 )
                  {
                          errno = ECONNREFUSED;
#ifdef WIN32
                          WSASetLastError(errno);
#endif
                          return(0);
                  }
*/
        }
#else
        *(strchr(node,'.')) = '\0';
        host_addr = hostGetByName(node);
        printf("node %s addr: %x\n",node, host_addr);
#endif

        if( (path = (int)socket(AF_INET, SOCK_STREAM, 0)) == -1 ) 
        {
                perror("socket");
                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, 
                        (char*)&val, sizeof(val))) == -1 ) 
        {
#ifdef DEBUG
                printf("Couln't set SO_SNDBUF\n");
#endif
                closesock(path); 
                return(0);
        }

        val = Read_buffer_size;
        if ((ret_code = setsockopt(path, SOL_SOCKET, SO_RCVBUF, 
                        (char*)&val, sizeof(val))) == -1 ) 
        {
#ifdef DEBUG
                printf("Couln't set SO_RCVBUF\n");
#endif
                closesock(path); 
                return(0);
        }

#if defined(__linux__) && !defined (darwin)
        val = 2;
        if ((ret_code = setsockopt(path, IPPROTO_TCP, TCP_SYNCNT, 
                        (char*)&val, sizeof(val))) == -1 ) 
        {
#ifdef DEBUG
                printf("Couln't set TCP_SYNCNT\n");
#endif
        }
#endif

        sockname.sin_family = PF_INET;
#ifndef VxWorks
    if(host_number)
                sockname.sin_addr = *((struct in_addr *) ipaddr);
    else
                sockname.sin_addr = *((struct in_addr *) host->h_addr);
#else
    if(host_number)
                sockname.sin_addr = *((struct in_addr *) ipaddr);
    else
                sockname.sin_addr = *((struct in_addr *) &host_addr);
#endif
        sockname.sin_port = htons((ushort) port); /* port number to send to */
        while((ret = connect(path, (struct sockaddr*)&sockname, sizeof(sockname))) == -1 )
        {
                if(errno != EINTR)
                {
                        closesock(path);
                        return(0);
                }
        }
        strcpy( Net_conns[conn_id].node, node );
        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: