suspendable_stream.rs - source

Files

addr2line

adler

ahash

convert.rs fallback_hash.rs hash_map.rs hash_set.rs lib.rs operations.rs random_state.rs specialize.rs

aho_corasick

packed

teddy

compile.rs mod.rs runtime.rs

api.rs mod.rs pattern.rs rabinkarp.rs vector.rs

ahocorasick.rs automaton.rs buffer.rs byte_frequencies.rs classes.rs dfa.rs error.rs lib.rs nfa.rs prefilter.rs state_id.rs

ansi_term

ansi.rs debug.rs difference.rs display.rs lib.rs style.rs windows.rs write.rs

anyhow

backtrace.rs chain.rs context.rs error.rs fmt.rs kind.rs lib.rs macros.rs ptr.rs wrapper.rs

arc_swap

access.rs as_raw.rs cache.rs compile_fail_tests.rs debt.rs gen_lock.rs lib.rs ref_cnt.rs

arrayref

arrayvec

array.rs array_string.rs char.rs errors.rs lib.rs maybe_uninit.rs

ascii

ascii_char.rs ascii_str.rs ascii_string.rs free_functions.rs lib.rs

assert_matches

async_stream

async_stream.rs lib.rs next.rs yielder.rs

async_stream_impl

async_trait

args.rs expand.rs lib.rs lifetime.rs parse.rs receiver.rs

atty

auto_enums

auto_enums_core

auto_enum

context.rs expr.rs mod.rs visitor.rs

lib.rs utils.rs

auto_enums_derive

derive

core

fmt.rs future.rs iter.rs mod.rs ops.rs

external

std

error.rs io.rs mod.rs

ty_impls

enum_derive.rs lib.rs utils.rs

backoff

retry

backoff.rs clock.rs default.rs error.rs exponential.rs lib.rs retry.rs

backtrace

backtrace

libunwind.rs mod.rs

symbolize

gimli

elf.rs mmap_unix.rs stash.rs

gimli.rs mod.rs

capture.rs lib.rs print.rs types.rs

base32

base64

read

decoder.rs mod.rs

write

encoder.rs encoder_string_writer.rs mod.rs

chunked_encoder.rs decode.rs display.rs encode.rs lib.rs tables.rs

bincode

config

endian.rs int.rs legacy.rs limit.rs mod.rs trailing.rs

de

ser

error.rs internal.rs lib.rs

bip39

crypto.rs error.rs language.rs lib.rs mnemonic.rs mnemonic_type.rs seed.rs util.rs

bitflags

bitvec

blake3

ffi_avx2.rs ffi_avx512.rs ffi_sse2.rs ffi_sse41.rs guts.rs join.rs lib.rs platform.rs portable.rs traits.rs

block_buffer

block_padding

borsh

de

ser

lib.rs schema.rs schema_helpers.rs

borsh_derive

borsh_derive_internal

attribute_helpers.rs enum_de.rs enum_ser.rs lib.rs struct_de.rs struct_ser.rs union_de.rs union_ser.rs

borsh_schema_derive_internal

enum_schema.rs helpers.rs lib.rs struct_schema.rs

bs58

alphabet.rs decode.rs encode.rs lib.rs

bstr

bv

byte_slice_cast

byte_unit

u128

constants.rs mod.rs

adjusted_byte.rs byte.rs byte_error.rs byte_unit.rs lib.rs macros.rs

bytecount

integer_simd.rs lib.rs naive.rs

byteorder

bytes

buf

buf_impl.rs buf_mut.rs chain.rs iter.rs limit.rs mod.rs reader.rs take.rs uninit_slice.rs vec_deque.rs writer.rs

fmt

debug.rs hex.rs mod.rs

bytes.rs bytes_mut.rs lib.rs loom.rs

bzip2

bufread.rs lib.rs mem.rs read.rs write.rs

bzip2_sys

cargo_build_bpf

cargo_metadata

dependency.rs diagnostic.rs errors.rs lib.rs messages.rs

cargo_platform

cfg.rs error.rs lib.rs

cargo_test_bpf

cast

cc

lib.rs windows_registry.rs

cfg_if

chrono

format

mod.rs parse.rs parsed.rs scan.rs strftime.rs

naive

date.rs datetime.rs internals.rs isoweek.rs time.rs

offset

fixed.rs local.rs mod.rs utc.rs

sys

date.rs datetime.rs div.rs lib.rs round.rs sys.rs

chrono_humanize

humantime.rs lib.rs

clap

colored

color.rs control.rs lib.rs style.rs

combine

parser

byte.rs char.rs choice.rs combinator.rs error.rs function.rs item.rs mod.rs range.rs repeat.rs sequence.rs

stream

buffered.rs easy.rs mod.rs state.rs

error.rs lib.rs

console

ansi.rs common_term.rs kb.rs lib.rs term.rs unix_term.rs utils.rs

const_fn

ast.rs error.rs iter.rs lib.rs to_tokens.rs utils.rs

constant_time_eq

core_affinity

cpufeatures

crc32fast

specialized

mod.rs pclmulqdq.rs

baseline.rs combine.rs lib.rs table.rs

criterion_stats

bivariate

bootstrap.rs mod.rs regression.rs resamples.rs

univariate

kde

kernel.rs mod.rs

outliers

mod.rs tukey.rs

bootstrap.rs mixed.rs mod.rs percentiles.rs resamples.rs sample.rs

float.rs lib.rs tuple.rs

crossbeam_channel

flavors

array.rs at.rs list.rs mod.rs never.rs tick.rs zero.rs

channel.rs context.rs counter.rs err.rs lib.rs select.rs select_macro.rs utils.rs waker.rs

crossbeam_deque

deque.rs lib.rs

crossbeam_epoch

sync

list.rs mod.rs queue.rs

