unsigned int i;
const struct kdbus_test *t;
+ kdbus_util_verbose = false;
+
for (t = tests; t->name; t++) {
printf("Testing %s (%s) ", t->desc, t->name);
for (i = 0; i < 60 - strlen(t->desc) - strlen(t->name); i++)
printf(".");
printf(" ");
- kdbus_util_verbose = false;
-
ret = test_run(t, busname, 0);
switch (ret) {
case TEST_OK:
item = KDBUS_ITEM_NEXT(item);
ret = ioctl(conn->fd, KDBUS_CMD_MSG_SEND, msg);
+ if (memfd >= 0)
+ close(memfd);
+
if (ret < 0) {
ret = -errno;
kdbus_printf("error sending message: %d (%m)\n", ret);
return ret;
}
- if (memfd >= 0)
- close(memfd);
-
if (flags & KDBUS_MSG_FLAGS_SYNC_REPLY) {
struct kdbus_msg *reply;
reply = (struct kdbus_msg *)(conn->buf + msg->offset_reply);
kdbus_msg_dump(conn, reply);
+ kdbus_msg_free(reply);
+
ret = kdbus_free(conn, msg->offset_reply);
if (ret < 0)
return ret;
if (item->type == KDBUS_ITEM_TIMESTAMP)
found = 1;
+ kdbus_msg_free(msg);
+
ASSERT_RETURN(found == 1);
/*
ASSERT_RETURN(found == 0);
+ kdbus_msg_free(msg);
+
kdbus_conn_free(conn);
return TEST_OK;
ASSERT_RETURN(memcmp(tmp, str, sizeof(tmp)) == 0);
close(item->fds[0]);
- break;
}
}
+ close(fds[0]);
+ close(fds[1]);
+
kdbus_conn_free(conn_src);
kdbus_conn_free(conn_dst);
return -EINVAL;
}
+ kdbus_msg_free(msg);
ret = kdbus_free(conn, recv.offset);
if (ret < 0)
return ret;
ASSERT_RETURN_VAL(0, -EINVAL);
}
+ kdbus_msg_free(msg);
ret = waitpid(pid, &status, 0);
ASSERT_RETURN(ret >= 0);
ASSERT_RETURN(ret == 0);
kdbus_printf("-- closing bus connections\n");
+
kdbus_conn_free(conn_a);
kdbus_conn_free(conn_b);
kdbus_conn_free(conn_a);
kdbus_conn_free(conn_b);
+#if 0
conn_a = kdbus_hello(env->buspath, 0, NULL, 0);
conn_b = kdbus_hello(env->buspath, 0, NULL, 0);
ASSERT_RETURN(conn_a && conn_b);
kdbus_conn_free(conn_a);
kdbus_conn_free(conn_b);
+#endif
return TEST_OK;
}