#include <sys/cdefs.h>
__RCSID("$NetBSD: record.c,v 1.2 2010/03/07 10:58:40 plunky Exp $");
#include <bluetooth.h>
#include <sdp.h>
#include <string.h>
#include "sdpd.h"
static bool sdpd_valid_record(sdp_data_t *);
uint16_t
record_insert_request(server_t *srv, int fd)
{
sdp_data_t seq;
bdaddr_t bdaddr;
log_debug("RecordInsertRequest by client on fd#%d", fd);
seq.next = srv->ibuf;
seq.end = srv->ibuf + srv->pdu.len;
if (!srv->fdidx[fd].control
|| !srv->fdidx[fd].priv)
return SDP_ERROR_CODE_INVALID_REQUEST_SYNTAX;
srv->fdidx[fd].offset = 0;
db_unselect(srv, fd);
if (seq.next + sizeof(bdaddr_t) > seq.end)
return SDP_ERROR_CODE_INVALID_REQUEST_SYNTAX;
memcpy(&bdaddr, seq.next, sizeof(bdaddr_t));
seq.next += sizeof(bdaddr_t);
if (!sdp_get_seq(&seq, &seq)
|| !sdpd_valid_record(&seq))
return SDP_ERROR_CODE_INVALID_REQUEST_SYNTAX;
if (!db_create(srv, fd, &bdaddr, srv->handle, &seq))
return SDP_ERROR_CODE_INSUFFICIENT_RESOURCES;
be16enc(srv->obuf, 0x0000);
be32enc(srv->obuf + sizeof(uint16_t), srv->handle++);
srv->pdu.pid = SDP_PDU_ERROR_RESPONSE;
srv->pdu.len = sizeof(uint16_t) + sizeof(uint32_t);
return 0;
}
uint16_t
record_update_request(server_t *srv, int fd)
{
record_t *rec;
sdp_data_t seq;
log_debug("RecordUpdateRequest by client on fd#%d", fd);
seq.next = srv->ibuf;
seq.end = srv->ibuf + srv->pdu.len;
if (!srv->fdidx[fd].control
|| !srv->fdidx[fd].priv)
return SDP_ERROR_CODE_INVALID_REQUEST_SYNTAX;
srv->fdidx[fd].offset = 0;
db_unselect(srv, fd);
if (seq.next + sizeof(uint32_t) > seq.end)
return SDP_ERROR_CODE_INVALID_REQUEST_SYNTAX;
db_select_handle(srv, fd, be32dec(seq.next));
seq.next += sizeof(uint32_t);
rec = NULL;
db_next(srv, fd, &rec);
if (rec == NULL || rec->fd != fd)
return SDP_ERROR_CODE_INVALID_SERVICE_RECORD_HANDLE;
db_unselect(srv, fd);
if (!sdp_get_seq(&seq, &seq)
|| !sdpd_valid_record(&seq))
return SDP_ERROR_CODE_INVALID_REQUEST_SYNTAX;
if (!db_create(srv, fd, &rec->bdaddr, rec->handle, &seq))
return SDP_ERROR_CODE_INSUFFICIENT_RESOURCES;
be16enc(srv->obuf, 0x0000);
srv->pdu.pid = SDP_PDU_ERROR_RESPONSE;
srv->pdu.len = sizeof(uint16_t);
return 0;
}
uint16_t
record_remove_request(server_t *srv, int fd)
{
record_t *rec;
log_debug("RecordRemoveRequest by client on fd#%d", fd);
if (!srv->fdidx[fd].control
|| !srv->fdidx[fd].priv)
return SDP_ERROR_CODE_INVALID_REQUEST_SYNTAX;
srv->fdidx[fd].offset = 0;
db_unselect(srv, fd);
if (srv->pdu.len != sizeof(uint32_t))
return SDP_ERROR_CODE_INVALID_REQUEST_SYNTAX;
db_select_handle(srv, fd, be32dec(srv->ibuf));
rec = NULL;
db_next(srv, fd, &rec);
if (rec == NULL || rec->fd != fd)
return SDP_ERROR_CODE_INVALID_SERVICE_RECORD_HANDLE;
rec->refcnt--;
rec->valid = false;
rec->fd = -1;
db_unselect(srv, fd);
be16enc(srv->obuf, 0x0000);
srv->pdu.pid = SDP_PDU_ERROR_RESPONSE;
srv->pdu.len = sizeof(uint16_t);
return 0;
}
static bool
sdpd_valid_record(sdp_data_t *data)
{
sdp_data_t d, s;
uintmax_t a0, a;
s = *data;
if (!sdp_data_valid(&s))
return false;
if (!sdp_get_data(&s, &d)
|| sdp_data_type(&d) != SDP_DATA_UINT16
|| !sdp_get_uint(&d, &a0)
|| a0 != SDP_ATTR_SERVICE_RECORD_HANDLE
|| !sdp_get_data(&s, &d)
|| sdp_data_type(&d) != SDP_DATA_UINT32)
return false;
while (sdp_get_data(&s, &d)
&& sdp_data_type(&d) == SDP_DATA_UINT16
&& sdp_get_uint(&d, &a)
&& a > a0
&& sdp_get_data(&s, &d))
a0 = a;
if (s.next != s.end)
return false;
return true;
}