2 #include <aura/packetizer.h>
18 slog(0, SLOG_INFO,
"Got a packet from packetizer");
20 if (expected[curpacket]!=result) {
21 slog(0, SLOG_ERROR,
"expected %d got %d packet %d", expected[curpacket],
30 void queue_packet(
struct aura_packetizer *pkt,
char *buf,
int offset, uint32_t value)
32 struct aura_packet8 *pck = (
struct aura_packet8 *) &buf[offset];
33 memcpy(pck->data, &value,
sizeof(value));
34 aura_packetizer_encapsulate(pkt, pck, 0x4);
42 struct aura_node *node =
aura_open(
"dummy", NULL);
43 struct aura_packetizer *pkt = aura_packetizer_create(node);
47 aura_packetizer_set_receive_cb(pkt, recvcb, NULL);
49 memset(buf,0x0, 1024 );
52 queue_packet(pkt, buf, 10, expected[0]);
54 queue_packet(pkt, buf, 18+
sizeof(
struct aura_packet8), expected[1]);
55 queue_packet(pkt, buf, 20+
sizeof(
struct aura_packet8), expected[1]);
57 queue_packet(pkt, buf, 64, expected[2]);
58 queue_packet(pkt, buf, 64 +
sizeof(
struct aura_packet8), expected[2]);
60 queue_packet(pkt, buf, 90, expected[3]);
65 aura_packetizer_feed(pkt, &buf[i], 1);
68 aura_packetizer_feed(pkt, buf, 256);
70 aura_packetizer_destroy(pkt);
uint32_t aura_buffer_get_u32(struct aura_buffer *buf)
Get an unsigned 32 bit integer from aura buffer.
struct aura_node * aura_open(const char *name, const char *opts)
void aura_buffer_release(struct aura_buffer *buf)
void aura_close(struct aura_node *node)