Method openConnectTo

engine/source/platform/platformNet.cpp:737–858

}

NetSocket Net::openConnectTo(const char *addressString)
{
#ifdef TORQUE_ALLOW_JOURNALING
   if (Game->isJournalReading())
   {
      U32 ret;
      Game->journalRead(&ret);
      return NetSocket::fromHandle(ret);
   }
#endif
   NetAddress address;
   NetSocket handleFd = NetSocket::INVALID;
   Net::Error error = NoError;

   error = Net::stringToAddress(addressString, &address, false);

   if (error == NoError && address.type != NetAddress::IPAddress && address.type != NetAddress::IPV6Address)
   {
      error = Net::WrongProtocolType;
   }

   // Open socket
   if (error == NoError || error == NeedHostLookup)
   {
      handleFd = openSocket();
   }

   // Attempt to connect or queue a lookup
   if (error == NoError && address.type == NetAddress::IPAddress)
   {
      sockaddr_in ipAddr;
      NetAddressToIPSocket(&address, &ipAddr);
      SOCKET socketFd = PlatformNetState::smReservedSocketList.activate(handleFd, AF_INET, false, true);
      if (socketFd != InvalidSocketHandle)
      {
         setBlocking(handleFd, false);
         if (::connect(socketFd, (struct sockaddr *)&ipAddr, sizeof(ipAddr)) == -1)
         {
            Net::Error err = PlatformNetState::getLastError();
            if (err != Net::WouldBlock)
            {
               Con::errorf("Error connecting to %s: %u",
                  addressString, err);
               closeSocket(handleFd);
               handleFd = NetSocket::INVALID;
            }
         }
      }
      else
      {
         PlatformNetState::smReservedSocketList.remove(handleFd);
         handleFd = NetSocket::INVALID;
      }

      if (handleFd != NetSocket::INVALID)
      {
         // add this socket to our list of polled sockets
         addPolledSocket(handleFd, socketFd, PolledSocket::ConnectionPending);