diff --git a/src/apps/relay/RelayIngester.cpp b/src/apps/relay/RelayIngester.cpp index b81654d..ca65cb6 100644 --- a/src/apps/relay/RelayIngester.cpp +++ b/src/apps/relay/RelayIngester.cpp @@ -33,7 +33,7 @@ void RelayServer::runIngester(ThreadPool::Thread &thr) { ingesterProcessEvent(txn, msg->connId, msg->ipAddr, secpCtx, arr[1], writerMsgs); } catch (std::exception &e) { sendOKResponse(msg->connId, arr[1].at("id").get_string(), false, std::string("invalid: ") + e.what()); - LI << "Rejected invalid event: " << e.what(); + if (cfg().relay__logging__invalidEvents) LI << "Rejected invalid event: " << e.what(); } } else if (cmd == "REQ") { if (cfg().relay__logging__dumpInReqs) LI << "[" << msg->connId << "] dumpInReq: " << msg->payload; diff --git a/src/apps/relay/golpe.yaml b/src/apps/relay/golpe.yaml index bbe5dc9..6bcacf3 100644 --- a/src/apps/relay/golpe.yaml +++ b/src/apps/relay/golpe.yaml @@ -77,6 +77,9 @@ config: - name: relay__logging__dbScanPerf desc: "Log performance metrics for initial REQ database scans" default: false + - name: relay__logging__invalidEvents + desc: "Log reason for invalid event rejection? Can be disabled to silence excessive logging" + default: true - name: relay__numThreads__ingester desc: Ingester threads: route incoming requests, validate events/sigs