korg/bluez
0
0
Fork 0
mirror of https://git.kernel.org/pub/scm/bluetooth/bluez.git synced 2025-01-19 10:05:09 +08:00
Code Issues Packages Projects Releases Wiki Activity

gobex: Add basic request callback support

Browse Source
This commit is contained in:
Johan Hedberg 2011-06-27 11:06:48 +03:00 committed by Marcel Holtmann
parent 696e89cfdc
commit 2e94a60c20
3 changed files with 101 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
gobex/gobex.c
View File

@ -79,6 +79,9 @@ struct _GObex {
guint16 tx_mtu;
GQueue *req_queue;
GObexRequestFunc req_func;
gpointer req_func_data;
};
struct connect_data {
@ -541,8 +544,18 @@ gboolean g_obex_send(GObex *obex, GObexPacket *pkt)
return TRUE;
}
void g_obex_set_request_function(GObex *obex, GObexRequestFunc func,
gpointer user_data)
{
obex->req_func = func;
obex->req_func_data = user_data;
}
static gboolean g_obex_handle_packet(GObex *obex, GObexPacket *pkt)
{
if (obex->req_func)
obex->req_func(obex, pkt, obex->req_func_data);
return TRUE;
}

8
gobex/gobex.h
View File

@ -72,6 +72,9 @@ typedef struct _GObex GObex;
typedef struct _GObexPacket GObexPacket;
typedef struct _GObexHeader GObexHeader;
typedef void (*GObexRequestFunc) (GObex *obex, GObexPacket *req,
gpointer user_data);
GObexHeader *g_obex_header_unicode(guint8 id, const char *str);
GObexHeader *g_obex_header_bytes(guint8 id, void *data, size_t len,
GObexDataPolicy data_policy);
@ -93,7 +96,10 @@ void g_obex_packet_free(GObexPacket *req);
GObexPacket *g_obex_packet_decode(const void *data, size_t len,
GObexDataPolicy data_policy);
gboolean g_obex_send(GObex *obex, GObexPacket *req);
gboolean g_obex_send(GObex *obex, GObexPacket *pkt);
void g_obex_set_request_function(GObex *obex, GObexRequestFunc func,
gpointer user_data);
GObex *g_obex_new(GIOChannel *io);

81
unit/test-gobex.c
View File

@ -19,11 +19,20 @@
*
*/
#include <stdlib.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <errno.h>
#include <unistd.h>
#include <string.h>
#include <gobex/gobex.h>
static GMainLoop *mainloop = NULL;
static uint8_t pkt_connect_req[] = { G_OBEX_OP_CONNECT | G_OBEX_FINAL,
0x00, 0x07, 0x01, 0x00, 0x10, 0x00 };
static uint8_t hdr_connid[] = { G_OBEX_HDR_ID_CONNECTION, 1, 2, 3, 4 };
static uint8_t hdr_name_ascii[] = { G_OBEX_HDR_ID_NAME, 0x00, 0x0b,
0x00, 'f', 0x00, 'o', 0x00, 'o',
@ -34,6 +43,17 @@ static uint8_t hdr_name_umlaut[] = { G_OBEX_HDR_ID_NAME, 0x00, 0x0b,
static uint8_t hdr_body[] = { G_OBEX_HDR_ID_BODY, 0x00, 0x07, 1, 2, 3, 4 };
static uint8_t hdr_actionid[] = { G_OBEX_HDR_ID_ACTION, 0x00 };
enum {
TEST_ERROR_TIMEOUT,
TEST_ERROR_UNEXPECTED,
};
static GQuark test_error_quark(void)
{
return g_quark_from_static_string("test-error-quark");
}
#define TEST_ERROR test_error_quark()
static GObex *create_gobex(int fd)
{
GIOChannel *io;
@ -67,6 +87,65 @@ static void assert_memequal(void *mem1, size_t len1, void *mem2, size_t len2)
g_assert(0);
}
static gboolean test_timeout(gpointer user_data)
{
GError **err = user_data;
if (!g_main_loop_is_running(mainloop))
return FALSE;
g_set_error(err, TEST_ERROR, TEST_ERROR_TIMEOUT, "Timed out");
g_main_loop_quit(mainloop);
return FALSE;
}
static void handle_request(GObex *obex, GObexPacket *pkt, gpointer user_data)
{
GError **err = user_data;
switch (g_obex_packet_get_operation(pkt, NULL)) {
case G_OBEX_OP_CONNECT:
break;
default:
g_set_error(err, TEST_ERROR, TEST_ERROR_UNEXPECTED,
"Unexpected operation");
break;
}
g_main_loop_quit(mainloop);
}
static void test_connect_stream(void)
{
GError *gerr = NULL;
GObex *obex;
ssize_t err;
int sv[2];
if (socketpair(AF_UNIX, SOCK_STREAM | SOCK_NONBLOCK, 0, sv) < 0) {
g_printerr("socketpair: %s", strerror(errno));
abort();
}
obex = create_gobex(sv[0]);
g_assert(obex != NULL);
g_obex_set_request_function(obex, handle_request, &gerr);
err = write(sv[1], pkt_connect_req, sizeof(pkt_connect_req));
g_assert_cmpint(err, ==, sizeof(pkt_connect_req));
mainloop = g_main_loop_new(NULL, FALSE);
g_timeout_add_seconds(1, test_timeout, &gerr);
g_main_loop_run(mainloop);
g_assert_no_error(gerr);
}
static void test_header_name_ascii(void)
{
GObexHeader *header;
@ -426,6 +505,8 @@ int main(int argc, char *argv[])
g_test_add_func("/gobex/test_decode_pkt", test_decode_pkt);
g_test_add_func("/gobex/test_connect_stream", test_connect_stream);
g_test_run();
return 0;