1 /****************************************************************************/
2 /* UCI2WB by H.G.Muller */
4 /* UCI2WB is an adapter to run engines that communicate in various dialects */
5 /* of the Universal Chess Interface in a GUI that supports XBoard protocol */
6 /* (CECP). It supports UCI (when used for Xiangqi: the 'Cyclone dialect'), */
7 /* as well as USI and UCCI when used with the flags -s or -x, respectively. */
8 /* This version of UCI2WB is released under the GNU General Public License, */
9 /* of which you should have received a copy together with this file. */
10 /****************************************************************************/
25 # include <sys/time.h>
26 int GetTickCount() // with thanks to Tord
27 { struct timeval t
; gettimeofday(&t
, NULL
); return t
.tv_sec
*1000 + t
.tv_usec
/1000; }
32 // Set VARIANTS for in WinBoard variant feature. (With -s option this will always be reset to use "shogi".)
33 #define VARIANTS ",normal,xiangqi"
34 #define STDVARS "chess,chess960,crazyhouse,threecheck,giveaway,atomic,seirawan,shogi,xiangqi"
35 #define EGT ",syzygypath,nalimovpath,gaviotapath,"
37 #define DPRINT if(debug) printf
38 #define EPRINT(X) { char f[999]; sprintf X; DPRINT("%s", f); fprintf(toE, "%s", f + 2*(*f == '#')); /* strip optional # prefix */ }
45 char move
[2000][10], iniPos
[256], hashOpt
[20], pause
, pondering
, suspended
, ponder
, post
, hasHash
, c
, sc
='c', suffix
[81], varOpt
, searching
, *binary
;
46 int mps
, tc
, inc
, sTime
, depth
, myTime
, hisTime
, stm
, computer
= NONE
, memory
, oldMem
=0, cores
, moveNr
, lastDepth
, lastScore
, startTime
, debug
, flob
;
47 int statDepth
, statScore
, statNodes
, statTime
, currNr
, size
, collect
, nr
, sm
, inex
, on
[500], frc
, byo
= -1, namOpt
, comp
;
48 char currMove
[20], moveMap
[500][10], /* for analyze mode */ canPonder
[20], threadOpt
[20], varList
[8000], anaOpt
[20], backLog
[10000], checkOptions
[8192] = "Ponder";
49 char board
[100]; // XQ board for UCCI
50 char *nameWord
= "name ", *valueWord
= "value ", *wTime
= "w", *bTime
= "b", *wInc
= "winc", *bInc
= "binc", newGame
; // keywords that differ in UCCI
51 int unit
= 1, drawOffer
;
52 volatile int logLen
, sentLen
;
54 FILE *toE
, *fromE
, *fromF
;
58 char *strcasestr (char *p
, char *q
) { while(*p
) { char *r
=p
++, *s
=q
; while(tolower(*r
++) == tolower(*s
) && *s
) s
++; if(!*s
) return p
-1; } return NULL
; }
60 WinPipe(HANDLE
*hRd
, HANDLE
*hWr
)
62 SECURITY_ATTRIBUTES saAttr
;
64 /* Set the bInheritHandle flag so pipe handles are inherited. */
65 saAttr
.nLength
= sizeof(SECURITY_ATTRIBUTES
);
66 saAttr
.bInheritHandle
= TRUE
;
67 saAttr
.lpSecurityDescriptor
= NULL
;
70 return CreatePipe(hRd
, hWr
, &saAttr
, 0);
82 static HANDLE hWr
, hRd
; DWORD d
; char c
;
84 case INIT
: WinPipe(&hRd
, &hWr
); break;
85 case WAKEUP
: WriteFile(hWr
, "\n", 1, &d
, NULL
); break;
86 case PAUSE
: ReadFile(hRd
, &c
, 1, &d
, NULL
);
89 static int syncPipe
[2]; char c
;
91 case INIT
: pipe(syncPipe
); break;
92 case WAKEUP
: write(syncPipe
[1], "\n", 1); break;
93 case PAUSE
: read(syncPipe
[0], &c
, 1);
103 if(c
>= 'A') board
[i
++] = c
; else
104 if(c
== '/') i
++; else
105 if(c
== ' ') break; else
106 while(c
-- > '0' && i
< 99) board
[i
++] = 0;
114 int i
, n
=0; static char fen
[200]; char *p
= fen
;
115 for(i
=0; i
<99; i
++) {
117 if(c
>= 'A') { if(n
) *p
++ = '0' + n
; n
= 0; *p
++ = c
; } else n
++;
118 if(i
%10 == 8) { if(n
) *p
++ = '0' + n
; n
= -1; *p
++ = '/'; }
120 sprintf(p
-1, " %c - - 0 1", stm
);
127 int n
= m
[j
] - 'a' + 10*('9' - m
[j
+1]);
128 if(n
< 0) n
= 0; else if(n
> 99) n
= 99; return n
;
135 FromFEN(iniPos
+ 4); // in XQ iniPos always has just "fen " prefix
136 for(i
=0; i
<nr
; i
++) {
137 int from
=Sqr(move
[i
], 0), to
=Sqr(move
[i
], 2);
138 if(board
[to
] || (board
[from
]|32) == 'p' && move
[i
][1] != move
[i
][3]) last
= i
;
139 board
[to
] = board
[from
]; board
[from
] = 0;
145 StartSearch(char *ponder
)
146 { // send the 'go' command to engine. Suffix by ponder.
147 int x
= (ponder
[0] != 0); // during ponder stm is the opponent
148 int black
= (stm
== BLACK
^ x
^ sc
== 's'); // set if our color is what the engine calls black
149 int nr
= moveNr
+ x
; // we ponder for one move ahead!
150 int t
= (flob
? inc
+ myTime
/40 : 1000*byo
*(byo
>0)); // byoyomi time
151 if(sc
== 'x') black
= 1; else drawOffer
= 0;// in UCCI 'black' refers to us and 'white' to opponent
152 if(!x
&& drawOffer
) ponder
= " draw", drawOffer
= 0; //pass draw offer only when not pondering
153 EPRINT((f
, "# go%s %stime %d %stime %d", ponder
, bTime
, (black
? myTime
: hisTime
) - t
, wTime
, (!black
? myTime
: hisTime
) - t
))
154 if(sTime
> 0) EPRINT((f
, " movetime %d", sTime
)) else
155 if(mps
) EPRINT((f
, " movestogo %d", mps
*(nr
/(2*mps
)+1)-nr
/2))
156 if(flob
|| byo
>= 0) sprintf(suffix
, " byoyomi %d", t
); // for engines running purely on byoyomi
157 if(inc
&& !*suffix
) EPRINT((f
, " %s %d %s %d", wInc
, inc
, bInc
, inc
))
158 if(depth
> 0) EPRINT((f
, " depth %d", depth
))
159 if(*suffix
) EPRINT((f
, suffix
, inc
))
164 StopPonder(int pondering
)
166 if(!pondering
) return;
168 EPRINT((f
, "# stop\n")) fflush(toE
); // note: 'pondering' remains set until engine acknowledges 'stop' with 'bestmove'
169 Sync(PAUSE
); // wait for engine to acknowledge 'stop' with 'bestmove'.
175 int j
, lastCapt
= 0; char *pos
= iniPos
, buf
[200], stm
;
176 if(sc
== 'x') { // UCCI: send only reversible moves
177 lastCapt
= Play(moveNr
); // find last capture (returns -1 if none!)
178 Play(++lastCapt
); // reconstruct board after last capture
179 stm
= (!strstr(iniPos
+4, " b ") ^ lastCapt
& 1 ? 'w' : 'b');
180 sprintf(buf
, "position fen %s", ToFEN(stm
)); pos
= buf
; // send it as FEN (with "position" in UCCI!)
182 EPRINT((f
, "# %s moves", pos
))
183 for(j
=lastCapt
; j
<moveNr
; j
++) EPRINT((f
, " %s", move
[j
]))
190 if(!move
[moveNr
][0]) return; // no ponder move
192 pondering
= 1; lastDepth
= 1;
193 StartSearch(" ponder");
199 if(*anaOpt
) EPRINT((f
, "# setoption %s%s %s%s\n", nameWord
, anaOpt
, valueWord
, val
));
204 { // send setoption commands backlogged during thinking to engine, aborting ponder or analysis search if necessary
205 int len
= logLen
- sentLen
, analyse
= searching
;
206 if(len
<= 0) return 0;
207 StopPonder(pondering
| searching
); pondering
= searching
= 0; // force new search if settings change during analysis (multi-PV!)
208 fwrite(backLog
+ sentLen
, 1, len
, toE
); sentLen
+= len
; DPRINT("# release %d\n", len
);
209 if(ponder
&& computer
== 1 - stm
) StartPonder(); // (re)start ponder search
210 return analyse
; // return 1 if analysis search should be restarted
213 char *Convert(char *pv
)
214 { // convert Shogi coordinates to WB
216 static char buf
[10000];
217 if(sc
!= 's') return pv
;
220 if(c
>= '0' && c
<= '9' || c
>= 'a' && c
<= 'z') *q
++ = 'a'+'0'+size
- c
; else *q
++ = c
;
230 // convert USI move to WB format
231 m
[2] = 'a'+'0'+size
- m
[2];
232 m
[3] = 'a'+'0'+size
- m
[3];
233 if(m
[1] == '*') { // drop
236 m
[0] = 'a'+'0'+size
- m
[0];
237 m
[1] = 'a'+'0'+size
- m
[1];
238 if((stm
== WHITE
? (m
[1]>'0'+size
-size
/3 || m
[3]>'0'+size
-size
/3)
239 : (m
[1] <= '0'+size
/3 || m
[3] <= '0'+size
/3)) && m
[4] != '+')
240 m
[4] = '=', m
[5] = 0;
250 if((c
= fgetc(fromF
)) != EOF
) return c
;
251 fclose(fromF
); fromF
= 0; printf("# end fake\n");
259 char line
[1024], command
[256]; static char egts
[999];
261 if(fromF
= fopen("DefectiveEngineOptions.ini", "r")) printf("# fake engine input\n");
263 int i
=0, x
; char *p
, dummy
, len
;
265 fflush(stdout
); fflush(toE
);
266 while((line
[i
] = x
= GetChar()) != EOF
&& line
[i
] != '\n') i
++;
268 if(x
== EOF
) printf("tellusererror UCI2WB: %s died on me\n", binary
), exit(0);
269 DPRINT("# engine said: %s", line
), fflush(stdout
);
270 if(sscanf(line
, "%s", command
) != 1) continue;
271 if(!strcmp(command
, "bestmove")) {
272 if(pause
== 1) { pondering
= pause
= 0; Sync(WAKEUP
); continue; } // bestmove was reply to ponder miss or analysis result; ignore.
273 else if(pondering
) { pondering
= 0; printf("%d 0 0 0 UCI violation! Engine moves during ponder\n", lastDepth
+1); continue; } // ignore ponder search
274 // move was a move to be played
275 if(p
= strstr(line
+8, " draw")) *p
= 0, printf("offer draw\n"); // UCCI
276 if(strstr(line
+9, "resign")) { printf("resign\n"); computer
= NONE
; }
277 if(strstr(line
+9, "win")) { printf("%s {claim}\n", stm
== WHITE
? "1-0" :"0-1"); computer
= NONE
; } // USI
278 if(strstr(line
+9, "(none)") || strstr(line
+9, "null") ||
279 strstr(line
+9, "0000")) { printf("%s\n", lastScore
< -99999 ? "resign" : "1/2-1/2 {stalemate}"); computer
= NONE
; }
280 sscanf(line
, "bestmove %s", move
[moveNr
++]);
281 Release(); // send setoption commands that arrived during search
282 myTime
-= (GetTickCount() - startTime
)*1.02 + inc
; // update own clock, so we can give correct wtime, btime with ponder
283 if(mps
&& ((moveNr
+1)/2) % mps
== 0) myTime
+= tc
; if(sTime
) myTime
= sTime
; // new session or move starts
284 stm
= WHITE
+BLACK
- stm
;
285 // first start a new ponder search, if pondering is on and we have a move to ponder on
286 if(p
= strstr(line
+9, "ponder")) {
287 sscanf(p
+7, "%s", move
[moveNr
]);
288 if(computer
!= NONE
&& ponder
) {
289 DPRINT("# ponder on %s\n", move
[moveNr
]);
292 p
[-1] = '\n'; *p
= 0; // strip off ponder move
293 } else move
[moveNr
][0] = 0;
295 printf("move %s\n", line
+9); // send move to GUI
296 if(move
[moveNr
][0]) printf("Hint: %s\n", move
[moveNr
]);
297 if(pause
) { pause
= 0; Sync(WAKEUP
); } // release commands that came in during think
298 if(lastScore
== 100001 && iniPos
[0] != 'f') { printf("%s {mate}\n", stm
== BLACK
? "1-0" : "0-1"); computer
= NONE
; }
300 else if(!strcmp(command
, "info")) {
301 int d
=0, s
=0, t
=(GetTickCount() - startTime
)/10, n
=1;
302 char *pv
, varName
[80];
303 if(sscanf(line
+5, "string times @ %c", &dummy
) == 1) { printf("# %s", line
+12); continue; }
304 if(sscanf(line
+5, "string variant %s", varName
) == 1) {
305 if(!strstr(STDVARS
, varName
) && (p
= strstr(line
+18, " startpos "))) printf("setup (-) 8x8+0_fairy %s", p
+10);
308 if(collect
&& (pv
= strstr(line
+5, "currmove "))) {
309 if(p
= strstr(line
+5, "currmovenumber ")) {
311 if(collect
== 1 && n
!= 1) continue; // wait for move 1
312 if(collect
+ (n
== 1) > 2) { // done collecting
313 if(inex
&& collect
== 2) printf("%d 0 0 0 OK to exclude\n", lastDepth
);
314 collect
= 3; continue;
316 collect
= 2; on
[nr
=n
] = 1; sscanf(pv
+9, "%s", moveMap
[n
]); continue; // store move
320 if(sscanf(line
+5, "string %c", &dummy
) == 1) printf("%d 0 0 0 %s", lastDepth
, line
+12); else {
321 if(p
= strstr(line
+4, " depth ")) sscanf(p
+7, "%d", &d
), statDepth
= d
;
322 if(p
= strstr(line
+4, " score cp ")) sscanf(p
+10, "%d", &s
), statScore
= s
; else
323 if(p
= strstr(line
+4, " score mate ")) sscanf(p
+12, "%d", &s
), s
+= s
>0 ? 100000 : -100000, statScore
= s
; else
324 if(p
= strstr(line
+4, " score ")) sscanf(p
+7, "%d", &s
), statScore
= s
;
325 if(p
= strstr(line
+4, " nodes ")) sscanf(p
+7, "%d", &n
), statNodes
= n
;
326 if(p
= strstr(line
+4, " time ")) sscanf(p
+6, "%d", &t
), t
/= 10, statTime
= t
;
327 if(p
= strstr(line
+4, " currmove ")) sscanf(p
+10,"%s", currMove
);
328 if(p
= strstr(line
+4, " currmovenumber ")) sscanf(p
+16,"%d", &currNr
);
329 if(pv
= strstr(line
+4, " pv ")) // convert PV info to WB thinking output
330 printf("%3d %6d %6d %10d %s", lastDepth
=d
, lastScore
=s
, t
, n
, Convert(pv
+4));
331 else if(s
== -100000) lastScore
= s
; // when checkmated score is valid even without PV (which might not come)
334 else if(!strcmp(command
, "option")) { // USI option: extract data fields
335 char name
[80], type
[80], buf
[1024], val
[256], *q
;
336 int min
=0, max
=1e9
; *val
= 0;
337 if(p
= strstr(line
+6, " type ")) sscanf(p
+1, "type %s", type
), *p
= '\n';
338 if(p
= strstr(line
+6, " min ")) sscanf(p
+1, "min %d", &min
), *p
= '\n';
339 if(p
= strstr(line
+6, " max ")) sscanf(p
+1, "max %d", &max
), *p
= '\n';
340 if(p
= strstr(line
+6, " default ")) sscanf(p
+1, "default %[^\n]*", val
), *p
= '\n';
341 if(!(p
= strstr(line
+6, " name "))) p
= line
+1; sscanf(p
+6, "%[^\n]", name
); // 'name' is omitted in UCCI
342 if(!strcasecmp(name
, "UCI_Chess960")) { frc
=2; continue; }
343 if(!strcasecmp(name
, "UCI_Variant")) { if(p
= strstr(line
+6, " var ")) strcpy(varList
, p
); varOpt
= 1; continue; }
344 if(!strcasecmp(name
, "UCI_Opponent")) { namOpt
= 1; continue; }
345 if(!strcasecmp(name
+2, "I_AnalyseMode")) { strcpy(anaOpt
, name
); continue; }
346 if(frc
< 0 && (strstr(name
, "960") || strcasestr(name
, "frc")) && !strcmp(type
, "check")) {
347 EPRINT((f
, "# setoption name %s value true\n", name
)) strcpy(val
, "true"); // set non-standard suspected FRC options
349 if(!strcasecmp(name
, "Threads")) { strcpy(threadOpt
, name
); continue; }
350 if(!strcasecmp(name
, "Ponder") || !strcasecmp(name
, "USI_Ponder")) { strcpy(canPonder
, name
); continue; }
351 if(!strcasecmp(name
, "Hash") || !strcasecmp(name
, "USI_Hash") || !strcasecmp(name
, "hashsize")) {
352 memory
= oldMem
= atoi(val
); hasHash
= 1;
353 strcpy(hashOpt
, name
);
356 if(!strcasecmp(name
, "newgame") && !strcmp(type
, "button")) { newGame
++; continue; }
357 if(!strcasecmp(name
, "usemillisec")) { unit
= (!strcmp(val
, "false") ? 2 : 1); continue; }
358 sprintf(buf
, ",%s,", name
); if(strcasestr(EGT
, buf
)) { buf
[strlen(buf
)-5] = 0; strcat(egts
, buf
); continue; } // collect EGT formats
359 // pass on engine-defined option as WB option feature
360 if(!strcmp(type
, "filename")) type
[4] = 0;
361 sprintf(buf
, "feature option=\"%s -%s", name
, type
); q
= buf
+ strlen(buf
);
362 if( !strcmp(type
, "file")
363 || !strcmp(type
, "string")) sprintf(q
, " %s\"\n", val
);
364 else if(!strcmp(type
, "spin")) sprintf(q
, " %d %d %d\"\n", atoi(val
), min
, max
);
365 else if(!strcmp(type
, "check")) sprintf(q
, " %d\"\n", strcmp(val
, "true") ? 0 : 1), strcat(checkOptions
, name
);
366 else if(!strcmp(type
, "button")) sprintf(q
, "\"\n");
367 else if(!strcmp(type
, "combo")) {
368 if(p
= strstr(line
+6, " default ")) sscanf(p
+1, "default %s", type
); // current setting
370 while(p
= strstr(p
, " var ")) {
371 sscanf(p
+= 5, "%s", val
); // next choice
372 sprintf(buf
+ strlen(buf
), "%s%s%s", min
++ ? " /// " : " ", strcmp(type
, val
) ? "" : "*", val
);
376 else buf
[0] = 0; // ignore unrecognized option types
377 if(buf
[0]) printf("%s", buf
);
379 else if(!strcmp(command
, "id")) {
380 static char name
[256], version
[256];
381 if(sscanf(line
, "id name %[^\n]", name
) == 1) printf("feature myname=\"%s (U%cI2WB)\"\n", name
, sc
-32);
382 if(sscanf(line
, "id version %[^\n]", version
) == 1 && *name
) printf("feature myname=\"%s %s (U%cI2WB)\"\n", name
, version
, sc
-32);
384 else if(!strcmp(command
, "readyok")) { pause
= 0; Sync(WAKEUP
); } // resume processing of GUI commands
385 else if(sc
== 'x'&& !strcmp(command
, "ucciok") || sscanf(command
, "u%ciok", &c
)==1 && c
==sc
) {
386 char *p
= varList
, *q
= varList
;
387 while(*q
&& *q
!= '\n') if(!strncmp(q
, " var ", 5)) *p
++ = ',', q
+=5; // replace var keywords by commas
388 else if(!strncmp(q
-1, " chess ", 7)) strcpy(p
, "normal"), p
+= 6, q
+= 5; // 'chess' is called 'normal' in CECP
389 else if(!strncmp(q
-1, " threecheck", 11)) *p
++ = '3', q
+= 5; // 'threecheck' is written '3check' in CECP
390 else *p
++ = *q
++; // copy other variant names unmodified
391 if(frc
) sprintf(p
, ",normal,fischerandom"), printf("feature oocastle=%d\n", frc
<0); // unannounced FRC uses O-O castling
392 if(*varList
) printf("feature variants=\"%s\"\n", varList
+1); // from UCI_Variant combo and/or UCI_Chess960 check options
393 if(*egts
) { for(p
=egts
; *p
= tolower(*p
); p
++); printf("feature egt=\"%s\"\n", egts
+1); }
394 printf("feature smp=1 memory=%d done=1\n", hasHash
);
395 if(unit
== 2) { unit
= 1; EPRINT((f
, "# setoption usemillisec true\n")) }
396 Sync(WAKEUP
); // done with options
405 // convert input move to USI format
406 if(m
[1] == '@') { // drop
409 m
[0] = 'a'+'0'+size
- m
[0];
410 m
[1] = 'a'+'0'+size
- m
[1];
412 m
[2] = 'a'+'0'+size
- m
[2];
413 m
[3] = 'a'+'0'+size
- m
[3];
414 if(m
[4] == '=') m
[4] = 0; // no '=' in USI format!
415 else if(m
[4]) m
[4] = '+'; // cater to WB 4.4 bug :-(
422 char line
[256], command
[256], *p
, *q
, *r
, mySide
, type
[99];
425 int i
, x
, difficult
, think
=0;
427 if((computer
== stm
|| computer
== ANALYZE
&& !searching
) && !suspended
) {
428 DPRINT("# start search\n");
429 LoadPos(moveNr
); fflush(stdout
); // load position
430 // and set engine thinking (note USI swaps colors!)
431 startTime
= GetTickCount(); mySide
= stm
; // remember side we last played for
432 if(computer
== ANALYZE
) {
433 EPRINT((f
, "# go infinite"))
434 if(sm
& 1) { // some moves are disabled
435 EPRINT((f
, " searchmoves"))
436 for(i
=1; i
<nr
; i
++) if(on
[i
]) EPRINT((f
, " %s", moveMap
[i
]))
438 EPRINT((f
, "\n")) searching
= 1; // suppresses spurious commands during analysis starting new searches
439 } else pause
= think
= 2, StartSearch(""); // request suspending of input processing while thinking
442 for(difficult
=0; !difficult
; ) { // read and handle commands that can (or must) be handled during thinking
443 fflush(toE
); fflush(stdout
);
444 i
= 0; while((x
= getchar()) != EOF
&& (line
[i
] = x
) != '\n') i
++;
445 line
[++i
] = 0; if(x
== EOF
) { printf("# EOF\n"); sprintf(line
, "quit -1\n"); }
446 if(think
&& !pause
) Sync(PAUSE
), think
= 0, Release(); // if no longer thinking, take dummy pause
447 sscanf(line
, "%s", command
); DPRINT("# '%s' think=%d pause=%d log=%d sent=%d\n", command
, think
, pause
, logLen
, sentLen
);
448 if(!strcmp(command
, "usermove")) { difficult
--; break; } // for efficiency during game play, moves, time & otim are tried first
449 else if(!strcmp(command
, "time")) sscanf(line
+4, "%d", &myTime
), myTime
= (10*myTime
)/unit
;
450 else if(!strcmp(command
, "otim")) sscanf(line
+4, "%d", &hisTime
), hisTime
= (10*hisTime
)/unit
;
451 else if(!strcmp(command
, "offer")) drawOffer
= 1; // backlogged anyway, so this can be done instantly
452 else if(!strcmp(command
, "post")) post
= 1;
453 else if(!strcmp(command
, "nopost"))post
= 0;
454 else if(!strcmp(command
, "pause")) {
455 if(computer
== stm
) myTime
-= GetTickCount() - startTime
;
456 suspended
= 1 + pondering
; // remember if we were pondering, and stop search ignoring bestmove
457 StopPonder(pondering
|| computer
== stm
);
459 else { //convert easy & hard to "option" after treating their effect on the adapter
460 if(!strcmp(command
, "easy")) {
461 if(*canPonder
) ponder
= 0, sprintf(command
, "option"), sprintf(line
, "option %s=0\n", canPonder
); else continue;
463 else if(!strcmp(command
, "hard")) {
464 if(*canPonder
) ponder
= 1, sprintf(command
, "option"), sprintf(line
, "option %s=1\n", canPonder
); else continue;
466 if(!strcmp(command
, "option")) {
468 if(logLen
== sentLen
) logLen
= 0, sentLen
= 0; // engine is up to date; reset buffer
469 if(sscanf(line
+7, "UCI2WB debug output=%d", &debug
) == 1) ; else
470 if(sscanf(line
+7, "Floating Byoyomi=%d", &flob
) == 1) ; else
471 if(sscanf(line
+7, "Byoyomi=%d", &byo
) == 1) ; else
472 if(p
= strchr(line
, '=')) {
474 if(strstr(checkOptions
, line
+7)) sprintf(p
, "%s\n", atoi(p
) ? "true" : "false");
475 snprintf(backLog
+logLen
, 9999-logLen
, "setoption %s%s %s%s", nameWord
, line
+7, valueWord
, p
);
476 } else snprintf(backLog
+logLen
, 9999-logLen
, "setoption %s%s\n", nameWord
, line
+7);
477 DPRINT("# backlog: %s", backLog
+logLen
); logLen
+= strlen(backLog
+logLen
);
478 if(!think
&& Release()) break; // break will restart analysis; pondering is restarted by Release itself
480 else difficult
= 1; // difficult command; terminate loop for easy ones
484 // some commands that should never come during thinking can be safely processed here
485 if(difficult
< 0) { // used as kludge to signal "usermove" was already matched
486 sscanf(line
, "usermove %s", command
); // strips off linefeed
487 Move4Engine(command
);
488 stm
= WHITE
+BLACK
- stm
; collect
= (computer
== ANALYZE
); sm
= 0;
489 // when pondering we either continue the ponder search as normal search, or abort it
490 if(pondering
|| computer
== ANALYZE
) {
491 if(pondering
&& !strcmp(command
, move
[moveNr
])) { // ponder hit
492 char *draw
= drawOffer
? " draw" : ""; drawOffer
= 0;
493 pondering
= 0; pause
= 2; moveNr
++; startTime
= GetTickCount(); // clock starts running now
494 EPRINT((f
, "# ponderhit%s\n", draw
)) fflush(toE
); fflush(stdout
);
495 think
= 2; // request blocking input during thinking
498 StopPonder(1); searching
= 0;
500 strcpy(move
[moveNr
++], command
); // possibly overwrites ponder move
503 if(!strcmp(command
, "resume")) {
504 if(suspended
== 2) StartPonder(); // restart interrupted ponder search
505 suspended
= think
= 0; continue; // causes thinking to start in normal way if on move or analyzing
507 if(think
) { // command arrived during thinking; order abort for 'instant commands'
508 if(!strcmp(command
, "?") || !strcmp(command
, "quit") ||
509 !strcmp(command
, "force") || !strcmp(command
, "result")) { EPRINT((f
, "# stop\n")); fflush(toE
); }
510 Sync(PAUSE
); Release(); // block processing of difficult commands during thinking; send backlog left because of race
512 if(!strcmp(command
, "new")) {
513 computer
= BLACK
; moveNr
= 0; depth
= -1; move
[0][0] = 0;
514 stm
= WHITE
; strcpy(iniPos
, "position startpos"); frc
&= ~1;
515 if(memory
!= oldMem
&& hasHash
) EPRINT((f
, "# setoption %s%s %s%d\n", nameWord
, hashOpt
, valueWord
, memory
))
517 // we can set other options here
518 if(sc
== 'x') { if(newGame
) EPRINT((f
, "# setoption newgame\n")) } else // optional in UCCI
519 if(varOpt
) EPRINT((f
, "# setoption name UCI_Variant value chess\n"))
520 pause
= 1; // wait for option settings to take effect
521 EPRINT((f
, "# isready\n")) fflush(toE
);
522 Sync(PAUSE
); // wait for readyok
523 EPRINT((f
, "# u%cinewgame\n", sc
)) fflush(toE
);
525 else if(!strcmp(command
, "level")) {
527 sscanf(line
, "level %d %d:%d %d", &mps
, &tc
, &sec
, &inc
) == 4 ||
528 sscanf(line
, "level %d %d %d", &mps
, &tc
, &inc
);
529 tc
= (60*tc
+ sec
)*1000; inc
*= 1000; sTime
= 0; tc
/= unit
; inc
/= unit
;
531 else if(!strcmp(command
, "protover")) {
532 if(!varList
[0]) strcpy(varList
, sc
=='s' ? ",shogi,5x5+5_shogi" : VARIANTS
);
533 printf("feature setboard=1 usermove=1 debug=1 ping=1 name=1 reuse=0 exclude=1 pause=1 sigint=0 sigterm=0 done=0\n");
534 printf("feature option=\"UCI2WB debug output -check %d\"\n", debug
);
535 if(sc
== 's') printf("feature option=\"Floating Byoyomi -check %d\"\nfeature option=\"Byoyomi -spin %d -1 1000\"\n", flob
, byo
);
536 EPRINT((f
, sc
== 'x' ? "# ucci\n" : "u%ci\n", sc
)) fflush(toE
); // prompt UCI engine for options
537 Sync(PAUSE
); // wait for uciok
539 else if(!strcmp(command
, "setboard")) {
540 stm
= (strstr(line
+9, " b ") ? BLACK
: WHITE
);
541 if((p
= strchr(line
+9, '[')) && !varOpt
) { char c
;
542 *p
++ = 0; q
= strchr(p
, ']'); *q
= 0; r
= q
+ 4;
543 if(sc
== 's') q
[2] = 'w' + 'b' - q
[2], strcpy(r
=q
+3, " 1\n"); // Shogi: reverse color
544 else r
= strchr(strchr(q
+4, ' ') + 1, ' '); // skip to second space (after e.p. square)
545 *r
= 0; sprintf(command
, "%s%s %s %s", line
+9, q
+1, p
, r
+1);
546 } else strcpy(command
, line
+9);
547 if(frc
== -1 && (p
= strchr(command
, ' '))) strncpy(p
+3, "KQkq", 4); // unannounced FRC
548 sprintf(iniPos
, "%s%sfen %s", iniPos
[0]=='p' ? "position " : "", sc
=='s' ? "s" : "", command
);
549 iniPos
[strlen(iniPos
)-1] = sm
= 0; collect
= (computer
== ANALYZE
);
551 else if(!strcmp(command
, "variant")) {
553 EPRINT((f
, "# setoption name UCI_Variant value %sucinewgame\nisready\n", strcmp(line
+8, "3check\n") ? line
+8 : "threecheck\n"))
554 fflush(toE
); Sync(PAUSE
);
556 if(!strcmp(line
+8, "shogi\n")) size
= 9, strcpy(iniPos
, "position startpos");
557 if(!strcmp(line
+8, "5x5+5_shogi\n")) size
= 5, strcpy(iniPos
, "position startpos");
558 if(!strcmp(line
+8, "xiangqi\n")) strcpy(iniPos
, "fen rnbakabnr/9/1c5c1/p1p1p1p1p/9/9/P1P1P1P1P/1C5C1/9/RNBAKABNR r");
559 if(!strcmp(line
+8, "fischerandom\n")) { frc
|= 1; if(frc
> 0) EPRINT((f
, "# setoption name UCI_Chess960 value true\n")) }
561 else if(!strcmp(command
, "undo") && (i
=1) || !strcmp(command
, "remove") && (i
=2)) {
562 if(pondering
|| computer
== ANALYZE
) StopPonder(1), searching
= 0;
563 moveNr
= moveNr
> i
? moveNr
- i
: 0; collect
= (computer
== ANALYZE
); sm
= 0;
565 else if(!strcmp(command
, ".")) {
566 printf("stat01: %d %d %d %d 100 %s\n", statTime
, statNodes
, statDepth
, 100-currNr
, currMove
);
569 else if(!strcmp(command
+2, "clude") && collect
> 2) { // include or exclude
570 int all
= !strcmp(line
+8, "all"), in
= command
[1] == 'n';
571 inex
= 1; line
[strlen(line
)-1] = sm
= 0; // strip LF and clear sm flag
572 for(i
=1; i
<nr
; i
++) { if(!strcmp(line
+8, moveMap
[i
]) || all
) on
[i
] = in
; sm
|= on
[i
]+1; } // sm: 2 = enabled, 1 = disabled
573 if(!(sm
& 2)) goto nomove
; // no moves enabled; continue current search
574 if(computer
== ANALYZE
) StopPonder(1), searching
= 0; // abort old analysis
576 else if(!strcmp(command
, "xboard")) ;
577 else if(!strcmp(command
, "analyze"))computer
= ANALYZE
, collect
= 1, sm
= 0, Analyze("true");
578 else if(!strcmp(command
, "exit")) computer
= NONE
, StopPonder(1), searching
= 0, Analyze("false");
579 else if(!strcmp(command
, "force")) computer
= NONE
, StopPonder(pondering
);
580 else if(!strcmp(command
, "go")) computer
= stm
;
581 else if(!strcmp(command
, "ping")) { /* static int done; if(!done) pause = 1, fprintf(toE, "isready\n"), fflush(toE), printf("# send isready\n"), fflush(stdout), Sync(PAUSE); done = 1;*/ printf("po%s", line
+2); }
582 else if(!strcmp(command
, "memory")) sscanf(line
, "memory %d", &memory
);
583 else if(!strcmp(command
, "cores")&& !!*threadOpt
) { sscanf(line
, "cores %d", &cores
); EPRINT((f
, "# setoption %s%s %s%d\n", nameWord
, threadOpt
, valueWord
, cores
)) }
584 else if(!strcmp(command
, "egtpath")){ sscanf(line
, "egtpath %s %[^\n]", type
, command
); EPRINT((f
, "# setoption name %sPath value %s\n", type
,command
)); }
585 else if(!strcmp(command
, "sd")) sscanf(line
, "sd %d", &depth
);
586 else if(!strcmp(command
, "st")) sscanf(line
, "st %d", &sTime
), sTime
= 1000*sTime
- 30, inc
= 0, sTime
/= unit
;
587 else if(!strcmp(command
, "name")) { if(namOpt
) EPRINT((f
, "# setoption name UCI_Opponent value none none %s %s", comp
? "computer" : "human", line
+5)) }
588 else if(!strcmp(command
, "computer")) comp
= 1;
589 else if(!strcmp(command
, "result")) {
590 if(sc
== 's') EPRINT((f
, "# gameover %s\n", line
[8] == '/' ? "draw" : (line
[7] == '0') == mySide
? "win" : "lose"))
593 else if(!strcmp(command
, "quit")) { EPRINT((f
, "# quit\n")) fflush(toE
), exit(atoi(line
+4)); }
598 StartEngine(char *cmdLine
, char *dir
)
601 HANDLE hChildStdinRd
, hChildStdinWr
,
602 hChildStdoutRd
, hChildStdoutWr
;
604 PROCESS_INFORMATION piProcInfo
;
605 STARTUPINFO siStartInfo
;
608 /* Create a pipe for the child's STDOUT. */
609 if (! WinPipe(&hChildStdoutRd
, &hChildStdoutWr
)) return GetLastError();
611 /* Create a pipe for the child's STDIN. */
612 if (! WinPipe(&hChildStdinRd
, &hChildStdinWr
)) return GetLastError();
614 SetCurrentDirectory(dir
); // go to engine directory
616 /* Now create the child process. */
617 siStartInfo
.cb
= sizeof(STARTUPINFO
);
618 siStartInfo
.lpReserved
= NULL
;
619 siStartInfo
.lpDesktop
= NULL
;
620 siStartInfo
.lpTitle
= NULL
;
621 siStartInfo
.dwFlags
= STARTF_USESTDHANDLES
;
622 siStartInfo
.cbReserved2
= 0;
623 siStartInfo
.lpReserved2
= NULL
;
624 siStartInfo
.hStdInput
= hChildStdinRd
;
625 siStartInfo
.hStdOutput
= hChildStdoutWr
;
626 siStartInfo
.hStdError
= hChildStdoutWr
;
628 fSuccess
= CreateProcess(NULL
,
629 cmdLine
, /* command line */
630 NULL
, /* process security attributes */
631 NULL
, /* primary thread security attrs */
632 TRUE
, /* handles are inherited */
633 DETACHED_PROCESS
|CREATE_NEW_PROCESS_GROUP
,
634 NULL
, /* use parent's environment */
636 &siStartInfo
, /* STARTUPINFO pointer */
637 &piProcInfo
); /* receives PROCESS_INFORMATION */
639 if (! fSuccess
) return GetLastError();
641 // if (0) { // in the future we could trigger this by an argument
642 // SetPriorityClass(piProcInfo.hProcess, GetWin32Priority(appData.niceEngines));
645 /* Close the handles we don't need in the parent */
646 CloseHandle(piProcInfo
.hThread
);
647 CloseHandle(hChildStdinRd
);
648 CloseHandle(hChildStdoutWr
);
650 process
= piProcInfo
.hProcess
;
651 pid
= piProcInfo
.dwProcessId
;
652 fromE
= (FILE*) _fdopen( _open_osfhandle((long)hChildStdoutRd
, _O_TEXT
|_O_RDONLY
), "r");
653 toE
= (FILE*) _fdopen( _open_osfhandle((long)hChildStdinWr
, _O_WRONLY
), "w");
655 char *argv
[10], *p
, buf
[200];
656 int i
, toEngine
[2], fromEngine
[2];
658 if (dir
&& dir
[0] && chdir(dir
)) { perror(dir
); exit(1); }
659 pipe(toEngine
); pipe(fromEngine
); // create two pipes
661 if ((pid
= fork()) == 0) { // Child
662 dup2(toEngine
[0], 0); close(toEngine
[0]); close(toEngine
[1]); // stdin from toE pipe
663 dup2(fromEngine
[1], 1); close(fromEngine
[0]); close(fromEngine
[1]); // stdout into fromE pipe
664 dup2(1, fileno(stderr
)); // stderr into frome pipe
666 strcpy(buf
, cmdLine
); p
= buf
;
667 for (i
=0;;) { argv
[i
++] = p
; p
= strchr(p
, ' '); if (p
== NULL
) break; *p
++ = 0; }
669 execvp(argv
[0], argv
); // startup engine
671 perror(argv
[0]); exit(1); // could not start engine; quit.
673 signal(SIGPIPE
, SIG_IGN
);
674 close(toEngine
[0]); close(fromEngine
[1]); // close engine ends of pipes in adapter
676 fromE
= (FILE*) fdopen(fromEngine
[0], "r"); // make into high-level I/O
677 toE
= (FILE*) fdopen(toEngine
[1], "w");
682 main(int argc
, char **argv
)
684 char *dir
= NULL
, *p
, *q
; int e
;
686 if(argc
== 2 && !strcmp(argv
[1], "-v")) { printf("UCI2WB " VERSION
" by H.G.Muller\n"); exit(0); }
687 if(argc
> 1 && !strcmp(argv
[1], "debug")) { debug
= 1; argc
--; argv
++; }
688 if(argc
> 1 && !strcmp(argv
[1], "-var")) { strcpy(varList
+1, argv
[2]); *varList
= ','; argc
-=2; argv
+=2; }
689 if(argc
> 1 && argv
[1][0] == '-') { sc
= argv
[1][1]; argc
--; argv
++; }
690 if(argc
< 2) { printf("usage is: U%cI2WB [debug] [-s] <engine.exe> [<engine directory>]\n", sc
-32); exit(-1); }
691 if(argc
> 2) dir
= argv
[2];
692 if(argc
> 3) strncpy(suffix
, argv
[3], 80);
694 if(sc
== 'x') nameWord
= valueWord
= bTime
= "", wTime
= "opp", bInc
= "increment", wInc
= "oppincrement", unit
= 1000; // switch to UCCI keywords
695 else if(sc
== 'f' ) frc
= -1, sc
= 'c'; // UCI for unannounced Chess960
696 else if(sc
== 'n') sc
= 'c'; // UCI for normal Chess
699 if(StartEngine(binary
= argv
[1], dir
) != NO_ERROR
) { perror(argv
[1]), exit(-1); }
703 // create separate thread to handle engine->GUI traffic
705 CreateThread(NULL
, 0, (LPTHREAD_START_ROUTINE
) Engine2GUI
, (LPVOID
) NULL
, 0, &thread_id
);
707 { pthread_t t
; signal(SIGINT
, SIG_IGN
); signal(SIGTERM
, SIG_IGN
); pthread_create(&t
, NULL
, Engine2GUI
, NULL
); }
710 // handle GUI->engine traffic in original thread