We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
https://queue.acm.org/detail.cfm?id=2209336
we have an implicit fifo queue w/ the future impl.
We need to timestamp the requests at time of accept() w/ the low precision timer (10ms steps) and then drop fast before processing requests.
The text was updated successfully, but these errors were encountered:
we have memory backpressure already & timeout already - we need to expose them via the IDL definition.
we will block the processing up to memory limits & also start a timeout on connection parsing.
we need 1 more limits.
seastar::keep_doing([this] { return listener_->accept().then( [this, stats = stats_, limits = limits_]( seastar::connected_socket fd, seastar::socket_address addr) mutable { auto conn = seastar::make_lw_shared<rpc_server_connection>( std::move(fd), limits, addr, stats, ++connection_idx_); open_connections_.insert({connection_idx_, conn}); // DO NOT return the future. Need to execute in parallel handle_client_connection(conn); }); })
handle_client_connection(conn)
rpc_service foo { foo (InputType): OutputType (codel_2000ms); }
and we would parse the backpressure strategy as codel & the timeout for foo would be 2 secs after header.
foo
Sorry, something went wrong.
No branches or pull requests
https://queue.acm.org/detail.cfm?id=2209336
we have an implicit fifo queue w/ the future impl.
We need to timestamp the requests at time of accept() w/ the low precision timer (10ms steps) and then drop fast before processing requests.
The text was updated successfully, but these errors were encountered: