Lines Matching refs:transport
40 ThriftTransport *transport = NULL; in test_open_and_close() local
62 transport = g_object_new (THRIFT_TYPE_FRAMED_TRANSPORT, in test_open_and_close()
66 g_assert (thrift_framed_transport_open (transport, NULL) == TRUE); in test_open_and_close()
67 g_assert (thrift_framed_transport_is_open (transport) == TRUE); in test_open_and_close()
68 g_assert (thrift_framed_transport_close (transport, NULL) == TRUE); in test_open_and_close()
69 g_object_unref (transport); in test_open_and_close()
77 transport = g_object_new (THRIFT_TYPE_FRAMED_TRANSPORT, in test_open_and_close()
80 g_assert (thrift_framed_transport_open (transport, &err) == FALSE); in test_open_and_close()
81 g_object_unref (transport); in test_open_and_close()
97 ThriftTransport *transport = NULL; in test_read_and_write() local
115 transport = g_object_new (THRIFT_TYPE_FRAMED_TRANSPORT, in test_read_and_write()
119 g_assert (thrift_framed_transport_open (transport, NULL) == TRUE); in test_read_and_write()
120 g_assert (thrift_framed_transport_is_open (transport)); in test_read_and_write()
123 thrift_framed_transport_write (transport, buf, 2, NULL); in test_read_and_write()
124 thrift_framed_transport_flush (transport, NULL); in test_read_and_write()
126 thrift_framed_transport_write (transport, buf, 3, NULL); in test_read_and_write()
127 thrift_framed_transport_flush (transport, NULL); in test_read_and_write()
129 thrift_framed_transport_write_end (transport, NULL); in test_read_and_write()
130 thrift_framed_transport_flush (transport, NULL); in test_read_and_write()
131 thrift_framed_transport_close (transport, NULL); in test_read_and_write()
133 g_object_unref (transport); in test_read_and_write()
144 ThriftServerTransport *transport = NULL; in thrift_socket_server_open() local
155 transport = THRIFT_SERVER_TRANSPORT (tsocket); in thrift_socket_server_open()
156 thrift_server_transport_listen (transport, NULL); in thrift_socket_server_open()
158 client = thrift_server_transport_accept (transport, NULL); in thrift_socket_server_open()
171 ThriftServerTransport *transport = NULL; in thrift_server() local
184 transport = THRIFT_SERVER_TRANSPORT (tsocket); in thrift_server()
185 thrift_server_transport_listen (transport, NULL); in thrift_server()
189 thrift_server_transport_accept (transport, NULL), in thrift_server()