X-Git-Url: https://git.sesse.net/?p=stockfish;a=blobdiff_plain;f=src%2Fmisc.cpp;h=33c3f1f70acceb9287ab08a36aed4db62a432064;hp=8cfba7341fa7fe7256fdaafa440dc3140ae9dbcd;hb=0a18adb02ac375f7d7fc31ef76b59e13a0263773;hpb=482b5b7ecebc85e427c2c839337c7a893ae3e402 diff --git a/src/misc.cpp b/src/misc.cpp index 8cfba734..33c3f1f7 100644 --- a/src/misc.cpp +++ b/src/misc.cpp @@ -17,25 +17,6 @@ along with this program. If not, see . */ -#if defined(_WIN32) || defined(_WIN64) - -#define NOMINMAX // disable macros min() and max() -#include - -#else - -# include -# if defined(__hpux) -# include -# endif - -#endif - -#if !defined(NO_PREFETCH) -# include -#endif - -#include #include #include #include @@ -43,12 +24,16 @@ #include "misc.h" #include "thread.h" +#if defined(__hpux) +# include +#endif + using namespace std; /// Version number. If Version is left empty, then Tag plus current /// date (in the format YYMMDD) is used as a version number. -static const string Version = ""; +static const string Version = "2.3"; static const string Tag = ""; @@ -66,17 +51,15 @@ const string engine_info(bool to_uci) { string month, day, year; stringstream s, date(__DATE__); // From compiler, format is "Sep 21 2008" + s << "Stockfish " << Version; + if (Version.empty()) { date >> month >> day >> year; - s << "Stockfish " << Tag - << setfill('0') << " " << year.substr(2) - << setw(2) << (1 + months.find(month) / 4) - << setw(2) << day; + s << Tag << setfill('0') << " " << year.substr(2) + << setw(2) << (1 + months.find(month) / 4) << setw(2) << day; } - else - s << "Stockfish " << Version; s << cpu64 << popcnt << (to_uci ? "\nid author ": " by ") << "Tord Romstad, Marco Costalba and Joona Kiiski"; @@ -85,6 +68,13 @@ const string engine_info(bool to_uci) { } +/// Convert system time to milliseconds. That's all we need. + +Time::point Time::now() { + sys_time_t t; system_time(&t); return time_to_msec(t); +} + + /// Debug functions used mainly to collect run-time statistics static uint64_t hits[2], means[2]; @@ -105,6 +95,85 @@ void dbg_print() { } +/// Our fancy logging facility. The trick here is to replace cin.rdbuf() and +/// cout.rdbuf() with two Tie objects that tie cin and cout to a file stream. We +/// can toggle the logging of std::cout and std:cin at runtime while preserving +/// usual i/o functionality and without changing a single line of code! +/// Idea from http://groups.google.com/group/comp.lang.c++/msg/1d941c0f26ea0d81 + +struct Tie: public streambuf { // MSVC requires splitted streambuf for cin and cout + + Tie(streambuf* b, ofstream* f) : buf(b), file(f) {} + + int sync() { return file->rdbuf()->pubsync(), buf->pubsync(); } + int overflow(int c) { return log(buf->sputc((char)c), "<< "); } + int underflow() { return buf->sgetc(); } + int uflow() { return log(buf->sbumpc(), ">> "); } + + streambuf* buf; + ofstream* file; + + int log(int c, const char* prefix) { + + static int last = '\n'; + + if (last == '\n') + file->rdbuf()->sputn(prefix, 3); + + return last = file->rdbuf()->sputc((char)c); + } +}; + +class Logger { + + Logger() : in(cin.rdbuf(), &file), out(cout.rdbuf(), &file) {} + ~Logger() { start(false); } + + ofstream file; + Tie in, out; + +public: + static void start(bool b) { + + static Logger l; + + if (b && !l.file.is_open()) + { + l.file.open("io_log.txt", ifstream::out | ifstream::app); + cin.rdbuf(&l.in); + cout.rdbuf(&l.out); + } + else if (!b && l.file.is_open()) + { + cout.rdbuf(l.out.buf); + cin.rdbuf(l.in.buf); + l.file.close(); + } + } +}; + + +/// Used to serialize access to std::cout to avoid multiple threads to write at +/// the same time. + +std::ostream& operator<<(std::ostream& os, SyncCout sc) { + + static Mutex m; + + if (sc == io_lock) + m.lock(); + + if (sc == io_unlock) + m.unlock(); + + return os; +} + + +/// Trampoline helper to avoid moving Logger to misc.h +void start_logger(bool b) { Logger::start(b); } + + /// cpu_count() tries to detect the number of CPU cores int cpu_count() { @@ -112,16 +181,16 @@ int cpu_count() { #if defined(_WIN32) || defined(_WIN64) SYSTEM_INFO s; GetSystemInfo(&s); - return std::min(int(s.dwNumberOfProcessors), MAX_THREADS); + return s.dwNumberOfProcessors; #else # if defined(_SC_NPROCESSORS_ONLN) - return std::min((int)sysconf(_SC_NPROCESSORS_ONLN), MAX_THREADS); + return sysconf(_SC_NPROCESSORS_ONLN); # elif defined(__hpux) struct pst_dynamic psd; if (pstat_getdynamic(&psd, sizeof(psd), (size_t)1, 0) == -1) return 1; - return std::min((int)psd.psd_proc_cnt, MAX_THREADS); + return psd.psd_proc_cnt; # else return 1; # endif @@ -139,7 +208,7 @@ void timed_wait(WaitCondition& sleepCond, Lock& sleepLock, int msec) { int tm = msec; #else timespec ts, *tm = &ts; - uint64_t ms = Time::current_time().msec() + msec; + uint64_t ms = Time::now() + msec; ts.tv_sec = ms / 1000; ts.tv_nsec = (ms % 1000) * 1000000LL; @@ -158,6 +227,8 @@ void prefetch(char*) {} #else +# include + void prefetch(char* addr) { # if defined(__INTEL_COMPILER) || defined(__ICL)