Lines Matching refs:srv_conn
155 UnixSocket*, UnixSocket* srv_conn) { in TEST_F() argument
156 EXPECT_CALL(event_listener_, OnDisconnect(srv_conn)) in TEST_F()
163 auto srv_conn = event_listener_.GetIncomingConnection(); in TEST_F() local
164 ASSERT_TRUE(srv_conn); in TEST_F()
175 EXPECT_CALL(event_listener_, OnDataAvailable(srv_conn.get())) in TEST_F()
181 ASSERT_TRUE(srv_conn->Send("srv>cli")); in TEST_F()
193 ASSERT_EQ(0u, srv_conn->Receive(&msg, sizeof(msg))); in TEST_F()
194 ASSERT_EQ("", srv_conn->ReceiveString()); in TEST_F()
196 ASSERT_FALSE(srv_conn->Send("bar")); in TEST_F()
221 UnixSocket*, UnixSocket* srv_conn) { in TEST_F() argument
223 EXPECT_CALL(event_listener_, OnDataAvailable(srv_conn)) in TEST_F()
225 InvokeWithoutArgs([srv_conn] { srv_conn->ReceiveString(); })); in TEST_F()
226 EXPECT_CALL(event_listener_, OnDisconnect(srv_conn)) in TEST_F()
292 UnixSocket*, UnixSocket* srv_conn) { in TEST_F() argument
293 EXPECT_CALL(event_listener_, OnDataAvailable(srv_conn)) in TEST_F()
346 .WillOnce(Invoke([this, receive_done](UnixSocket*, UnixSocket* srv_conn) { in TEST_F() argument
347 EXPECT_CALL(event_listener_, OnDataAvailable(srv_conn)) in TEST_F()
523 UnixSocket* srv_conn) { in TEST_F() argument
524 srv_client_conn = srv_conn; in TEST_F()
525 EXPECT_EQ(geteuid(), static_cast<uint32_t>(srv_conn->peer_uid_posix())); in TEST_F()
528 EXPECT_EQ(getpid(), static_cast<pid_t>(srv_conn->peer_pid_linux())); in TEST_F()
581 UnixSocket*, UnixSocket* srv_conn) { in TEST_F() argument
582 EXPECT_CALL(event_listener_, OnDisconnect(srv_conn)) in TEST_F()
588 auto srv_conn = event_listener_.GetIncomingConnection(); in TEST_F() local
589 ASSERT_TRUE(srv_conn); in TEST_F()
616 EXPECT_CALL(event_listener_, OnDataAvailable(srv_conn.get())) in TEST_F()
639 ASSERT_TRUE(srv_conn->Send(srv_str, sizeof(srv_str), buf_fd, in TEST_F()