Lines Matching refs:transport
39 ThriftTransport *transport = NULL; in test_create_and_destroy() local
46 g_object_get (G_OBJECT (object), "transport", &transport, in test_create_and_destroy()
56 ThriftTransport *transport = NULL; in test_open_and_close() local
78 transport = g_object_new (THRIFT_TYPE_FRAMED_TRANSPORT, in test_open_and_close()
82 g_assert (thrift_framed_transport_open (transport, NULL) == TRUE); in test_open_and_close()
83 g_assert (thrift_framed_transport_is_open (transport) == TRUE); in test_open_and_close()
84 g_assert (thrift_framed_transport_close (transport, NULL) == TRUE); in test_open_and_close()
85 g_object_unref (transport); in test_open_and_close()
93 transport = g_object_new (THRIFT_TYPE_FRAMED_TRANSPORT, in test_open_and_close()
96 g_assert (thrift_framed_transport_open (transport, &err) == FALSE); in test_open_and_close()
97 g_object_unref (transport); in test_open_and_close()
113 ThriftTransport *transport = NULL; in test_read_and_write() local
131 transport = g_object_new (THRIFT_TYPE_FRAMED_TRANSPORT, in test_read_and_write()
135 g_assert (thrift_framed_transport_open (transport, NULL) == TRUE); in test_read_and_write()
136 g_assert (thrift_framed_transport_is_open (transport)); in test_read_and_write()
139 thrift_framed_transport_write (transport, buf, 10, NULL); in test_read_and_write()
140 thrift_framed_transport_flush (transport, NULL); in test_read_and_write()
142 thrift_framed_transport_write (transport, buf, 1, NULL); in test_read_and_write()
143 thrift_framed_transport_flush (transport, NULL); in test_read_and_write()
145 thrift_framed_transport_write (transport, buf, 10, NULL); in test_read_and_write()
146 thrift_framed_transport_flush (transport, NULL); in test_read_and_write()
148 thrift_framed_transport_write (transport, buf, 10, NULL); in test_read_and_write()
149 thrift_framed_transport_flush (transport, NULL); in test_read_and_write()
151 thrift_framed_transport_write_end (transport, NULL); in test_read_and_write()
152 thrift_framed_transport_flush (transport, NULL); in test_read_and_write()
153 thrift_framed_transport_close (transport, NULL); in test_read_and_write()
155 g_object_unref (transport); in test_read_and_write()
208 ThriftTransport *transport = NULL; in test_read_after_peer_close() local
218 transport = g_object_new (THRIFT_TYPE_FRAMED_TRANSPORT, in test_read_after_peer_close()
223 g_assert (thrift_transport_open (transport, NULL) == TRUE); in test_read_after_peer_close()
224 g_assert (thrift_transport_is_open (transport)); in test_read_after_peer_close()
229 thrift_transport_read (transport, buf, 10, &err); in test_read_after_peer_close()
235 thrift_transport_read_end (transport, &err); in test_read_after_peer_close()
238 thrift_transport_close (transport, &err); in test_read_after_peer_close()
241 g_object_unref (transport); in test_read_after_peer_close()
252 ThriftServerTransport *transport = NULL; in thrift_socket_server_open() local
259 transport = THRIFT_SERVER_TRANSPORT (tsocket); in thrift_socket_server_open()
260 thrift_server_transport_listen (transport, NULL); in thrift_socket_server_open()
262 client = thrift_server_transport_accept (transport, NULL); in thrift_socket_server_open()
274 ThriftServerTransport *transport = NULL; in thrift_server() local
282 transport = THRIFT_SERVER_TRANSPORT (tsocket); in thrift_server()
283 thrift_server_transport_listen (transport, NULL); in thrift_server()
287 thrift_server_transport_accept (transport, NULL), in thrift_server()