1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
646
647
648
649
650
651
652
653
654
655
656
657
658
659
660
661
662
663
664
665
666
667
668
669
670
671
672
673
|
// Copyright (c) 2009 Satoshi Nakamoto
// Distributed under the MIT/X11 software license, see the accompanying
// file license.txt or http://www.opensource.org/licenses/mit-license.php.
// For abi::__forced_unwind, which CATCH_PRINT_EXCEPTION below must let past.
#ifndef _WIN32
#include <cxxabi.h>
#endif
// For AvailableCoreCount() below: sched_getaffinity on Linux, and
// hardware_concurrency as the fallback everywhere else.
#include <thread>
#ifdef __linux__
#include <sched.h>
#endif
#if defined(_MSC_VER) || defined(__BORLANDC__)
typedef __int64 int64;
typedef unsigned __int64 uint64;
#else
typedef long long int64;
typedef unsigned long long uint64;
#endif
#if defined(_MSC_VER) && _MSC_VER < 1300
#define for if (false) ; else for
#endif
// MinGW already provides __forceinline for MSVC compatibility, so defining it
// unconditionally warned ten times per build once -w was removed.
#if !defined(_MSC_VER) && !defined(__forceinline)
#define __forceinline inline
#endif
#define foreach BOOST_FOREACH
#define loop for (;;)
#define BEGIN(a) ((char*)&(a))
#define END(a) ((char*)&((&(a))[1]))
#define UBEGIN(a) ((unsigned char*)&(a))
#define UEND(a) ((unsigned char*)&((&(a))[1]))
#define ARRAYLEN(array) (sizeof(array)/sizeof((array)[0]))
// Route printf to debug.log (and the console on non-Windows) everywhere.
// (Previously gated on `defined(_WINDOWS) || !defined(_WIN32)` -- but
// _WINDOWS is only ever defined by the legacy, unused makefile.vc build;
// the real Windows build (makefile.mingw) never defines it, so on actual
// Windows this condition was always false and debug.log was never written.
// OutputDebugStringF() is already platform-safe internally: it always
// writes debug.log, and only echoes to the console when not on Windows.)
#define printf OutputDebugStringF
#ifdef snprintf
#undef snprintf
#endif
#define snprintf my_snprintf
// One definition for every target. The MSVCRT branch that used to sit here
// produced "I64d", which is the specifier that segfaults on glibc (issue #5) --
// and it was pointless besides: this build targets UCRT, which accepts the C99
// forms, and the rest of the tree already prints int64 with %lld on Windows.
// Keeping one spelling everywhere is also what lets the format attributes below
// use a single archetype, so a bad specifier fails the build on both platforms.
#ifndef PRId64
#define PRId64 "lld"
#define PRIu64 "llu"
#define PRIx64 "llx"
#endif
// This is needed because the foreach macro can't get over the comma in pair<t1, t2>
#define PAIRTYPE(t1, t2) pair<t1, t2>
// Used to bypass the rule against non-const reference to temporary
// where it makes sense with wrappers such as CFlatData or CTxDB
template<typename T>
inline T& REF(const T& val)
{
return (T&)val;
}
extern bool fDebug;
// /debugrelay: the per-message firehose ("relay" and "nostrdiscovery"
// categories) that even -debug keeps off. See LogAcceptsCategory().
extern bool fDebugRelay;
// debug.log is rolled to debug.log.old once it grows past this many bytes
// (set from -maxdebugfilesize, in MB; 0 disables the check). See the roll
// site in OutputDebugStringF() below.
extern int64 nMaxDebugFileSize;
// ---------------------------------------------------------------------------
// Categorized, burst-collapsing logging
//
// Plain printf() (routed to OutputDebugStringF below) writes every call
// unfiltered to debug.log. That's fine for one-off events, but a loop that
// logs once per item -- once per discovered peer, once per connect attempt,
// once per share -- turns debug.log into a wall of near-identical lines that
// differ only by an address, while the line that actually explains a stuck
// flow ("Stratum: no job available for ...") scrolls off screen under the
// noise. LogPrint() is a drop-in replacement for printf() that fixes both
// problems without touching call sites' formatting:
//
// 1. Category tag: every call names the subsystem it belongs to ("pool",
// "worker", "payout", "net", "nostr", ...). LogAcceptsCategory()
// controls what's written (see util.cpp); the pool/worker/payout flow
// the person actually needs visibility into is on by default.
// 2. Burst collapse: repeated LogPrint() calls from the *same source line*
// only emit one line per DEDUP_WINDOW_SECS; if more calls land inside
// that window they're counted instead of reprinted, and the count is
// flushed as a single "(xN similar in Ws)" line once the window expires
// -- whether or not that call site ever fires again. A loop discovering
// 500 peers by address now produces a small, bounded number of lines
// instead of 500 -- log growth is capped by elapsed time, not by how
// many similar events happen to fire.
//
// Use LogPrintAlways() instead for anything that reports an irreversible
// change to money: an obligation voided, a payment sent, a payment that
// failed. One line standing in for an unknown number of identical events is
// a tidy report of peer chatter and a false report of a ledger. A reorg
// voiding 100 entries hits one source line 100 times inside one window;
// under LogPrint() that read as a single block losing a single 49.49 BTF
// payment, while 4,950 BTF of obligations were actually destroyed, and the
// discrepancy was only found by counting entries in pending_payouts.json
// (issue #3). Bounded log growth is not worth that ambiguity here.
// ---------------------------------------------------------------------------
bool LogAcceptsCategory(const char* category);
void LogPrintDedup(const char* category, const char* file, int line, const std::string& msg);
void LogPrintNoCollapse(const char* category, const std::string& msg);
#define LogPrint(category, ...) \
do { if (LogAcceptsCategory(category)) LogPrintDedup((category), __FILE__, __LINE__, strprintf(__VA_ARGS__)); } while (0)
#define LogPrintAlways(category, ...) \
do { if (LogAcceptsCategory(category)) LogPrintNoCollapse((category), strprintf(__VA_ARGS__)); } while (0)
// Every format string in this project goes through one of the four functions
// below -- `printf` itself is remapped to OutputDebugStringF just above, and
// snprintf to my_snprintf. None of them carried a format attribute, and GCC
// only checks format strings for functions it knows are printf-like, so
// -Wformat had nothing to inspect and the whole tree was unchecked. That is
// how `%I64d` (MSVC-only, and a segfault on glibc) survived in
// CTxOut::ToString until it crashed a node mid-sync -- see issue #5.
//
// gnu_printf on both platforms, deliberately. MinGW's other option, ms_printf,
// models the legacy msvcrt: it rejects %zu, which this tree uses and UCRT
// supports, and it accepts %I64d, which is the specifier that crashes on glibc.
// It would give false positives where the code is right and stay silent where it
// is dangerous. gnu_printf describes UCRT's C99 behaviour accurately, so one
// archetype covers both builds and a bad specifier fails either one.
#if defined(__GNUC__)
#define BF_FORMAT(fmt, args) __attribute__((format(gnu_printf, fmt, args)))
#else
#define BF_FORMAT(fmt, args)
#endif
void RandAddSeed(bool fPerfmon=false);
int my_snprintf(char* buffer, size_t limit, const char* format, ...) BF_FORMAT(3, 4);
string strprintf(const char* format, ...) BF_FORMAT(1, 2);
bool error(const char* format, ...) BF_FORMAT(1, 2);
void PrintException(std::exception* pex, const char* pszThread);
void ParseString(const string& str, char c, vector<string>& v);
string FormatMoney(int64 n, bool fPlus=false);
bool ParseMoney(const char* pszIn, int64& nRet);
bool FileExists(const char* psz);
int64 GetFilesize(FILE* file);
uint64 GetRand(uint64 nMax);
int64 GetTime();
int64 GetAdjustedTime();
void AddTimeData(unsigned int ip, int64 nTime);
// Cores this process is actually allowed to run on.
//
// std::thread::hardware_concurrency() reports the MACHINE's core count, which
// is not the same number inside a container. With --cpuset-cpus 0-5 on a
// 12-core host it still answers 12, so every caller that sized a thread pool
// from it oversubscribed by 2x and then wondered why the box was thrashing:
// the pool node started 11 miner threads on 6 permitted CPUs, and a burst
// miner asked for 2 cores filled the ~2 GB RandomX dataset with 12 threads.
//
// sched_getaffinity reports what the cpuset permits, which is the number every
// one of those callers meant. Falls back to hardware_concurrency where the
// call is unavailable, and never returns 0 -- callers divide by this.
inline unsigned int AvailableCoreCount()
{
#ifdef __linux__
cpu_set_t cpuset;
CPU_ZERO(&cpuset);
if (sched_getaffinity(0, sizeof(cpuset), &cpuset) == 0)
{
int nAllowed = CPU_COUNT(&cpuset);
if (nAllowed > 0)
return (unsigned int)nAllowed;
}
#endif
unsigned int nCores = std::thread::hardware_concurrency();
return nCores > 0 ? nCores : 1;
}
// Wrapper to automatically initialize critical section
// Could use wxCriticalSection for portability, but it doesn't support TryEnterCriticalSection
class CCriticalSection
{
protected:
CRITICAL_SECTION cs;
public:
char* pszFile;
int nLine;
explicit CCriticalSection() : pszFile(NULL), nLine(0) { InitializeCriticalSection(&cs); }
~CCriticalSection() { DeleteCriticalSection(&cs); }
void Enter() { EnterCriticalSection(&cs); }
void Leave() { LeaveCriticalSection(&cs); }
bool TryEnter() { return TryEnterCriticalSection(&cs); }
CRITICAL_SECTION* operator&() { return &cs; }
};
// Automatically leave critical section when leaving block, needed for exception safety
class CCriticalBlock
{
protected:
CRITICAL_SECTION* pcs;
public:
CCriticalBlock(CRITICAL_SECTION& csIn) { pcs = &csIn; EnterCriticalSection(pcs); }
CCriticalBlock(CCriticalSection& csIn) { pcs = &csIn; EnterCriticalSection(pcs); }
~CCriticalBlock() { LeaveCriticalSection(pcs); }
};
// WARNING: This will catch continue and break!
// break is caught with an assertion, but there's no way to detect continue.
// I'd rather be careful than suffer the other more error prone syntax.
// The compiler will optimise away all this loop junk.
#define CRITICAL_BLOCK(cs) \
for (bool fcriticalblockonce=true; fcriticalblockonce; assert(("break caught by CRITICAL_BLOCK!", !fcriticalblockonce)), fcriticalblockonce=false) \
for (CCriticalBlock criticalblock(cs); fcriticalblockonce && (cs.pszFile=__FILE__, cs.nLine=__LINE__, true); fcriticalblockonce=false, cs.pszFile=NULL, cs.nLine=0)
class CTryCriticalBlock
{
protected:
CRITICAL_SECTION* pcs;
public:
CTryCriticalBlock(CRITICAL_SECTION& csIn) { pcs = (TryEnterCriticalSection(&csIn) ? &csIn : NULL); }
CTryCriticalBlock(CCriticalSection& csIn) { pcs = (TryEnterCriticalSection(&csIn) ? &csIn : NULL); }
~CTryCriticalBlock() { if (pcs) LeaveCriticalSection(pcs); }
bool Entered() { return pcs != NULL; }
};
#define TRY_CRITICAL_BLOCK(cs) \
for (bool fcriticalblockonce=true; fcriticalblockonce; assert(("break caught by TRY_CRITICAL_BLOCK!", !fcriticalblockonce)), fcriticalblockonce=false) \
for (CTryCriticalBlock criticalblock(cs); fcriticalblockonce && (fcriticalblockonce = criticalblock.Entered()) && (cs.pszFile=__FILE__, cs.nLine=__LINE__, true); fcriticalblockonce=false, cs.pszFile=NULL, cs.nLine=0)
inline string i64tostr(int64 n)
{
return strprintf("%" PRId64, n);
}
inline string itostr(int n)
{
return strprintf("%d", n);
}
inline int64 atoi64(const char* psz)
{
#ifdef _MSC_VER
return _atoi64(psz);
#else
return strtoll(psz, NULL, 10);
#endif
}
inline int64 atoi64(const string& str)
{
#ifdef _MSC_VER
return _atoi64(str.c_str());
#else
return strtoll(str.c_str(), NULL, 10);
#endif
}
inline int atoi(const string& str)
{
return atoi(str.c_str());
}
inline int roundint(double d)
{
return (int)(d > 0 ? d + 0.5 : d - 0.5);
}
template<typename T>
string HexStr(const T itbegin, const T itend, bool fSpaces=true)
{
const unsigned char* pbegin = (const unsigned char*)&itbegin[0];
const unsigned char* pend = pbegin + (itend - itbegin) * sizeof(itbegin[0]);
string str;
for (const unsigned char* p = pbegin; p != pend; p++)
str += strprintf((fSpaces && p != pend-1 ? "%02x " : "%02x"), *p);
return str;
}
template<typename T>
string HexNumStr(const T itbegin, const T itend, bool f0x=true)
{
const unsigned char* pbegin = (const unsigned char*)&itbegin[0];
const unsigned char* pend = pbegin + (itend - itbegin) * sizeof(itbegin[0]);
string str = (f0x ? "0x" : "");
for (const unsigned char* p = pend-1; p >= pbegin; p--)
str += strprintf("%02X", *p);
return str;
}
template<typename T>
void PrintHex(const T pbegin, const T pend, const char* pszFormat="%s", bool fSpaces=true)
{
printf(pszFormat, HexStr(pbegin, pend, fSpaces).c_str());
}
// Forward declaration -- defined in main.cpp
string GetAppDir();
// Give a command-line operation somewhere to print.
//
// The Windows binary is linked -mwindows and starts with no console, so stdout
// goes nowhere even when it was launched from a terminal. Commands that report
// to the person who typed them -- the self-tests, the wallet phrase commands --
// call this first.
//
// Only when there is nowhere for stdout to go already: if the caller redirected
// it to a file or a pipe, that handle is inherited and works, and reopening it
// on CONOUT$ would take the output away from the file and put it on the screen.
inline void AttachTerminal()
{
#ifdef _WIN32
HANDLE hOut = GetStdHandle(STD_OUTPUT_HANDLE);
if (hOut != NULL && hOut != INVALID_HANDLE_VALUE)
return;
if (AttachConsole(ATTACH_PARENT_PROCESS))
{
// Return values ignored on purpose: if the reopen fails there is
// nowhere left to report it, and the exit status still carries the
// result.
freopen("CONOUT$", "w", stdout);
freopen("CONOUT$", "w", stderr);
}
#endif
}
inline int OutputDebugStringF(const char* pszFormat, ...) BF_FORMAT(1, 2);
inline int OutputDebugStringF(const char* pszFormat, ...)
{
#if 1 // debug.log always enabled
// Write to data directory so it's always findable.
//
// Path resolution and the write are both under the lock, because neither
// used to be under anything. strDebugFile was filled in lazily inside an
// `if (empty())`, so one thread could read the path while another was
// still assigning to it -- and at startup three threads log within
// milliseconds of each other. When that raced, fopen got a torn path,
// returned NULL, and the `if (fileout)` below dropped the line silently.
// Measured before this change: unconditional first-statement printfs in
// ThreadBtfAccept, ThreadNostrSeed and the cached-peer thread reached the
// file in only 4/6, 5/6 and 2/6 of runs respectively. Concluding a thread
// never ran because its line was absent was not sound, and the lock also
// stops several threads calling fopen on the same file at once.
static CCriticalSection cs_debugFile;
CRITICAL_BLOCK(cs_debugFile)
{
static string strDebugFile;
if (strDebugFile.empty()) {
string dir = GetAppDir();
if (!dir.empty())
strDebugFile = dir +
#ifdef _WIN32
"\\"
#else
"/"
#endif
+ "debug.log";
else
strDebugFile = "debug.log";
}
// Latched by a failed rename in the roll below, which cannot be
// retried usefully and must not be retried endlessly.
static bool fRollDisabled = false;
FILE* fileout = fopen(strDebugFile.c_str(), "a");
if (fileout && nMaxDebugFileSize > 0 && !fRollDisabled)
{
// Roll an overgrown debug.log before adding to it. Nothing in the
// tree shrinks this file once the process is running (there is no
// ShrinkDebugFile, and even Bitcoin's only ran at startup), so a
// node that stays up for months grows the log without bound --
// production hit ~2 GiB. The file is opened and closed per line,
// so a rename is safe here: the next line simply reopens the
// path. One generation is kept as debug.log.old; logrotate
// (contrib/logrotate/) handles anything longer-term.
int64 nSize = GetFilesize(fileout);
if (nSize >= 0 && nSize > nMaxDebugFileSize)
{
fclose(fileout);
string strOldFile = strDebugFile + ".old";
remove(strOldFile.c_str()); // rename() won't clobber on Windows
bool fRolled = (rename(strDebugFile.c_str(), strOldFile.c_str()) == 0);
int nRenameErrno = errno; // before fopen() can overwrite it
fileout = fopen(strDebugFile.c_str(), "a");
if (fRolled)
{
if (fileout)
fprintf(fileout,
"debug.log grew past %lld MB; previous contents moved to debug.log.old (-maxdebugfilesize)\n",
(long long)(nMaxDebugFileSize / 1024 / 1024));
}
else if (nRenameErrno == ENOENT)
{
// The file went away between the size check and the
// rename, so an external rotator (logrotate) got there
// first. Nothing left to roll and nothing wrong: the
// fopen above has already recreated it. Latching on this
// would let a benign race with logrotate switch the cap
// off for the rest of the run.
}
else
{
// The file is still over the cap, so this branch would be
// reached again on the next line and every line after it.
// Unlatched, the complaint about failing to roll becomes
// the runaway growth the roll exists to prevent. Say it
// once and stop trying -- on stderr too, because whatever
// blocked the rename (read-only mount, permissions, EXDEV
// across a bind mount) may equally block the log write.
fRollDisabled = true;
fprintf(stderr,
"cannot roll %s (rename to .old failed: %s); -maxdebugfilesize disabled for this run\n",
strDebugFile.c_str(), strerror(nRenameErrno));
if (fileout)
fprintf(fileout,
"cannot roll debug.log (rename to .old failed: %s); -maxdebugfilesize disabled for this run\n",
strerror(nRenameErrno));
}
}
}
if (fileout)
{
va_list arg_ptr;
va_start(arg_ptr, pszFormat);
vfprintf(fileout, pszFormat, arg_ptr);
va_end(arg_ptr);
fclose(fileout);
}
}
#ifndef _WIN32
// Headless build: also echo to the console (the Windows path below returns
// early before reaching the console print, which is fine for the GUI app).
{
va_list arg_ptr;
va_start(arg_ptr, pszFormat);
vprintf(pszFormat, arg_ptr);
va_end(arg_ptr);
fflush(stdout);
}
#endif
// accumulate a line at a time
static CCriticalSection cs_OutputDebugStringF;
CRITICAL_BLOCK(cs_OutputDebugStringF)
{
static char pszBuffer[50000];
static char* pend;
if (pend == NULL)
pend = pszBuffer;
va_list arg_ptr;
va_start(arg_ptr, pszFormat);
int limit = END(pszBuffer) - pend - 2;
int ret = _vsnprintf(pend, limit, pszFormat, arg_ptr);
va_end(arg_ptr);
if (ret < 0 || ret >= limit)
{
pend = END(pszBuffer) - 2;
*pend++ = '\n';
}
else
pend += ret;
*pend = '\0';
char* p1 = pszBuffer;
char* p2;
while (p2 = strchr(p1, '\n'))
{
p2++;
char c = *p2;
*p2 = '\0';
OutputDebugStringA(p1);
*p2 = c;
p1 = p2;
}
if (p1 != pszBuffer)
memmove(pszBuffer, p1, pend - p1 + 1);
pend -= (p1 - pszBuffer);
return ret;
}
#endif
va_list arg_ptr;
va_start(arg_ptr, pszFormat);
vprintf(pszFormat, arg_ptr);
va_end(arg_ptr);
return 0;
}
inline void heapchk()
{
if (_heapchk() != _HEAPOK)
DebugBreak();
}
// Randomize the stack to help protect against buffer overrun exploits
#define IMPLEMENT_RANDOMIZE_STACK(ThreadFn) \
{ \
static char nLoops; \
if (nLoops <= 0) \
nLoops = GetRand(50) + 1; \
if (nLoops-- > 1) \
{ \
ThreadFn; \
return; \
} \
}
// The forced-unwind arm has to come first, and it has to rethrow.
//
// On POSIX, _endthread() is pthread_exit(), and glibc implements that by
// throwing abi::__forced_unwind through the stack. It is not a real exception
// and catching it without rethrowing is a fatal error by contract: glibc
// notices and calls abort().
//
// The bare catch(...) below did exactly that. Every shutdown on Linux died with
//
// UNKNOWN EXCEPTION bitflash-node in ThreadSocketHandler()
// FATAL: exception not rethrown
//
// which looked like nothing worse than an ugly exit, and was not: the process
// aborted partway through shutting down, so nothing after StopNode() ran. See
// main_gui.cpp, where DBFlush(true) is now called -- it could never have
// worked while this abort stood in front of it. Windows is unaffected; there
// _endthread() is the CRT's and unwinds nothing.
#ifdef _WIN32
#define CATCH_FORCED_UNWIND
#else
#define CATCH_FORCED_UNWIND \
catch (abi::__forced_unwind&) { \
throw; \
}
#endif
#define CATCH_PRINT_EXCEPTION(pszFn) \
CATCH_FORCED_UNWIND \
catch (std::exception& e) { \
PrintException(&e, (pszFn)); \
} catch (...) { \
PrintException(NULL, (pszFn)); \
}
template<typename T1>
inline uint256 Hash(const T1 pbegin, const T1 pend)
{
uint256 hash1;
SHA256((unsigned char*)&pbegin[0], (pend - pbegin) * sizeof(pbegin[0]), (unsigned char*)&hash1);
uint256 hash2;
SHA256((unsigned char*)&hash1, sizeof(hash1), (unsigned char*)&hash2);
return hash2;
}
template<typename T1, typename T2>
inline uint256 Hash(const T1 p1begin, const T1 p1end,
const T2 p2begin, const T2 p2end)
{
uint256 hash1;
SHA256_CTX ctx;
SHA256_Init(&ctx);
SHA256_Update(&ctx, (unsigned char*)&p1begin[0], (p1end - p1begin) * sizeof(p1begin[0]));
SHA256_Update(&ctx, (unsigned char*)&p2begin[0], (p2end - p2begin) * sizeof(p2begin[0]));
SHA256_Final((unsigned char*)&hash1, &ctx);
uint256 hash2;
SHA256((unsigned char*)&hash1, sizeof(hash1), (unsigned char*)&hash2);
return hash2;
}
template<typename T1, typename T2, typename T3>
inline uint256 Hash(const T1 p1begin, const T1 p1end,
const T2 p2begin, const T2 p2end,
const T3 p3begin, const T3 p3end)
{
uint256 hash1;
SHA256_CTX ctx;
SHA256_Init(&ctx);
SHA256_Update(&ctx, (unsigned char*)&p1begin[0], (p1end - p1begin) * sizeof(p1begin[0]));
SHA256_Update(&ctx, (unsigned char*)&p2begin[0], (p2end - p2begin) * sizeof(p2begin[0]));
SHA256_Update(&ctx, (unsigned char*)&p3begin[0], (p3end - p3begin) * sizeof(p3begin[0]));
SHA256_Final((unsigned char*)&hash1, &ctx);
uint256 hash2;
SHA256((unsigned char*)&hash1, sizeof(hash1), (unsigned char*)&hash2);
return hash2;
}
template<typename T>
uint256 SerializeHash(const T& obj, int nType=SER_GETHASH, int nVersion=VERSION)
{
// Most of the time is spent allocating and deallocating CDataStream's
// buffer. If this ever needs to be optimized further, make a CStaticStream
// class with its buffer on the stack.
CDataStream ss(nType, nVersion);
ss.reserve(10000);
ss << obj;
return Hash(ss.begin(), ss.end());
}
inline uint160 Hash160(const vector<unsigned char>& vch)
{
uint256 hash1;
SHA256(&vch[0], vch.size(), (unsigned char*)&hash1);
uint160 hash2;
RIPEMD160((unsigned char*)&hash1, sizeof(hash1), (unsigned char*)&hash2);
return hash2;
}
|