atomic.rs collector.rs default.rs deferred.rs epoch.rs guard.rs internal.rs lib.rs

crossbeam_queue

array_queue.rs err.rs lib.rs seg_queue.rs

crossbeam_utils

atomic

atomic_cell.rs consume.rs mod.rs seq_lock.rs

sync

mod.rs parker.rs sharded_lock.rs wait_group.rs

backoff.rs cache_padded.rs lib.rs thread.rs

crunchy

crypto_mac

errors.rs lib.rs

csv

byte_record.rs cookbook.rs deserializer.rs error.rs lib.rs reader.rs serializer.rs string_record.rs tutorial.rs writer.rs

csv_core

lib.rs reader.rs writer.rs

ctrlc

platform

unix

error.rs lib.rs signal.rs

curve25519_dalek

backend

serial

curve_models

scalar_mul

mod.rs pippenger.rs precomputed_straus.rs straus.rs variable_base.rs vartime_double_base.rs

u64

constants.rs field.rs mod.rs scalar.rs

constants.rs edwards.rs field.rs lib.rs macros.rs montgomery.rs prelude.rs ristretto.rs scalar.rs traits.rs window.rs

dashmap

mapref

entry.rs mod.rs multiple.rs one.rs

rayon

setref

mod.rs multiple.rs one.rs

iter.rs iter_set.rs lib.rs lock.rs read_only.rs set.rs t.rs util.rs

derivative

ast.rs attr.rs bound.rs clone.rs cmp.rs debug.rs default.rs hash.rs lib.rs matcher.rs paths.rs utils.rs

derive_more

derive_utils

ast.rs lib.rs parse.rs utils.rs

dialoguer

prompts

confirm.rs input.rs mod.rs multi_select.rs password.rs select.rs sort.rs

edit.rs lib.rs theme.rs validate.rs

digest

digest.rs dyn_digest.rs errors.rs fixed.rs lib.rs variable.rs xof.rs

dir_diff

dirs_next

dirs_sys_next

lib.rs xdg_user_dirs.rs

dlopen

dlopen_derive

api.rs common.rs lib.rs multi_api.rs wrapper.rs

doc_comment

dtoa

diyfp.rs dtoa.rs lib.rs

ed25519

ed25519_dalek

constants.rs errors.rs keypair.rs lib.rs public.rs secret.rs signature.rs

either

encoding_rs

ascii.rs big5.rs data.rs euc_jp.rs euc_kr.rs gb18030.rs handles.rs iso_2022_jp.rs lib.rs macros.rs mem.rs replacement.rs shift_jis.rs single_byte.rs utf_16.rs utf_8.rs variant.rs x_user_defined.rs

enum_iterator

enum_iterator_derive

env_logger

filter

mod.rs regex.rs

fmt

humantime

extern_impl.rs mod.rs

writer

termcolor

extern_impl.rs mod.rs

ethabi

ethbloom

ethereum

account.rs block.rs header.rs lib.rs log.rs receipt.rs transaction.rs util.rs

ethereum_types

hash.rs lib.rs uint.rs

evm

backend

memory.rs mod.rs

executor

stack

mod.rs state.rs

evm_bridge

evm_core

eval

arithmetic.rs bitwise.rs macros.rs misc.rs mod.rs

error.rs lib.rs memory.rs opcode.rs stack.rs utils.rs valids.rs

evm_gasometer

consts.rs costs.rs lib.rs memory.rs utils.rs

evm_rpc

error.rs lib.rs serialize.rs

evm_runtime

eval

macros.rs mod.rs system.rs

context.rs handler.rs interrupt.rs lib.rs

evm_state

sdk

src

deserialize_utils.rs

context.rs error.rs executor.rs lib.rs persist_old.rs state.rs storage.rs transactions.rs types.rs

evm_utils

failure

backtrace

internal.rs mod.rs

error

error_impl.rs mod.rs

as_fail.rs box_std.rs compat.rs context.rs error_message.rs lib.rs macros.rs result_ext.rs sync_failure.rs

failure_derive

fake_simd

fast_math

atan.rs exp.rs float.rs lib.rs log.rs

fd_lock

error.rs lib.rs unix.rs

filetime

unix

linux.rs mod.rs utimes.rs

fixed_hash

flate2

deflate

bufread.rs mod.rs read.rs write.rs

ffi

gz

bufread.rs mod.rs read.rs write.rs

zlib

bufread.rs mod.rs read.rs write.rs

bufreader.rs crc.rs lib.rs mem.rs zio.rs

fnv

foreign_types

foreign_types_shared

form_urlencoded

fs_extra

dir.rs error.rs file.rs lib.rs

futures

futures_channel

mpsc

mod.rs queue.rs sink_impl.rs

lib.rs lock.rs oneshot.rs

futures_core

task

__internal

atomic_waker.rs mod.rs

future.rs lib.rs stream.rs

futures_executor

enter.rs lib.rs local_pool.rs

futures_io

futures_macro

join.rs lib.rs select.rs

futures_sink

futures_task

arc_wake.rs future_obj.rs lib.rs noop_waker.rs spawn.rs waker.rs waker_ref.rs

futures_util

async_await

join_mod.rs mod.rs pending.rs poll.rs random.rs select_mod.rs

future

io

lock

bilock.rs mod.rs mutex.rs

sink

buffer.rs close.rs drain.rs err_into.rs fanout.rs feed.rs flush.rs map_err.rs mod.rs send.rs send_all.rs unfold.rs with.rs with_flat_map.rs

stream

task

mod.rs spawn.rs

fns.rs lib.rs never.rs unfold_state.rs

gag

buffer.rs gag.rs hold.rs lib.rs redirect.rs

generic_array

arr.rs functional.rs hex.rs impl_serde.rs impls.rs iter.rs lib.rs sequence.rs

