cedric pushed a commit to branch master.
http://git.enlightenment.org/core/efl.git/commit/?id=3d697254b0e8283f74b90ca3ff6900179ddb9b01
commit 3d697254b0e8283f74b90ca3ff6900179ddb9b01
Author: Srivardhan Hebbar <sri.heb...@samsung.com>
Date: Wed Apr 15 14:50:03 2015 +0200
ecore_con: add test cases for ecore_con_eet.
Summary:
Added test case for ecore_con_eet.
Signed-off-by: Srivardhan Hebbar <sri.heb...@samsung.com>
Reviewers: cedric
Subscribers: cedric
Differential Revision: https://phab.enlightenment.org/D2347
Signed-off-by: Cedric BAIL <ced...@osg.samsung.com>
---
src/Makefile_Ecore_Con.am | 1 +
src/tests/ecore_con/ecore_con_suite.c | 1 +
src/tests/ecore_con/ecore_con_suite.h | 1 +
src/tests/ecore_con/ecore_con_test_ecore_con_eet.c | 173 +++++++++++++++++++++
4 files changed, 176 insertions(+)
diff --git a/src/Makefile_Ecore_Con.am b/src/Makefile_Ecore_Con.am
index 8f37ff7..a443e67 100644
--- a/src/Makefile_Ecore_Con.am
+++ b/src/Makefile_Ecore_Con.am
@@ -84,6 +84,7 @@ tests_ecore_con_ecore_con_suite_SOURCES = \
tests/ecore_con/ecore_con_suite.c \
tests/ecore_con/ecore_con_test_ecore_con.c \
tests/ecore_con/ecore_con_test_ecore_con_url.c \
+tests/ecore_con/ecore_con_test_ecore_con_eet.c \
tests/ecore_con/ecore_con_suite.h
tests_ecore_con_ecore_con_suite_CPPFLAGS = -I$(top_builddir)/src/lib/efl \
diff --git a/src/tests/ecore_con/ecore_con_suite.c
b/src/tests/ecore_con/ecore_con_suite.c
index b695873..331f660 100644
--- a/src/tests/ecore_con/ecore_con_suite.c
+++ b/src/tests/ecore_con/ecore_con_suite.c
@@ -20,6 +20,7 @@ struct _Ecore_Con_Test_Case
static const Ecore_Con_Test_Case etc[] = {
{ "Ecore_Con", ecore_con_test_ecore_con },
{ "Ecore_Con_Url", ecore_con_test_ecore_con_url },
+ { "Ecore_Con_Eet", ecore_con_test_ecore_con_eet },
{ NULL, NULL }
};
diff --git a/src/tests/ecore_con/ecore_con_suite.h
b/src/tests/ecore_con/ecore_con_suite.h
index 9232189..5d18647 100644
--- a/src/tests/ecore_con/ecore_con_suite.h
+++ b/src/tests/ecore_con/ecore_con_suite.h
@@ -5,5 +5,6 @@
void ecore_con_test_ecore_con(TCase *tc);
void ecore_con_test_ecore_con_url(TCase *tc);
+void ecore_con_test_ecore_con_eet(TCase *tc);
#endif /* _ECORE_CON_SUITE_H */
diff --git a/src/tests/ecore_con/ecore_con_test_ecore_con_eet.c
b/src/tests/ecore_con/ecore_con_test_ecore_con_eet.c
new file mode 100644
index 0000000..d981a93
--- /dev/null
+++ b/src/tests/ecore_con/ecore_con_test_ecore_con_eet.c
@@ -0,0 +1,173 @@
+#ifdef HAVE_CONFIG_H
+# include <config.h>
+#endif
+
+#include "ecore_con_suite.h"
+
+#include <Eet.h>
+#include <Ecore_Con_Eet.h>
+
+#define TEST_STREAM "test_stream"
+#define SRV_MSG "Server Message"
+#define CLI_MSG "Client Message"
+
+static Eet_Data_Descriptor *_ece_test_descriptor;
+static char eet_data[] = "test_data";
+
+typedef struct
+{
+ int id;
+ char *message;
+}ECE_Test;
+
+static void
+_ece_test_descriptor_init(void)
+{
+ Eet_Data_Descriptor_Class eddc;
+
+ EET_EINA_STREAM_DATA_DESCRIPTOR_CLASS_SET(&eddc, ECE_Test);
+ _ece_test_descriptor = eet_data_descriptor_stream_new(&eddc);
+
+#define ECE_TEST_ADD_BASIC(member, eet_type) \
+ EET_DATA_DESCRIPTOR_ADD_BASIC \
+ (_ece_test_descriptor, ECE_Test, # member, member, eet_type)
+
+ ECE_TEST_ADD_BASIC(id, EET_T_INT);
+ ECE_TEST_ADD_BASIC(message, EET_T_STRING);
+#undef ECE_TEST_ADD_BASIC
+}
+
+static void
+_ece_test_descriptor_shutdown(void)
+{
+ eet_data_descriptor_free(_ece_test_descriptor);
+}
+
+Eina_Bool
+_eet_client_discnct_cb(void *data EINA_UNUSED, Ecore_Con_Reply *reply
EINA_UNUSED, Ecore_Con_Client *conn EINA_UNUSED)
+{
+ ecore_main_loop_quit();
+
+ return EINA_FALSE;
+}
+
+Eina_Bool
+_eet_client_cnct_cb(void *data EINA_UNUSED, Ecore_Con_Reply *reply,
Ecore_Con_Client *conn EINA_UNUSED)
+{
+ char *ec_eet_data;
+ Ecore_Con_Eet *ec_eet = ecore_con_eet_reply(reply);
+ fail_unless(ec_eet);
+
+ ec_eet_data = ecore_con_eet_data_get(ec_eet);
+ fail_if(strcmp(ec_eet_data, eet_data));
+
+ return EINA_TRUE;
+}
+
+static void
+_eet_data_cb(void *data EINA_UNUSED, Ecore_Con_Reply *reply, const char
*protocol_name, void *value)
+{
+ char toSend[] = SRV_MSG;
+ ECE_Test *received = value;
+
+ fprintf(stderr, "id: %d\n message: %s\n",
+ received->id, received->message);
+ fail_if(strcmp(received->message, CLI_MSG));
+ fail_if(received->id != 1);
+
+ ecore_con_eet_raw_send(reply, protocol_name, "message", toSend,
+ strlen(toSend));
+}
+
+Eina_Bool
+_eet_svr_discnct_cb(void *data EINA_UNUSED, Ecore_Con_Reply *reply
EINA_UNUSED, Ecore_Con_Client *conn EINA_UNUSED)
+{
+ ecore_main_loop_quit();
+ return EINA_FALSE;
+}
+
+Eina_Bool
+_eet_svr_cnct_cb(void *data EINA_UNUSED, Ecore_Con_Reply *reply,
Ecore_Con_Client *conn EINA_UNUSED)
+{
+ ECE_Test toSend = {1, CLI_MSG};
+
+ ecore_con_eet_send(reply, TEST_STREAM, &toSend);
+ return EINA_TRUE;
+}
+
+static void
+_eet_raw_data_cb(void *data EINA_UNUSED, Ecore_Con_Reply *reply EINA_UNUSED,
const char *protocol_name EINA_UNUSED, const char *section, void *value, size_t
length)
+{
+ fprintf(stderr, "Section: %s\n", section);
+ fprintf(stderr, "Value: %s\n", (char *) value);
+ fail_if(strncmp((char *) value, SRV_MSG, length));
+
+ ecore_main_loop_quit();
+}
+
+START_TEST(ecore_con_test_ecore_con_eet_svr_cl)
+{
+ Ecore_Con_Eet *ece_svr, *ece_cl;
+ Ecore_Con_Server *svr, *cl;
+
+ eina_init();
+ eet_init();
+ ecore_con_init();
+ _ece_test_descriptor_init();
+
+ svr = ecore_con_server_add(ECORE_CON_REMOTE_TCP, "127.0.0.1",
+ 8080, NULL);
+ fail_unless(svr);
+
+ ece_svr = ecore_con_eet_server_new(svr);
+ fail_unless(ece_svr);
+
+ ecore_con_eet_data_set(ece_svr, eet_data);
+
+ ecore_con_eet_register(ece_svr, TEST_STREAM, _ece_test_descriptor);
+ ecore_con_eet_data_callback_add(ece_svr, TEST_STREAM, _eet_data_cb,
+ NULL);
+ ecore_con_eet_client_connect_callback_add(ece_svr, _eet_client_cnct_cb,
+ NULL);
+ ecore_con_eet_client_disconnect_callback_add(ece_svr,
+ _eet_client_discnct_cb, NULL);
+
+ cl = ecore_con_server_connect(ECORE_CON_REMOTE_TCP, "127.0.0.1",
+ 8080, NULL);
+ fail_unless (cl);
+
+ ece_cl = ecore_con_eet_client_new(cl);
+ fail_unless (ece_cl);
+
+ ecore_con_eet_register(ece_cl, TEST_STREAM, _ece_test_descriptor);
+ ecore_con_eet_raw_data_callback_add(ece_cl, TEST_STREAM,
+ _eet_raw_data_cb, NULL);
+ ecore_con_eet_server_connect_callback_add(ece_cl, _eet_svr_cnct_cb, NULL);
+ ecore_con_eet_server_disconnect_callback_add(ece_cl, _eet_svr_discnct_cb,
+ NULL);
+
+ ecore_main_loop_begin();
+
+ ecore_con_eet_raw_data_callback_del(ece_cl, TEST_STREAM);
+ ecore_con_eet_server_connect_callback_del(ece_cl, _eet_svr_cnct_cb, NULL);
+ ecore_con_eet_server_disconnect_callback_del(ece_cl, _eet_svr_discnct_cb,
+ NULL);
+
+ ecore_con_eet_data_callback_del(ece_svr, TEST_STREAM);
+ ecore_con_eet_client_connect_callback_del(ece_svr, _eet_client_cnct_cb,
+ NULL);
+ ecore_con_eet_client_disconnect_callback_del(ece_svr,
+ _eet_client_discnct_cb, NULL);
+
+ _ece_test_descriptor_shutdown();
+ ecore_con_server_del(cl);
+ ecore_con_server_del(svr);
+ ecore_con_shutdown();
+ eet_shutdown();
+ eina_shutdown();
+}
+END_TEST
+void ecore_con_test_ecore_con_eet(TCase *tc)
+{
+ tcase_add_test(tc, ecore_con_test_ecore_con_eet_svr_cl);
+}
--
