enable_tx(obex);
}
+static gboolean check_connid(GObex *obex, GObexPacket *pkt)
+{
+ GObexHeader *hdr;
+ guint32 id;
+
+ if (obex->conn_id == CONNID_INVALID)
+ return TRUE;
+
+ hdr = g_obex_packet_get_header(pkt, G_OBEX_HDR_CONNECTION);
+ if (hdr == NULL)
+ return FALSE;
+
+ g_obex_header_get_uint32(hdr, &id);
+
+ return obex->conn_id == id;
+}
+
static void handle_request(GObex *obex, GObexPacket *req)
{
GSList *match;
guint op;
- if (g_obex_packet_get_operation(req, NULL) == G_OBEX_OP_CONNECT)
- parse_connect_data(obex, req);
-
op = g_obex_packet_get_operation(req, NULL);
+ if (op == G_OBEX_OP_CONNECT)
+ parse_connect_data(obex, req);
+ else if (check_connid(obex, req) == FALSE) {
+ g_obex_debug(G_OBEX_DEBUG_ERROR, "Invalid Connection ID");
+ g_obex_send_rsp(obex, G_OBEX_RSP_SERVICE_UNAVAILABLE, NULL,
+ G_OBEX_HDR_INVALID);
+ return;
+ }
+
match = g_slist_find_custom(obex->req_handlers, GUINT_TO_POINTER(op),
req_handler_cmpop);
if (match) {