gethostname

getrandom

error.rs error_impls.rs lib.rs linux_android.rs use_file.rs util.rs util_libc.rs

gimli

globset

glob.rs lib.rs pathutil.rs

goauth

auth.rs credentials.rs fetcher.rs lib.rs scopes.rs

goblin

h2

half

bfloat

binary16

bfloat.rs binary16.rs lib.rs slice.rs

hash256_std_hasher

hash32

fnv.rs lib.rs murmur3.rs

hash_db

hashbrown

external_trait_impls

raw

bitmask.rs mod.rs sse2.rs

lib.rs macros.rs map.rs scopeguard.rs set.rs

heck

camel.rs kebab.rs lib.rs mixed.rs shouty_kebab.rs shouty_snake.rs snake.rs title.rs

hex

error.rs lib.rs

hidapi

error.rs ffi.rs lib.rs

histogram

hmac

hmac_drbg

http

header

map.rs mod.rs name.rs value.rs

uri

authority.rs builder.rs mod.rs path.rs port.rs scheme.rs

byte_str.rs convert.rs error.rs extensions.rs lib.rs method.rs request.rs response.rs status.rs version.rs

http_body

lib.rs next.rs size_hint.rs

httparse

simd

avx2.rs mod.rs sse42.rs

iter.rs lib.rs macros.rs

httpdate

httpdate.rs lib.rs

humantime

date.rs duration.rs lib.rs wrapper.rs

hyper

body

aggregate.rs body.rs mod.rs to_bytes.rs

client

connect

dns.rs http.rs mod.rs

conn.rs dispatch.rs mod.rs pool.rs service.rs

common

io

mod.rs rewind.rs

buf.rs drain.rs exec.rs lazy.rs mod.rs never.rs sync_wrapper.rs task.rs watch.rs

proto

h1

conn.rs date.rs decode.rs dispatch.rs encode.rs io.rs mod.rs role.rs

h2

client.rs mod.rs ping.rs server.rs

server

accept.rs conn.rs mod.rs shutdown.rs tcp.rs

service

http.rs make.rs mod.rs oneshot.rs util.rs

error.rs headers.rs lib.rs rt.rs upgrade.rs

hyper_rustls

connector.rs lib.rs stream.rs

hyper_tls

client.rs lib.rs stream.rs

idna

lib.rs punycode.rs uts46.rs

ieee754

impls.rs iter.rs lib.rs traits.rs

impl_codec

impl_rlp

impl_serde

lib.rs serialize.rs

indexed

indexmap

map

core

rayon

map.rs mod.rs set.rs

equivalent.rs lib.rs macros.rs map.rs mutable_keys.rs set.rs util.rs

indicatif

format.rs iter.rs lib.rs progress.rs style.rs utils.rs

inflector

cases

camelcase

case

classcase

kebabcase

pascalcase

screamingsnakecase

sentencecase

snakecase

tablecase

titlecase

traincase

numbers

deordinalize

ordinalize

string

constants

deconstantize

demodulize

pluralize

singularize

suffix

foreignkey

input_buffer

instant

lib.rs native.rs

iovec

sys

ipnet

ipext.rs ipnet.rs lib.rs parser.rs

itertools

itoa

jemalloc_ctl

arenas.rs config.rs error.rs keys.rs lib.rs macros.rs opt.rs raw.rs stats.rs thread.rs

jemalloc_sys

jemallocator

jobserver

jsonrpc_client_transports

transports

duplex.rs local.rs mod.rs ws.rs

jsonrpc_core

types

error.rs id.rs mod.rs params.rs request.rs response.rs version.rs

calls.rs delegates.rs io.rs lib.rs middleware.rs

jsonrpc_core_client

jsonrpc_derive

lib.rs options.rs params_style.rs rpc_attr.rs rpc_trait.rs to_client.rs to_delegate.rs

jsonrpc_http_server

handler.rs lib.rs response.rs utils.rs

jsonrpc_pubsub

delegates.rs handler.rs lib.rs manager.rs oneshot.rs subscription.rs typed.rs types.rs

jsonrpc_server_utils

cors.rs hosts.rs lib.rs matcher.rs reactor.rs session.rs stream_codec.rs suspendable_stream.rs

jsonrpc_ws_server

error.rs lib.rs metadata.rs server.rs server_builder.rs session.rs

keccak

keccak_hash

keccak_hasher

kernel32

lazy_static

core_lazy.rs lib.rs

lazycell

libc

unix

linux_like

linux

gnu

b64

x86_64

align.rs mod.rs not_x32.rs

align.rs mod.rs

align.rs mod.rs

align.rs mod.rs

fixed_width_ints.rs lib.rs macros.rs

libloading

os

unix

consts.rs mod.rs

changelog.rs error.rs lib.rs util.rs

librocksdb_sys

linked_hash_map

lock_api

lib.rs mutex.rs remutex.rs rwlock.rs

log

lib.rs macros.rs

lru

matches

maybe_uninit

memchr

x86

avx.rs mod.rs sse2.rs

fallback.rs iter.rs lib.rs naive.rs

memmap2

memoffset

lib.rs offset_of.rs raw_field.rs span_of.rs

mime

lib.rs parse.rs

mime_guess

impl_bin_search.rs lib.rs

miniz_oxide

deflate

buffer.rs core.rs mod.rs stream.rs

inflate

core.rs mod.rs output_buffer.rs stream.rs

lib.rs shared.rs

mio

event

event.rs events.rs mod.rs source.rs

net

tcp

listener.rs mod.rs socket.rs stream.rs

uds

datagram.rs listener.rs mod.rs stream.rs

sys

unix

selector

epoll.rs mod.rs

uds

datagram.rs listener.rs mod.rs socketaddr.rs stream.rs

mod.rs net.rs pipe.rs sourcefd.rs tcp.rs udp.rs waker.rs

