diff --git a/gobex/gobex.c b/gobex/gobex.c
index e225a50..ed051ee 100644
--- a/gobex/gobex.c
+++ b/gobex/gobex.c
guint8 op;
gboolean enabled;
guint8 srm;
+ guint8 srmp;
+ gboolean outgoing;
};
struct _GObex {
g_obex_packet_prepend_header(rsp, connid);
}
+static void set_srmp(GObex *obex, guint8 srmp, gboolean outgoing)
+{
+ struct srm_config *config = obex->srm;
+
+ if (config == NULL)
+ return;
+
+ /* Dont't reset if direction doesn't match */
+ if (srmp > G_OBEX_SRMP_NEXT_WAIT && config->outgoing != outgoing)
+ return;
+
+ config->srmp = srmp;
+ config->outgoing = outgoing;
+}
+
static void set_srm(GObex *obex, guint8 op, guint8 srm)
{
struct srm_config *config = obex->srm;
obex->srm = NULL;
}
-static void setup_srm(GObex *obex, GObexPacket *pkt)
+static void setup_srm(GObex *obex, GObexPacket *pkt, gboolean outgoing)
{
GObexHeader *hdr;
guint8 op;
set_srm(obex, op, srm);
}
+ hdr = g_obex_packet_get_header(pkt, G_OBEX_HDR_SRMP);
+ if (hdr != NULL) {
+ guint8 srmp;
+ g_obex_header_get_uint8(hdr, &srmp);
+ g_obex_debug(G_OBEX_DEBUG_COMMAND, "srmp 0x%02x", srmp);
+ set_srmp(obex, srmp, outgoing);
+ } else
+ set_srmp(obex, -1, outgoing);
+
if (obex->srm == NULL || !obex->srm->enabled || !final)
return;
if (obex->rx_last_op == G_OBEX_OP_CONNECT)
prepare_connect_rsp(obex, pkt);
- setup_srm(obex, pkt);
+ setup_srm(obex, pkt, TRUE);
p = g_new0(struct pending_pkt, 1);
p->pkt = pkt;
g_obex_debug(G_OBEX_DEBUG_COMMAND, "conn %u", obex->conn_id);
- setup_srm(obex, req);
+ setup_srm(obex, req, TRUE);
if (obex->conn_id == CONNID_INVALID)
goto create_pending;
if (obex->srm == NULL || !obex->srm->enabled)
goto done;
+ if (obex->srm->srmp <= G_OBEX_SRMP_NEXT_WAIT)
+ goto done;
+
ret = TRUE;
done:
g_obex_debug(G_OBEX_DEBUG_COMMAND, "%s", ret ? "yes" : "no");
if (opcode == G_OBEX_OP_CONNECT)
parse_connect_data(obex, rsp);
- setup_srm(obex, rsp);
+ setup_srm(obex, rsp, FALSE);
if (!g_obex_srm_active(obex))
return final;
return -G_OBEX_RSP_SERVICE_UNAVAILABLE;
}
- setup_srm(obex, req);
+ setup_srm(obex, req, FALSE);
return op;
}