28 ctx context;  variable
43 	context.server->serve();  in server_func()
64 	std::shared_ptr<TTransport> trans(new TFDTransport(context.fds[ctx::CLIENT]));  in setup_client()
73 		trans = std::make_shared<TFDTransport>(context.fds[ctx::CLIENT]);  in setup_client()
102 		serverTransport = std::make_shared<TFDServer>(context.fds[ctx::SERVER]);  in setup_server()
136 	rv = socketpair(AF_UNIX, SOCK_STREAM, 0, &context.fds.front());  in thrift_test_before()
140 	context.server = setup_server();  in thrift_test_before()
143 	rv = pthread_create(&context.server_thread, attrp, server_func, nullptr);  in thrift_test_before()
150 	context.client = setup_client();  in thrift_test_before()
157 	context.server->stop();  in thrift_test_after()
159 	pthread_join(context.server_thread, NULL);  in thrift_test_after()
161 	for (auto &fd : context.fds) {  in thrift_test_after()
166 	context.client.reset();  in thrift_test_after()
167 	context.server.reset();  in thrift_test_after()