Endil

cn-lab2-server

Sep 4th, 2015
78
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
C++ 2.22 KB | None | 0 0
  1. // cn-lab2-server.cpp: определяет точку входа для консольного приложения.
  2. //
  3.  
  4. #include "stdafx.h"
  5. #include <winsock2.h>
  6. #include <iostream>
  7. #include <windows.h>
  8. #include <sstream>
  9. #include <thread>
  10.  
  11. #pragma comment(lib, "ws2_32.lib")
  12.  
  13. using namespace std;
  14.  
  15. int client_processing(SOCKET my_sock, const sockaddr_in client_addr, const int client_addr_size, char recv_buff[]) {
  16.     int a, b, c;
  17.     stringstream ss;
  18.     ss << recv_buff;
  19.     ss >> a >> b >> c;
  20.     string triangle_exist = "false";
  21.     if ((a < b + c) && (b < a + c) && (c < a + b))
  22.         triangle_exist = "true";
  23.     sendto(my_sock, triangle_exist.c_str(), triangle_exist.length(), 0, (sockaddr *)&client_addr, client_addr_size);
  24.     cout << "Answer sent" << endl;
  25.     return 0;
  26. }
  27.  
  28. int port_listen(SOCKET my_sock) {
  29.     while (true) {
  30.         sockaddr_in client_addr;
  31.         int client_addr_size = sizeof(client_addr);
  32.         char recv_buff[1024];
  33.         int len = recvfrom(my_sock, &recv_buff[0], sizeof(recv_buff) - 1, 0, (sockaddr *)&client_addr, &client_addr_size);
  34.         if (len < 0)
  35.             return 0;
  36.         cout << "Request received" << endl;
  37.         recv_buff[len] = '\0';
  38.         thread client(client_processing, my_sock, client_addr, client_addr_size, recv_buff);
  39.     }
  40.     return 0;
  41. }
  42.  
  43. int main()
  44. {
  45.     cout << "cn-lab2 var10 server start" << endl;
  46.     WSAData wsadata;
  47.     WSAStartup(0x0202, &wsadata);
  48.     cout << "Winsock2 initialized" << endl;
  49.     SOCKET my_sock;
  50.     my_sock = socket(AF_INET, SOCK_DGRAM, 0);
  51.     if (my_sock == INVALID_SOCKET) {
  52.         cout << "Create socket error " << WSAGetLastError() << endl;
  53.         WSACleanup();
  54.         return 1;
  55.     }
  56.     cout << "Socket created successfully" << endl;
  57.     sockaddr_in local_addr;
  58.     local_addr.sin_family = AF_INET;
  59.     local_addr.sin_addr.S_un.S_addr = 0;
  60.     local_addr.sin_port = htons(5002);
  61.     if (::bind(my_sock, (sockaddr *)&local_addr, sizeof(local_addr))) {
  62.         cout << "Error bind " << WSAGetLastError() << endl;
  63.         closesocket(my_sock);
  64.         WSACleanup();
  65.         return 2;
  66.     }
  67.     cout << "Binding successful" << endl;
  68.     thread listen(port_listen, ref(my_sock));
  69.     string s;
  70.     do {
  71.         cin >> s;
  72.     } while (s != "stop");
  73.     shutdown(my_sock, SD_BOTH);
  74.     closesocket(my_sock);
  75.     if (listen.joinable())
  76.         listen.join();
  77.     listen.~thread();
  78.     WSACleanup();
  79.     return 0;
  80. }
Advertisement
Add Comment
Please, Sign In to add comment