interest.rs io_source.rs lib.rs macros.rs poll.rs token.rs waker.rs

mio_extras

channel.rs lib.rs timer.rs

miow

native_tls

imp

net2

sys

unix

impls.rs mod.rs

ext.rs lib.rs socket.rs tcp.rs udp.rs unix.rs utils.rs

nix

num_cpus

lib.rs linux.rs

num_derive

num_enum

num_enum_derive

num_integer

average.rs lib.rs roots.rs

num_traits

ops

checked.rs inv.rs mod.rs mul_add.rs overflowing.rs saturating.rs wrapping.rs

bounds.rs cast.rs float.rs identities.rs int.rs lib.rs macros.rs pow.rs real.rs sign.rs

number_prefix

object

once_cell

imp_pl.rs lib.rs race.rs

opaque_debug

openssl

openssl_probe

openssl_sys

ouroboros

ouroboros_macro

parity_scale_codec

codec.rs compact.rs decode_all.rs depth_limit.rs encode_append.rs encode_like.rs joiner.rs keyedvec.rs lib.rs

parity_scale_codec_derive

decode.rs encode.rs lib.rs trait_bounds.rs utils.rs

parity_ws

capped_buffer.rs communication.rs connection.rs factory.rs frame.rs handler.rs handshake.rs io.rs lib.rs message.rs protocol.rs result.rs stream.rs util.rs

parking_lot

condvar.rs deadlock.rs elision.rs fair_mutex.rs lib.rs mutex.rs once.rs raw_fair_mutex.rs raw_mutex.rs raw_rwlock.rs remutex.rs rwlock.rs util.rs

parking_lot_core

thread_parker

linux.rs mod.rs

lib.rs parking_lot.rs spinwait.rs util.rs word_lock.rs

paste

paste_impl

enum_hack.rs error.rs lib.rs

paw

paw_attributes

paw_raw

pbkdf2

percent_encoding

pest

iterators

flat_pairs.rs mod.rs pair.rs pairs.rs queueable_token.rs tokens.rs

unicode

binary.rs category.rs mod.rs

error.rs lib.rs macros.rs parser.rs parser_state.rs position.rs prec_climber.rs span.rs stack.rs token.rs

pickledb

error.rs extenders.rs iterators.rs lib.rs pickledb.rs serialization.rs

pin_project

pin_project_lite

pin_utils

lib.rs projection.rs stack_pin.rs

plain

error.rs lib.rs methods.rs plain.rs

ppv_lite86

x86_64

lib.rs soft.rs types.rs

pretty_hex

lib.rs pretty_hex.rs

primitive_types

proc_macro2

detection.rs fallback.rs lib.rs marker.rs parse.rs wrapper.rs

proc_macro_crate

proc_macro_error

imp

diagnostic.rs dummy.rs lib.rs macros.rs sealed.rs

proc_macro_error_attr

lib.rs parse.rs settings.rs

proc_macro_hack

error.rs iter.rs lib.rs parse.rs quote.rs

proc_macro_nested

prost

encoding.rs error.rs lib.rs message.rs types.rs

prost_derive

field

group.rs map.rs message.rs mod.rs oneof.rs scalar.rs

prost_types

compiler.rs lib.rs protobuf.rs

quote

ext.rs format.rs ident_fragment.rs lib.rs runtime.rs spanned.rs to_tokens.rs

radium

rand

distributions

bernoulli.rs float.rs integer.rs mod.rs other.rs uniform.rs utils.rs weighted.rs weighted_index.rs

rngs

adapter

mod.rs read.rs reseeding.rs

mock.rs mod.rs small.rs std.rs thread.rs xoshiro256plusplus.rs

seq

index.rs mod.rs

lib.rs prelude.rs rng.rs

rand_chacha

chacha.rs guts.rs lib.rs

rand_core

block.rs error.rs impls.rs le.rs lib.rs os.rs

rand_isaac

isaac.rs isaac64.rs isaac_array.rs lib.rs

raptorq

rayon

delegate.rs lib.rs math.rs option.rs par_either.rs prelude.rs private.rs range.rs range_inclusive.rs result.rs split_producer.rs str.rs string.rs vec.rs

rayon_core

compile_fail

mod.rs quicksort_race1.rs quicksort_race2.rs quicksort_race3.rs rc_return.rs rc_upvar.rs scope_join_bad.rs

join

scope

sleep

counters.rs mod.rs

spawn

thread_pool

job.rs latch.rs lib.rs log.rs private.rs registry.rs unwind.rs util.rs

reed_solomon_erasure

core.rs errors.rs galois_16.rs galois_8.rs inversion_tree.rs lib.rs macros.rs matrix.rs

regex

regex_automata

classes.rs dense.rs dfa.rs lib.rs regex.rs sparse.rs state_id.rs

regex_syntax

remove_dir_all

reqwest

retain_mut

ring

ripemd160

block.rs lib.rs

rlp

error.rs impls.rs lib.rs rlpin.rs stream.rs traits.rs

rlp_derive

de.rs en.rs lib.rs

rocksdb

backup.rs checkpoint.rs column_family.rs compaction_filter.rs compaction_filter_factory.rs comparator.rs db.rs db_iterator.rs db_options.rs db_pinnable_slice.rs ffi_util.rs lib.rs merge_operator.rs perf.rs slice_transform.rs snapshot.rs sst_file_writer.rs write_batch.rs

rpassword

lib.rs zero_on_drop.rs

rustc_demangle

legacy.rs lib.rs v0.rs

rustc_hash

rustc_hex

rustls

rustversion

attr.rs bound.rs constfn.rs date.rs error.rs expr.rs iter.rs lib.rs release.rs time.rs token.rs version.rs

ryu

buffer

pretty

