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

 // global variables used in this module only
 static wchar_t chessengine_path[MAX_PATH];
 static wchar_t chessengine_shellcommand[MAX_PATH];
 static wchar_t chessengineinitfile_pathname[MAX_PATH];
 static int current_obstinacy;
+static int max_cores;
 static bool is_hint_pending;
+static bool should_initialize;
 FILE *fpipe;
 // 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
    engineprogram_t *program;
    wchar_t current_path[MAX_PATH];
    wchar_t widechar_buffer[256];
    SYSTEM_INFO sysinfo;
-   int try_index;
    FILE *fp;
    // reset stuff first
    player->wants_hint = false;
       PlayerEngine_Shutdown (player); // on error, shutdown the engine
       return (false);
+   }
-   // wait for the engine process to display something (which will mean it's ready). Try for 5 seconds.
+   // SMP HACK -- save the max CPUs to use to core max - 1 (the computer will look like hung if all CPU is taken)
-   for (try_index = 0; try_index < 50; try_index++)
-   {
-      // read from pipe (non-blocking)
-      PlayerEngine_Recv (player);
-      if (player->recvbuffer[0] != 0)
-         break; // break as soon as we get something
-      Sleep (100); // next try in 100 milliseconds
+   GetSystemInfo (&sysinfo); // get the number of cores
-   }
-   // has the engine process not spoken yet ?
+   max_cores = max (1, sysinfo.dwNumberOfProcessors - 1);
-   if (player->recvbuffer[0] == 0)
-   {
-      messagebox.hWndParent = hMainWnd;
-      wcscpy_s (messagebox.title, WCHAR_SIZEOF (messagebox.title), LOCALIZE (L"ImportantMessage"));
-      swprintf_s (messagebox.text, WCHAR_SIZEOF (messagebox.text), LOCALIZE (L"Error_ChessEngineInitializationFailed"), program->folder);
-      messagebox.flags = MB_ICONWARNING | MB_OK;
-      DialogBox_Message (&messagebox); // display a modeless error message box
-      PlayerEngine_Shutdown (player); // on error, shutdown the engine
-      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);
    // could the init file be opened ?
    if (fp != NULL)
+   {
       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));
       // read line per line
       while (fgetws (widechar_buffer, WCHAR_SIZEOF (widechar_buffer), fp) != NULL)
+      {
          if ((widechar_buffer[0] == L'#') || (widechar_buffer[0] == L'\n'))
+   }
    // everything's okay, set engine name as the player's name
    wcscpy_s (player->name, WCHAR_SIZEOF (player->name), program->friendly_name);
+   should_initialize = true; // remember the engine should be initialized
    return (true); // finished
+}
 void PlayerEngine_Shutdown (player_t *player)
       // 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 ())
+         if (Debug_SendLogToAuthor ())
+            MessageBox (hMainWnd, LOCALIZE (L"MessageSent"), PROGRAM_NAME, MB_ICONINFORMATION | MB_OK); // send the game engine history to the author
+         else
-            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
+            MessageBox (hMainWnd, LOCALIZE (L"NoInternetConnection"), LOCALIZE (L"FatalError"), MB_ICONWARNING | MB_OK); // 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 ();
+      }
       // 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 AND not a polyglot error ?
