summaryrefslogtreecommitdiffstats
path: root/net/bluetooth/hidp
diff options
context:
space:
mode:
authorDavid Herrmann <dh.herrmann@gmail.com>2013-04-06 20:28:49 +0200
committerGustavo Padovan <gustavo.padovan@collabora.co.uk>2013-04-17 03:04:03 -0300
commit7350e6cf360d32206cbe4e3d34fb48ab863bdb14 (patch)
tree6ed42830673826c03e918ea8e85c5fc34e47bc0e /net/bluetooth/hidp
parent2df012001d36e56cd92dab0255cf4bce3f5b16bc (diff)
Bluetooth: hidp: merge hidp_process_{ctrl,intr}_transmit()
Both hidp_process_ctrl_transmit() and hidp_process_intr_transmit() are exactly the same apart from the transmit-queue and socket pointers. Therefore, pass them as argument and merge both functions into one so we avoid 25 lines of code-duplication. Signed-off-by: David Herrmann <dh.herrmann@gmail.com> Acked-by: Marcel Holtmann <marcel@holtmann.org> Signed-off-by: Gustavo Padovan <gustavo.padovan@collabora.co.uk>
Diffstat (limited to 'net/bluetooth/hidp')
-rw-r--r--net/bluetooth/hidp/core.c40
1 files changed, 11 insertions, 29 deletions
diff --git a/net/bluetooth/hidp/core.c b/net/bluetooth/hidp/core.c
index 3f6ef0630a8..8f81379e990 100644
--- a/net/bluetooth/hidp/core.c
+++ b/net/bluetooth/hidp/core.c
@@ -636,40 +636,20 @@ static int hidp_send_frame(struct socket *sock, unsigned char *data, int len)
return kernel_sendmsg(sock, &msg, &iv, 1, len);
}
-static void hidp_process_intr_transmit(struct hidp_session *session)
+/* dequeue message from @transmit and send via @sock */
+static void hidp_process_transmit(struct hidp_session *session,
+ struct sk_buff_head *transmit,
+ struct socket *sock)
{
struct sk_buff *skb;
int ret;
BT_DBG("session %p", session);
- while ((skb = skb_dequeue(&session->intr_transmit))) {
- ret = hidp_send_frame(session->intr_sock, skb->data, skb->len);
+ while ((skb = skb_dequeue(transmit))) {
+ ret = hidp_send_frame(sock, skb->data, skb->len);
if (ret == -EAGAIN) {
- skb_queue_head(&session->intr_transmit, skb);
- break;
- } else if (ret < 0) {
- hidp_session_terminate(session);
- kfree_skb(skb);
- break;
- }
-
- hidp_set_timer(session);
- kfree_skb(skb);
- }
-}
-
-static void hidp_process_ctrl_transmit(struct hidp_session *session)
-{
- struct sk_buff *skb;
- int ret;
-
- BT_DBG("session %p", session);
-
- while ((skb = skb_dequeue(&session->ctrl_transmit))) {
- ret = hidp_send_frame(session->ctrl_sock, skb->data, skb->len);
- if (ret == -EAGAIN) {
- skb_queue_head(&session->ctrl_transmit, skb);
+ skb_queue_head(transmit, skb);
break;
} else if (ret < 0) {
hidp_session_terminate(session);
@@ -1224,7 +1204,8 @@ static void hidp_session_run(struct hidp_session *session)
}
/* send pending intr-skbs */
- hidp_process_intr_transmit(session);
+ hidp_process_transmit(session, &session->intr_transmit,
+ session->intr_sock);
/* parse incoming ctrl-skbs */
while ((skb = skb_dequeue(&ctrl_sk->sk_receive_queue))) {
@@ -1236,7 +1217,8 @@ static void hidp_session_run(struct hidp_session *session)
}
/* send pending ctrl-skbs */
- hidp_process_ctrl_transmit(session);
+ hidp_process_transmit(session, &session->ctrl_transmit,
+ session->ctrl_sock);
schedule();
}