WebSVN – Games.Chess Giants – Diff – /chessengine.cpp

 // prototypes of local functions
 static void PlayerEngine_Recv (player_t *player);
 static void PlayerEngine_Send (player_t *player);
 static wchar_t *Move_BuildString (boardmove_t *move);
+static bool SendEngineHistoryToAuthor (void);
 bool PlayerEngine_Init (player_t *player)
+{
    // this function starts a chess engine as a child process. This process's stdin and
       return (false);
+   }
    // optionally initialize the debug log file
    Debug_Init (L"Chess engine output.txt");
+   Debug_Log (L"===Using engine: %s [%s]===\n", program->friendly_name, chessengine_shellcommand);
    // build the init file full qualified path name and try to open it
    swprintf_s (chessengineinitfile_pathname, WCHAR_SIZEOF (chessengineinitfile_pathname), L"%s/engines/%s/init.txt", app_path, program->folder);
    _wfopen_s (&fp, chessengineinitfile_pathname, L"r");
    // could the init file be opened ?
    if (fp != NULL)
+   {
-      Debug_Log (L"===Found initialization file, parsing...===\n");
+      Debug_Log (L"===Found initialization file, parsing...===\n", chessengineinitfile_pathname);
       // SMP HACK -- assume our engine is CECP compatible and set the max CPUs to use to core max - 1
       // (the computer will look like hung if all CPU is taken)
       GetSystemInfo (&sysinfo); // get the number of cores and build the corresponding engine initialization order
       Player_SendBuffer_Add (player, 1000, L"mt %d\n", max (1, sysinfo.dwNumberOfProcessors - 1));
    do_update = false;
    // get current and opposite players
    current_player = Player_GetCurrent ();
    opposite_player = Player_GetOpposite ();
+   // is the game still alive AND has the engine just died ?
+   if ((the_board.game_state == STATE_PLAYING) && !pipe_isalive (fpipe))
+   {
+      Debug_Log (L"===Unrecoverable engine error: opponent wins!===\n");
+      // if opponent player is human, play the victory sound, else, play defeat sound at the center of the board
+      Audio_PlaySound (opposite_player->type == PLAYER_HUMAN ? SOUNDTYPE_VICTORY : SOUNDTYPE_DEFEAT, 0.0f, 0.0f, 0.04f);
+      // display a crash notification dialog box
+      if (MessageBox (hMainWnd, LOCALIZE (L"Error_EngineCrashed"), LOCALIZE (L"ImportantMessage"), MB_ICONWARNING | MB_YESNO) == IDYES)
+         if (!SendEngineHistoryToAuthor ())
+            MessageBox (hMainWnd, LOCALIZE (L"NoInternetConnection"), LOCALIZE (L"FatalError"), MB_ICONWARNING | MB_OK); // send the game engine history to the author and display an error message if failed
+      // and display the game over dialog box
+      the_board.game_state = (opposite_player->color == COLOR_BLACK ? STATE_WHITEWIN_RESIGNORFORFEIT : STATE_BLACKWIN_RESIGNORFORFEIT);
+      DialogBox_EndGame ();
+      do_update = true; // remember to update the 3D scene
+   }
    // read from pipe (non-blocking)
    PlayerEngine_Recv (player);
    ////////////////
       // has the game ended already ?
       if (the_board.game_state > STATE_PLAYING)
          continue; // ignore all that the engine tells us. Game is over already.
-      // else is it a normal move ?
+      // else is it a normal move AND not a polyglot error ?
-      else if ((move_string = wcsstr (line_buffer, program->replystring_move)) != NULL)
+      else if (((move_string = wcsstr (line_buffer, program->replystring_move)) != NULL) && (wcsstr (line_buffer, L"illegal") == NULL))
          move_string += wcslen (program->replystring_move); // go to the parsable data
+      // else is it an unrecoverable engine error ?
+      else if (wcsstr (line_buffer, L"illegal") != NULL)
+      {
+         Debug_Log (L"===Unrecoverable engine error: opponent wins!===\n");
+         // if opponent player is human, play the victory sound, else, play defeat sound at the center of the board
+         Audio_PlaySound (opposite_player->type == PLAYER_HUMAN ? SOUNDTYPE_VICTORY : SOUNDTYPE_DEFEAT, 0.0f, 0.0f, 0.04f);
+         // display a crash notification dialog box
+         if (MessageBox (hMainWnd, LOCALIZE (L"Error_EngineCrashed"), LOCALIZE (L"ImportantMessage"), MB_ICONWARNING | MB_YESNO) == IDYES)
+            if (!SendEngineHistoryToAuthor ())
+               MessageBox (hMainWnd, LOCALIZE (L"NoInternetConnection"), LOCALIZE (L"FatalError"), MB_ICONWARNING | MB_OK); // send the game engine history to the author and display an error message if failed
+         // and display the game over dialog box
+         the_board.game_state = (opposite_player->color == COLOR_BLACK ? STATE_WHITEWIN_RESIGNORFORFEIT : STATE_BLACKWIN_RESIGNORFORFEIT);
+         DialogBox_EndGame ();
+         do_update = true; // remember to update the 3D scene
+      }
       // else it's any other sort of line
       else
          continue; // skip lines that don't contain any valid move data
       wcscat_s  (output_string, WCHAR_SIZEOF (output_string), L"b");
    else if (move->promotion_type == PART_QUEEN)
       wcscat_s  (output_string, WCHAR_SIZEOF (output_string), L"q");
    return (output_string); // finished, return the move string
+}
+static bool SendEngineHistoryToAuthor (void)
+{
+   // this function upload the engine history to the remote server for debug purposes.
+   static char history_buffer[512 * 1024];
+   static char base64_buffer[1024 * 1024];
+   static char http_buffer[1024 * 1024]; // used both for request and reply
+   struct sockaddr_in service;
+   struct hostent *hostinfo;
+   int write_index;
+   int read_index;
+   int length;
+   SOCKET s;
+   FILE *fp;
+   // get a hand on the log file and read its contents
+   _wfopen_s (&fp, logfile_pathname, L"rb");
+   if (fp == NULL)
+      return (false); // couldn't open game history log file, return an error condition
+   fseek (fp, 0, SEEK_END);
+   length = ftell (fp); // get file size
+   fseek (fp, 0, SEEK_SET);
+   if (length > sizeof (base64_buffer) - 1)
+      return (false); // history file too big, return an error condition
+   fread (base64_buffer, 1, length, fp);
+   base64_buffer[length] = 0; // terminate buffer ourselves
+   fclose (fp);
+   ConvertTo7BitASCII (history_buffer, sizeof (history_buffer), (wchar_t *) base64_buffer);
+   // initialize the network subsystem if required
+   if (!Network_Init ())
+      return (false); // couldn't initialize WinSock, return an error condition
+   // get our distribution server's IP address from the host name
+   hostinfo = gethostbyname ("pmbaty.com");
+   if (hostinfo == NULL)
+      return (false); // couldn't resolve hostname, return an error condition
+   // fill in the sockaddr server structure with the server hostinfo data
+   service.sin_family = AF_INET;
+   service.sin_addr.s_addr = inet_addr (inet_ntoa (*(struct in_addr *) hostinfo->h_addr_list[0]));
+   service.sin_port = htons (80); // connect to webserver there (port 80)
+   // create our socket
+   if ((s = socket (AF_INET, SOCK_STREAM, IPPROTO_TCP)) == INVALID_SOCKET)
+      return (false); // couldn't resolve hostname, return an error condition
+   // connect to the distributor's webserver using that socket
+   if (connect (s, (struct sockaddr *) &service, sizeof (service)) == -1)
+   {
+      closesocket (s); // finished communicating, close TCP socket
+      return (false); // couldn't resolve hostname, return an error condition
+   }
+   // build the HTTP POST query and send it
+   length = strlen ("data=") + base64_encode (base64_buffer, history_buffer, strlen (history_buffer));
+   sprintf_s (http_buffer, sizeof (http_buffer),
+      "POST /chess/sendcrash.php HTTP/1.1\r\n"
+      "Host: pmbaty.com\r\n"
+      "Content-Type: application/x-www-form-urlencoded\r\n"
+      "Content-Length: %d\r\n"
+      "Connection: close\r\n"
+      "\r\n"
+      "data=", length);
+   strcat_s (http_buffer, sizeof (http_buffer), base64_buffer);
+   length = strlen (http_buffer);
+   write_index = send (s, http_buffer, length, 0); // send the HTTP query
+   if (write_index != length)
+   {
+      closesocket (s); // finished communicating, close TCP socket
+      return (false); // couldn't resolve hostname, return an error condition
+   }
+   // read the reply (10 seconds timeout)
+   http_buffer[0] = 0;
+   read_index = RecvWithTimeout (s, 10.0f, http_buffer, sizeof (http_buffer), 0);
+   if (read_index < 1)
+   {
+      closesocket (s); // finished communicating, close TCP socket
+      return (false); // couldn't resolve hostname, return an error condition
+   }
+   closesocket (s); // finished communicating, close TCP socket
+   // terminate recv buffer ourselves
+   http_buffer[read_index] = 0;
+   //MessageBoxA (NULL, http_buffer, "HTTP response", MB_OK);
+   return (strstr (http_buffer, "Success") != NULL); // and return whether the server accepted our post
+}

Subversion Repositories Games.Chess Giants

Games.Chess Giants/chessengine.cpp – Rev 150 → 153