112 static void CreateCloser(CloseWithPacketArg* arg) {  in CreateCloser()  argument
113     fdevent_run_on_main_thread([arg]() {  in CreateCloser()
114         asocket* s = create_local_socket(std::move(arg->socket_fd));  in CreateCloser()
116         arg->bytes_written = 0;  in CreateCloser()
126             arg->bytes_written += data.size();  in CreateCloser()
138         asocket* cause_close_s = create_local_socket(std::move(arg->cause_close_fd));  in CreateCloser()
156     CloseWithPacketArg arg;  in TEST_F()  local
157     arg.socket_fd.reset(socket_fd[1]);  in TEST_F()
158     arg.cause_close_fd.reset(cause_close_fd[1]);  in TEST_F()
161     CreateCloser(&arg);  in TEST_F()
180     CloseWithPacketArg arg;  in TEST_F()  local
181     arg.socket_fd.reset(socket_fd[1]);  in TEST_F()
182     arg.cause_close_fd.reset(cause_close_fd[1]);  in TEST_F()
185     CreateCloser(&arg);  in TEST_F()
194     std::vector<char> buf(arg.bytes_written);  in TEST_F()
195     ASSERT_NE(0u, arg.bytes_written);  in TEST_F()
213     CloseWithPacketArg arg;  in TEST_F()  local
214     arg.socket_fd.reset(socket_fd[1]);  in TEST_F()
215     arg.cause_close_fd.reset(cause_close_fd[1]);  in TEST_F()
218     CreateCloser(&arg);  in TEST_F()