Function mz_storage::boundary::tcp_boundary::server::handle_compute
source · [−]async fn handle_compute(
client_id: u64,
state: Arc<Mutex<Shared>>,
socket: TcpStream,
render_requests: UnboundedSender<SourceInstanceRequest>,
storage_workers: usize
) -> Result<()>
Expand description
Handle the server side of a compute client connection in socket
, identified by
client_id
. state
is a handle to the shared state.
This function calls into the inner part and upon client termination cleans up state.