Return-Path: From: Andrei Emeltchenko To: linux-bluetooth@vger.kernel.org Subject: [PATCHv3 06/16] android/socket: Implement Android RFCOMM stack events Date: Mon, 18 Nov 2013 10:26:09 +0200 Message-Id: <1384763179-2218-7-git-send-email-Andrei.Emeltchenko.news@gmail.com> In-Reply-To: <1384763179-2218-1-git-send-email-Andrei.Emeltchenko.news@gmail.com> References: <1384763179-2218-1-git-send-email-Andrei.Emeltchenko.news@gmail.com> Sender: linux-bluetooth-owner@vger.kernel.org List-ID: From: Andrei Emeltchenko Handle events from Android framework. Write everything to real RFCOMM socket. Consider splice() in the future. --- android/socket.c | 61 ++++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 61 insertions(+) diff --git a/android/socket.c b/android/socket.c index c9ee32f..027b519 100644 --- a/android/socket.c +++ b/android/socket.c @@ -115,9 +115,70 @@ static int get_rfcomm_default_chan(const uint8_t *uuid) return -1; } +static int try_write_all(int fd, unsigned char *buf, int len) +{ + int sent = 0; + + while (len > 0) { + int written; + + written = write(fd, buf, len); + if (written < 0) { + if (errno == EINTR || errno == EAGAIN) + continue; + return -1; + } + + if (!written) + return 0; + + len -= written; buf += written; sent += written; + } + + return sent; +} + static gboolean sock_stack_event_cb(GIOChannel *io, GIOCondition cond, gpointer data) { + struct rfcomm_slot *rfslot = data; + unsigned char buf[1024]; + int len, sent; + + DBG("rfslot: fd %d real_sock %d chan %u sock %d", + rfslot->fd, rfslot->real_sock, rfslot->channel, + g_io_channel_unix_get_fd(io)); + + if (!g_list_find(rfcomm_connected_list, rfslot)) { + error("rfslot %p not found in the list", rfslot); + return FALSE; + } + + if (cond & (G_IO_ERR | G_IO_HUP | G_IO_NVAL)) { + error("Socket error: sock %d cond %d", + g_io_channel_unix_get_fd(io), cond); + rfcomm_connected_list = g_list_remove(rfcomm_connected_list, + rfslot); + cleanup_rfslot(rfslot); + return FALSE; + } + + len = read(rfslot->fd, buf, sizeof(buf)); + if (len <= 0) { + error("read(): %s", strerror(errno)); + return FALSE; + } + + DBG("read %d bytes write to %d", len, rfslot->real_sock); + + sent = try_write_all(rfslot->real_sock, buf, len); + if (sent < 0) { + error("write(): %s", strerror(errno)); + return FALSE; + } + + DBG("Written %d bytes", sent); + return TRUE; } -- 1.7.10.4