exponent.rs mantissa.rs mod.rs

common.rs d2s.rs d2s_full_table.rs d2s_intrinsics.rs digit_table.rs f2s.rs f2s_intrinsics.rs lib.rs

same_file

scopeguard

scroll

ctx.rs endian.rs error.rs greater.rs leb128.rs lesser.rs lib.rs pread.rs pwrite.rs

scroll_derive

sct

secp256k1

constants.rs context.rs ecdh.rs key.rs lib.rs macros.rs recovery.rs

secp256k1_sys

lib.rs macros.rs recovery.rs types.rs

semver

lib.rs version.rs version_req.rs

semver_parser

generated.rs lexer.rs lib.rs parser.rs range.rs range_set.rs version.rs

serde

de

ignored_any.rs impls.rs mod.rs seed.rs utf8.rs value.rs

private

de.rs doc.rs mod.rs ser.rs size_hint.rs

ser

fmt.rs impls.rs impossible.rs mod.rs

integer128.rs lib.rs macros.rs

serde_bytes

bytebuf.rs bytes.rs de.rs lib.rs ser.rs

serde_cbor

value

de.rs mod.rs ser.rs

de.rs error.rs lib.rs read.rs ser.rs tags.rs write.rs

serde_derive

internals

ast.rs attr.rs case.rs check.rs ctxt.rs mod.rs receiver.rs respan.rs symbol.rs

bound.rs de.rs dummy.rs fragment.rs lib.rs pretend.rs ser.rs try.rs

serde_json

features_check

io

value

de.rs from.rs index.rs mod.rs partial_eq.rs ser.rs

de.rs error.rs iter.rs lib.rs macros.rs map.rs number.rs read.rs ser.rs

serde_urlencoded

ser

key.rs mod.rs pair.rs part.rs value.rs

serde_yaml

value

de.rs from.rs index.rs mod.rs partial_eq.rs ser.rs

de.rs error.rs lib.rs mapping.rs number.rs path.rs ser.rs

sha1

consts.rs lib.rs utils.rs

sha2

sha256

sha512

consts.rs lib.rs sha256.rs sha512.rs

sha3

lib.rs macros.rs paddings.rs reader.rs state.rs

signal_hook

cleanup.rs flag.rs iterator.rs lib.rs pipe.rs

signal_hook_registry

half_lock.rs lib.rs

signature

error.rs lib.rs signature.rs signer.rs verifier.rs

simpl

simple_logger

slab

smallvec

smpl_jwt

snafu

guide

examples

backtrace.rs basic.rs

backtrace_inert.rs lib.rs

snafu_derive

lib.rs shared.rs

socket2

sys

lib.rs sockaddr.rs socket.rs utils.rs

solana_account_decoder

lib.rs parse_account_data.rs parse_bpf_loader.rs parse_config.rs parse_nonce.rs parse_stake.rs parse_sysvar.rs parse_token.rs parse_vote.rs validator_info.rs

solana_accounts_bench

solana_banking_bench

solana_banks_client

solana_banks_interface

solana_banks_server

banks_server.rs lib.rs rpc_banks_service.rs send_transaction_service.rs

solana_bench_exchange

bench.rs cli.rs lib.rs order_book.rs

solana_bench_streamer

solana_bench_tps

bench.rs cli.rs lib.rs

solana_bench_tps_evm

bench.rs bench_evm.rs cli.rs lib.rs

solana_bpf_loader_program

alloc.rs allocator_bump.rs bpf_verifier.rs deprecated.rs lib.rs serialization.rs syscalls.rs upgradeable.rs upgradeable_with_jit.rs with_jit.rs

solana_budget_program

budget_expr.rs budget_instruction.rs budget_processor.rs budget_state.rs lib.rs

solana_clap_utils

fee_payer.rs input_parsers.rs input_validators.rs keypair.rs lib.rs nonce.rs offline.rs

solana_cli

checks.rs cli.rs cluster_query.rs feature.rs inflation.rs lib.rs nonce.rs program.rs send_tpu.rs spend_utils.rs stake.rs test_utils.rs validator_info.rs vote.rs

solana_cli_config

config.rs lib.rs

solana_cli_output

cli_output.rs display.rs lib.rs

solana_client

blockhash_query.rs client_error.rs http_sender.rs lib.rs mock_sender.rs nonce_utils.rs perf_utils.rs pubsub_client.rs rpc_cache.rs rpc_client.rs rpc_config.rs rpc_custom_error.rs rpc_filter.rs rpc_request.rs rpc_response.rs rpc_sender.rs thin_client.rs

solana_config_program

config_instruction.rs config_processor.rs date_instruction.rs lib.rs

solana_core

broadcast_stage

broadcast_fake_shreds_run.rs broadcast_metrics.rs broadcast_utils.rs fail_entry_verification_broadcast_run.rs standard_broadcast_run.rs

evm_rpc_impl

evm_services

block_recorder.rs mod.rs

accounts_hash_verifier.rs banking_stage.rs bigtable_upload_service.rs broadcast_stage.rs cache_block_time_service.rs cluster_info.rs cluster_info_vote_listener.rs cluster_slots.rs cluster_slots_service.rs commitment_service.rs completed_data_sets_service.rs consensus.rs contact_info.rs crds.rs crds_gossip.rs crds_gossip_error.rs crds_gossip_pull.rs crds_gossip_push.rs crds_shards.rs crds_value.rs data_budget.rs deprecated.rs duplicate_shred.rs epoch_slots.rs fetch_stage.rs fork_choice.rs gen_keys.rs gossip_service.rs heaviest_subtree_fork_choice.rs ledger_cleanup_service.rs lib.rs max_slots.rs non_circulating_supply.rs optimistic_confirmation_verifier.rs optimistically_confirmed_bank_tracker.rs packet_hasher.rs ping_pong.rs poh_recorder.rs poh_service.rs progress_map.rs repair_response.rs repair_service.rs repair_weight.rs repair_weighted_traversal.rs replay_stage.rs result.rs retransmit_stage.rs rewards_recorder_service.rs rpc.rs rpc_health.rs rpc_pubsub.rs rpc_pubsub_service.rs rpc_service.rs rpc_subscriptions.rs sample_performance_service.rs send_transaction_service.rs serve_repair.rs serve_repair_service.rs shred_fetch_stage.rs sigverify.rs sigverify_shreds.rs sigverify_stage.rs snapshot_packager_service.rs test_validator.rs tpu.rs transaction_status_service.rs tree_diff.rs tvu.rs validator.rs verified_vote_packets.rs vote_stake_tracker.rs weighted_shuffle.rs window_service.rs

