}
nns_edge_lock_init (ed);
- ed->magic = NNS_EDGE_MAGIC;
+ nns_edge_handle_set_magic (ed, NNS_EDGE_MAGIC);
nns_edge_metadata_create (&ed->metadata);
*data_h = ed;
return NNS_EDGE_ERROR_INVALID_PARAMETER;
}
- nns_edge_lock (ed);
-
- if (!NNS_EDGE_MAGIC_IS_VALID (ed)) {
+ if (!nns_edge_handle_is_valid (ed)) {
nns_edge_loge ("Invalid param, given edge data is invalid.");
- nns_edge_unlock (ed);
return NNS_EDGE_ERROR_INVALID_PARAMETER;
}
- ed->magic = NNS_EDGE_MAGIC_DEAD;
+ nns_edge_lock (ed);
+ nns_edge_handle_set_magic (ed, NNS_EDGE_MAGIC_DEAD);
for (i = 0; i < ed->num; i++) {
if (ed->data[i].destroy_cb)
return NNS_EDGE_ERROR_INVALID_PARAMETER;
}
- nns_edge_lock (ed);
-
- if (!NNS_EDGE_MAGIC_IS_VALID (ed)) {
+ if (!nns_edge_handle_is_valid (ed)) {
nns_edge_loge ("Invalid param, edge data handle is invalid.");
- nns_edge_unlock (ed);
return NNS_EDGE_ERROR_INVALID_PARAMETER;
}
- nns_edge_unlock (ed);
return NNS_EDGE_ERROR_NONE;
}
return NNS_EDGE_ERROR_INVALID_PARAMETER;
}
- nns_edge_lock (ed);
-
- if (!NNS_EDGE_MAGIC_IS_VALID (ed)) {
+ if (!nns_edge_handle_is_valid (ed)) {
nns_edge_loge ("Invalid param, edge data handle is invalid.");
- nns_edge_unlock (ed);
return NNS_EDGE_ERROR_INVALID_PARAMETER;
}
+ nns_edge_lock (ed);
+
ret = nns_edge_data_create (new_data_h);
if (ret != NNS_EDGE_ERROR_NONE) {
nns_edge_loge ("Failed to create new data handle.");
return NNS_EDGE_ERROR_INVALID_PARAMETER;
}
- nns_edge_lock (ed);
-
- if (!NNS_EDGE_MAGIC_IS_VALID (ed)) {
+ if (!nns_edge_handle_is_valid (ed)) {
nns_edge_loge ("Invalid param, given edge data is invalid.");
- nns_edge_unlock (ed);
return NNS_EDGE_ERROR_INVALID_PARAMETER;
}
+ nns_edge_lock (ed);
+
if (ed->num >= NNS_EDGE_DATA_LIMIT) {
nns_edge_loge ("Cannot add data, the maximum number of edge data is %d.",
NNS_EDGE_DATA_LIMIT);
return NNS_EDGE_ERROR_INVALID_PARAMETER;
}
- nns_edge_lock (ed);
-
- if (!NNS_EDGE_MAGIC_IS_VALID (ed)) {
+ if (!nns_edge_handle_is_valid (ed)) {
nns_edge_loge ("Invalid param, given edge data is invalid.");
- nns_edge_unlock (ed);
return NNS_EDGE_ERROR_INVALID_PARAMETER;
}
+ nns_edge_lock (ed);
+
if (index >= ed->num) {
nns_edge_loge
("Invalid param, the number of edge data is %u but requested %uth data.",
return NNS_EDGE_ERROR_INVALID_PARAMETER;
}
- nns_edge_lock (ed);
-
- if (!NNS_EDGE_MAGIC_IS_VALID (ed)) {
+ if (!nns_edge_handle_is_valid (ed)) {
nns_edge_loge ("Invalid param, given edge data is invalid.");
- nns_edge_unlock (ed);
return NNS_EDGE_ERROR_INVALID_PARAMETER;
}
+ nns_edge_lock (ed);
*count = ed->num;
-
nns_edge_unlock (ed);
+
return NNS_EDGE_ERROR_NONE;
}
return NNS_EDGE_ERROR_INVALID_PARAMETER;
}
- nns_edge_lock (ed);
-
- if (!NNS_EDGE_MAGIC_IS_VALID (ed)) {
+ if (!nns_edge_handle_is_valid (ed)) {
nns_edge_loge ("Invalid param, given edge data is invalid.");
- nns_edge_unlock (ed);
return NNS_EDGE_ERROR_INVALID_PARAMETER;
}
+ nns_edge_lock (ed);
ret = nns_edge_metadata_set (ed->metadata, key, value);
-
nns_edge_unlock (ed);
+
return ret;
}
return NNS_EDGE_ERROR_INVALID_PARAMETER;
}
- nns_edge_lock (ed);
-
- if (!NNS_EDGE_MAGIC_IS_VALID (ed)) {
+ if (!nns_edge_handle_is_valid (ed)) {
nns_edge_loge ("Invalid param, given edge data is invalid.");
- nns_edge_unlock (ed);
return NNS_EDGE_ERROR_INVALID_PARAMETER;
}
+ nns_edge_lock (ed);
ret = nns_edge_metadata_get (ed->metadata, key, value);
-
nns_edge_unlock (ed);
+
return ret;
}
return NNS_EDGE_ERROR_INVALID_PARAMETER;
}
- nns_edge_lock (ed);
-
- if (!NNS_EDGE_MAGIC_IS_VALID (ed)) {
+ if (!nns_edge_handle_is_valid (ed)) {
nns_edge_loge ("Invalid param, given edge data is invalid.");
- nns_edge_unlock (ed);
return NNS_EDGE_ERROR_INVALID_PARAMETER;
}
+ nns_edge_lock (ed);
ret = nns_edge_metadata_serialize (ed->metadata, data, data_len);
-
nns_edge_unlock (ed);
+
return ret;
}
return NNS_EDGE_ERROR_INVALID_PARAMETER;
}
- nns_edge_lock (ed);
-
- if (!NNS_EDGE_MAGIC_IS_VALID (ed)) {
+ if (!nns_edge_handle_is_valid (ed)) {
nns_edge_loge ("Invalid param, given edge data is invalid.");
- nns_edge_unlock (ed);
return NNS_EDGE_ERROR_INVALID_PARAMETER;
}
+ nns_edge_lock (ed);
ret = nns_edge_metadata_deserialize (ed->metadata, data, data_len);
-
nns_edge_unlock (ed);
+
return ret;
}
return NNS_EDGE_ERROR_INVALID_PARAMETER;
}
- nns_edge_lock (ed);
-
- if (!NNS_EDGE_MAGIC_IS_VALID (ed)) {
+ if (!nns_edge_handle_is_valid (ed)) {
nns_edge_loge ("Invalid param, given edge data is invalid.");
- nns_edge_unlock (ed);
return NNS_EDGE_ERROR_INVALID_PARAMETER;
}
+ nns_edge_lock (ed);
header_len = sizeof (nns_edge_data_header_s);
data_len = 0;
return NNS_EDGE_ERROR_INVALID_PARAMETER;
}
- nns_edge_lock (ed);
-
- if (!NNS_EDGE_MAGIC_IS_VALID (ed)) {
+ if (!nns_edge_handle_is_valid (ed)) {
nns_edge_loge ("Invalid param, given edge data is invalid.");
- ret = NNS_EDGE_ERROR_INVALID_PARAMETER;
- goto error;
+ return NNS_EDGE_ERROR_INVALID_PARAMETER;
}
+ nns_edge_lock (ed);
header = (nns_edge_data_header_s *) data;
/* Check mem size */
return;
memset (cmd, 0, sizeof (nns_edge_cmd_s));
- cmd->info.magic = NNS_EDGE_MAGIC;
+ nns_edge_handle_set_magic (&cmd->info, NNS_EDGE_MAGIC);
cmd->info.cmd = c;
cmd->info.client_id = cid;
cmd->info.num = 0;
if (!cmd)
return;
- cmd->info.magic = NNS_EDGE_MAGIC_DEAD;
+ nns_edge_handle_set_magic (&cmd->info, NNS_EDGE_MAGIC_DEAD);
for (i = 0; i < cmd->info.num; i++) {
SAFE_FREE (cmd->mem[i]);
command = (int) cmd->info.cmd;
- if (!NNS_EDGE_MAGIC_IS_VALID (&cmd->info) ||
+ if (!nns_edge_handle_is_valid (&cmd->info) ||
(command < 0 || command >= _NNS_EDGE_CMD_END)) {
return false;
}
struct pollfd poll_fd;
/* Validate edge handle */
- if (!NNS_EDGE_MAGIC_IS_VALID (eh)) {
+ if (!nns_edge_handle_is_valid (eh)) {
nns_edge_loge ("The edge handle is invalid, it would be expired.");
break;
}
}
nns_edge_lock_init (eh);
- eh->magic = NNS_EDGE_MAGIC;
+ nns_edge_handle_set_magic (eh, NNS_EDGE_MAGIC);
eh->id = STR_IS_VALID (id) ? nns_edge_strdup (id) :
nns_edge_strdup_printf ("%lld", (long long) nns_edge_generate_id ());
eh->connect_type = connect_type;
return NNS_EDGE_ERROR_INVALID_PARAMETER;
}
- nns_edge_lock (eh);
-
- if (!NNS_EDGE_MAGIC_IS_VALID (eh)) {
+ if (!nns_edge_handle_is_valid (eh)) {
nns_edge_loge ("Invalid param, given edge handle is invalid.");
- nns_edge_unlock (eh);
return NNS_EDGE_ERROR_INVALID_PARAMETER;
}
+ nns_edge_lock (eh);
+
if (eh->port <= 0) {
eh->port = nns_edge_get_available_port ();
if (eh->port <= 0) {
nns_edge_loge ("Invalid param, given edge handle is null.");
return NNS_EDGE_ERROR_INVALID_PARAMETER;
}
- nns_edge_lock (eh);
- if (!NNS_EDGE_MAGIC_IS_VALID (eh)) {
+ if (!nns_edge_handle_is_valid (eh)) {
nns_edge_loge ("Invalid param, given edge handle is invalid.");
- nns_edge_unlock (eh);
return NNS_EDGE_ERROR_INVALID_PARAMETER;
}
+ nns_edge_lock (eh);
+
switch (eh->connect_type) {
case NNS_EDGE_CONNECT_TYPE_HYBRID:
if (NNS_EDGE_ERROR_NONE != nns_edge_mqtt_close (eh->broker_h)) {
}
/* Clear event callback and handles */
- eh->magic = NNS_EDGE_MAGIC_DEAD;
+ nns_edge_handle_set_magic (eh, NNS_EDGE_MAGIC_DEAD);
eh->event_cb = NULL;
eh->user_data = NULL;
eh->broker_h = NULL;
return NNS_EDGE_ERROR_INVALID_PARAMETER;
}
- nns_edge_lock (eh);
-
- if (!NNS_EDGE_MAGIC_IS_VALID (eh)) {
+ if (!nns_edge_handle_is_valid (eh)) {
nns_edge_loge ("Invalid param, given edge handle is invalid.");
- nns_edge_unlock (eh);
return NNS_EDGE_ERROR_INVALID_PARAMETER;
}
+ nns_edge_lock (eh);
+
ret = nns_edge_event_invoke_callback (eh->event_cb, eh->user_data,
NNS_EDGE_EVENT_CALLBACK_RELEASED, NULL, 0, NULL);
if (ret != NNS_EDGE_ERROR_NONE) {
return NNS_EDGE_ERROR_INVALID_PARAMETER;
}
- nns_edge_lock (eh);
-
- if (!NNS_EDGE_MAGIC_IS_VALID (eh)) {
+ if (!nns_edge_handle_is_valid (eh)) {
nns_edge_loge ("Invalid param, given edge handle is invalid.");
- nns_edge_unlock (eh);
return NNS_EDGE_ERROR_INVALID_PARAMETER;
}
+ nns_edge_lock (eh);
+
if (!eh->event_cb) {
nns_edge_loge ("NNStreamer-edge event callback is not registered.");
nns_edge_unlock (eh);
return NNS_EDGE_ERROR_INVALID_PARAMETER;
}
- nns_edge_lock (eh);
-
- if (!NNS_EDGE_MAGIC_IS_VALID (eh)) {
+ if (!nns_edge_handle_is_valid (eh)) {
nns_edge_loge ("Invalid param, given edge handle is invalid.");
- nns_edge_unlock (eh);
return NNS_EDGE_ERROR_INVALID_PARAMETER;
}
+ nns_edge_lock (eh);
_nns_edge_remove_all_connection (eh);
-
nns_edge_unlock (eh);
+
return NNS_EDGE_ERROR_NONE;
}
return NNS_EDGE_ERROR_INVALID_PARAMETER;
}
- nns_edge_lock (eh);
-
- if (!NNS_EDGE_MAGIC_IS_VALID (eh)) {
+ if (!nns_edge_handle_is_valid (eh)) {
nns_edge_loge ("Invalid param, given edge handle is invalid.");
- nns_edge_unlock (eh);
return NNS_EDGE_ERROR_INVALID_PARAMETER;
}
+ nns_edge_lock (eh);
+
if (!_nns_edge_is_connected (eh)) {
nns_edge_loge ("There is no available connection.");
nns_edge_unlock (eh);
return NNS_EDGE_ERROR_INVALID_PARAMETER;
}
- nns_edge_lock (eh);
-
- if (!NNS_EDGE_MAGIC_IS_VALID (eh)) {
+ if (!nns_edge_handle_is_valid (eh)) {
nns_edge_loge ("Invalid param, given edge handle is invalid.");
- nns_edge_unlock (eh);
return NNS_EDGE_ERROR_INVALID_PARAMETER;
}
+ nns_edge_lock (eh);
+
if (0 == strcasecmp (key, "CAPS") || 0 == strcasecmp (key, "CAPABILITY")) {
SAFE_FREE (eh->caps_str);
eh->caps_str = nns_edge_strdup (value);
return NNS_EDGE_ERROR_INVALID_PARAMETER;
}
- nns_edge_lock (eh);
-
- if (!NNS_EDGE_MAGIC_IS_VALID (eh)) {
+ if (!nns_edge_handle_is_valid (eh)) {
nns_edge_loge ("Invalid param, given edge handle is invalid.");
- nns_edge_unlock (eh);
return NNS_EDGE_ERROR_INVALID_PARAMETER;
}
+ nns_edge_lock (eh);
+
if (0 == strcasecmp (key, "CAPS") || 0 == strcasecmp (key, "CAPABILITY")) {
*value = nns_edge_strdup (eh->caps_str);
} else if (0 == strcasecmp (key, "IP") || 0 == strcasecmp (key, "HOST")) {
TEST(edge, startInvalidParam02_n)
{
nns_edge_h edge_h;
- nns_edge_handle_s *eh;
int ret;
ret = nns_edge_create_handle ("temp-id", NNS_EDGE_CONNECT_TYPE_TCP,
NNS_EDGE_NODE_TYPE_QUERY_CLIENT, &edge_h);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
- eh = (nns_edge_handle_s *) edge_h;
- eh->magic = NNS_EDGE_MAGIC_DEAD;
+ nns_edge_handle_set_magic (edge_h, NNS_EDGE_MAGIC_DEAD);
ret = nns_edge_start (edge_h);
EXPECT_NE (ret, NNS_EDGE_ERROR_NONE);
- eh->magic = NNS_EDGE_MAGIC;
+ nns_edge_handle_set_magic (edge_h, NNS_EDGE_MAGIC);
ret = nns_edge_release_handle (edge_h);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
TEST(edge, releaseHandleInvalidParam02_n)
{
nns_edge_h edge_h;
- nns_edge_handle_s *eh;
int ret;
ret = nns_edge_create_handle ("temp-id", NNS_EDGE_CONNECT_TYPE_TCP,
NNS_EDGE_NODE_TYPE_QUERY_CLIENT, &edge_h);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
- eh = (nns_edge_handle_s *) edge_h;
- eh->magic = NNS_EDGE_MAGIC_DEAD;
+ nns_edge_handle_set_magic (edge_h, NNS_EDGE_MAGIC_DEAD);
ret = nns_edge_release_handle (edge_h);
EXPECT_NE (ret, NNS_EDGE_ERROR_NONE);
- eh->magic = NNS_EDGE_MAGIC;
+ nns_edge_handle_set_magic (edge_h, NNS_EDGE_MAGIC);
ret = nns_edge_release_handle (edge_h);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
TEST(edge, setEventCbInvalidParam02_n)
{
nns_edge_h edge_h;
- nns_edge_handle_s *eh;
ne_test_data_s *_td;
int ret;
NNS_EDGE_NODE_TYPE_QUERY_CLIENT, &edge_h);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
- eh = (nns_edge_handle_s *) edge_h;
- eh->magic = NNS_EDGE_MAGIC_DEAD;
+ nns_edge_handle_set_magic (edge_h, NNS_EDGE_MAGIC_DEAD);
ret = nns_edge_set_event_callback (edge_h, _test_edge_event_cb, _td);
EXPECT_NE (ret, NNS_EDGE_ERROR_NONE);
- eh->magic = NNS_EDGE_MAGIC;
+ nns_edge_handle_set_magic (edge_h, NNS_EDGE_MAGIC);
ret = nns_edge_release_handle (edge_h);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
TEST(edge, connectInvalidParam02_n)
{
nns_edge_h edge_h;
- nns_edge_handle_s *eh;
int ret;
ret = nns_edge_create_handle ("temp-id", NNS_EDGE_CONNECT_TYPE_TCP,
ret = nns_edge_set_event_callback (edge_h, _test_edge_event_cb, NULL);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
- eh = (nns_edge_handle_s *) edge_h;
- eh->magic = NNS_EDGE_MAGIC_DEAD;
+ nns_edge_handle_set_magic (edge_h, NNS_EDGE_MAGIC_DEAD);
ret = nns_edge_connect (edge_h, "127.0.0.1", 80);
EXPECT_NE (ret, NNS_EDGE_ERROR_NONE);
- eh->magic = NNS_EDGE_MAGIC;
+ nns_edge_handle_set_magic (edge_h, NNS_EDGE_MAGIC);
ret = nns_edge_release_handle (edge_h);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
TEST(edge, disconnectInvalidParam02_n)
{
nns_edge_h edge_h;
- nns_edge_handle_s *eh;
int ret;
ret = nns_edge_create_handle ("temp-id", NNS_EDGE_CONNECT_TYPE_TCP,
NNS_EDGE_NODE_TYPE_QUERY_CLIENT, &edge_h);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
- eh = (nns_edge_handle_s *) edge_h;
- eh->magic = NNS_EDGE_MAGIC_DEAD;
+ nns_edge_handle_set_magic (edge_h, NNS_EDGE_MAGIC_DEAD);
ret = nns_edge_disconnect (edge_h);
EXPECT_NE (ret, NNS_EDGE_ERROR_NONE);
- eh->magic = NNS_EDGE_MAGIC;
+ nns_edge_handle_set_magic (edge_h, NNS_EDGE_MAGIC);
ret = nns_edge_release_handle (edge_h);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
{
nns_edge_h edge_h;
nns_edge_data_h data_h;
- nns_edge_handle_s *eh;
int ret;
ret = nns_edge_create_handle ("temp-id", NNS_EDGE_CONNECT_TYPE_TCP,
ret = nns_edge_data_set_info (data_h, "client_id", "10");
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
- eh = (nns_edge_handle_s *) edge_h;
- eh->magic = NNS_EDGE_MAGIC_DEAD;
+ nns_edge_handle_set_magic (edge_h, NNS_EDGE_MAGIC_DEAD);
ret = nns_edge_send (edge_h, data_h);
EXPECT_NE (ret, NNS_EDGE_ERROR_NONE);
- eh->magic = NNS_EDGE_MAGIC;
+ nns_edge_handle_set_magic (edge_h, NNS_EDGE_MAGIC);
ret = nns_edge_release_handle (edge_h);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
TEST(edge, setInfoInvalidParam02_n)
{
nns_edge_h edge_h;
- nns_edge_handle_s *eh;
int ret;
ret = nns_edge_create_handle ("temp-id", NNS_EDGE_CONNECT_TYPE_TCP,
NNS_EDGE_NODE_TYPE_QUERY_CLIENT, &edge_h);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
- eh = (nns_edge_handle_s *) edge_h;
- eh->magic = NNS_EDGE_MAGIC_DEAD;
+ nns_edge_handle_set_magic (edge_h, NNS_EDGE_MAGIC_DEAD);
ret = nns_edge_set_info (edge_h, "caps", "temp-caps");
EXPECT_NE (ret, NNS_EDGE_ERROR_NONE);
- eh->magic = NNS_EDGE_MAGIC;
+ nns_edge_handle_set_magic (edge_h, NNS_EDGE_MAGIC);
ret = nns_edge_release_handle (edge_h);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
TEST(edge, getInfoInvalidParam02_n)
{
nns_edge_h edge_h;
- nns_edge_handle_s *eh;
char *value;
int ret;
NNS_EDGE_NODE_TYPE_QUERY_CLIENT, &edge_h);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
- eh = (nns_edge_handle_s *) edge_h;
- eh->magic = NNS_EDGE_MAGIC_DEAD;
+ nns_edge_handle_set_magic (edge_h, NNS_EDGE_MAGIC_DEAD);
ret = nns_edge_get_info (edge_h, "temp-key", &value);
EXPECT_NE (ret, NNS_EDGE_ERROR_NONE);
- eh->magic = NNS_EDGE_MAGIC;
+ nns_edge_handle_set_magic (edge_h, NNS_EDGE_MAGIC);
ret = nns_edge_release_handle (edge_h);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
TEST(edgeData, destroyInvalidParam02_n)
{
nns_edge_data_h data_h;
- nns_edge_data_s *ed;
int ret;
ret = nns_edge_data_create (&data_h);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
- ed = (nns_edge_data_s *) data_h;
- ed->magic = NNS_EDGE_MAGIC_DEAD;
+ nns_edge_handle_set_magic (data_h, NNS_EDGE_MAGIC_DEAD);
ret = nns_edge_data_destroy (data_h);
EXPECT_NE (ret, NNS_EDGE_ERROR_NONE);
- ed->magic = NNS_EDGE_MAGIC;
+ nns_edge_handle_set_magic (data_h, NNS_EDGE_MAGIC);
ret = nns_edge_data_destroy (data_h);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
TEST(edgeData, validateInvalidParam02_n)
{
nns_edge_data_h data_h;
- nns_edge_data_s *ed;
int ret;
ret = nns_edge_data_create (&data_h);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
- ed = (nns_edge_data_s *) data_h;
- ed->magic = NNS_EDGE_MAGIC_DEAD;
+ nns_edge_handle_set_magic (data_h, NNS_EDGE_MAGIC_DEAD);
ret = nns_edge_data_is_valid (data_h);
EXPECT_NE (ret, NNS_EDGE_ERROR_NONE);
- ed->magic = NNS_EDGE_MAGIC;
+ nns_edge_handle_set_magic (data_h, NNS_EDGE_MAGIC);
ret = nns_edge_data_destroy (data_h);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
TEST(edgeData, copyInvalidParam02_n)
{
nns_edge_data_h src_h, desc_h;
- nns_edge_data_s *ed;
int ret;
ret = nns_edge_data_create (&src_h);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
- ed = (nns_edge_data_s *) src_h;
- ed->magic = NNS_EDGE_MAGIC_DEAD;
+ nns_edge_handle_set_magic (src_h, NNS_EDGE_MAGIC_DEAD);
ret = nns_edge_data_copy (src_h, &desc_h);
EXPECT_NE (ret, NNS_EDGE_ERROR_NONE);
- ed->magic = NNS_EDGE_MAGIC;
+ nns_edge_handle_set_magic (src_h, NNS_EDGE_MAGIC);
ret = nns_edge_data_destroy (src_h);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
TEST(edgeData, addInvalidParam02_n)
{
nns_edge_data_h data_h;
- nns_edge_data_s *ed;
void *data;
nns_size_t data_len;
int ret;
ret = nns_edge_data_create (&data_h);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
- ed = (nns_edge_data_s *) data_h;
- ed->magic = NNS_EDGE_MAGIC_DEAD;
+ nns_edge_handle_set_magic (data_h, NNS_EDGE_MAGIC_DEAD);
ret = nns_edge_data_add (data_h, data, data_len, NULL);
EXPECT_NE (ret, NNS_EDGE_ERROR_NONE);
- ed->magic = NNS_EDGE_MAGIC;
+ nns_edge_handle_set_magic (data_h, NNS_EDGE_MAGIC);
ret = nns_edge_data_destroy (data_h);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
TEST(edgeData, getInvalidParam02_n)
{
nns_edge_data_h data_h;
- nns_edge_data_s *ed;
void *data, *result;
nns_size_t data_len, result_len;
int ret;
ret = nns_edge_data_add (data_h, data, data_len, NULL);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
- ed = (nns_edge_data_s *) data_h;
- ed->magic = NNS_EDGE_MAGIC_DEAD;
+ nns_edge_handle_set_magic (data_h, NNS_EDGE_MAGIC_DEAD);
ret = nns_edge_data_get (data_h, 0, &result, &result_len);
EXPECT_NE (ret, NNS_EDGE_ERROR_NONE);
- ed->magic = NNS_EDGE_MAGIC;
+ nns_edge_handle_set_magic (data_h, NNS_EDGE_MAGIC);
ret = nns_edge_data_destroy (data_h);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
TEST(edgeData, getCountInvalidParam02_n)
{
nns_edge_data_h data_h;
- nns_edge_data_s *ed;
void *data;
nns_size_t data_len;
unsigned int count;
ret = nns_edge_data_add (data_h, data, data_len, NULL);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
- ed = (nns_edge_data_s *) data_h;
- ed->magic = NNS_EDGE_MAGIC_DEAD;
+ nns_edge_handle_set_magic (data_h, NNS_EDGE_MAGIC_DEAD);
ret = nns_edge_data_get_count (data_h, &count);
EXPECT_NE (ret, NNS_EDGE_ERROR_NONE);
- ed->magic = NNS_EDGE_MAGIC;
+ nns_edge_handle_set_magic (data_h, NNS_EDGE_MAGIC);
ret = nns_edge_data_destroy (data_h);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
TEST(edgeData, setInfoInvalidParam02_n)
{
nns_edge_data_h data_h;
- nns_edge_data_s *ed;
int ret;
ret = nns_edge_data_create (&data_h);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
- ed = (nns_edge_data_s *) data_h;
- ed->magic = NNS_EDGE_MAGIC_DEAD;
+ nns_edge_handle_set_magic (data_h, NNS_EDGE_MAGIC_DEAD);
ret = nns_edge_data_set_info (data_h, "temp-key", "temp-value");
EXPECT_NE (ret, NNS_EDGE_ERROR_NONE);
- ed->magic = NNS_EDGE_MAGIC;
+ nns_edge_handle_set_magic (data_h, NNS_EDGE_MAGIC);
ret = nns_edge_data_destroy (data_h);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
TEST(edgeData, getInfoInvalidParam02_n)
{
nns_edge_data_h data_h;
- nns_edge_data_s *ed;
char *value = NULL;
int ret;
ret = nns_edge_data_set_info (data_h, "temp-key", "temp-value");
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
- ed = (nns_edge_data_s *) data_h;
- ed->magic = NNS_EDGE_MAGIC_DEAD;
+ nns_edge_handle_set_magic (data_h, NNS_EDGE_MAGIC_DEAD);
ret = nns_edge_data_get_info (data_h, "temp-key", &value);
EXPECT_NE (ret, NNS_EDGE_ERROR_NONE);
- ed->magic = NNS_EDGE_MAGIC;
+ nns_edge_handle_set_magic (data_h, NNS_EDGE_MAGIC);
ret = nns_edge_data_destroy (data_h);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
TEST(edgeData, serializeInvalidParam02_n)
{
nns_edge_data_h data_h;
- nns_edge_data_s *ed;
void *data;
nns_size_t data_len;
int ret;
ret = nns_edge_data_set_info (data_h, "temp-key", "temp-value");
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
- ed = (nns_edge_data_s *) data_h;
- ed->magic = NNS_EDGE_MAGIC_DEAD;
+ nns_edge_handle_set_magic (data_h, NNS_EDGE_MAGIC_DEAD);
ret = nns_edge_data_serialize_meta (data_h, &data, &data_len);
EXPECT_NE (ret, NNS_EDGE_ERROR_NONE);
- ed->magic = NNS_EDGE_MAGIC;
+ nns_edge_handle_set_magic (data_h, NNS_EDGE_MAGIC);
ret = nns_edge_data_destroy (data_h);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
TEST(edgeData, deserializeInvalidParam02_n)
{
nns_edge_data_h data_h;
- nns_edge_data_s *ed;
void *data;
nns_size_t data_len;
int ret;
ret = nns_edge_data_serialize_meta (data_h, &data, &data_len);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
- ed = (nns_edge_data_s *) data_h;
- ed->magic = NNS_EDGE_MAGIC_DEAD;
+ nns_edge_handle_set_magic (data_h, NNS_EDGE_MAGIC_DEAD);
ret = nns_edge_data_deserialize_meta (data_h, data, data_len);
EXPECT_NE (ret, NNS_EDGE_ERROR_NONE);
- ed->magic = NNS_EDGE_MAGIC;
+ nns_edge_handle_set_magic (data_h, NNS_EDGE_MAGIC);
ret = nns_edge_data_destroy (data_h);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
TEST(edgeData, invalidParam02_n)
{
nns_edge_data_h data_h;
- nns_edge_data_s *ed;
void *data;
nns_size_t data_len;
int ret;
ret = nns_edge_data_set_info (data_h, "temp-key", "temp-value");
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
- ed = (nns_edge_data_s *) data_h;
- ed->magic = NNS_EDGE_MAGIC_DEAD;
+ nns_edge_handle_set_magic (data_h, NNS_EDGE_MAGIC_DEAD);
ret = nns_edge_data_serialize (data_h, &data, &data_len);
EXPECT_NE (ret, NNS_EDGE_ERROR_NONE);
- ed->magic = NNS_EDGE_MAGIC;
+ nns_edge_handle_set_magic (data_h, NNS_EDGE_MAGIC);
ret = nns_edge_data_destroy (data_h);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
TEST(edgeDataDeserialize, invalidParam02_n)
{
nns_edge_data_h data_h;
- nns_edge_data_s *ed;
void *data;
nns_size_t data_len;
int ret;
ret = nns_edge_data_serialize (data_h, &data, &data_len);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
- ed = (nns_edge_data_s *) data_h;
- ed->magic = NNS_EDGE_MAGIC_DEAD;
+ nns_edge_handle_set_magic (data_h, NNS_EDGE_MAGIC_DEAD);
ret = nns_edge_data_deserialize (data_h, data, data_len);
EXPECT_NE (ret, NNS_EDGE_ERROR_NONE);
- ed->magic = NNS_EDGE_MAGIC;
+ nns_edge_handle_set_magic (data_h, NNS_EDGE_MAGIC);
ret = nns_edge_data_destroy (data_h);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
TEST(edgeEvent, destroyInvalidParam02_n)
{
nns_edge_event_h event_h;
- nns_edge_event_s *ee;
void *data;
nns_size_t data_len;
int ret;
ret = nns_edge_event_set_data (event_h, data, data_len, free);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
- ee = (nns_edge_event_s *) event_h;
- ee->magic = NNS_EDGE_MAGIC_DEAD;
+ nns_edge_handle_set_magic (event_h, NNS_EDGE_MAGIC_DEAD);
ret = nns_edge_event_destroy (event_h);
EXPECT_NE (ret, NNS_EDGE_ERROR_NONE);
- ee->magic = NNS_EDGE_MAGIC;
+ nns_edge_handle_set_magic (event_h, NNS_EDGE_MAGIC);
ret = nns_edge_event_destroy (event_h);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
TEST(edgeEvent, setDataInvalidParam04_n)
{
nns_edge_event_h event_h;
- nns_edge_event_s *ee;
void *data;
nns_size_t data_len;
int ret;
ret = nns_edge_event_create (NNS_EDGE_EVENT_CUSTOM, &event_h);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
- ee = (nns_edge_event_s *) event_h;
- ee->magic = NNS_EDGE_MAGIC_DEAD;
+ nns_edge_handle_set_magic (event_h, NNS_EDGE_MAGIC_DEAD);
ret = nns_edge_event_set_data (event_h, data, data_len, NULL);
EXPECT_NE (ret, NNS_EDGE_ERROR_NONE);
- ee->magic = NNS_EDGE_MAGIC;
+ nns_edge_handle_set_magic (event_h, NNS_EDGE_MAGIC);
ret = nns_edge_event_destroy (event_h);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
{
nns_edge_event_h event_h;
nns_edge_event_e event;
- nns_edge_event_s *ee;
int ret;
ret = nns_edge_event_create (NNS_EDGE_EVENT_CUSTOM, &event_h);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
- ee = (nns_edge_event_s *) event_h;
- ee->magic = NNS_EDGE_MAGIC_DEAD;
+ nns_edge_handle_set_magic (event_h, NNS_EDGE_MAGIC_DEAD);
ret = nns_edge_event_get_type (event_h, &event);
EXPECT_NE (ret, NNS_EDGE_ERROR_NONE);
- ee->magic = NNS_EDGE_MAGIC;
+ nns_edge_handle_set_magic (event_h, NNS_EDGE_MAGIC);
ret = nns_edge_event_destroy (event_h);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
{
nns_edge_event_h event_h;
nns_edge_data_h data_h;
- nns_edge_event_s *ee;
int ret;
ret = nns_edge_event_create (NNS_EDGE_EVENT_NEW_DATA_RECEIVED, &event_h);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
- ee = (nns_edge_event_s *) event_h;
- ee->magic = NNS_EDGE_MAGIC_DEAD;
+ nns_edge_handle_set_magic (event_h, NNS_EDGE_MAGIC_DEAD);
ret = nns_edge_event_parse_new_data (event_h, &data_h);
EXPECT_NE (ret, NNS_EDGE_ERROR_NONE);
- ee->magic = NNS_EDGE_MAGIC;
+ nns_edge_handle_set_magic (event_h, NNS_EDGE_MAGIC);
ret = nns_edge_event_destroy (event_h);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
TEST(edgeEvent, parseCapabilityInvalidParam03_n)
{
nns_edge_event_h event_h;
- nns_edge_event_s *ee;
char *caps = NULL;
int ret;
ret = nns_edge_event_create (NNS_EDGE_EVENT_CAPABILITY, &event_h);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
- ee = (nns_edge_event_s *) event_h;
- ee->magic = NNS_EDGE_MAGIC_DEAD;
+ nns_edge_handle_set_magic (event_h, NNS_EDGE_MAGIC_DEAD);
ret = nns_edge_event_parse_capability (event_h, &caps);
EXPECT_NE (ret, NNS_EDGE_ERROR_NONE);
- ee->magic = NNS_EDGE_MAGIC;
+ nns_edge_handle_set_magic (event_h, NNS_EDGE_MAGIC);
ret = nns_edge_event_destroy (event_h);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);