blob: d73a38631e77117b44f7644872df4f2934e24fcd [file] [log] [blame]
#include <iostream>
#include <cassert>
#include <sdbusplus/message.hpp>
#include <sdbusplus/bus.hpp>
// Global to share the dbus type string between client and server.
static std::string verifyTypeString;
using verifyCallback_t = void(*)(sd_bus_message*);
verifyCallback_t verifyCallback = nullptr;
static constexpr auto SERVICE = "sdbusplus.test.message.append";
static constexpr auto INTERFACE = SERVICE;
static constexpr auto TEST_METHOD = "test";
static constexpr auto QUIT_METHOD = "quit";
// Open up the sdbus and claim SERVICE name.
auto serverInit()
{
auto b = sdbusplus::bus::new_default();
b.request_name(SERVICE);
return std::move(b);
}
// Thread to run the dbus server.
void* server(void* b)
{
auto bus = sdbusplus::bus::bus(reinterpret_cast<sdbusplus::bus::busp_t>(b));
while(1)
{
// Wait for messages.
auto m = bus.process().release();
if(m == nullptr)
{
bus.wait();
continue;
}
if (sd_bus_message_is_method_call(m, INTERFACE, TEST_METHOD))
{
// Verify the message type matches what the test expects.
assert(verifyTypeString == sd_bus_message_get_signature(m, true));
if (verifyCallback)
{
verifyCallback(m);
verifyCallback = nullptr;
}
else
{
std::cout << "Warning: No verification for "
<< verifyTypeString << std::endl;
}
// Reply to client.
sd_bus_reply_method_return(m, nullptr);
}
else if (sd_bus_message_is_method_call(m, INTERFACE, QUIT_METHOD))
{
// Reply and exit.
sd_bus_reply_method_return(m, nullptr);
break;
}
}
return nullptr;
}
auto newMethodCall__test(sdbusplus::bus::bus& b)
{
// Allocate a method-call message for INTERFACE,TEST_METHOD.
return b.new_method_call(SERVICE, "/", INTERFACE, TEST_METHOD);
}
void runTests()
{
using namespace std::literals;
auto b = sdbusplus::bus::new_default();
// Test r-value int.
{
auto m = newMethodCall__test(b);
m.append(1);
verifyTypeString = "i";
struct verify
{
static void op(sd_bus_message* m)
{
int32_t i = 0;
sd_bus_message_read_basic(m, 'i', &i);
assert(i == 1);
}
};
verifyCallback = &verify::op;
b.call_noreply(m);
}
// Test l-value int.
{
auto m = newMethodCall__test(b);
int a = 1;
m.append(a, a);
verifyTypeString = "ii";
struct verify
{
static void op(sd_bus_message* m)
{
int32_t a = 0, b = 0;
sd_bus_message_read(m, "ii", &a, &b);
assert(a == 1);
assert(b == 1);
}
};
verifyCallback = &verify::op;
b.call_noreply(m);
}
// Test multiple ints.
{
auto m = newMethodCall__test(b);
m.append(1, 2, 3, 4, 5);
verifyTypeString = "iiiii";
struct verify
{
static void op(sd_bus_message* m)
{
int32_t a = 0, b = 0, c = 0, d = 0, e = 0;
sd_bus_message_read(m, "iiiii", &a, &b, &c, &d, &e);
assert(a == 1);
assert(b == 2);
assert(c == 3);
assert(d == 4);
assert(e == 5);
}
};
verifyCallback = &verify::op;
b.call_noreply(m);
}
// Test double and bool.
{
auto m = newMethodCall__test(b);
bool t = true;
bool f = false;
bool f2 = false;
m.append(t, true, f, std::move(f2), false, 1.1);
verifyTypeString = "bbbbbd";
struct verify
{
static void op(sd_bus_message* m)
{
bool t1, t2, f1, f2, f3;
double d;
sd_bus_message_read(m, "bbbbbd", &t1, &t2, &f1, &f2, &f3, &d);
assert(t1);
assert(t2);
assert(!f1);
assert(!f2);
assert(!f3);
assert(d == 1.1);
}
};
verifyCallback = &verify::op;
b.call_noreply(m);
}
// Test r-value string.
{
auto m = newMethodCall__test(b);
m.append("asdf"s);
verifyTypeString = "s";
struct verify
{
static void op(sd_bus_message* m)
{
const char* s = nullptr;
sd_bus_message_read_basic(m, 's', &s);
assert(0 == strcmp("asdf", s));
}
};
verifyCallback = &verify::op;
b.call_noreply(m);
}
// Test multiple strings, various forms.
{
auto m = newMethodCall__test(b);
auto str = "jkl;"s;
auto str2 = "JKL:"s;
m.append(1, "asdf", "ASDF"s, str,
std::move(str2), 5);
verifyTypeString = "issssi";
struct verify
{
static void op(sd_bus_message* m)
{
int32_t a = 0, b = 0;
const char *s0 = nullptr, *s1 = nullptr, *s2 = nullptr,
*s3 = nullptr;
sd_bus_message_read(m, "issssi", &a, &s0, &s1, &s2, &s3, &b);
assert(a == 1);
assert(b == 5);
assert(0 == strcmp("asdf", s0));
assert(0 == strcmp("ASDF", s1));
assert(0 == strcmp("jkl;", s2));
assert(0 == strcmp("JKL:", s3));
}
};
verifyCallback = &verify::op;
b.call_noreply(m);
}
// Test object_path and signature.
{
auto m = newMethodCall__test(b);
auto o = sdbusplus::message::object_path("/asdf");
auto s = sdbusplus::message::signature("iii");
m.append(1, o, s, 4);
verifyTypeString = "iogi";
struct verify
{
static void op(sd_bus_message* m)
{
int32_t a = 0, b = 0;
const char *s0 = nullptr, *s1 = nullptr;
sd_bus_message_read(m, "iogi", &a, &s0, &s1, &b);
assert(a == 1);
assert(b == 4);
assert(0 == strcmp("/asdf", s0));
assert(0 == strcmp("iii", s1));
}
};
verifyCallback = &verify::op;
b.call_noreply(m);
}
// Test vector.
{
auto m = newMethodCall__test(b);
std::vector<std::string> s{ "1", "2", "3"};
m.append(1, s, 2);
verifyTypeString = "iasi";
struct verify
{
static void op(sd_bus_message* m)
{
int32_t a = 0;
sd_bus_message_read(m, "i", &a);
assert(a == 1);
auto rc = sd_bus_message_enter_container(m,
SD_BUS_TYPE_ARRAY,
"s");
assert(0 <= rc);
const char* s = nullptr;
sd_bus_message_read_basic(m, 's', &s);
assert(0 == strcmp("1", s));
sd_bus_message_read_basic(m, 's', &s);
assert(0 == strcmp("2", s));
sd_bus_message_read_basic(m, 's', &s);
assert(0 == strcmp("3", s));
assert(1 == sd_bus_message_at_end(m, false));
sd_bus_message_exit_container(m);
sd_bus_message_read(m, "i", &a);
assert(a == 2);
}
};
verifyCallback = &verify::op;
b.call_noreply(m);
}
// Test map.
{
auto m = newMethodCall__test(b);
std::map<std::string, int> s = { { "asdf", 3 }, { "jkl;", 4 } };
m.append(1, s, 2);
verifyTypeString = "ia{si}i";
struct verify
{
static void op(sd_bus_message* m)
{
int32_t a = 0;
sd_bus_message_read(m, "i", &a);
assert(a == 1);
auto rc = sd_bus_message_enter_container(m,
SD_BUS_TYPE_ARRAY,
"{si}");
assert(0 <= rc);
rc = sd_bus_message_enter_container(m,
SD_BUS_TYPE_DICT_ENTRY,
"si");
assert(0 <= rc);
const char* s = nullptr;
sd_bus_message_read_basic(m, 's', &s);
assert(0 == strcmp("asdf", s));
sd_bus_message_read_basic(m, 'i', &a);
assert(a == 3);
assert(1 == sd_bus_message_at_end(m, false));
sd_bus_message_exit_container(m);
rc = sd_bus_message_enter_container(m,
SD_BUS_TYPE_DICT_ENTRY,
"si");
assert(0 <= rc);
sd_bus_message_read_basic(m, 's', &s);
assert(0 == strcmp("jkl;", s));
sd_bus_message_read_basic(m, 'i', &a);
assert(a == 4);
assert(1 == sd_bus_message_at_end(m, false));
sd_bus_message_exit_container(m);
assert(1 == sd_bus_message_at_end(m, false));
sd_bus_message_exit_container(m);
sd_bus_message_read(m, "i", &a);
assert(a == 2);
}
};
verifyCallback = &verify::op;
b.call_noreply(m);
}
// Test tuple.
{
auto m = newMethodCall__test(b);
std::tuple<int, double, std::string> a{ 3, 4.1, "asdf" };
m.append(1, a, 2);
verifyTypeString = "i(ids)i";
struct verify
{
static void op(sd_bus_message* m)
{
int32_t a = 0;
double b = 0;
const char* c = nullptr;
sd_bus_message_read(m, "i", &a);
assert(a == 1);
auto rc = sd_bus_message_enter_container(m,
SD_BUS_TYPE_STRUCT,
"ids");
assert(0 <= rc);
sd_bus_message_read(m, "ids", &a, &b, &c);
assert(a == 3);
assert(b == 4.1);
assert(0 == strcmp(c, "asdf"));
sd_bus_message_exit_container(m);
sd_bus_message_read(m, "i", &a);
assert(a == 2);
}
};
verifyCallback = &verify::op;
b.call_noreply(m);
}
// Test variant.
{
auto m = newMethodCall__test(b);
sdbusplus::message::variant<int, double> a1{3.1}, a2{4};
m.append(1, a1, a2, 2);
verifyTypeString = "ivvi";
struct verify
{
static void op(sd_bus_message* m)
{
int32_t a = 0;
double b = 0;
sd_bus_message_read(m, "i", &a);
assert(a == 1);
sd_bus_message_enter_container(m, SD_BUS_TYPE_VARIANT, "d");
sd_bus_message_read(m, "d", &b);
assert(b == 3.1);
sd_bus_message_exit_container(m);
sd_bus_message_enter_container(m, SD_BUS_TYPE_VARIANT, "i");
sd_bus_message_read(m, "i", &a);
assert(a == 4);
sd_bus_message_exit_container(m);
sd_bus_message_read(m, "i", &a);
assert(a == 2);
}
};
verifyCallback = &verify::op;
b.call_noreply(m);
}
// Test map-variant.
{
auto m = newMethodCall__test(b);
std::map<std::string, sdbusplus::message::variant<int, double>> a1 =
{ { "asdf", 3 }, { "jkl;", 4.1 } };
m.append(1, a1, 2);
verifyTypeString = "ia{sv}i";
struct verify
{
static void op(sd_bus_message* m)
{
int32_t a = 0;
double b = 0;
const char* c = nullptr;
sd_bus_message_read(m, "i", &a);
assert(a == 1);
sd_bus_message_enter_container(m, SD_BUS_TYPE_ARRAY, "{sv}");
sd_bus_message_enter_container(m, SD_BUS_TYPE_DICT_ENTRY, "sv");
sd_bus_message_read(m, "s", &c);
assert(0 == strcmp("asdf", c));
sd_bus_message_enter_container(m, SD_BUS_TYPE_VARIANT, "i");
sd_bus_message_read(m, "i", &a);
assert(a == 3);
sd_bus_message_exit_container(m);
sd_bus_message_exit_container(m);
sd_bus_message_enter_container(m, SD_BUS_TYPE_DICT_ENTRY, "sv");
sd_bus_message_read(m, "s", &c);
assert(0 == strcmp("jkl;", c));
sd_bus_message_enter_container(m, SD_BUS_TYPE_VARIANT, "d");
sd_bus_message_read(m, "d", &b);
assert(b == 4.1);
sd_bus_message_exit_container(m);
sd_bus_message_exit_container(m);
sd_bus_message_exit_container(m);
sd_bus_message_read(m, "i", &a);
assert(a == 2);
}
};
verifyCallback = &verify::op;
b.call_noreply(m);
}
// Shutdown server.
{
auto m = b.new_method_call(SERVICE, "/", INTERFACE, QUIT_METHOD);
b.call_noreply(m);
}
}
int main()
{
// Initialize and start server thread.
pthread_t t;
{
auto b = serverInit();
pthread_create(&t, NULL, server, b.release());
}
runTests();
// Wait for server thread to exit.
pthread_join(t, NULL);
return 0;
}