solana_crate_features

solana_csv_to_validator_infos

csv_to_validator_infos.rs

solana_dos

solana_download_utils

solana_evm_loader_program

precompiles

abi_parse.rs builtins.rs compatibility.rs errors.rs mod.rs

account_structure.rs instructions.rs lib.rs processor.rs tx_chunks.rs

solana_exchange_program

exchange_instruction.rs exchange_processor.rs exchange_state.rs lib.rs

solana_failure_program

solana_faucet

faucet.rs faucet_mock.rs lib.rs

solana_frozen_abi

solana_frozen_abi_macro

solana_genesis

address_generator.rs lib.rs solana_genesis_accounts.rs stakes.rs unlocks.rs

solana_ip_address

solana_ip_address_server

ip_address_server.rs

solana_ledger

solana_ledger_tool

bigtable.rs evm_blockstore.rs main.rs

solana_ledger_udev

solana_local_cluster

cluster.rs cluster_tests.rs lib.rs local_cluster.rs

solana_log_analyzer

solana_logger

solana_measure

lib.rs measure.rs thread_mem_usage.rs

solana_merkle_root_bench

solana_merkle_tree

lib.rs merkle_tree.rs

solana_metrics

counter.rs datapoint.rs lib.rs metrics.rs

solana_net_shaper

solana_net_utils

ip_echo_server.rs lib.rs

solana_noop_program

solana_notifier

solana_ownable

lib.rs ownable_instruction.rs ownable_processor.rs

solana_perf

cuda_runtime.rs lib.rs packet.rs perf_libs.rs recycler.rs recycler_cache.rs sigverify.rs test_tx.rs

solana_poh_bench

solana_program

solana_program_test

lib.rs programs.rs

solana_ramp_tps

main.rs results.rs stake.rs tps.rs utils.rs voters.rs

solana_rayon_threadlimit

solana_rbpf

asm_parser.rs assembler.rs call_frames.rs disassembler.rs ebpf.rs elf.rs error.rs fuzz.rs insn_builder.rs jit.rs lib.rs memory_region.rs syscalls.rs user_error.rs verifier.rs vm.rs

solana_remote_wallet

ledger.rs ledger_error.rs lib.rs remote_keypair.rs remote_wallet.rs

solana_runtime

solana_sdk

solana_sdk_macro

solana_secp256k1_program

solana_sleep_program

solana_stake_accounts

arg_parser.rs args.rs main.rs stake_accounts.rs

solana_stake_monitor

solana_stake_o_matic

main.rs validator_list.rs

solana_stake_program

config.rs lib.rs stake_instruction.rs stake_state.rs

solana_storage_bigtable

access_token.rs bigtable.rs compression.rs lib.rs root_ca_certificate.rs

solana_storage_proto

convert.rs lib.rs

solana_store_tool

solana_streamer

lib.rs packet.rs recvmmsg.rs sendmmsg.rs streamer.rs

solana_sys_tuner

solana_tokens

arg_parser.rs args.rs commands.rs db.rs lib.rs spl_token.rs token_display.rs

solana_transaction_status

lib.rs parse_accounts.rs parse_bpf_loader.rs parse_instruction.rs parse_stake.rs parse_system.rs parse_token.rs parse_vote.rs token_balances.rs

solana_upload_perf

solana_version

solana_vest_program

lib.rs vest_instruction.rs vest_processor.rs vest_schedule.rs vest_state.rs

solana_vote_program

vote_state

mod.rs vote_state_0_23_5.rs vote_state_versions.rs

authorized_voters.rs lib.rs vote_instruction.rs vote_transaction.rs

solana_watchtower

spin

lib.rs mutex.rs once.rs rw_lock.rs

spl_associated_token_account

entrypoint.rs lib.rs processor.rs

spl_memo

lib.rs processor.rs

spl_token

error.rs instruction.rs lib.rs native_mint.rs processor.rs state.rs

stable_deref_trait

standback

static_assertions

assert_cfg.rs assert_eq_align.rs assert_eq_size.rs assert_fields.rs assert_impl.rs assert_obj_safe.rs assert_trait.rs assert_type.rs const_assert.rs lib.rs

strsim

structopt

structopt_derive

attrs.rs doc_comments.rs lib.rs parse.rs spanned.rs ty.rs

subtle

symlink

syn

synstructure

lib.rs macros.rs

sysctl

linux

ctl.rs ctl_iter.rs funcs.rs mod.rs

consts.rs ctl_error.rs ctl_flags.rs ctl_info.rs ctl_type.rs ctl_value.rs lib.rs traits.rs

tar

archive.rs builder.rs entry.rs entry_type.rs error.rs header.rs lib.rs pax.rs

tarpc

rpc

client

server

filter.rs throttle.rs

transport

util

client.rs context.rs server.rs transport.rs util.rs

lib.rs rpc.rs serde_transport.rs trace.rs

tarpc_plugins

tempfile

file

imp

dir.rs error.rs lib.rs spooled.rs util.rs

