#include <limits>
#include <queue>
#include <grpc/grpc.h>
#include "src/core/ext/transport/chttp2/transport/flow_control.h"
#include "src/core/lib/iomgr/exec_ctx.h"
#include "src/libfuzzer/libfuzzer_macro.h"
#include "test/core/transport/chttp2/flow_control_fuzzer.pb.h"
Go to the source code of this file.
◆ DEFINE_PROTO_FUZZER()
DEFINE_PROTO_FUZZER |
( |
const flow_control_fuzzer::Msg & |
msg | ) |
|
◆ ack_initial_window_size
◆ allocated_memory_
◆ bdp_ping
◆ bdp_pong
◆ fc
◆ gpr_now_impl
◆ id
◆ initial_window_size
◆ memory_owner_
MemoryOwner memory_owner_ = memory_quota_->CreateMemoryOwner("owner") |
|
private |
◆ memory_quota_
MemoryQuotaRefPtr memory_quota_ = MakeMemoryQuota("fuzzer") |
|
private |
◆ next_bdp_ping_
Timestamp next_bdp_ping_ = Timestamp::ProcessEpoch() |
|
private |
◆ queued_initial_window_size_
◆ queued_send_max_frame_size_
◆ queued_writes
◆ remote_initial_window_size_
uint32_t remote_initial_window_size_ = kDefaultWindow |
|
private |
◆ remote_transport_window_size_
int64_t remote_transport_window_size_ = kDefaultWindow |
|
private |
◆ scheduled_write_
◆ send_from_remote_
std::deque<SendFromRemote> send_from_remote_ |
|
private |
◆ send_to_remote_
std::deque<SendToRemote> send_to_remote_ |
|
private |
◆ sending_initial_window_size_
◆ size
◆ squelch
◆ stream_window_updates
std::vector<StreamPayload> stream_window_updates |
◆ stream_writes
std::vector<StreamPayload> stream_writes |
◆ streams_
◆ streams_to_update_
◆ tfc_
std::unique_ptr<TransportFlowControl> tfc_ |
|
private |
◆ transport_window_update
◆ window_delta