Lines Matching full:p_buf
1139 BT_HDR *p_buf;
1164 while ((p_buf = (BT_HDR *)fixed_queue_try_dequeue(p_port->rx.queue)) != NULL)
1165 osi_free(p_buf);
1180 while ((p_buf = (BT_HDR *)fixed_queue_try_dequeue(p_port->tx.queue)) != NULL)
1181 osi_free(p_buf);
1216 BT_HDR *p_buf;
1249 p_buf = (BT_HDR *)fixed_queue_try_peek_first(p_port->rx.queue);
1250 if (p_buf == NULL)
1253 if (p_buf->len > max_len)
1255 memcpy (p_data, (UINT8 *)(p_buf + 1) + p_buf->offset, max_len);
1256 p_buf->offset += max_len;
1257 p_buf->len -= max_len;
1271 memcpy (p_data, (UINT8 *)(p_buf + 1) + p_buf->offset, p_buf->len);
1273 *p_len += p_buf->len;
1274 max_len -= p_buf->len;
1278 p_port->rx.queue_size -= p_buf->len;
1282 p_data += p_buf->len;
1323 BT_HDR *p_buf;
1346 p_buf = (BT_HDR *)fixed_queue_try_dequeue(p_port->rx.queue);
1347 if (p_buf)
1349 p_port->rx.queue_size -= p_buf->len;
1362 *pp_buf = p_buf;
1374 ** p_buf - pointer to address of buffer with data,
1377 static int port_write (tPORT *p_port, BT_HDR *p_buf)
1382 osi_free(p_buf);
1402 osi_free(p_buf);
1416 fixed_queue_enqueue(p_port->tx.queue, p_buf);
1417 p_port->tx.queue_size += p_buf->len;
1425 RFCOMM_DataReq (p_port->rfc.p_mcb, p_port->dlci, p_buf);
1441 int PORT_Write (UINT16 handle, BT_HDR *p_buf)
1452 osi_free(p_buf);
1460 osi_free(p_buf);
1468 osi_free(p_buf);
1472 rc = port_write (p_port, p_buf);
1510 BT_HDR *p_buf;
1554 if (((p_buf = (BT_HDR *)fixed_queue_try_peek_last(p_port->tx.queue)) != NULL)
1555 && (((int)p_buf->len + available) <= (int)p_port->peer_mtu)
1556 && (((int)p_buf->len + available) <= (int)length))
1558 //if(recv(fd, (UINT8 *)(p_buf + 1) + p_buf->offset + p_buf->len, available, 0) != available)
1559 if(p_port->p_data_co_callback(handle, (UINT8 *)(p_buf + 1) + p_buf->offset + p_buf->len,
1567 //memcpy ((UINT8 *)(p_buf + 1) + p_buf->offset + p_buf->len, p_data, max_len);
1571 p_buf->len += (UINT16)available;
1598 p_buf = (BT_HDR *)osi_malloc(RFCOMM_DATA_BUF_SIZE);
1599 p_buf->offset = L2CAP_MIN_OFFSET + RFCOMM_MIN_OFFSET;
1600 p_buf->layer_specific = handle;
1606 p_buf->len = length;
1607 p_buf->event = BT_EVT_TO_BTU_SP_DATA;
1609 //memcpy ((UINT8 *)(p_buf + 1) + p_buf->offset, p_data, length);
1610 //if(recv(fd, (UINT8 *)(p_buf + 1) + p_buf->offset, (int)length, 0) != (int)length)
1611 if(p_port->p_data_co_callback(handle, (UINT8 *)(p_buf + 1) + p_buf->offset, length,
1620 rc = port_write (p_port, p_buf);
1663 BT_HDR *p_buf;
1699 if (((p_buf = (BT_HDR *)fixed_queue_try_peek_last(p_port->tx.queue)) != NULL)
1700 && ((p_buf->len + max_len) <= p_port->peer_mtu)
1701 && ((p_buf->len + max_len) <= length))
1703 memcpy ((UINT8 *)(p_buf + 1) + p_buf->offset + p_buf->len, p_data, max_len);
1707 p_buf->len += max_len;
1724 p_buf = (BT_HDR *)osi_malloc(RFCOMM_DATA_BUF_SIZE);
1725 p_buf->offset = L2CAP_MIN_OFFSET + RFCOMM_MIN_OFFSET;
1726 p_buf->layer_specific = handle;
1732 p_buf->len = length;
1733 p_buf->event = BT_EVT_TO_BTU_SP_DATA;
1735 memcpy ((UINT8 *)(p_buf + 1) + p_buf->offset, p_data, length);
1739 rc = port_write (p_port, p_buf);
1801 BT_HDR *p_buf = (BT_HDR *)osi_malloc(RFCOMM_CMD_BUF_SIZE);
1802 p_buf->offset = L2CAP_MIN_OFFSET + RFCOMM_MIN_OFFSET + 2;
1803 p_buf->len = len;
1805 memcpy((UINT8 *)(p_buf + 1) + p_buf->offset, p_data, p_buf->len);
1807 rfc_send_test(p_port->rfc.p_mcb, TRUE, p_buf);
