1294 lines
55 KiB
C
1294 lines
55 KiB
C
/*
|
|
* Licensed to the Apache Software Foundation (ASF) under one
|
|
* or more contributor license agreements. See the NOTICE file
|
|
* distributed with this work for additional information
|
|
* regarding copyright ownership. The ASF licenses this file
|
|
* to you under the Apache License, Version 2.0 (the
|
|
* "License"); you may not use this file except in compliance
|
|
* with the License. You may obtain a copy of the License at
|
|
*
|
|
* http://www.apache.org/licenses/LICENSE-2.0
|
|
*
|
|
* Unless required by applicable law or agreed to in writing,
|
|
* software distributed under the License is distributed on an
|
|
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
|
|
* KIND, either express or implied. See the License for the
|
|
* specific language governing permissions and limitations
|
|
* under the License.
|
|
*/
|
|
|
|
/* Disable string-function optimizations when glibc is used, as these produce
|
|
compiler warnings about string length when a string function is used inside
|
|
a call to g_assert () */
|
|
#if !defined(__APPLE__) && !defined(__FreeBSD__) && \
|
|
!defined(__OpenBSD__) && !defined(__NetBSD__)
|
|
#include <features.h>
|
|
#endif
|
|
|
|
#ifdef __GLIBC__
|
|
#define __NO_STRING_INLINES 1
|
|
#endif
|
|
|
|
#include <unistd.h>
|
|
#include <stdlib.h>
|
|
#include <stdio.h>
|
|
#include <netdb.h>
|
|
#include <string.h>
|
|
#include <sys/wait.h>
|
|
|
|
#include <thrift/c_glib/protocol/thrift_protocol.h>
|
|
#include <thrift/c_glib/transport/thrift_socket.h>
|
|
#include <thrift/c_glib/transport/thrift_server_socket.h>
|
|
#include <thrift/c_glib/transport/thrift_framed_transport.h>
|
|
|
|
#define TEST_BOOL TRUE
|
|
#define TEST_BYTE 123
|
|
#define TEST_I16 12345
|
|
#define TEST_I32 1234567890
|
|
#define TEST_I64 123456789012345
|
|
#define TEST_NI16 (-12345)
|
|
#define TEST_NI32 (-1234567890)
|
|
#define TEST_NI64 (-123456789012345)
|
|
#define TEST_DOUBLE 1234567890.123
|
|
#define TEST_STRING "this is a test string 1234567890!@#$%^&*()"
|
|
#define TEST_PORT 51199
|
|
|
|
static int transport_read_count = 0;
|
|
static int transport_read_error = 0;
|
|
static int transport_read_error_at = -1;
|
|
gint32
|
|
my_thrift_transport_read_all (ThriftTransport *transport, gpointer buf,
|
|
guint32 len, GError **error)
|
|
{
|
|
if (transport_read_count != transport_read_error_at
|
|
&& transport_read_error == 0)
|
|
{
|
|
transport_read_count++;
|
|
return thrift_transport_read_all (transport, buf, len, error);
|
|
}
|
|
return -1;
|
|
}
|
|
|
|
static int transport_write_count = 0;
|
|
static int transport_write_error = 0;
|
|
static int transport_write_error_at = -1;
|
|
gboolean
|
|
my_thrift_transport_write (ThriftTransport *transport, const gpointer buf,
|
|
const guint32 len, GError **error)
|
|
{
|
|
if (transport_write_count != transport_write_error_at
|
|
&& transport_write_error == 0)
|
|
{
|
|
transport_write_count++;
|
|
return thrift_transport_write (transport, buf, len, error);
|
|
}
|
|
return FALSE;
|
|
}
|
|
|
|
#define thrift_transport_read_all my_thrift_transport_read_all
|
|
#define thrift_transport_write my_thrift_transport_write
|
|
#include "../src/thrift/c_glib/protocol/thrift_compact_protocol.c"
|
|
#undef thrift_transport_read_all
|
|
#undef thrift_transport_write
|
|
|
|
static void thrift_server_primitives (const int port);
|
|
static void thrift_server_complex_types (const int port);
|
|
static void thrift_server_many_frames (const int port);
|
|
|
|
static void
|
|
test_create_and_destroy (void)
|
|
{
|
|
GObject *object = NULL;
|
|
|
|
/* create an object and then destroy it */
|
|
object = g_object_new (THRIFT_TYPE_COMPACT_PROTOCOL, NULL);
|
|
g_assert (object != NULL);
|
|
g_object_unref (object);
|
|
}
|
|
|
|
static void
|
|
test_initialize (void)
|
|
{
|
|
ThriftSocket *tsocket = NULL;
|
|
ThriftCompactProtocol *protocol = NULL;
|
|
ThriftSocket *temp = NULL;
|
|
|
|
/* create a ThriftTransport */
|
|
tsocket = g_object_new (THRIFT_TYPE_SOCKET, "hostname", "localhost",
|
|
"port", 51188, NULL);
|
|
g_assert (tsocket != NULL);
|
|
/* create a ThriftCompactProtocol using the Transport */
|
|
protocol = g_object_new (THRIFT_TYPE_COMPACT_PROTOCOL, "transport",
|
|
tsocket, NULL);
|
|
g_assert (protocol != NULL);
|
|
/* fetch the properties */
|
|
g_object_get (G_OBJECT (protocol), "transport", &temp, NULL);
|
|
g_object_unref (temp);
|
|
|
|
/* clean up memory */
|
|
g_object_unref (protocol);
|
|
g_object_unref (tsocket);
|
|
}
|
|
|
|
static void
|
|
test_read_and_write_primitives (void)
|
|
{
|
|
int status;
|
|
pid_t pid;
|
|
ThriftSocket *tsocket = NULL;
|
|
ThriftTransport *transport = NULL;
|
|
ThriftCompactProtocol *tc = NULL;
|
|
ThriftProtocol *protocol = NULL;
|
|
gpointer binary = (gpointer *) TEST_STRING;
|
|
guint32 len = strlen (TEST_STRING);
|
|
int port = TEST_PORT;
|
|
|
|
/* fork a server from the client */
|
|
pid = fork ();
|
|
g_assert (pid >= 0);
|
|
|
|
if (pid == 0)
|
|
{
|
|
/* child listens */
|
|
thrift_server_primitives (port);
|
|
exit (0);
|
|
} else {
|
|
/* parent. wait a bit for the socket to be created. */
|
|
sleep (1);
|
|
|
|
/* create a ThriftSocket */
|
|
tsocket = g_object_new (THRIFT_TYPE_SOCKET, "hostname", "localhost",
|
|
"port", port, NULL);
|
|
transport = THRIFT_TRANSPORT (tsocket);
|
|
thrift_transport_open (transport, NULL);
|
|
g_assert (thrift_transport_is_open (transport));
|
|
|
|
/* create a ThriftCompactTransport */
|
|
tc = g_object_new (THRIFT_TYPE_COMPACT_PROTOCOL, "transport",
|
|
tsocket, NULL);
|
|
protocol = THRIFT_PROTOCOL (tc);
|
|
g_assert (protocol != NULL);
|
|
|
|
/* write a bunch of primitives */
|
|
g_assert (thrift_compact_protocol_write_bool (protocol, TEST_BOOL, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_write_byte (protocol, TEST_BYTE, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_write_i16 (protocol, TEST_I16, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_write_i32 (protocol, TEST_I32, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_write_i64 (protocol, TEST_I64, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_write_i16 (protocol, TEST_NI16, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_write_i32 (protocol, TEST_NI32, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_write_i64 (protocol, TEST_NI64, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_write_i16 (protocol, 2, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_write_i32 (protocol, 2, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_write_i64 (protocol, 2, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_write_i16 (protocol, -2, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_write_i32 (protocol, -2, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_write_i64 (protocol, -2, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_write_double (protocol,
|
|
TEST_DOUBLE, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_write_string (protocol,
|
|
TEST_STRING, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_write_string (protocol, "", NULL) > 0);
|
|
g_assert (thrift_compact_protocol_write_binary (protocol, binary,
|
|
len, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_write_binary (protocol, NULL, 0, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_write_binary (protocol, binary,
|
|
len, NULL) > 0);
|
|
|
|
/* test write errors */
|
|
transport_write_error = 1;
|
|
g_assert (thrift_compact_protocol_write_byte (protocol, TEST_BYTE,
|
|
NULL) == -1);
|
|
g_assert (thrift_compact_protocol_write_i16 (protocol, TEST_I16, NULL) == -1);
|
|
g_assert (thrift_compact_protocol_write_i32 (protocol, TEST_I32, NULL) == -1);
|
|
g_assert (thrift_compact_protocol_write_i64 (protocol, TEST_I64, NULL) == -1);
|
|
g_assert (thrift_compact_protocol_write_i16 (protocol, TEST_NI16,
|
|
NULL) == -1);
|
|
g_assert (thrift_compact_protocol_write_i32 (protocol, TEST_NI32,
|
|
NULL) == -1);
|
|
g_assert (thrift_compact_protocol_write_i64 (protocol, TEST_NI64,
|
|
NULL) == -1);
|
|
g_assert (thrift_compact_protocol_write_double (protocol, TEST_DOUBLE,
|
|
NULL) == -1);
|
|
g_assert (thrift_compact_protocol_write_binary (protocol, binary, len,
|
|
NULL) == -1);
|
|
transport_write_error = 0;
|
|
|
|
/* test binary partial failure */
|
|
transport_write_count = 0;
|
|
transport_write_error_at = 1;
|
|
g_assert (thrift_compact_protocol_write_binary (protocol, binary,
|
|
len, NULL) == -1);
|
|
transport_write_error_at = -1;
|
|
|
|
/* clean up */
|
|
thrift_transport_close (transport, NULL);
|
|
g_object_unref (tsocket);
|
|
g_object_unref (protocol);
|
|
g_assert (wait (&status) == pid);
|
|
g_assert (status == 0);
|
|
}
|
|
}
|
|
|
|
static void
|
|
test_read_and_write_complex_types (void)
|
|
{
|
|
int status;
|
|
pid_t pid;
|
|
ThriftSocket *tsocket = NULL;
|
|
ThriftTransport *transport = NULL;
|
|
ThriftCompactProtocol *tc = NULL;
|
|
ThriftProtocol *protocol = NULL;
|
|
int port = TEST_PORT;
|
|
|
|
/* fork a server from the client */
|
|
pid = fork ();
|
|
g_assert (pid >= 0);
|
|
|
|
if (pid == 0)
|
|
{
|
|
/* child listens */
|
|
thrift_server_complex_types (port);
|
|
exit (0);
|
|
} else {
|
|
/* parent. wait a bit for the socket to be created. */
|
|
sleep (1);
|
|
|
|
/* create a ThriftSocket */
|
|
tsocket = g_object_new (THRIFT_TYPE_SOCKET, "hostname", "localhost",
|
|
"port", port, NULL);
|
|
transport = THRIFT_TRANSPORT (tsocket);
|
|
thrift_transport_open (transport, NULL);
|
|
g_assert (thrift_transport_is_open (transport));
|
|
|
|
/* create a ThriftCompactTransport */
|
|
tc = g_object_new (THRIFT_TYPE_COMPACT_PROTOCOL, "transport",
|
|
tsocket, NULL);
|
|
protocol = THRIFT_PROTOCOL (tc);
|
|
g_assert (protocol != NULL);
|
|
|
|
/* test structures */
|
|
g_assert (thrift_compact_protocol_write_struct_begin (protocol,
|
|
NULL, NULL) == 0);
|
|
g_assert (thrift_compact_protocol_write_struct_end (protocol, NULL) == 0);
|
|
|
|
/* test field state w.r.t. deltas */
|
|
|
|
g_assert (thrift_compact_protocol_write_field_begin (protocol, "test",
|
|
T_DOUBLE, 1, NULL) == 1);
|
|
g_assert (thrift_compact_protocol_write_field_begin (protocol, "test",
|
|
T_DOUBLE,
|
|
16, NULL) == 1);
|
|
g_assert (thrift_compact_protocol_write_field_begin (protocol, "test",
|
|
T_DOUBLE,
|
|
17, NULL) == 1);
|
|
g_assert (thrift_compact_protocol_write_field_begin (protocol, "test",
|
|
T_DOUBLE,
|
|
15, NULL) > 1);
|
|
g_assert (thrift_compact_protocol_write_field_begin (protocol, "test",
|
|
T_DOUBLE,
|
|
30, NULL) == 1);
|
|
g_assert (thrift_compact_protocol_write_field_begin (protocol, "test",
|
|
T_DOUBLE,
|
|
46, NULL) > 1);
|
|
g_assert (thrift_compact_protocol_write_field_begin (protocol, "test",
|
|
T_DOUBLE,
|
|
47, NULL) == 1);
|
|
|
|
/* test fields */
|
|
g_assert (thrift_compact_protocol_write_field_begin (protocol, "test",
|
|
T_DOUBLE,
|
|
1, NULL) > 1);
|
|
g_assert (thrift_compact_protocol_write_field_end (protocol, NULL) == 0);
|
|
|
|
/* test field state w.r.t. structs */
|
|
|
|
g_assert (thrift_compact_protocol_write_field_begin (protocol, "test",
|
|
T_DOUBLE,
|
|
1, NULL) > 1);
|
|
g_assert (thrift_compact_protocol_write_field_end (protocol, NULL) == 0);
|
|
g_assert (thrift_compact_protocol_write_field_begin (protocol, "test",
|
|
T_DOUBLE,
|
|
16, NULL) == 1);
|
|
g_assert (thrift_compact_protocol_write_field_end (protocol, NULL) == 0);
|
|
|
|
g_assert (thrift_compact_protocol_write_struct_begin (protocol,
|
|
NULL, NULL) == 0);
|
|
g_assert (thrift_compact_protocol_write_field_begin (protocol, "test",
|
|
T_DOUBLE,
|
|
17, NULL) > 1);
|
|
g_assert (thrift_compact_protocol_write_field_end (protocol, NULL) == 0);
|
|
|
|
g_assert (thrift_compact_protocol_write_struct_begin (protocol,
|
|
NULL, NULL) == 0);
|
|
g_assert (thrift_compact_protocol_write_field_begin (protocol, "test",
|
|
T_DOUBLE,
|
|
18, NULL) > 1);
|
|
g_assert (thrift_compact_protocol_write_field_end (protocol, NULL) == 0);
|
|
g_assert (thrift_compact_protocol_write_field_begin (protocol, "test",
|
|
T_DOUBLE,
|
|
19, NULL) == 1);
|
|
g_assert (thrift_compact_protocol_write_field_end (protocol, NULL) == 0);
|
|
g_assert (thrift_compact_protocol_write_struct_end (protocol, NULL) == 0);
|
|
|
|
g_assert (thrift_compact_protocol_write_field_begin (protocol, "test",
|
|
T_DOUBLE,
|
|
18, NULL) == 1);
|
|
g_assert (thrift_compact_protocol_write_field_end (protocol, NULL) == 0);
|
|
g_assert (thrift_compact_protocol_write_field_begin (protocol, "test",
|
|
T_DOUBLE,
|
|
25, NULL) == 1);
|
|
g_assert (thrift_compact_protocol_write_field_end (protocol, NULL) == 0);
|
|
g_assert (thrift_compact_protocol_write_struct_end (protocol, NULL) == 0);
|
|
|
|
g_assert (thrift_compact_protocol_write_field_begin (protocol, "test",
|
|
T_DOUBLE,
|
|
17, NULL) == 1);
|
|
g_assert (thrift_compact_protocol_write_field_end (protocol, NULL) == 0);
|
|
|
|
/* test field state w.r.t. bools */
|
|
|
|
/* deltas */
|
|
/* non-bool field -> bool field -> non-bool field */
|
|
g_assert (thrift_compact_protocol_write_field_begin (protocol, "test",
|
|
T_DOUBLE,
|
|
18, NULL) == 1);
|
|
g_assert (thrift_compact_protocol_write_field_end (protocol, NULL) == 0);
|
|
g_assert (thrift_compact_protocol_write_field_begin (protocol, "test", T_BOOL,
|
|
19, NULL) == 0);
|
|
g_assert (thrift_compact_protocol_write_bool (protocol, TEST_BOOL,
|
|
NULL) == 1);
|
|
g_assert (thrift_compact_protocol_write_field_end (protocol, NULL) == 0);
|
|
g_assert (thrift_compact_protocol_write_field_begin (protocol, "test",
|
|
T_DOUBLE,
|
|
20, NULL) == 1);
|
|
g_assert (thrift_compact_protocol_write_field_end (protocol, NULL) == 0);
|
|
/* bool -> bool field -> bool */
|
|
g_assert (thrift_compact_protocol_write_bool (protocol, TEST_BOOL, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_write_field_begin (protocol, "test", T_BOOL,
|
|
21, NULL) == 0);
|
|
g_assert (thrift_compact_protocol_write_bool (protocol, TEST_BOOL,
|
|
NULL) == 1);
|
|
g_assert (thrift_compact_protocol_write_field_end (protocol, NULL) == 0);
|
|
g_assert (thrift_compact_protocol_write_bool (protocol, TEST_BOOL, NULL) > 0);
|
|
|
|
/* no deltas */
|
|
/* non-bool field -> bool field -> non-bool field */
|
|
g_assert (thrift_compact_protocol_write_field_begin (protocol, "test",
|
|
T_DOUBLE,
|
|
1, NULL) > 1);
|
|
g_assert (thrift_compact_protocol_write_field_end (protocol, NULL) == 0);
|
|
g_assert (thrift_compact_protocol_write_field_begin (protocol, "test", T_BOOL,
|
|
1, NULL) == 0);
|
|
g_assert (thrift_compact_protocol_write_bool (protocol, TEST_BOOL, NULL) > 1);
|
|
g_assert (thrift_compact_protocol_write_field_end (protocol, NULL) == 0);
|
|
g_assert (thrift_compact_protocol_write_field_begin (protocol, "test",
|
|
T_DOUBLE,
|
|
1, NULL) > 1);
|
|
g_assert (thrift_compact_protocol_write_field_end (protocol, NULL) == 0);
|
|
/* bool -> bool field -> bool */
|
|
g_assert (thrift_compact_protocol_write_bool (protocol, TEST_BOOL, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_write_field_begin (protocol, "test", T_BOOL,
|
|
1, NULL) == 0);
|
|
g_assert (thrift_compact_protocol_write_bool (protocol, TEST_BOOL, NULL) > 1);
|
|
g_assert (thrift_compact_protocol_write_field_end (protocol, NULL) == 0);
|
|
g_assert (thrift_compact_protocol_write_bool (protocol, TEST_BOOL, NULL) > 0);
|
|
|
|
/* test write error */
|
|
transport_write_error = 1;
|
|
g_assert (thrift_compact_protocol_write_field_begin (protocol, "test",
|
|
T_DOUBLE,
|
|
1, NULL) == -1);
|
|
transport_write_error = 0;
|
|
|
|
/* test 2nd write error */
|
|
transport_write_count = 0;
|
|
transport_write_error_at = 1;
|
|
g_assert (thrift_compact_protocol_write_field_begin (protocol, "test",
|
|
T_DOUBLE,
|
|
1, NULL) == -1);
|
|
transport_write_error_at = -1;
|
|
|
|
/* test 2nd read failure on a field */
|
|
thrift_compact_protocol_write_byte (protocol, T_DOUBLE, NULL);
|
|
|
|
/* test write_field_stop */
|
|
g_assert (thrift_compact_protocol_write_field_stop (protocol, NULL) > 0);
|
|
|
|
/* write a map */
|
|
g_assert (thrift_compact_protocol_write_map_begin (protocol, T_DOUBLE,
|
|
T_DOUBLE,
|
|
1, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_write_map_end (protocol, NULL) == 0);
|
|
|
|
/* test 1st read failure on map---nothing to do on our side */
|
|
|
|
/* test 2nd read failure on a map */
|
|
thrift_compact_protocol_write_byte (protocol, T_DOUBLE, NULL);
|
|
|
|
/* test 1st write failure on a map */
|
|
transport_write_error = 1;
|
|
g_assert (thrift_compact_protocol_write_map_begin (protocol, T_DOUBLE,
|
|
T_DOUBLE,
|
|
1, NULL) == -1);
|
|
transport_write_error = 0;
|
|
|
|
/* test 2nd write failure on a map */
|
|
transport_write_count = 0;
|
|
transport_write_error_at = 1;
|
|
g_assert (thrift_compact_protocol_write_map_begin (protocol, T_DOUBLE,
|
|
T_DOUBLE,
|
|
1, NULL) == -1);
|
|
transport_write_error_at = -1;
|
|
|
|
/* test negative map size */
|
|
thrift_compact_protocol_write_varint32 (tc, -10, NULL);
|
|
thrift_compact_protocol_write_byte (protocol, T_DOUBLE, NULL);
|
|
|
|
/* test list operations */
|
|
g_assert (thrift_compact_protocol_write_list_begin (protocol, T_DOUBLE,
|
|
15, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_write_list_end (protocol, NULL) == 0);
|
|
|
|
/* test 1st read failure on a small list---nothing to do on our end */
|
|
|
|
/* test 1st read failure on a big list---nothing to do on our end */
|
|
|
|
/* test 2nd read failure on a big list */
|
|
thrift_compact_protocol_write_byte (protocol, (gint8) 0xf0, NULL);
|
|
|
|
/* test negative list size */
|
|
thrift_compact_protocol_write_byte (protocol, (gint8) 0xf0, NULL);
|
|
thrift_compact_protocol_write_varint32 (tc, -10, NULL);
|
|
|
|
/* test first write error on a small list */
|
|
transport_write_error = 1;
|
|
g_assert (thrift_compact_protocol_write_list_begin (protocol, T_DOUBLE,
|
|
14, NULL) == -1);
|
|
transport_write_error = 0;
|
|
|
|
/* test first write error on a big list */
|
|
transport_write_error = 1;
|
|
g_assert (thrift_compact_protocol_write_list_begin (protocol, T_DOUBLE,
|
|
15, NULL) == -1);
|
|
transport_write_error = 0;
|
|
|
|
/* test 2nd write error on a big list */
|
|
transport_write_count = 0;
|
|
transport_write_error_at = 1;
|
|
g_assert (thrift_compact_protocol_write_list_begin (protocol, T_DOUBLE,
|
|
15, NULL) == -1);
|
|
transport_write_error_at = -1;
|
|
|
|
/* test set operation s*/
|
|
g_assert (thrift_compact_protocol_write_set_begin (protocol, T_DOUBLE,
|
|
1, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_write_set_end (protocol, NULL) == 0);
|
|
|
|
/* invalid protocol */
|
|
g_assert (thrift_compact_protocol_write_byte (protocol, 0, NULL) > 0);
|
|
|
|
/* invalid version */
|
|
g_assert (thrift_compact_protocol_write_byte (protocol, (gint8) 0x82u,
|
|
NULL) > 0);
|
|
g_assert (thrift_compact_protocol_write_byte (protocol, 0, NULL) > 0);
|
|
|
|
/* send a valid message */
|
|
g_assert (thrift_compact_protocol_write_byte (protocol, (gint8) 0x82u,
|
|
NULL) > 0);
|
|
g_assert (thrift_compact_protocol_write_byte (protocol, 0x01u, NULL) > 0);
|
|
thrift_compact_protocol_write_varint32 (tc, 1, NULL);
|
|
thrift_compact_protocol_write_string (protocol, "test", NULL);
|
|
|
|
/* broken 2nd read */
|
|
thrift_compact_protocol_write_byte (protocol, (gint8) 0x82u, NULL);
|
|
|
|
/* send a broken 3rd read */
|
|
thrift_compact_protocol_write_byte (protocol, (gint8) 0x82u, NULL);
|
|
thrift_compact_protocol_write_byte (protocol, 0x01u, NULL);
|
|
|
|
/* send a broken 4th read */
|
|
thrift_compact_protocol_write_byte (protocol, (gint8) 0x82u, NULL);
|
|
thrift_compact_protocol_write_byte (protocol, 0x01u, NULL);
|
|
thrift_compact_protocol_write_varint32 (tc, 1, NULL);
|
|
|
|
/* send a valid message */
|
|
g_assert (thrift_compact_protocol_write_message_begin (protocol, "test",
|
|
T_CALL, 1, NULL) > 0);
|
|
|
|
g_assert (thrift_compact_protocol_write_message_end (protocol, NULL) == 0);
|
|
|
|
/* send broken writes */
|
|
transport_write_error = 1;
|
|
g_assert (thrift_compact_protocol_write_message_begin (protocol, "test",
|
|
T_CALL, 1, NULL) == -1);
|
|
transport_write_error = 0;
|
|
|
|
transport_write_count = 0;
|
|
transport_write_error_at = 1;
|
|
g_assert (thrift_compact_protocol_write_message_begin (protocol, "test",
|
|
T_CALL, 1, NULL) == -1);
|
|
transport_write_error_at = -1;
|
|
|
|
transport_write_count = 0;
|
|
transport_write_error_at = 2;
|
|
g_assert (thrift_compact_protocol_write_message_begin (protocol, "test",
|
|
T_CALL, 1, NULL) == -1);
|
|
transport_write_error_at = -1;
|
|
|
|
transport_write_count = 0;
|
|
transport_write_error_at = 3;
|
|
g_assert (thrift_compact_protocol_write_message_begin (protocol, "test",
|
|
T_CALL, 1, NULL) == -1);
|
|
transport_write_error_at = -1;
|
|
|
|
/* clean up */
|
|
thrift_transport_close (transport, NULL);
|
|
g_object_unref (tsocket);
|
|
g_object_unref (protocol);
|
|
g_assert (wait (&status) == pid);
|
|
g_assert (status == 0);
|
|
}
|
|
}
|
|
|
|
static void
|
|
test_read_and_write_many_frames (void)
|
|
{
|
|
int status;
|
|
pid_t pid;
|
|
ThriftSocket *tsocket = NULL;
|
|
ThriftTransport *transport = NULL;
|
|
ThriftFramedTransport *ft = NULL;
|
|
ThriftCompactProtocol *tc = NULL;
|
|
ThriftProtocol *protocol = NULL;
|
|
gpointer binary = (gpointer *) TEST_STRING;
|
|
const guint32 len = strlen (TEST_STRING);
|
|
int port = TEST_PORT;
|
|
|
|
/* fork a server from the client */
|
|
pid = fork ();
|
|
g_assert (pid >= 0);
|
|
|
|
if (pid == 0)
|
|
{
|
|
/* child listens */
|
|
thrift_server_many_frames (port);
|
|
exit (0);
|
|
} else {
|
|
/* parent. wait a bit for the socket to be created. */
|
|
sleep (1);
|
|
|
|
/* create a ThriftSocket */
|
|
tsocket = g_object_new (THRIFT_TYPE_SOCKET, "hostname", "localhost",
|
|
"port", port, NULL);
|
|
g_assert (tsocket != NULL);
|
|
transport = THRIFT_TRANSPORT (tsocket);
|
|
|
|
/* wrap in a framed transport */
|
|
ft = g_object_new (THRIFT_TYPE_FRAMED_TRANSPORT, "transport", transport,
|
|
"w_buf_size", 1, NULL);
|
|
g_assert (ft != NULL);
|
|
transport = THRIFT_TRANSPORT (ft);
|
|
|
|
thrift_transport_open (transport, NULL);
|
|
g_assert (thrift_transport_is_open (transport));
|
|
|
|
/* create a compact protocol */
|
|
tc = g_object_new (THRIFT_TYPE_COMPACT_PROTOCOL, "transport",
|
|
transport, NULL);
|
|
protocol = THRIFT_PROTOCOL (tc);
|
|
g_assert (protocol != NULL);
|
|
|
|
/* write a bunch of primitives */
|
|
g_assert (thrift_compact_protocol_write_bool (protocol, TEST_BOOL,
|
|
NULL) > 0);
|
|
thrift_transport_flush (transport, NULL);
|
|
g_assert (thrift_compact_protocol_write_byte (protocol, TEST_BYTE,
|
|
NULL) > 0);
|
|
thrift_transport_flush (transport, NULL);
|
|
g_assert (thrift_compact_protocol_write_i16 (protocol, TEST_I16, NULL) > 0);
|
|
thrift_transport_flush (transport, NULL);
|
|
g_assert (thrift_compact_protocol_write_i32 (protocol, TEST_I32, NULL) > 0);
|
|
thrift_transport_flush (transport, NULL);
|
|
g_assert (thrift_compact_protocol_write_i64 (protocol, TEST_I64, NULL) > 0);
|
|
thrift_transport_flush (transport, NULL);
|
|
g_assert (thrift_compact_protocol_write_i16 (protocol, TEST_NI16, NULL) > 0);
|
|
thrift_transport_flush (transport, NULL);
|
|
g_assert (thrift_compact_protocol_write_i32 (protocol, TEST_NI32, NULL) > 0);
|
|
thrift_transport_flush (transport, NULL);
|
|
g_assert (thrift_compact_protocol_write_i64 (protocol, TEST_NI64, NULL) > 0);
|
|
thrift_transport_flush (transport, NULL);
|
|
g_assert (thrift_compact_protocol_write_i16 (protocol, 2, NULL) > 0);
|
|
thrift_transport_flush (transport, NULL);
|
|
g_assert (thrift_compact_protocol_write_i32 (protocol, 2, NULL) > 0);
|
|
thrift_transport_flush (transport, NULL);
|
|
g_assert (thrift_compact_protocol_write_i64 (protocol, 2, NULL) > 0);
|
|
thrift_transport_flush (transport, NULL);
|
|
g_assert (thrift_compact_protocol_write_i16 (protocol, -2, NULL) > 0);
|
|
thrift_transport_flush (transport, NULL);
|
|
g_assert (thrift_compact_protocol_write_i32 (protocol, -2, NULL) > 0);
|
|
thrift_transport_flush (transport, NULL);
|
|
g_assert (thrift_compact_protocol_write_i64 (protocol, -2, NULL) > 0);
|
|
thrift_transport_flush (transport, NULL);
|
|
g_assert (thrift_compact_protocol_write_double (protocol,
|
|
TEST_DOUBLE, NULL) > 0);
|
|
thrift_transport_flush (transport, NULL);
|
|
g_assert (thrift_compact_protocol_write_string (protocol,
|
|
TEST_STRING, NULL) > 0);
|
|
thrift_transport_flush (transport, NULL);
|
|
g_assert (thrift_compact_protocol_write_string (protocol, "", NULL) > 0);
|
|
thrift_transport_flush (transport, NULL);
|
|
g_assert (thrift_compact_protocol_write_binary (protocol, binary,
|
|
len, NULL) > 0);
|
|
thrift_transport_flush (transport, NULL);
|
|
g_assert (thrift_compact_protocol_write_binary (protocol, NULL,
|
|
0, NULL) > 0);
|
|
thrift_transport_flush (transport, NULL);
|
|
g_assert (thrift_compact_protocol_write_binary (protocol, binary,
|
|
len, NULL) > 0);
|
|
thrift_transport_flush (transport, NULL);
|
|
|
|
/* clean up */
|
|
thrift_transport_write_end (transport, NULL);
|
|
thrift_transport_close (transport, NULL);
|
|
g_object_unref (ft);
|
|
g_object_unref (tsocket);
|
|
g_object_unref (tc);
|
|
g_assert (wait (&status) == pid);
|
|
g_assert (status == 0);
|
|
}
|
|
}
|
|
|
|
|
|
static void
|
|
thrift_server_primitives (const int port)
|
|
{
|
|
ThriftServerTransport *transport = NULL;
|
|
ThriftTransport *client = NULL;
|
|
ThriftCompactProtocol *tc = NULL;
|
|
ThriftProtocol *protocol = NULL;
|
|
gboolean value_boolean = FALSE;
|
|
gint8 value_byte = 0,
|
|
zigzag_p16 = 0, zigzag_p32 = 0, zigzag_p64 = 0,
|
|
zigzag_n16 = 0, zigzag_n32 = 0, zigzag_n64 = 0;
|
|
gint16 value_16 = 0;
|
|
gint32 value_32 = 0;
|
|
gint64 value_64 = 0;
|
|
gint16 value_n16 = 0;
|
|
gint32 value_n32 = 0;
|
|
gint64 value_n64 = 0;
|
|
gdouble value_double = 0;
|
|
gchar *string = NULL;
|
|
gchar *empty_string = NULL;
|
|
gpointer binary = NULL;
|
|
guint32 len = 0;
|
|
void *comparator = (void *) TEST_STRING;
|
|
|
|
ThriftServerSocket *tsocket = g_object_new (THRIFT_TYPE_SERVER_SOCKET,
|
|
"port", port, NULL);
|
|
transport = THRIFT_SERVER_TRANSPORT (tsocket);
|
|
thrift_server_transport_listen (transport, NULL);
|
|
client = thrift_server_transport_accept (transport, NULL);
|
|
g_assert (client != NULL);
|
|
|
|
tc = g_object_new (THRIFT_TYPE_COMPACT_PROTOCOL, "transport",
|
|
client, NULL);
|
|
protocol = THRIFT_PROTOCOL (tc);
|
|
|
|
g_assert (thrift_compact_protocol_read_bool (protocol,
|
|
&value_boolean, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_read_byte (protocol, &value_byte, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_read_i16 (protocol, &value_16, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_read_i32 (protocol, &value_32, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_read_i64 (protocol, &value_64, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_read_i16 (protocol, &value_n16, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_read_i32 (protocol, &value_n32, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_read_i64 (protocol, &value_n64, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_read_byte (protocol, &zigzag_p16, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_read_byte (protocol, &zigzag_p32, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_read_byte (protocol, &zigzag_p64, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_read_byte (protocol, &zigzag_n16, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_read_byte (protocol, &zigzag_n32, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_read_byte (protocol, &zigzag_n64, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_read_double (protocol,
|
|
&value_double, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_read_string (protocol, &string, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_read_string (protocol, &empty_string,
|
|
NULL) > 0);
|
|
g_assert (thrift_compact_protocol_read_binary (protocol, &binary,
|
|
&len, NULL) > 0);
|
|
|
|
g_assert (value_boolean == TEST_BOOL);
|
|
g_assert (value_byte == TEST_BYTE);
|
|
g_assert (value_16 == TEST_I16);
|
|
g_assert (value_32 == TEST_I32);
|
|
g_assert (value_64 == TEST_I64);
|
|
g_assert (value_n16 == TEST_NI16);
|
|
g_assert (value_n32 == TEST_NI32);
|
|
g_assert (value_n64 == TEST_NI64);
|
|
g_assert (zigzag_p16 == 4);
|
|
g_assert (zigzag_p32 == 4);
|
|
g_assert (zigzag_p64 == 4);
|
|
g_assert (zigzag_n16 == 3);
|
|
g_assert (zigzag_n32 == 3);
|
|
g_assert (zigzag_n64 == 3);
|
|
g_assert (value_double == TEST_DOUBLE);
|
|
g_assert (strcmp (TEST_STRING, string) == 0);
|
|
g_assert (strcmp ("", empty_string) == 0);
|
|
g_assert (memcmp (comparator, binary, len) == 0);
|
|
|
|
g_free (string);
|
|
g_free (empty_string);
|
|
g_free (binary);
|
|
|
|
g_assert (thrift_compact_protocol_read_binary (protocol, &binary,
|
|
&len, NULL) > 0);
|
|
g_assert (binary == NULL);
|
|
g_assert (len == 0);
|
|
g_free (binary);
|
|
|
|
transport_read_count = 0;
|
|
transport_read_error_at = 0;
|
|
g_assert (thrift_compact_protocol_read_binary (protocol, &binary,
|
|
&len, NULL) == -1);
|
|
transport_read_error_at = -1;
|
|
|
|
transport_read_count = 0;
|
|
transport_read_error_at = 1;
|
|
g_assert (thrift_compact_protocol_read_binary (protocol, &binary,
|
|
&len, NULL) == -1);
|
|
transport_read_error_at = -1;
|
|
|
|
transport_read_error = 1;
|
|
g_assert (thrift_compact_protocol_read_bool (protocol,
|
|
&value_boolean, NULL) == -1);
|
|
g_assert (thrift_compact_protocol_read_byte (protocol,
|
|
&value_byte, NULL) == -1);
|
|
g_assert (thrift_compact_protocol_read_i16 (protocol,
|
|
&value_16, NULL) == -1);
|
|
g_assert (thrift_compact_protocol_read_i32 (protocol, &value_32, NULL) == -1);
|
|
g_assert (thrift_compact_protocol_read_i64 (protocol, &value_64, NULL) == -1);
|
|
g_assert (thrift_compact_protocol_read_i16 (protocol,
|
|
&value_n16, NULL) == -1);
|
|
g_assert (thrift_compact_protocol_read_i32 (protocol, &value_n32, NULL) == -1);
|
|
g_assert (thrift_compact_protocol_read_i64 (protocol, &value_n64, NULL) == -1);
|
|
g_assert (thrift_compact_protocol_read_double (protocol,
|
|
&value_double, NULL) == -1);
|
|
transport_read_error = 0;
|
|
|
|
/* test partial write failure */
|
|
thrift_protocol_read_i32 (protocol, &value_32, NULL);
|
|
|
|
thrift_transport_read_end (client, NULL);
|
|
thrift_transport_close (client, NULL);
|
|
|
|
g_object_unref (tc);
|
|
g_object_unref (client);
|
|
g_object_unref (tsocket);
|
|
}
|
|
|
|
static void
|
|
thrift_server_complex_types (const int port)
|
|
{
|
|
ThriftServerTransport *transport = NULL;
|
|
ThriftTransport *client = NULL;
|
|
ThriftCompactProtocol *tc = NULL;
|
|
ThriftProtocol *protocol = NULL;
|
|
gchar *struct_name = NULL;
|
|
gchar *field_name = NULL;
|
|
gchar *message_name = NULL;
|
|
ThriftType element_type, key_type, value_type, field_type;
|
|
ThriftMessageType message_type;
|
|
gboolean value_boolean = ! TEST_BOOL;
|
|
gint8 value = 0;
|
|
gint16 field_id = 0;
|
|
guint32 size = 0;
|
|
gint32 seqid = 0;
|
|
gint8 version_and_type = 0;
|
|
gint8 protocol_id = 0;
|
|
|
|
ThriftServerSocket *tsocket = g_object_new (THRIFT_TYPE_SERVER_SOCKET,
|
|
"port", port, NULL);
|
|
transport = THRIFT_SERVER_TRANSPORT (tsocket);
|
|
thrift_server_transport_listen (transport, NULL);
|
|
client = thrift_server_transport_accept (transport, NULL);
|
|
g_assert (client != NULL);
|
|
|
|
tc = g_object_new (THRIFT_TYPE_COMPACT_PROTOCOL, "transport",
|
|
client, NULL);
|
|
protocol = THRIFT_PROTOCOL (tc);
|
|
|
|
/* test struct operations */
|
|
|
|
thrift_compact_protocol_read_struct_begin (protocol, &struct_name, NULL);
|
|
thrift_compact_protocol_read_struct_end (protocol, NULL);
|
|
|
|
/* test field state w.r.t. deltas */
|
|
|
|
field_id = 0;
|
|
g_assert (thrift_compact_protocol_read_field_begin (protocol, &field_name,
|
|
&field_type,
|
|
&field_id, NULL) == 1);
|
|
g_assert (field_id == 1);
|
|
field_id = 0;
|
|
g_assert (thrift_compact_protocol_read_field_begin (protocol, &field_name,
|
|
&field_type,
|
|
&field_id, NULL) == 1);
|
|
g_assert (field_id == 16);
|
|
field_id = 0;
|
|
g_assert (thrift_compact_protocol_read_field_begin (protocol, &field_name,
|
|
&field_type,
|
|
&field_id, NULL) == 1);
|
|
g_assert (field_id == 17);
|
|
field_id = 0;
|
|
g_assert (thrift_compact_protocol_read_field_begin (protocol, &field_name,
|
|
&field_type,
|
|
&field_id, NULL) > 1);
|
|
g_assert (field_id == 15);
|
|
field_id = 0;
|
|
g_assert (thrift_compact_protocol_read_field_begin (protocol, &field_name,
|
|
&field_type,
|
|
&field_id, NULL) == 1);
|
|
g_assert (field_id == 30);
|
|
field_id = 0;
|
|
g_assert (thrift_compact_protocol_read_field_begin (protocol, &field_name,
|
|
&field_type,
|
|
&field_id, NULL) > 1);
|
|
g_assert (field_id == 46);
|
|
field_id = 0;
|
|
g_assert (thrift_compact_protocol_read_field_begin (protocol, &field_name,
|
|
&field_type,
|
|
&field_id, NULL) == 1);
|
|
g_assert (field_id == 47);
|
|
field_id = 0;
|
|
|
|
/* test field operations */
|
|
|
|
thrift_compact_protocol_read_field_begin (protocol, &field_name, &field_type,
|
|
&field_id, NULL);
|
|
thrift_compact_protocol_read_field_end (protocol, NULL);
|
|
|
|
/* test field state w.r.t. structs */
|
|
|
|
g_assert (thrift_compact_protocol_read_field_begin (protocol, &field_name,
|
|
&field_type,
|
|
&field_id, NULL) > 1);
|
|
g_assert (field_id == 1);
|
|
field_id = 0;
|
|
thrift_compact_protocol_read_field_end (protocol, NULL);
|
|
g_assert (thrift_compact_protocol_read_field_begin (protocol, &field_name,
|
|
&field_type,
|
|
&field_id, NULL) == 1);
|
|
g_assert (field_id == 16);
|
|
field_id = 0;
|
|
thrift_compact_protocol_read_field_end (protocol, NULL);
|
|
|
|
g_assert (thrift_compact_protocol_read_struct_begin (protocol,
|
|
&struct_name, NULL) == 0);
|
|
g_assert (thrift_compact_protocol_read_field_begin (protocol, &field_name,
|
|
&field_type,
|
|
&field_id, NULL) > 1);
|
|
g_assert (field_id == 17);
|
|
field_id = 0;
|
|
thrift_compact_protocol_read_field_end (protocol, NULL);
|
|
|
|
g_assert (thrift_compact_protocol_read_struct_begin (protocol,
|
|
&struct_name, NULL) == 0);
|
|
g_assert (thrift_compact_protocol_read_field_begin (protocol, &field_name,
|
|
&field_type,
|
|
&field_id, NULL) > 1);
|
|
g_assert (field_id == 18);
|
|
field_id = 0;
|
|
thrift_compact_protocol_read_field_end (protocol, NULL);
|
|
g_assert (thrift_compact_protocol_read_field_begin (protocol, &field_name,
|
|
&field_type,
|
|
&field_id, NULL) == 1);
|
|
g_assert (field_id == 19);
|
|
field_id = 0;
|
|
thrift_compact_protocol_read_field_end (protocol, NULL);
|
|
g_assert (thrift_compact_protocol_read_struct_end (protocol, NULL) == 0);
|
|
|
|
g_assert (thrift_compact_protocol_read_field_begin (protocol, &field_name,
|
|
&field_type,
|
|
&field_id, NULL) == 1);
|
|
g_assert (field_id == 18);
|
|
field_id = 0;
|
|
thrift_compact_protocol_read_field_end (protocol, NULL);
|
|
g_assert (thrift_compact_protocol_read_field_begin (protocol, &field_name,
|
|
&field_type,
|
|
&field_id, NULL) == 1);
|
|
g_assert (field_id == 25);
|
|
field_id = 0;
|
|
thrift_compact_protocol_read_field_end (protocol, NULL);
|
|
g_assert (thrift_compact_protocol_read_struct_end (protocol, NULL) == 0);
|
|
|
|
g_assert (thrift_compact_protocol_read_field_begin (protocol, &field_name,
|
|
&field_type,
|
|
&field_id, NULL) == 1);
|
|
g_assert (field_id == 17);
|
|
field_id = 0;
|
|
thrift_compact_protocol_read_field_end (protocol, NULL);
|
|
|
|
/* test field state w.r.t. bools */
|
|
|
|
/* deltas */
|
|
/* non-bool field -> bool field -> non-bool field */
|
|
g_assert (thrift_compact_protocol_read_field_begin (protocol, &field_name,
|
|
&field_type,
|
|
&field_id, NULL) == 1);
|
|
thrift_compact_protocol_read_field_end (protocol, NULL);
|
|
g_assert (thrift_compact_protocol_read_field_begin (protocol, &field_name,
|
|
&field_type,
|
|
&field_id, NULL) == 1);
|
|
g_assert (field_type == T_BOOL);
|
|
g_assert (thrift_compact_protocol_read_bool (protocol,
|
|
&value_boolean, NULL) == 0);
|
|
g_assert (value_boolean == TEST_BOOL);
|
|
value_boolean = ! TEST_BOOL;
|
|
thrift_compact_protocol_read_field_end (protocol, NULL);
|
|
g_assert (thrift_compact_protocol_read_field_begin (protocol, &field_name,
|
|
&field_type,
|
|
&field_id, NULL) == 1);
|
|
thrift_compact_protocol_read_field_end (protocol, NULL);
|
|
/* bool -> bool field -> bool */
|
|
g_assert (thrift_compact_protocol_read_bool (protocol,
|
|
&value_boolean, NULL) > 0);
|
|
g_assert (value_boolean == TEST_BOOL);
|
|
value_boolean = ! TEST_BOOL;
|
|
g_assert (thrift_compact_protocol_read_field_begin (protocol, &field_name,
|
|
&field_type,
|
|
&field_id, NULL) == 1);
|
|
g_assert (field_type == T_BOOL);
|
|
g_assert (thrift_compact_protocol_read_bool (protocol,
|
|
&value_boolean, NULL) == 0);
|
|
g_assert (value_boolean == TEST_BOOL);
|
|
value_boolean = ! TEST_BOOL;
|
|
thrift_compact_protocol_read_field_end (protocol, NULL);
|
|
g_assert (thrift_compact_protocol_read_bool (protocol,
|
|
&value_boolean, NULL) > 0);
|
|
g_assert (value_boolean == TEST_BOOL);
|
|
value_boolean = ! TEST_BOOL;
|
|
|
|
/* no deltas */
|
|
/* non-bool field -> bool field -> non-bool field */
|
|
g_assert (thrift_compact_protocol_read_field_begin (protocol, &field_name,
|
|
&field_type,
|
|
&field_id, NULL) > 1);
|
|
thrift_compact_protocol_read_field_end (protocol, NULL);
|
|
g_assert (thrift_compact_protocol_read_field_begin (protocol, &field_name,
|
|
&field_type,
|
|
&field_id, NULL) > 1);
|
|
g_assert (field_type == T_BOOL);
|
|
g_assert (thrift_compact_protocol_read_bool (protocol,
|
|
&value_boolean, NULL) == 0);
|
|
g_assert (value_boolean == TEST_BOOL);
|
|
value_boolean = ! TEST_BOOL;
|
|
thrift_compact_protocol_read_field_end (protocol, NULL);
|
|
g_assert (thrift_compact_protocol_read_field_begin (protocol, &field_name,
|
|
&field_type,
|
|
&field_id, NULL) > 1);
|
|
thrift_compact_protocol_read_field_end (protocol, NULL);
|
|
/* bool -> bool field -> bool */
|
|
g_assert (thrift_compact_protocol_read_bool (protocol,
|
|
&value_boolean, NULL) > 0);
|
|
g_assert (value_boolean == TEST_BOOL);
|
|
value_boolean = ! TEST_BOOL;
|
|
g_assert (thrift_compact_protocol_read_field_begin (protocol, &field_name,
|
|
&field_type,
|
|
&field_id, NULL) > 1);
|
|
g_assert (field_type == T_BOOL);
|
|
g_assert (thrift_compact_protocol_read_bool (protocol,
|
|
&value_boolean, NULL) == 0);
|
|
g_assert (value_boolean == TEST_BOOL);
|
|
value_boolean = ! TEST_BOOL;
|
|
thrift_compact_protocol_read_field_end (protocol, NULL);
|
|
g_assert (thrift_compact_protocol_read_bool (protocol,
|
|
&value_boolean, NULL) > 0);
|
|
g_assert (value_boolean == TEST_BOOL);
|
|
value_boolean = ! TEST_BOOL;
|
|
|
|
/* test first read error on a field */
|
|
transport_read_error = 1;
|
|
g_assert (thrift_compact_protocol_read_field_begin (protocol,
|
|
&field_name, &field_type,
|
|
&field_id, NULL) == -1);
|
|
transport_read_error = 0;
|
|
|
|
/* test 2nd write failure */
|
|
thrift_compact_protocol_read_byte (protocol, &value, NULL);
|
|
|
|
/* test 2nd read failure on a field */
|
|
transport_read_count = 0;
|
|
transport_read_error_at = 1;
|
|
g_assert (thrift_compact_protocol_read_field_begin (protocol,
|
|
&field_name, &field_type,
|
|
&field_id, NULL) == -1);
|
|
transport_read_error_at = -1;
|
|
|
|
/* test field stop */
|
|
thrift_compact_protocol_read_field_begin (protocol, &field_name, &field_type,
|
|
&field_id, NULL);
|
|
|
|
/* test map operations */
|
|
|
|
thrift_compact_protocol_read_map_begin (protocol, &key_type, &value_type,
|
|
&size, NULL);
|
|
thrift_compact_protocol_read_map_end (protocol, NULL);
|
|
|
|
/* test 1st read failure on a map */
|
|
transport_read_count = 0;
|
|
transport_read_error_at = 0;
|
|
g_assert (thrift_compact_protocol_read_map_begin (protocol,
|
|
&key_type, &value_type,
|
|
&size, NULL) == -1);
|
|
transport_read_error_at = -1;
|
|
|
|
/* test 2nd read failure on a map */
|
|
transport_read_count = 0;
|
|
transport_read_error_at = 1;
|
|
g_assert (thrift_compact_protocol_read_map_begin (protocol,
|
|
&key_type, &value_type,
|
|
&size, NULL) == -1);
|
|
transport_read_error_at = -1;
|
|
|
|
/* test 1st write failure on map---nothing to do on our side */
|
|
|
|
/* test 2nd write failure */
|
|
thrift_compact_protocol_read_byte (protocol, &value, NULL);
|
|
|
|
/* test negative map size */
|
|
g_assert (thrift_compact_protocol_read_map_begin (protocol,
|
|
&key_type, &value_type,
|
|
&size, NULL) == -1);
|
|
|
|
/* test list operations */
|
|
thrift_compact_protocol_read_list_begin (protocol, &element_type, &size,
|
|
NULL);
|
|
thrift_compact_protocol_read_list_end (protocol, NULL);
|
|
|
|
/* test small list 1st read failure */
|
|
transport_read_error = 1;
|
|
g_assert (thrift_compact_protocol_read_list_begin (protocol, &element_type,
|
|
&size, NULL) == -1);
|
|
transport_read_error = 0;
|
|
|
|
/* test big list 1st read failure */
|
|
transport_read_error = 1;
|
|
g_assert (thrift_compact_protocol_read_list_begin (protocol, &element_type,
|
|
&size, NULL) == -1);
|
|
transport_read_error = 0;
|
|
|
|
/* test big list 2nd read failure */
|
|
transport_read_count = 0;
|
|
transport_read_error_at = 1;
|
|
thrift_compact_protocol_read_list_begin (protocol, &element_type, &size,
|
|
NULL);
|
|
transport_read_error_at = -1;
|
|
|
|
/* test negative list size failure */
|
|
thrift_compact_protocol_read_list_begin (protocol, &element_type, &size,
|
|
NULL);
|
|
|
|
/* test small list 1st write failure---nothing to do on our end */
|
|
|
|
/* test big list 1st write failure---nothing to do on our end */
|
|
|
|
/* test big list 2nd write failure */
|
|
thrift_compact_protocol_read_byte (protocol, &value, NULL);
|
|
|
|
/* test set operations */
|
|
thrift_compact_protocol_read_set_begin (protocol, &element_type, &size, NULL);
|
|
thrift_compact_protocol_read_set_end (protocol, NULL);
|
|
|
|
/* broken read */
|
|
transport_read_error = 1;
|
|
g_assert (thrift_compact_protocol_read_message_begin (protocol, &message_name,
|
|
&message_type, &seqid,
|
|
NULL) == -1);
|
|
transport_read_error = 0;
|
|
|
|
/* invalid protocol */
|
|
g_assert (thrift_compact_protocol_read_message_begin (protocol, &message_name,
|
|
&message_type, &seqid,
|
|
NULL) == -1);
|
|
|
|
/* invalid version */
|
|
g_assert (thrift_compact_protocol_read_message_begin (protocol, &message_name,
|
|
&message_type, &seqid,
|
|
NULL) == -1);
|
|
|
|
/* read a valid message */
|
|
g_assert (thrift_compact_protocol_read_message_begin (protocol, &message_name,
|
|
&message_type, &seqid,
|
|
NULL) > 0);
|
|
g_free (message_name);
|
|
|
|
/* broken 2nd read on a message */
|
|
transport_read_count = 0;
|
|
transport_read_error_at = 1;
|
|
g_assert (thrift_compact_protocol_read_message_begin (protocol, &message_name,
|
|
&message_type, &seqid,
|
|
NULL) == -1);
|
|
transport_read_error_at = -1;
|
|
|
|
/* broken 3rd read on a message */
|
|
transport_read_count = 0;
|
|
transport_read_error_at = 2;
|
|
g_assert (thrift_compact_protocol_read_message_begin (protocol, &message_name,
|
|
&message_type, &seqid,
|
|
NULL) == -1);
|
|
transport_read_error_at = -1;
|
|
|
|
/* broken 4th read on a message */
|
|
transport_read_count = 0;
|
|
transport_read_error_at = 3;
|
|
g_assert (thrift_compact_protocol_read_message_begin (protocol, &message_name,
|
|
&message_type, &seqid,
|
|
NULL) == -1);
|
|
transport_read_error_at = -1;
|
|
|
|
/* read a valid message */
|
|
g_assert (thrift_compact_protocol_read_message_begin (protocol, &message_name,
|
|
&message_type, &seqid,
|
|
NULL) > 0);
|
|
g_free (message_name);
|
|
|
|
g_assert (thrift_compact_protocol_read_message_end (protocol, NULL) == 0);
|
|
|
|
/* handle 2nd write failure on a message */
|
|
thrift_compact_protocol_read_byte (protocol, &protocol_id, NULL);
|
|
|
|
/* handle 3rd write failure on a message */
|
|
thrift_compact_protocol_read_byte (protocol, &protocol_id, NULL);
|
|
thrift_compact_protocol_read_byte (protocol, &version_and_type, NULL);
|
|
|
|
/* handle 4th write failure on a message */
|
|
thrift_compact_protocol_read_byte (protocol, &protocol_id, NULL);
|
|
thrift_compact_protocol_read_byte (protocol, &version_and_type, NULL);
|
|
thrift_compact_protocol_read_varint32 (tc, &seqid, NULL);
|
|
|
|
g_object_unref (client);
|
|
g_object_unref (tsocket);
|
|
}
|
|
|
|
static void
|
|
thrift_server_many_frames (const int port)
|
|
{
|
|
ThriftServerTransport *transport = NULL;
|
|
ThriftTransport *client = NULL;
|
|
ThriftCompactProtocol *tcp = NULL;
|
|
ThriftProtocol *protocol = NULL;
|
|
ThriftServerSocket *tsocket = NULL;
|
|
gboolean value_boolean = FALSE;
|
|
gint8 value_byte = 0,
|
|
zigzag_p16 = 0, zigzag_p32 = 0, zigzag_p64 = 0,
|
|
zigzag_n16 = 0, zigzag_n32 = 0, zigzag_n64 = 0;
|
|
gint16 value_16 = 0;
|
|
gint32 value_32 = 0;
|
|
gint64 value_64 = 0;
|
|
gint16 value_n16 = 0;
|
|
gint32 value_n32 = 0;
|
|
gint64 value_n64 = 0;
|
|
gdouble value_double = 0;
|
|
gchar *string = NULL;
|
|
gchar *empty_string = NULL;
|
|
gpointer binary = NULL;
|
|
guint32 len = 0;
|
|
void *comparator = (void *) TEST_STRING;
|
|
|
|
tsocket = g_object_new (THRIFT_TYPE_SERVER_SOCKET, "port", port, NULL);
|
|
transport = THRIFT_SERVER_TRANSPORT (tsocket);
|
|
thrift_server_transport_listen (transport, NULL);
|
|
|
|
/* wrap the client in a framed transport */
|
|
client = g_object_new (THRIFT_TYPE_FRAMED_TRANSPORT, "transport",
|
|
thrift_server_transport_accept (transport, NULL),
|
|
"r_buf_size", 1, NULL);
|
|
g_assert (client != NULL);
|
|
|
|
tcp = g_object_new (THRIFT_TYPE_COMPACT_PROTOCOL, "transport",
|
|
client, NULL);
|
|
protocol = THRIFT_PROTOCOL (tcp);
|
|
|
|
g_assert (thrift_compact_protocol_read_bool (protocol,
|
|
&value_boolean, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_read_byte (protocol, &value_byte, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_read_i16 (protocol, &value_16, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_read_i32 (protocol, &value_32, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_read_i64 (protocol, &value_64, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_read_i16 (protocol, &value_n16, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_read_i32 (protocol, &value_n32, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_read_i64 (protocol, &value_n64, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_read_byte (protocol, &zigzag_p16, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_read_byte (protocol, &zigzag_p32, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_read_byte (protocol, &zigzag_p64, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_read_byte (protocol, &zigzag_n16, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_read_byte (protocol, &zigzag_n32, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_read_byte (protocol, &zigzag_n64, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_read_double (protocol,
|
|
&value_double, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_read_string (protocol, &string, NULL) > 0);
|
|
g_assert (thrift_compact_protocol_read_string (protocol, &empty_string,
|
|
NULL) > 0);
|
|
g_assert (thrift_compact_protocol_read_binary (protocol, &binary,
|
|
&len, NULL) > 0);
|
|
|
|
g_assert (value_boolean == TEST_BOOL);
|
|
g_assert (value_byte == TEST_BYTE);
|
|
g_assert (value_16 == TEST_I16);
|
|
g_assert (value_32 == TEST_I32);
|
|
g_assert (value_64 == TEST_I64);
|
|
g_assert (value_n16 == TEST_NI16);
|
|
g_assert (value_n32 == TEST_NI32);
|
|
g_assert (value_n64 == TEST_NI64);
|
|
g_assert (zigzag_p16 == 4);
|
|
g_assert (zigzag_p32 == 4);
|
|
g_assert (zigzag_p64 == 4);
|
|
g_assert (zigzag_n16 == 3);
|
|
g_assert (zigzag_n32 == 3);
|
|
g_assert (zigzag_n64 == 3);
|
|
g_assert (value_double == TEST_DOUBLE);
|
|
g_assert (strcmp (TEST_STRING, string) == 0);
|
|
g_assert (strcmp ("", empty_string) == 0);
|
|
g_assert (memcmp (comparator, binary, len) == 0);
|
|
|
|
g_free (string);
|
|
g_free (empty_string);
|
|
g_free (binary);
|
|
|
|
g_assert (thrift_compact_protocol_read_binary (protocol, &binary,
|
|
&len, NULL) > 0);
|
|
g_assert (binary == NULL);
|
|
g_assert (len == 0);
|
|
g_free (binary);
|
|
|
|
thrift_transport_read_end (client, NULL);
|
|
thrift_transport_close (client, NULL);
|
|
|
|
g_object_unref (tcp);
|
|
g_object_unref (client);
|
|
g_object_unref (tsocket);
|
|
}
|
|
|
|
int
|
|
main (int argc, char *argv[])
|
|
{
|
|
#if (!GLIB_CHECK_VERSION (2, 36, 0))
|
|
g_type_init ();
|
|
#endif
|
|
|
|
g_test_init (&argc, &argv, NULL);
|
|
|
|
g_test_add_func ("/testcompactprotocol/CreateAndDestroy",
|
|
test_create_and_destroy);
|
|
g_test_add_func ("/testcompactprotocol/Initialize", test_initialize);
|
|
g_test_add_func ("/testcompactprotocol/ReadAndWritePrimitives",
|
|
test_read_and_write_primitives);
|
|
g_test_add_func ("/testcompactprotocol/ReadAndWriteComplexTypes",
|
|
test_read_and_write_complex_types);
|
|
g_test_add_func ("/testcompactprotocol/ReadAndWriteManyFrames",
|
|
test_read_and_write_many_frames);
|
|
|
|
return g_test_run ();
|
|
}
|