Форум программистов [Powered by Invision Power Board]

Код

  //описание переменных 
  int iOptVal = 64;
  char RecvBuf[1024];

  TCHAR szError[100];                          // Error message string
  SOCKET Sock = INVALID_SOCKET;     // Datagram window socket


  struct ip_mreq mreq;                          // Used in adding or dropping
                                                             // multicasting addresses

  SOCKADDR_IN source_sin,                 // Source socket address
                          dest_sin;                    // Destination socket address

  WSADATA WSAData;                           // Contains details of the
                                                             // Winsock implementation

  // Initialize Winsock
  char iResult = WSAStartup(MAKEWORD(2,2), &WSAData);
  if (iResult != 0)
  {
    ShowMessage("Ñåòü íå ðàáîòàåò");
    return;
  }

  //создаем сокет
  if ((Sock = socket (AF_INET, SOCK_DGRAM, 0)) == INVALID_SOCKET)
  {
    ShowMessage("Allocating socket failed!");
    return;
  }

  //источник
  source_sin.sin_family = AF_INET;
  source_sin.sin_port = htons (SOURCE_PORT);
  source_sin.sin_addr.s_addr = htonl (INADDR_ANY);

  // Associate the source socket's address with the socket, Sock.
  if (bind (Sock, (struct sockaddr FAR *) &source_sin,
            sizeof (source_sin)) == SOCKET_ERROR)
  {
    ShowMessage("Binding socket failed!");
    closesocket (Sock);
    return;
  }
  //время жизни пакетов TTL
  if (setsockopt (Sock,
                  IPPROTO_IP,
                  IP_MULTICAST_TTL,
                  (char FAR *)&iOptVal,
                  sizeof (int)) == SOCKET_ERROR)
  {
    ShowMessage("setsockopt failed!");
    closesocket (Sock);
    return;
  }

  // Join the multicast group from which to receive datagrams.
  mreq.imr_multiaddr.s_addr = inet_addr (DEST_MCAST);
  mreq.imr_interface.s_addr = INADDR_ANY;
  if (setsockopt (Sock,
                  IPPROTO_IP,
                  IP_ADD_MEMBERSHIP,
                  (char FAR *)&mreq,
                  sizeof (mreq)) == SOCKET_ERROR)
  {
    ShowMessage("setsockopt failed!");
    closesocket (Sock);
    return;
  }

  //мультикастовая группа
  dest_sin.sin_family = AF_INET;
  dest_sin.sin_port = htons (DESTINATION_PORT);
  dest_sin.sin_addr.s_addr = inet_addr (DEST_MCAST);

  int iRecvLen = sizeof (source_sin);

  do //собственно принимаем и передаем, пока поток не остановлен
  {
    if (Form1->Multi_Param.send_flag)
    {
      Form1->Multi_Param.send_flag=false;
      // Send a message to the multicasting address.
      if (sendto (Sock,
                  Form1->Multi_Param.multi_mess,
                  strlen (Form1->Multi_Param.multi_mess),
                  0,
                  (struct sockaddr FAR *) &dest_sin,
                  sizeof (dest_sin)) == SOCKET_ERROR)
      {
        ShowMessage("sendto failed!");
        closesocket (Sock);
        return;
      }
    }
    else
    {
      // Receive data from the multicasting group server.
//Вот здесь программа останавливается и ждет пока придет сообщение!!!
      int Errnum=recvfrom (Sock,
                           RecvBuf,
                           100,
                           0,
                           (struct sockaddr FAR *) &source_sin,
                           &iRecvLen);
      if (Errnum == SOCKET_ERROR)
      {
        ShowMessage("recvfrom failed!");
        closesocket (Sock);
        return;
      }
    }
  }
  while (!Terminated); //óáèëè ïðèëîæåíèå Æ-(
  // Disable sending on Sock before closing it.
  shutdown (Sock, 0x01);
  // Close Sock.
  closesocket (Sock);
  WSACleanup();