Searched refs:from_stream (Results 1 – 16 of 16) sorted by relevance
111 pub fn from_stream(sock: UnixStream) -> Self { in from_stream() method112 Self::new(Endpoint::<SlaveReq>::from_stream(sock)) in from_stream()151 let fs_cache = SlaveFsCacheReq::from_stream(p1); in test_slave_fs_cache_req_set_failed()162 let fs_cache = SlaveFsCacheReq::from_stream(p1); in test_slave_fs_cache_send_failure()186 let fs_cache = SlaveFsCacheReq::from_stream(p1); in test_slave_fs_cache_recv_negative()187 let mut master = Endpoint::<SlaveReq>::from_stream(p2); in test_slave_fs_cache_recv_negative()
105 Ok(Self::from_stream(sock)) in connect()109 pub fn from_stream(sock: UnixStream) -> Self { in from_stream() method648 let mut slave = Endpoint::<MasterReq>::from_stream(sock); in send_data()676 let mut slave = Endpoint::<MasterReq>::from_stream(sock); in send_fd()832 let mut slave = Endpoint::<MasterReq>::from_stream(sock); in send_recv()
155 sub_sock: Endpoint::<SlaveReq>::from_stream(rx), in new()431 let fs_cache = SlaveFsCacheReq::from_stream(stream); in test_master_slave_req_handler()461 let fs_cache = SlaveFsCacheReq::from_stream(stream); in test_master_slave_req_handler_with_ack()
35 Endpoint::<MasterReq>::from_stream(fd), in accept()
96 pub fn from_stream(sock: UnixStream, max_queue_num: u64) -> Self { in from_stream() method97 Self::new(Endpoint::<MasterReq>::from_stream(sock), max_queue_num) in from_stream()722 (master, Endpoint::from_stream(slave)) in create_pair()734 let mut slave = Endpoint::<MasterReq>::from_stream(listener.accept().unwrap().unwrap()); in create_master()
618 let vu_req = SlaveFsCacheReq::from_stream(sock); in set_slave_req_fd()819 let endpoint = Endpoint::<MasterReq>::from_stream(p1); in test_slave_req_handler_new()
102 GoogleCredentials.from_stream(116 GoogleCredentials.from_stream(140 GoogleCredentials.from_stream(
56 credential = GoogleCredentials.from_stream(self.credential_file)
179 return GoogleCredentials.from_stream(_SERVICE_CREDS_FILE)
38 let vhost_user_net = Master::from_stream(socket, 16 /* # of queues */); in new()
43 let vhost_user_blk = Master::from_stream(socket, 1 /* queues_num */); in new()
54 let master = Master::from_stream(socket, default_queue_size as u64); in new()
729 credentials = self.get_a_google_credentials_object().from_stream(737 credentials = self.get_a_google_credentials_object().from_stream(747 self.get_a_google_credentials_object().from_stream(763 self.get_a_google_credentials_object().from_stream(778 self.get_a_google_credentials_object().from_stream(786 self.get_a_google_credentials_object().from_stream(792 creds = client.GoogleCredentials.from_stream(credentials_file)801 creds1 = client.GoogleCredentials.from_stream(credentials_file)814 creds1 = client.GoogleCredentials.from_stream(credentials_file)
484 StandardStreamLock::from_stream(self) in lock()490 fn from_stream(stream: &StandardStream) -> StandardStreamLock<'_> { in from_stream() method503 fn from_stream(stream: &StandardStream) -> StandardStreamLock { in from_stream() method
1291 def from_stream(credential_filename): member in GoogleCredentials
388 * Add `TcpStream::from_stream` which converts a std TCP stream to Mio.