termcolor

terminal_size

textwrap

indentation.rs lib.rs splitting.rs

thiserror

aserror.rs display.rs lib.rs

thiserror_impl

ast.rs attr.rs expand.rs fmt.rs lib.rs prop.rs valid.rs

thread_scoped

time

time_macros

time_macros_impl

time_crate

date.rs ext.rs lib.rs offset.rs time.rs

tiny_keccak

keccak.rs keccakf.rs lib.rs

tinyvec

array

generated_impl.rs

array.rs arrayvec.rs arrayvec_drain.rs lib.rs slicevec.rs tinyvec.rs

tinyvec_macros

tokio

fs

future

block_on.rs maybe_done.rs mod.rs poll_fn.rs ready.rs try_join.rs

io

loom

std

atomic_ptr.rs atomic_u16.rs atomic_u32.rs atomic_u64.rs atomic_u8.rs atomic_usize.rs mod.rs mutex.rs parking_lot.rs unsafe_cell.rs

macros

cfg.rs join.rs loom.rs mod.rs pin.rs ready.rs scoped_tls.rs select.rs support.rs thread_local.rs try_join.rs

net

park

either.rs mod.rs thread.rs

process

unix

driver.rs mod.rs orphan.rs reap.rs

runtime

signal

unix

ctrl_c.rs mod.rs registry.rs unix.rs

stream

sync

mpsc

block.rs bounded.rs chan.rs error.rs list.rs mod.rs unbounded.rs

task

atomic_waker.rs mod.rs

barrier.rs batch_semaphore.rs broadcast.rs mod.rs mutex.rs notify.rs oneshot.rs rwlock.rs semaphore.rs watch.rs

task

blocking.rs local.rs mod.rs spawn.rs task_local.rs yield_now.rs

time

driver

wheel

level.rs mod.rs

entry.rs handle.rs mod.rs sleep.rs

clock.rs error.rs instant.rs interval.rs mod.rs timeout.rs

util

bit.rs linked_list.rs mod.rs rand.rs slab.rs trace.rs try_lock.rs wake.rs

blocking.rs coop.rs lib.rs prelude.rs

tokio_codec

bytes_codec.rs lib.rs lines_codec.rs

tokio_executor

enter.rs error.rs executor.rs global.rs lib.rs park.rs typed.rs

tokio_fs

tokio_io

tokio_reactor

background.rs lib.rs poll_evented.rs registration.rs sharded_rwlock.rs

tokio_rustls

common

handshake.rs mod.rs

client.rs lib.rs server.rs

tokio_serde

tokio_sync

mpsc

block.rs bounded.rs chan.rs list.rs mod.rs unbounded.rs

task

atomic_task.rs mod.rs

lib.rs lock.rs loom.rs oneshot.rs semaphore.rs watch.rs

tokio_tcp

incoming.rs lib.rs listener.rs stream.rs

tokio_threadpool

tokio_tls

tokio_util

codec

bytes_codec.rs decoder.rs encoder.rs framed.rs framed_impl.rs framed_read.rs framed_write.rs length_delimited.rs lines_codec.rs mod.rs

sync

cancellation_token.rs intrusive_double_linked_list.rs mod.rs

cfg.rs either.rs lib.rs loom.rs

toml

datetime.rs de.rs lib.rs macros.rs map.rs ser.rs spanned.rs tokens.rs value.rs

tonic

client

grpc.rs mod.rs service.rs

codec

buffer.rs decode.rs encode.rs mod.rs prost.rs

metadata

encoding.rs key.rs map.rs mod.rs value.rs

server

grpc.rs mod.rs service.rs

transport

channel

endpoint.rs mod.rs tls.rs

server

conn.rs incoming.rs mod.rs tls.rs

service

add_origin.rs connection.rs connector.rs discover.rs io.rs layer.rs mod.rs reconnect.rs router.rs tls.rs

error.rs mod.rs tls.rs

body.rs codegen.rs interceptor.rs lib.rs macros.rs request.rs response.rs status.rs

tower

builder

tower_balance

p2c

layer.rs make.rs mod.rs service.rs

pool

error.rs lib.rs

tower_buffer

error.rs future.rs layer.rs lib.rs message.rs service.rs worker.rs

tower_discover

error.rs lib.rs list.rs stream.rs

tower_layer

identity.rs layer_fn.rs lib.rs stack.rs

tower_limit

concurrency

sync

cell.rs mod.rs semaphore.rs waker.rs

future.rs layer.rs mod.rs service.rs

rate

layer.rs mod.rs rate.rs service.rs

tower_load

constant.rs instrument.rs lib.rs peak_ewma.rs pending_requests.rs

tower_load_shed

error.rs future.rs layer.rs lib.rs

tower_make

lib.rs make_connection.rs make_service.rs

tower_ready_cache

cache.rs error.rs lib.rs

tower_retry

budget.rs future.rs layer.rs lib.rs policy.rs

tower_service

tower_timeout

error.rs future.rs layer.rs lib.rs

tower_util

boxed

mod.rs sync.rs unsync.rs

call_all

common.rs mod.rs ordered.rs unordered.rs

optional

error.rs future.rs mod.rs

either.rs lib.rs oneshot.rs ready.rs service_fn.rs

tracing

dispatcher.rs field.rs instrument.rs level_filters.rs lib.rs macros.rs span.rs stdlib.rs subscriber.rs

tracing_attributes

tracing_core

callsite.rs dispatcher.rs event.rs field.rs lib.rs metadata.rs parent.rs span.rs stdlib.rs subscriber.rs

tracing_futures

executor

lib.rs stdlib.rs

trees

triedb

merkle

mod.rs nibble.rs node.rs

ops

build.rs delete.rs get.rs insert.rs mod.rs

