Return-Path: From: Andrei Emeltchenko To: linux-bluetooth@vger.kernel.org Subject: [PATCHv6 06/19] android/socket: Implement RFCOMM events Date: Wed, 20 Nov 2013 12:24:24 +0200 Message-Id: <1384943077-5366-7-git-send-email-Andrei.Emeltchenko.news@gmail.com> In-Reply-To: <1384943077-5366-1-git-send-email-Andrei.Emeltchenko.news@gmail.com> References: <1384943077-5366-1-git-send-email-Andrei.Emeltchenko.news@gmail.com> Sender: linux-bluetooth-owner@vger.kernel.org List-ID: From: Andrei Emeltchenko Copy data from RFCOMM socket to Android framework. Consider splice in the future. --- android/socket.c | 36 ++++++++++++++++++++++++++++++++++++ 1 file changed, 36 insertions(+) diff --git a/android/socket.c b/android/socket.c index 49b7413..3e738a4 100644 --- a/android/socket.c +++ b/android/socket.c @@ -201,7 +201,43 @@ fail: static gboolean sock_rfcomm_event_cb(GIOChannel *io, GIOCondition cond, gpointer data) { + struct rfcomm_sock *rfsock = data; + unsigned char buf[1024]; + int len, sent; + + DBG("rfsock: fd %d real_sock %d chan %u sock %d", + rfsock->fd, rfsock->real_sock, rfsock->channel, + g_io_channel_unix_get_fd(io)); + + 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); + goto fail; + } + + len = read(rfsock->real_sock, buf, sizeof(buf)); + if (len <= 0) { + error("read(): %s", strerror(errno)); + /* Read again */ + return TRUE; + } + + DBG("read %d bytes, write to fd %d", len, rfsock->fd); + + sent = try_write_all(rfsock->fd, buf, len); + if (sent < 0) { + error("write(): %s", strerror(errno)); + goto fail; + } + + DBG("Written %d bytes", sent); + return TRUE; +fail: + connections = g_list_remove(connections, rfsock); + cleanup_rfsock(rfsock); + + return FALSE; } static void accept_cb(GIOChannel *io, GError *err, gpointer user_data) -- 1.7.10.4