aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/blockcodecs/fuzz
diff options
context:
space:
mode:
authoryazevnul <yazevnul@yandex-team.ru>2022-02-10 16:46:48 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:46:48 +0300
commit9abfb1a53b7f7b791444d1378e645d8fad9b06ed (patch)
tree49e222ea1c5804306084bb3ae065bb702625360f /library/cpp/blockcodecs/fuzz
parent8cbc307de0221f84c80c42dcbe07d40727537e2c (diff)
downloadydb-9abfb1a53b7f7b791444d1378e645d8fad9b06ed.tar.gz
Restoring authorship annotation for <yazevnul@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/blockcodecs/fuzz')
-rw-r--r--library/cpp/blockcodecs/fuzz/main.cpp146
-rw-r--r--library/cpp/blockcodecs/fuzz/proto/case.proto20
-rw-r--r--library/cpp/blockcodecs/fuzz/proto/ya.make24
-rw-r--r--library/cpp/blockcodecs/fuzz/ya.make28
4 files changed, 109 insertions, 109 deletions
diff --git a/library/cpp/blockcodecs/fuzz/main.cpp b/library/cpp/blockcodecs/fuzz/main.cpp
index cddf79f7f6..763c6c5a10 100644
--- a/library/cpp/blockcodecs/fuzz/main.cpp
+++ b/library/cpp/blockcodecs/fuzz/main.cpp
@@ -1,84 +1,84 @@
-#include <contrib/libs/protobuf-mutator/src/libfuzzer/libfuzzer_macro.h>
+#include <contrib/libs/protobuf-mutator/src/libfuzzer/libfuzzer_macro.h>
#include <google/protobuf/stubs/logging.h>
-
+
#include <library/cpp/blockcodecs/codecs.h>
#include <library/cpp/blockcodecs/fuzz/proto/case.pb.h>
#include <library/cpp/blockcodecs/stream.h>
-#include <util/stream/input.h>
-#include <util/stream/length.h>
+#include <util/stream/input.h>
+#include <util/stream/length.h>
#include <util/stream/mem.h>
-#include <util/stream/null.h>
-#include <util/stream/str.h>
+#include <util/stream/null.h>
+#include <util/stream/str.h>
+
+using NBlockCodecs::NFuzz::TPackUnpackCase;
+using NBlockCodecs::TCodedOutput;
+using NBlockCodecs::TDecodedInput;
-using NBlockCodecs::NFuzz::TPackUnpackCase;
-using NBlockCodecs::TCodedOutput;
-using NBlockCodecs::TDecodedInput;
+static void ValidateBufferSize(const ui32 size) {
+ Y_ENSURE(size > 0 && size <= 16ULL * 1024);
+}
-static void ValidateBufferSize(const ui32 size) {
- Y_ENSURE(size > 0 && size <= 16ULL * 1024);
-}
-
-static void DoOnlyDecode(const TPackUnpackCase& case_) {
- if (!case_.GetPacked()) {
- return;
+static void DoOnlyDecode(const TPackUnpackCase& case_) {
+ if (!case_.GetPacked()) {
+ return;
}
- TMemoryInput mi(case_.GetData().data(), case_.GetData().size());
- TDecodedInput di(&mi);
- TNullOutput no;
- TCountingOutput cno(&no);
- TransferData(&di, &cno);
+ TMemoryInput mi(case_.GetData().data(), case_.GetData().size());
+ TDecodedInput di(&mi);
+ TNullOutput no;
+ TCountingOutput cno(&no);
+ TransferData(&di, &cno);
+}
+
+static void DoDecodeEncode(const TPackUnpackCase& case_) {
+ auto* const codec = NBlockCodecs::Codec(case_.GetCodecName());
+ Y_ENSURE(codec);
+
+ TMemoryInput mi(case_.GetData().data(), case_.GetData().size());
+ TDecodedInput di(&mi, codec);
+ TStringStream decoded;
+ TransferData(&di, &decoded);
+ TNullOutput no;
+ TCountingOutput cno(&no);
+ TCodedOutput co(&cno, codec, case_.GetBufferLength());
+ TransferData(&decoded, &co);
+ co.Flush();
+
+ Y_VERIFY((case_.GetData().size() > 0) == (cno.Counter() > 0));
+ Y_VERIFY((case_.GetData().size() > 0) == (decoded.Str().size() > 0));
+}
+
+static void DoEncodeDecode(const TPackUnpackCase& case_) {
+ auto* const codec = NBlockCodecs::Codec(case_.GetCodecName());
+ Y_ENSURE(codec);
+
+ TMemoryInput mi(case_.GetData().data(), case_.GetData().size());
+ TStringStream encoded;
+ TCodedOutput co(&encoded, codec, case_.GetBufferLength());
+ TransferData(&mi, &co);
+ co.Flush();
+ TStringStream decoded;
+ TDecodedInput di(&encoded, codec);
+ TransferData(&di, &decoded);
+
+ Y_VERIFY((case_.GetData().size() > 0) == (encoded.Str().size() > 0));
+ Y_VERIFY(case_.GetData() == decoded.Str());
+}
+
+DEFINE_BINARY_PROTO_FUZZER(const TPackUnpackCase& case_) {
+ try {
+ if (!case_.GetCodecName()) {
+ DoOnlyDecode(case_);
+ return;
+ }
+
+ ValidateBufferSize(case_.GetBufferLength());
+ if (case_.GetPacked()) {
+ DoDecodeEncode(case_);
+ } else {
+ DoEncodeDecode(case_);
+ }
+ } catch (const std::exception&) {
+ }
}
-
-static void DoDecodeEncode(const TPackUnpackCase& case_) {
- auto* const codec = NBlockCodecs::Codec(case_.GetCodecName());
- Y_ENSURE(codec);
-
- TMemoryInput mi(case_.GetData().data(), case_.GetData().size());
- TDecodedInput di(&mi, codec);
- TStringStream decoded;
- TransferData(&di, &decoded);
- TNullOutput no;
- TCountingOutput cno(&no);
- TCodedOutput co(&cno, codec, case_.GetBufferLength());
- TransferData(&decoded, &co);
- co.Flush();
-
- Y_VERIFY((case_.GetData().size() > 0) == (cno.Counter() > 0));
- Y_VERIFY((case_.GetData().size() > 0) == (decoded.Str().size() > 0));
-}
-
-static void DoEncodeDecode(const TPackUnpackCase& case_) {
- auto* const codec = NBlockCodecs::Codec(case_.GetCodecName());
- Y_ENSURE(codec);
-
- TMemoryInput mi(case_.GetData().data(), case_.GetData().size());
- TStringStream encoded;
- TCodedOutput co(&encoded, codec, case_.GetBufferLength());
- TransferData(&mi, &co);
- co.Flush();
- TStringStream decoded;
- TDecodedInput di(&encoded, codec);
- TransferData(&di, &decoded);
-
- Y_VERIFY((case_.GetData().size() > 0) == (encoded.Str().size() > 0));
- Y_VERIFY(case_.GetData() == decoded.Str());
-}
-
-DEFINE_BINARY_PROTO_FUZZER(const TPackUnpackCase& case_) {
- try {
- if (!case_.GetCodecName()) {
- DoOnlyDecode(case_);
- return;
- }
-
- ValidateBufferSize(case_.GetBufferLength());
- if (case_.GetPacked()) {
- DoDecodeEncode(case_);
- } else {
- DoEncodeDecode(case_);
- }
- } catch (const std::exception&) {
- }
-}
diff --git a/library/cpp/blockcodecs/fuzz/proto/case.proto b/library/cpp/blockcodecs/fuzz/proto/case.proto
index 622ed0ce47..85518b0da9 100644
--- a/library/cpp/blockcodecs/fuzz/proto/case.proto
+++ b/library/cpp/blockcodecs/fuzz/proto/case.proto
@@ -1,10 +1,10 @@
-syntax="proto3";
-
-package NBlockCodecs.NFuzz;
-
-message TPackUnpackCase {
- bool Packed = 1;
- uint32 BufferLength = 2;
- string CodecName = 3;
- bytes Data = 4;
-}
+syntax="proto3";
+
+package NBlockCodecs.NFuzz;
+
+message TPackUnpackCase {
+ bool Packed = 1;
+ uint32 BufferLength = 2;
+ string CodecName = 3;
+ bytes Data = 4;
+}
diff --git a/library/cpp/blockcodecs/fuzz/proto/ya.make b/library/cpp/blockcodecs/fuzz/proto/ya.make
index dbd32e0f1c..da840bc8c9 100644
--- a/library/cpp/blockcodecs/fuzz/proto/ya.make
+++ b/library/cpp/blockcodecs/fuzz/proto/ya.make
@@ -1,14 +1,14 @@
-OWNER(
- yazevnul
- g:util
-)
-
-PROTO_LIBRARY()
-
-SRCS(
- case.proto
-)
-
+OWNER(
+ yazevnul
+ g:util
+)
+
+PROTO_LIBRARY()
+
+SRCS(
+ case.proto
+)
+
EXCLUDE_TAGS(GO_PROTO)
-END()
+END()
diff --git a/library/cpp/blockcodecs/fuzz/ya.make b/library/cpp/blockcodecs/fuzz/ya.make
index dee86d56a2..bc8becc9e1 100644
--- a/library/cpp/blockcodecs/fuzz/ya.make
+++ b/library/cpp/blockcodecs/fuzz/ya.make
@@ -3,21 +3,21 @@ OWNER(
g:util
)
-IF (NOT MSVC)
- FUZZ()
+IF (NOT MSVC)
+ FUZZ()
- SIZE(MEDIUM)
+ SIZE(MEDIUM)
- SRCS(
- main.cpp
- )
-
- PEERDIR(
- contrib/libs/protobuf
- contrib/libs/protobuf-mutator
+ SRCS(
+ main.cpp
+ )
+
+ PEERDIR(
+ contrib/libs/protobuf
+ contrib/libs/protobuf-mutator
library/cpp/blockcodecs
library/cpp/blockcodecs/fuzz/proto
- )
-
- END()
-ENDIF()
+ )
+
+ END()
+ENDIF()