cache.rs error.rs gc.rs impls.rs lib.rs memory.rs mutable.rs rocksdb.rs

triehash

try_lock

tungstenite

handshake

client.rs headers.rs machine.rs mod.rs server.rs

protocol

frame

coding.rs frame.rs mask.rs mod.rs

message.rs mod.rs

client.rs error.rs lib.rs server.rs stream.rs util.rs

typenum

array.rs bit.rs int.rs lib.rs marker_traits.rs operator_aliases.rs private.rs type_operators.rs uint.rs

ucd_trie

lib.rs owned.rs

uint

unicase

unicode

ascii.rs lib.rs

unicode_bidi

char_data

mod.rs tables.rs

deprecated.rs explicit.rs format_chars.rs implicit.rs level.rs lib.rs prepare.rs

unicode_normalization

__test_api.rs decompose.rs lib.rs lookups.rs no_std_prelude.rs normalize.rs perfect_hash.rs quick_check.rs recompose.rs replace.rs stream_safe.rs tables.rs

unicode_segmentation

grapheme.rs lib.rs sentence.rs tables.rs word.rs

unicode_width

lib.rs tables.rs

unicode_xid

lib.rs tables.rs

unix_socket

unreachable

untrusted

url

host.rs lib.rs origin.rs parser.rs path_segments.rs quirks.rs slicing.rs

users

base.rs cache.rs lib.rs mock.rs switch.rs traits.rs

utf8

lib.rs lossy.rs read.rs

utf8_width

vec_map

velas

velas_account_program

velas_faucet

velas_genesis

velas_gossip

velas_install

build_env.rs command.rs config.rs defaults.rs lib.rs stop_process.rs update_manifest.rs

velas_install_init

velas-install-init.rs

velas_keygen

velas_test_validator

velas-test-validator.rs

velas_validator

void

walkdir

dent.rs error.rs lib.rs util.rs

want

webpki

calendar.rs cert.rs der.rs error.rs name.rs signed_data.rs time.rs trust_anchor_util.rs verify_cert.rs webpki.rs

webpki_roots

websocket

client

async.rs builder.rs mod.rs sync.rs

codec

header

accept.rs extensions.rs key.rs mod.rs origin.rs protocol.rs version.rs

server

upgrade

async.rs mod.rs sync.rs

async.rs mod.rs sync.rs

lib.rs receiver.rs result.rs sender.rs

websocket_base

codec

ws

util

header.rs mask.rs mod.rs

dataframe.rs message.rs mod.rs receiver.rs sender.rs

dataframe.rs header.rs lib.rs message.rs result.rs stream.rs

winapi

ws2_32

xattr

sys

linux_macos

linux.rs mod.rs

error.rs lib.rs util.rs

yaml_rust

emitter.rs lib.rs parser.rs scanner.rs yaml.rs

zeroize

zeroize_derive

zstd

block

compressor.rs decompressor.rs mod.rs

stream

read

write

zio

mod.rs reader.rs writer.rs

functions.rs mod.rs raw.rs

zstd_safe

zstd_sys

bindings_experimental.rs lib.rs

use std::io;
use std::time::{Duration, Instant};
use tokio::prelude::*;
use tokio::timer::Delay;

/// `Incoming` is a stream of incoming sockets
/// Polling the stream may return a temporary io::Error (for instance if we can't open the connection because of "too many open files" limit)
/// we use for_each combinator which:
/// 1. Runs for every Ok(socket)
/// 2. Stops on the FIRST Err()
/// So any temporary io::Error will cause the entire server to terminate.
/// This wrapper type for tokio::Incoming stops accepting new connections
/// for a specified amount of time once an io::Error is encountered
pub struct SuspendableStream<S> {
	stream: S,
	next_delay: Duration,
	initial_delay: Duration,
	max_delay: Duration,
	timeout: Option<Delay>,
}

impl<S> SuspendableStream<S> {
	/// construct a new Suspendable stream, given tokio::Incoming
	/// and the amount of time to pause for.
	pub fn new(stream: S) -> Self {
		SuspendableStream {
			stream,
			next_delay: Duration::from_millis(20),
			initial_delay: Duration::from_millis(10),
			max_delay: Duration::from_secs(5),
			timeout: None,
		}
	}
}

impl<S, I> Stream for SuspendableStream<S>
where
	S: Stream<Item = I, Error = io::Error>,
{
	type Item = I;
	type Error = ();

	fn poll(&mut self) -> Result<Async<Option<Self::Item>>, ()> {
		loop {
			if let Some(mut timeout) = self.timeout.take() {
				match timeout.poll() {
					Ok(Async::Ready(_)) => {}
					Ok(Async::NotReady) => {
						self.timeout = Some(timeout);
						return Ok(Async::NotReady);
					}
					Err(err) => {
						warn!("Timeout error {:?}", err);
						task::current().notify();
						return Ok(Async::NotReady);
					}
				}
			}

			match self.stream.poll() {
				Ok(item) => {
					if self.next_delay > self.initial_delay {
						self.next_delay = self.initial_delay;
					}
					return Ok(item);
				}
				Err(ref err) => {
					if connection_error(err) {
						warn!("Connection Error: {:?}", err);
						continue;
					}
					self.next_delay = if self.next_delay < self.max_delay {
						self.next_delay * 2
					} else {
						self.next_delay
					};
					debug!("Error accepting connection: {}", err);
					debug!("The server will stop accepting connections for {:?}", self.next_delay);
					self.timeout = Some(Delay::new(Instant::now() + self.next_delay));
				}
			}
		}
	}
}

/// assert that the error was a connection error
fn connection_error(e: &io::Error) -> bool {
	e.kind() == io::ErrorKind::ConnectionRefused
		|| e.kind() == io::ErrorKind::ConnectionAborted
		|| e.kind() == io::ErrorKind::ConnectionReset
}