From 06aece31cf5ddb3f847e18a2f578bc67627260f1 Mon Sep 17 00:00:00 2001 From: Anton Kaliaev Date: Tue, 12 Dec 2017 13:02:40 -0600 Subject: [PATCH] lower the max message size --- consensus/wal.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/consensus/wal.go b/consensus/wal.go index 42b040115..5c45961ff 100644 --- a/consensus/wal.go +++ b/consensus/wal.go @@ -18,7 +18,7 @@ import ( ) const ( - maxMsgSizeBytes = 10024 // 10MB + maxMsgSizeBytes = 1024 // 1MB, must be greater than BlockPartSizeBytes ) //-------------------------------------------------------- @@ -139,6 +139,7 @@ func (wal *baseWAL) Save(msg WALMessage) { // WALSearchOptions are optional arguments to SearchForEndHeight. type WALSearchOptions struct { + // IgnoreDataCorruptionErrors set to true will result in skipping data corruption errors. IgnoreDataCorruptionErrors bool } @@ -227,6 +228,7 @@ func IsDataCorruptionError(err error) bool { return ok } +// DataCorruptionError is an error that occures if data on disk was corrupted. type DataCorruptionError struct { cause error }