-      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)
+      else if ((wcsstr (line_buffer, L"illegal") != NULL) || (wcsstr (line_buffer, L"invalid") != 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 ())
+            if (Debug_SendLogToAuthor ())
+               MessageBox (hMainWnd, LOCALIZE (L"MessageSent"), PROGRAM_NAME, MB_ICONINFORMATION | MB_OK); // send the game engine history to the author
+            else
-               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
+               MessageBox (hMainWnd, LOCALIZE (L"NoInternetConnection"), LOCALIZE (L"FatalError"), MB_ICONWARNING | MB_OK); // 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 is it a normal move ?
+      else if ((move_string = wcsstr (line_buffer, program->replystring_move)) != NULL)
+         move_string += wcslen (program->replystring_move); // go to the parsable data
       // else it's any other sort of line
       else
          continue; // skip lines that don't contain any valid move data
       // now we are sure it's either a hint or a move (or some pondering)
       length = wcslen (move_string);
-      if ((length < 2) || (length > 9))
+      if (length < 2)
-         continue; // if string is too long to be a move, skip it
+         continue; // if string is too short to be a move, skip it
       // there must be valid move data on that line.
       // evaluate the engine move string
       memcpy (move.slots, the_board.moves[the_board.move_count - 1].slots, sizeof (move.slots));
+      char_index = 0;
+      while ((move_string[char_index] != 0) && !iswspace (move_string[char_index]))
+      {
-      wcscpy_s (move.pgntext, WCHAR_SIZEOF (move.pgntext), move_string);
+         move.pgntext[char_index] = move_string[char_index];
+         char_index++;
+      }
+      move.pgntext[char_index] = 0;
       if (!Move_SetupFromSAN (&the_board.moves[the_board.move_count - 1], &move, Board_ColorToMove (&the_board)))
+      {
          Debug_Log (L"===Skipping line (invalid move syntax)===\n%s", move_string);
          continue; // so now, if there are NOT two digits AND it's not a kind of castle, it can't be a move so skip that line
+      }
       // is it NOT a hint, are blunders allowed, should we do one now AND can we do one now ?
       if (!is_hint_pending && (options.engine.blunder_chances > 0) && (rand () % 100 < options.engine.blunder_chances)
           && Move_FindRandomMove (&the_board.moves[the_board.move_count - 1], player->color, &move))
+      {
+         if (program->command_force[0] != 0)
+         {
-         Player_SendBuffer_Add (player, 1000, program->command_force, Move_BuildString (&move)); // send the blunderous move to the engine
+            Player_SendBuffer_Add (player, 1000, program->command_force, Move_BuildString (&move)); // send the blunderous move to the engine
-         Player_SendBuffer_Add (player, 1000, L"\n"); // since the format string was read from the options, don't forget to end it with a carriage return
+            Player_SendBuffer_Add (player, 1000, L"\n"); // since the format string was read from the options, don't forget to end it with a carriage return
-         if (_wcsnicmp (program->friendly_name, L"Crafty", 6) == 0)
+            if (_wcsnicmp (program->friendly_name, L"Crafty", 6) == 0)
-            Player_SendBuffer_Add (player, 1000, L"disp\n"); // FIXME: we no longer need this Crafty-specific hack, do we?
+               Player_SendBuffer_Add (player, 1000, L"disp\n"); // FIXME: we no longer need this Crafty-specific hack, do we?
+         }
          Debug_Log (L"===Discarding engine move, forcing a blunderous move (%s) instead===\n", Move_BuildString (&move)); // blunder
+      }
       // mark the engine's selected and hovered squares
       Board_SetSelectedAndHovered (&the_board, move.source[0], move.source[1], move.target[0], move.target[1]);
          // we must now restore the board to its last state. Just set up the board again from its current Forsyth-Edwards notation
          Debug_Log (L"===Hint received, rebuilding board and telling engine to backup 1 move===\n");
          Debug_Log (L"===setting up board using FEN string===\n");
-         // instruct it about its allowed search depth BEFORE each table set (this ensures engine will be "ready" to handle the command)
-         // then get the current game state in FEN format and feed it to the engine
+         // get the current game state in FEN format and feed it to the engine
-         Player_SendBuffer_Add (player, 1000, program->command_sd, options.engine.depth);
-         Player_SendBuffer_Add (player, 1000, L"\n"); // since the format string was read from the options, don't forget to end it with a carriage return
          Player_SendBuffer_Add (player, 1000, program->command_setboard, the_board.moves[the_board.move_count - 1].fen_string);
          Player_SendBuffer_Add (player, 1000, L"\n"); // since the format string was read from the options, don't forget to end it with a carriage return
          if (_wcsnicmp (program->friendly_name, L"Crafty", 6) == 0)
             Player_SendBuffer_Add (player, 1000, L"disp\n"); // FIXME: we no longer need this Crafty-specific hack, do we?
       Player_SendBuffer_Add (player, 1000, L"\n"); // since the format string was read from the options, don't forget to end it with a carriage return
       // just set up the board from its Forsyth-Edwards notation
       Debug_Log (L"===setting up board using FEN string===\n");
-      // instruct it about its allowed search depth BEFORE each table set (this ensures engine will be "ready" to handle the command)
-      // then get the current game state in FEN format and feed it to the engine
+      // get the current game state in FEN format and feed it to the engine
-      Player_SendBuffer_Add (player, 1000, program->command_sd, options.engine.depth);
-      Player_SendBuffer_Add (player, 1000, L"\n"); // since the format string was read from the options, don't forget to end it with a carriage return
       Player_SendBuffer_Add (player, 1000, program->command_setboard, the_board.moves[the_board.move_count - 1].fen_string);
       Player_SendBuffer_Add (player, 1000, L"\n"); // since the format string was read from the options, don't forget to end it with a carriage return
       current_obstinacy = 0; // reset current obstinacy
       is_hint_pending = false; // no hint was requested so far
+         {
             Debug_Log (L"===Player just played, sending the chosen move to engine===\n");
             if (_wcsnicmp (program->friendly_name, L"Crafty", 6) == 0)
                Player_SendBuffer_Add (player, 1000, L"disp\n"); // FIXME: we no longer need this Crafty-specific hack, do we?
-            // instruct it about its allowed search depth BEFORE each move (this ensures engine will be "ready" to handle the command)
-            // then build the move string, and send the move string to the engine
+            // build the move string, and send the move string to the engine
-            Player_SendBuffer_Add (player, 1000, program->command_sd, options.engine.depth);
-            Player_SendBuffer_Add (player, 1000, L"\n"); // since the format string was read from the options, don't forget to end it with a carriage return
             Player_SendBuffer_Add (player, 1000, program->command_move, Move_BuildString (&the_board.moves[the_board.move_count - 1]));
             Player_SendBuffer_Add (player, 1000, L"\n"); // end the send buffer with a carriage return
+         }
          // else game has not started yet, but it's our turn
          the_board.game_state = STATE_PLAYING; // remember the game is now playing (in case we wanted to cancel the closing move of a finished game, this opens the game again)
          // just set up the board from its Forsyth-Edwards notation
          Debug_Log (L"===setting up board using FEN string===\n");
-         // instruct it about its allowed search depth BEFORE each table set (this ensures engine will be "ready" to handle the command)
-         // then get the current game state in FEN format and feed it to the engine
+         // get the current game state in FEN format and feed it to the engine
-         Player_SendBuffer_Add (player, 1000, program->command_sd, options.engine.depth);
-         Player_SendBuffer_Add (player, 1000, L"\n"); // since the format string was read from the options, don't forget to end it with a carriage return
          Player_SendBuffer_Add (player, 1000, program->command_setboard, the_board.moves[the_board.move_count - 1].fen_string);
          Player_SendBuffer_Add (player, 1000, L"\n"); // since the format string was read from the options, don't forget to end it with a carriage return
          if (_wcsnicmp (program->friendly_name, L"Crafty", 6) == 0)
             Player_SendBuffer_Add (player, 1000, L"disp\n"); // FIXME: we no longer need this Crafty-specific hack, do we?
    // write what we received (if we received anything)
    if (wcslen (player->recvbuffer) > initial_pos)
       Debug_Log (L"===================================RECEIVED:===================================\n%s\n", &player->recvbuffer[initial_pos]);
    return; // finished
+}
+int wcs_replace (wchar_t *haystack, wchar_t *needle, wchar_t *replacement)
+{
+   size_t replacement_length;
+   size_t replacement_count;
+   size_t pattern_length;
+   wchar_t *line_pointer;
+   replacement_count = 0;
+   while ((line_pointer = wcsstr (haystack, needle)) != NULL)
+   {
+      pattern_length = wcslen (needle);
+      replacement_length = wcslen (replacement);
+      memmove (&line_pointer[replacement_length], &line_pointer[pattern_length], (wcslen (&line_pointer[pattern_length]) + 1) * sizeof (wchar_t));
+      memcpy (line_pointer, replacement, replacement_length * sizeof (wchar_t));
+      replacement_count++;
+   }
+   return (replacement_count);
+}
 static void PlayerEngine_Send (player_t *player)
