diff options
Diffstat (limited to 'test/core/transport/chaotic_good/transport_test.cc')
-rw-r--r-- | test/core/transport/chaotic_good/transport_test.cc | 60 |
1 files changed, 60 insertions, 0 deletions
diff --git a/test/core/transport/chaotic_good/transport_test.cc b/test/core/transport/chaotic_good/transport_test.cc new file mode 100644 index 0000000000..b43098fa7c --- /dev/null +++ b/test/core/transport/chaotic_good/transport_test.cc @@ -0,0 +1,60 @@ +// Copyright 2023 gRPC authors. +// +// Licensed under the Apache License, Version 2.0 (the "License"); +// you may not use this file except in compliance with the License. +// You may obtain a copy of the License at +// +// http://www.apache.org/licenses/LICENSE-2.0 +// +// Unless required by applicable law or agreed to in writing, software +// distributed under the License is distributed on an "AS IS" BASIS, +// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +// See the License for the specific language governing permissions and +// limitations under the License. + +#include "test/core/transport/chaotic_good/transport_test.h" + +namespace grpc_core { +namespace chaotic_good { +namespace testing { + +grpc_event_engine::experimental::Slice SerializedFrameHeader( + FrameType type, uint8_t flags, uint32_t stream_id, uint32_t header_length, + uint32_t message_length, uint32_t message_padding, + uint32_t trailer_length) { + uint8_t buffer[24] = {static_cast<uint8_t>(type), + flags, + 0, + 0, + static_cast<uint8_t>(stream_id), + static_cast<uint8_t>(stream_id >> 8), + static_cast<uint8_t>(stream_id >> 16), + static_cast<uint8_t>(stream_id >> 24), + static_cast<uint8_t>(header_length), + static_cast<uint8_t>(header_length >> 8), + static_cast<uint8_t>(header_length >> 16), + static_cast<uint8_t>(header_length >> 24), + static_cast<uint8_t>(message_length), + static_cast<uint8_t>(message_length >> 8), + static_cast<uint8_t>(message_length >> 16), + static_cast<uint8_t>(message_length >> 24), + static_cast<uint8_t>(message_padding), + static_cast<uint8_t>(message_padding >> 8), + static_cast<uint8_t>(message_padding >> 16), + static_cast<uint8_t>(message_padding >> 24), + static_cast<uint8_t>(trailer_length), + static_cast<uint8_t>(trailer_length >> 8), + static_cast<uint8_t>(trailer_length >> 16), + static_cast<uint8_t>(trailer_length >> 24)}; + return grpc_event_engine::experimental::Slice::FromCopiedBuffer(buffer, 24); +} + +grpc_event_engine::experimental::Slice Zeros(uint32_t length) { + std::string zeros(length, 0); + return grpc_event_engine::experimental::Slice::FromCopiedBuffer(zeros.data(), + length); +} + +} // namespace testing +} // namespace chaotic_good +} // namespace grpc_core |