X-Git-Url: http://www.chiark.greenend.org.uk/ucgi/~ianmdlvl/git?a=blobdiff_plain;f=src%2Flibsystemd%2Fsd-bus%2Ftest-bus-zero-copy.c;h=4ea9f9fc3530ae895846a910f7f7aa577ee888de;hb=4d2b1e0a3f98d8cf93beb943b05868b55231006a;hp=e938a48b639afd68a0d91b24d12842a0e6989dcf;hpb=a09abc4ae0bdc0200324eaa0416f23ff2170ec4e;p=elogind.git diff --git a/src/libsystemd/sd-bus/test-bus-zero-copy.c b/src/libsystemd/sd-bus/test-bus-zero-copy.c index e938a48b6..4ea9f9fc3 100644 --- a/src/libsystemd/sd-bus/test-bus-zero-copy.c +++ b/src/libsystemd/sd-bus/test-bus-zero-copy.c @@ -39,6 +39,7 @@ int main(int argc, char *argv[]) { _cleanup_free_ char *name = NULL, *bus_name = NULL, *address = NULL; + const char *unique; uint8_t *p; sd_bus *a, *b; int r, bus_ref; @@ -48,6 +49,7 @@ int main(int argc, char *argv[]) { uint32_t u32; size_t i, l; char *s; + _cleanup_close_ int sfd = -1; log_set_max_level(LOG_DEBUG); @@ -80,7 +82,10 @@ int main(int argc, char *argv[]) { r = sd_bus_start(b); assert_se(r >= 0); - r = sd_bus_message_new_method_call(b, &m, ":1.1", "/a/path", "an.inter.face", "AMethod"); + r = sd_bus_get_unique_name(a, &unique); + assert_se(r >= 0); + + r = sd_bus_message_new_method_call(b, &m, unique, "/a/path", "an.inter.face", "AMethod"); assert_se(r >= 0); r = sd_bus_message_open_container(m, 'r', "aysay"); @@ -107,7 +112,7 @@ int main(int argc, char *argv[]) { assert_se(r >= 0); assert_se(sz == STRING_SIZE); - r = sd_bus_message_append_string_memfd(m, f); + r = sd_bus_message_append_string_memfd(m, f, 0, (uint64_t) -1); assert_se(r >= 0); close(f); @@ -124,7 +129,7 @@ int main(int argc, char *argv[]) { assert_se(r >= 0); assert_se(sz == SECOND_ARRAY); - r = sd_bus_message_append_array_memfd(m, 'y', f); + r = sd_bus_message_append_array_memfd(m, 'y', f, 0, (uint64_t) -1); assert_se(r >= 0); close(f); @@ -135,10 +140,15 @@ int main(int argc, char *argv[]) { r = sd_bus_message_append(m, "u", 4711); assert_se(r >= 0); + assert_se((sfd = memfd_new_and_map(NULL, 6, (void**) &p)) >= 0); + memcpy(p, "abcd\0", 6); + munmap(p, 6); + assert_se(sd_bus_message_append_string_memfd(m, sfd, 1, 4) >= 0); + r = bus_message_seal(m, 55, 99*USEC_PER_SEC); assert_se(r >= 0); - bus_message_dump(m, stdout, true); + bus_message_dump(m, stdout, BUS_MESSAGE_DUMP_WITH_HEADER); r = sd_bus_send(b, m, NULL); assert_se(r >= 0); @@ -148,7 +158,7 @@ int main(int argc, char *argv[]) { r = sd_bus_process(a, &m); assert_se(r > 0); - bus_message_dump(m, stdout, true); + bus_message_dump(m, stdout, BUS_MESSAGE_DUMP_WITH_HEADER); sd_bus_message_rewind(m, true); r = sd_bus_message_enter_container(m, 'r', "aysay"); @@ -188,6 +198,10 @@ int main(int argc, char *argv[]) { assert_se(r > 0); assert_se(u32 == 4711); + r = sd_bus_message_read(m, "s", &s); + assert_se(r > 0); + assert_se(streq_ptr(s, "bcd")); + sd_bus_message_unref(m); sd_bus_unref(a);