+{
    // helper function to send data through the pipe communicating with the game engine process
+   static wchar_t replacement_string[65536];
    wchar_t widechar_buffer[256];
    wchar_t *line_pointer;
    char ascii_buffer[256];
    unsigned long amount_written;
+   int move_index;
+   int try_index;
    player->sendbuffer_locked = true; // lock the buffer
+   // perform variable replacements on sendbuffer
+   if (the_board.move_count > 0)
+   {
+      wcs_replace (player->sendbuffer, L"${CURRENT_POS}", (/*the_board.move_count == 2 ? L"startpos" : */the_board.moves[the_board.move_count - 1].fen_string));
+      wcs_replace (player->sendbuffer, L"${LAST_MOVE}", Move_BuildString (&the_board.moves[the_board.move_count - 1]));
+      while (wcsstr (player->sendbuffer, L"${MAX_CORES}") != NULL)
+      {
+         swprintf_s (replacement_string, WCHAR_SIZEOF (replacement_string), L"%d", max_cores);
+         wcs_replace (player->sendbuffer, L"${MAX_CORES}", replacement_string);
+      }
+      while (wcsstr (player->sendbuffer, L"${SEARCH_DEPTH}") != NULL)
+      {
+         swprintf_s (replacement_string, WCHAR_SIZEOF (replacement_string), L"%d", options.engine.depth);
+         wcs_replace (player->sendbuffer, L"${SEARCH_DEPTH}", replacement_string);
+      }
+      while (wcsstr (player->sendbuffer, L"${GAME_HISTORY}") != NULL)
+      {
+         replacement_string[0] = 0;
+         for (move_index = 1; move_index < the_board.move_count; move_index++)
+         {
+            if (move_index > 1)
+               wcscat_s (replacement_string, WCHAR_SIZEOF (replacement_string), L" ");
+            wcscat_s (replacement_string, WCHAR_SIZEOF (replacement_string), Move_BuildString (&the_board.moves[move_index]));
+         }
+         wcs_replace (player->sendbuffer, L"${GAME_HISTORY}", replacement_string);
+      }
+   }
    // write what we're sending (if we're sending anything)
    if (player->sendbuffer[0] != 0)
       Debug_Log (L"====================================SENDING:===================================\n%s\n", player->sendbuffer);
       amount_written = pipe_write (fpipe, ascii_buffer, strlen (ascii_buffer)); // send data
+   }
    player->sendbuffer[0] = 0; // what we had to send has been sent, reset the send buffer
    player->sendbuffer_locked = false; // and unlock it
