2 #include <aura/private.h>
3 #include <aura/packetizer.h>
5 static int dummy_open(
struct aura_node *node,
const char *opts)
7 slog(1, SLOG_INFO,
"Opening dummy transport");
13 static void dummy_populate_etable(
struct aura_node *node)
15 struct aura_export_table *etbl = aura_etable_create(node, 16);
17 BUG(node,
"Failed to create etable");
18 aura_etable_add(etbl,
"echo_str",
"s128.",
"s128.");
19 aura_etable_add(etbl,
"echo_u8",
"1",
"1");
20 aura_etable_add(etbl,
"echo_u16",
"2",
"2");
21 aura_etable_add(etbl,
"echo_i16",
"7",
"7");
22 aura_etable_add(etbl,
"echo_u32",
"3",
"3");
23 aura_etable_add(etbl,
"ping", NULL,
"1");
24 aura_etable_add(etbl,
"echo_i32",
"8",
"8");
25 aura_etable_add(etbl,
"noargs_func",
"",
"");
26 aura_etable_add(etbl,
"echo_seq",
"321",
"321");
27 aura_etable_add(etbl,
"echo_bin",
"s32.s32.",
"s32.s32.");
28 aura_etable_add(etbl,
"echo_buf",
"b",
"b");
29 aura_etable_add(etbl,
"echo_u64",
"4",
"4");
30 aura_etable_activate(etbl);
33 static void dummy_close(
struct aura_node *node)
35 slog(1, SLOG_INFO,
"Closing dummy transport");
38 static void dummy_loop(
struct aura_node *node,
const struct aura_pollfds *fd)
41 struct aura_object *o;
43 if (node->status != AURA_STATUS_ONLINE) {
44 dummy_populate_etable(node);
54 slog(1, SLOG_DEBUG,
"Dequeued/requeued obj id %d (%s)", o->id, o->name);
62 slog(0, SLOG_DEBUG,
"dummy: serializing buf 0x%x", buf);
63 uint64_t ptr = (uintptr_t) buf;
70 slog(0, SLOG_DEBUG,
"dummy: deserializing buf 0x%x", ret);
79 .buffer_overhead =
sizeof(
struct aura_packet8),
80 .buffer_offset =
sizeof(
struct aura_packet8),
81 .buffer_get = dummy_buffer_get,
82 .buffer_put = dummy_buffer_put,
84 AURA_TRANSPORT(dummy);
void aura_set_status(struct aura_node *node, int status)
struct aura_buffer * aura_dequeue_buffer(struct list_head *head)
const char * name
Required.
struct aura_eventloop * aura_eventloop_get_data(struct aura_node *node)
void aura_buffer_put_u64(struct aura_buffer *buf, uint64_t value)
Put an unsigned 64 bit integer to aura buffer.
uint64_t aura_buffer_get_u64(struct aura_buffer *buf)
Get an unsigned 64 bit integer from aura buffer.
void aura_queue_buffer(struct list_head *list, struct aura_buffer *buf)
struct aura_object * object