1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
|
#include <netdb.h>
#include <thrift/c_glib/thrift.h>
#include <thrift/c_glib/transport/thrift_server_transport.h>
#include <thrift/c_glib/transport/thrift_server_socket.h>
#include "t_test_thrift_test_types.h"
#include "thrift_test_handler.h"
static const char TEST_ADDRESS[] = "localhost";
static const int TEST_PORT = 64444;
static void
test_thrift_server (void)
{
ThriftServerSocket *tsocket = g_object_new (THRIFT_TYPE_SERVER_SOCKET,
"port", TEST_PORT, NULL);
g_object_unref (tsocket);
}
static void
set_indicator (gpointer data, GObject *where_the_object_was) {
THRIFT_UNUSED_VAR(where_the_object_was);
*(gboolean *) data = TRUE;
}
static void
test_thrift_handler (void)
{
GError *error;
GHashTable *_return;
TTestInsanity *argument;
gboolean indicator;
TTestXtruct *xtruct, *xtruct2;
TTestNumberz numberz;
TTestNumberz numberz2;
TTestUserId user_id, *user_id_ptr, *user_id_ptr2;
GHashTable *user_map;
GPtrArray *xtructs;
error = NULL;
indicator = FALSE;
user_map = NULL;
xtructs = NULL;
argument = g_object_new (T_TEST_TYPE_INSANITY, NULL);
g_object_get (argument,
"userMap", &user_map,
"xtructs", &xtructs,
NULL);
numberz = T_TEST_NUMBERZ_FIVE;
numberz2 = T_TEST_NUMBERZ_EIGHT;
user_id_ptr = g_malloc (sizeof *user_id_ptr);
*user_id_ptr = 5;
user_id_ptr2 = g_malloc (sizeof *user_id_ptr);
*user_id_ptr2 = 8;
g_hash_table_insert (user_map, (gpointer)numberz, user_id_ptr);
g_hash_table_insert (user_map, (gpointer)numberz2, user_id_ptr2);
g_hash_table_unref (user_map);
xtruct = g_object_new (T_TEST_TYPE_XTRUCT,
"string_thing", "Hello2",
"byte_thing", 2,
"i32_thing", 2,
"i64_thing", 2LL,
NULL);
xtruct2 = g_object_new (T_TEST_TYPE_XTRUCT,
"string_thing", "Goodbye4",
"byte_thing", 4,
"i32_thing", 4,
"i64_thing", 4LL,
NULL);
g_ptr_array_add (xtructs, xtruct2);
g_ptr_array_add (xtructs, xtruct);
g_ptr_array_unref (xtructs);
_return = g_hash_table_new_full (g_int64_hash,
g_int64_equal,
g_free,
(GDestroyNotify)g_hash_table_unref);
g_object_weak_ref (G_OBJECT (argument), set_indicator, (gpointer) &indicator);
g_assert (thrift_test_handler_test_insanity (NULL, &_return, argument, &error));
g_assert (! indicator);
g_hash_table_unref (_return);
g_assert (! indicator);
g_object_unref (argument);
g_assert (indicator);
}
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 ("/testthrift/Server", test_thrift_server);
g_test_add_func ("/testthrift/Handler", test_thrift_handler);
return g_test_run ();
}
|