+   // should the engine be initialized ?
+   if (should_initialize)
+   {
+      // wait for the engine process to display something (which will mean it's ready). Try for 5 seconds.
+      for (try_index = 0; try_index < 50; try_index++)
+      {
+         // read from pipe (non-blocking)
+         PlayerEngine_Recv (player);
+         if (player->recvbuffer[0] != 0)
+            break; // break as soon as we get something
+         Sleep (100); // next try in 100 milliseconds
+      }
+      // has the engine process not spoken yet ?
+      if (player->recvbuffer[0] == 0)
+      {
+         messagebox.hWndParent = hMainWnd;
+         wcscpy_s (messagebox.title, WCHAR_SIZEOF (messagebox.title), LOCALIZE (L"ImportantMessage"));
+         swprintf_s (messagebox.text, WCHAR_SIZEOF (messagebox.text), LOCALIZE (L"Error_ChessEngineInitializationFailed"), options.engine.programs[options.engine.selected_program].folder);
+         messagebox.flags = MB_ICONWARNING | MB_OK;
+         DialogBox_Message (&messagebox); // display a modeless error message box
+         PlayerEngine_Shutdown (player); // on error, shutdown the engine
+      }
+      should_initialize = false; // remember this is no longer to be done (until the next call to PlayerEngine_Init())
+   }
    return; // finished
+}
       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 153 → 154