korg/bluez
0
0
Fork 0
mirror of https://git.kernel.org/pub/scm/bluetooth/bluez.git synced 2024-12-12 21:44:12 +08:00
Code Issues Packages Projects Releases Wiki Activity

gobex: Add put streaming support to test-server

Browse Source
This commit is contained in:
Johan Hedberg 2011-07-06 01:56:05 +03:00 committed by Marcel Holtmann
parent d070d17059
commit bfb84a44a7
1 changed files with 21 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
tools/obex-server-tool.c
View File

@ -28,6 +28,7 @@
#include <errno.h> #include <errno.h>
#include <gobex/gobex.h> #include <gobex/gobex.h>
#include <gobex/gobex-transfer.h>
static GMainLoop *main_loop = NULL; static GMainLoop *main_loop = NULL;
@ -61,9 +62,23 @@ static void disconn_func(GObex *obex, GError *err, gpointer user_data)
g_obex_unref(obex); g_obex_unref(obex);
} }
static void put_complete(GObex *obex, GError *err, gpointer user_data)
{
if (err != NULL)
g_printerr("put failed: %s\n", err->message);
else
g_print("put succeeded\n");
}
static gboolean recv_data(const void *buf, gsize len, gpointer user_data)
{
g_print("received %zu bytes of data\n", len);
return TRUE;
}
static void handle_put(GObex *obex, GObexPacket *req, gpointer user_data) static void handle_put(GObex *obex, GObexPacket *req, gpointer user_data)
{ {
GObexPacket *rsp; GError *err = NULL;
GObexHeader *hdr; GObexHeader *hdr;
const char *type, *name; const char *type, *name;
gsize type_len; gsize type_len;
@ -88,12 +103,11 @@ static void handle_put(GObex *obex, GObexPacket *req, gpointer user_data)
g_print("put type \"%s\" name \"%s\"\n", type ? type : "", g_print("put type \"%s\" name \"%s\"\n", type ? type : "",
name ? name : ""); name ? name : "");
if (g_obex_packet_find_header(req, G_OBEX_HDR_ID_BODY)) g_obex_put_rsp(obex, req, recv_data, put_complete, NULL, &err);
rsp = g_obex_packet_new(G_OBEX_RSP_CONTINUE, TRUE, NULL); if (err != NULL) {
else g_printerr("Unable to send response: %s\n", err->message);
rsp = g_obex_packet_new(G_OBEX_RSP_SUCCESS, TRUE, NULL); g_error_free(err);
}
g_obex_send(obex, rsp, NULL);
} }
static void handle_connect(GObex *obex, GObexPacket *req, gpointer user_data) static void handle_connect(GObex *obex, GObexPacket *req, gpointer user_data)