mirror of
https://github.com/hoytech/strfry.git
synced 2025-06-20 09:50:28 +00:00
@ -1,5 +1,6 @@
|
|||||||
#pragma once
|
#pragma once
|
||||||
|
|
||||||
|
#include<string.h>
|
||||||
#include <hoytech/protected_queue.h>
|
#include <hoytech/protected_queue.h>
|
||||||
|
|
||||||
#include "golpe.h"
|
#include "golpe.h"
|
||||||
@ -71,7 +72,10 @@ struct WriterPipeline {
|
|||||||
try {
|
try {
|
||||||
parseAndVerifyEvent(m.eventJson, secpCtx, verifyMsg, verifyTime, packedStr, jsonStr);
|
parseAndVerifyEvent(m.eventJson, secpCtx, verifyMsg, verifyTime, packedStr, jsonStr);
|
||||||
} catch (std::exception &e) {
|
} catch (std::exception &e) {
|
||||||
if (verboseReject) LW << "Rejected event: " << m.eventJson << " reason: " << e.what();
|
if (verboseReject) {
|
||||||
|
jsonStr = tao::json::to_string(m.eventJson).substr(0,200);
|
||||||
|
LW << "Rejected event: " << jsonStr << " reason: " << e.what();
|
||||||
|
}
|
||||||
numLive--;
|
numLive--;
|
||||||
totalRejected++;
|
totalRejected++;
|
||||||
continue;
|
continue;
|
||||||
|
Reference in New Issue
Block a user