Lines Matching refs:transport
94 ThriftTransport *transport = NULL; in test_open_and_close() local
115 transport = THRIFT_TRANSPORT (tsocket); in test_open_and_close()
116 thrift_socket_open (transport, NULL); in test_open_and_close()
117 g_assert (thrift_socket_is_open (transport) == TRUE); in test_open_and_close()
118 thrift_socket_close (transport, NULL); in test_open_and_close()
119 g_assert (thrift_socket_is_open (transport) == FALSE); in test_open_and_close()
123 thrift_socket_close (transport, NULL); in test_open_and_close()
129 transport = THRIFT_TRANSPORT (tsocket); in test_open_and_close()
130 g_assert (thrift_socket_open (transport, &err) == FALSE); in test_open_and_close()
137 transport = THRIFT_TRANSPORT (tsocket); in test_open_and_close()
139 g_assert (thrift_socket_open (transport, &err) == FALSE); in test_open_and_close()
152 ThriftTransport *transport = NULL; in test_read_and_write() local
172 transport = THRIFT_TRANSPORT (tsocket); in test_read_and_write()
173 g_assert (thrift_socket_open (transport, NULL) == TRUE); in test_read_and_write()
174 g_assert (thrift_socket_is_open (transport)); in test_read_and_write()
175 thrift_socket_write (transport, buf, 10, NULL); in test_read_and_write()
179 thrift_socket_write (transport, buf, 1, NULL); in test_read_and_write()
182 thrift_socket_write_end (transport, NULL); in test_read_and_write()
183 thrift_socket_flush (transport, NULL); in test_read_and_write()
184 thrift_socket_close (transport, NULL); in test_read_and_write()
294 ThriftServerTransport *transport = NULL; in thrift_socket_server_open() local
300 transport = THRIFT_SERVER_TRANSPORT (tsocket); in thrift_socket_server_open()
301 thrift_server_transport_listen (transport, NULL); in thrift_socket_server_open()
303 client = thrift_server_transport_accept (transport, NULL); in thrift_socket_server_open()
316 ThriftServerTransport *transport = NULL; in thrift_socket_server() local
324 transport = THRIFT_SERVER_TRANSPORT (tsocket); in thrift_socket_server()
325 thrift_server_transport_listen (transport, NULL); in thrift_socket_server()
326 client = thrift_server_transport_accept (transport, NULL); in thrift_socket_server()