* [PATCH obexd] btio: Adjust socket buffers to be at least as big as MTU
@ 2012-02-09 14:46 Luiz Augusto von Dentz
2012-02-09 15:36 ` Luiz Augusto von Dentz
0 siblings, 1 reply; 2+ messages in thread
From: Luiz Augusto von Dentz @ 2012-02-09 14:46 UTC (permalink / raw)
To: linux-bluetooth
From: Luiz Augusto von Dentz <luiz.von.dentz@intel.com>
---
btio/btio.c | 50 ++++++++++++++++++++++++++++++++++++++++++++++----
1 files changed, 46 insertions(+), 4 deletions(-)
diff --git a/btio/btio.c b/btio/btio.c
index 9781ec4..be81faf 100644
--- a/btio/btio.c
+++ b/btio/btio.c
@@ -119,6 +119,34 @@ static gboolean check_nval(GIOChannel *io)
return FALSE;
}
+static void adjust_buffers(GIOChannel *io)
+{
+ int sk = g_io_channel_unix_get_fd(io);
+ int omtu = 0, imtu = 0, sndbuf = 0, rcvbuf = 0;
+ socklen_t len = sizeof(int);
+
+ if (!bt_io_get(io, BT_IO_L2CAP, NULL, BT_IO_OPT_OMTU, &omtu,
+ BT_IO_OPT_IMTU, &imtu,
+ BT_IO_OPT_INVALID))
+ return;
+
+ if (getsockopt(sk, SOL_SOCKET, SO_SNDBUF, &sndbuf, &len) < 0)
+ return;
+
+ if (sndbuf < omtu) {
+ sndbuf = omtu;
+ setsockopt(sk, SOL_SOCKET, SO_SNDBUF, &sndbuf, len);
+ }
+
+ if (getsockopt(sk, SOL_SOCKET, SO_RCVBUF, &rcvbuf, &len) < 0)
+ return;
+
+ if (rcvbuf < imtu) {
+ rcvbuf = imtu;
+ setsockopt(sk, SOL_SOCKET, SO_RCVBUF, &rcvbuf, len);
+ }
+}
+
static gboolean accept_cb(GIOChannel *io, GIOCondition cond,
gpointer user_data)
{
@@ -129,10 +157,15 @@ static gboolean accept_cb(GIOChannel *io, GIOCondition cond,
if ((cond & G_IO_NVAL) || check_nval(io))
return FALSE;
- if (cond & (G_IO_HUP | G_IO_ERR))
+ if (cond & (G_IO_HUP | G_IO_ERR)) {
g_set_error(&err, BT_IO_ERROR, BT_IO_ERROR_DISCONNECTED,
"HUP or ERR on socket");
+ goto done;
+ }
+ adjust_buffers(io);
+
+done:
accept->connect(io, err, accept->user_data);
g_clear_error(&err);
@@ -159,14 +192,21 @@ static gboolean connect_cb(GIOChannel *io, GIOCondition cond,
else
err = -sk_err;
- if (err < 0)
+ if (err < 0) {
g_set_error(&gerr, BT_IO_ERROR,
BT_IO_ERROR_CONNECT_FAILED, "%s (%d)",
strerror(-err), -err);
- } else if (cond & (G_IO_HUP | G_IO_ERR))
+ goto done;
+ }
+ } else if (cond & (G_IO_HUP | G_IO_ERR)) {
g_set_error(&gerr, BT_IO_ERROR, BT_IO_ERROR_CONNECT_FAILED,
"HUP or ERR on socket");
+ goto done;
+ }
+
+ adjust_buffers(io);
+done:
conn->connect(io, gerr, conn->user_data);
if (gerr)
@@ -199,8 +239,10 @@ static gboolean server_cb(GIOChannel *io, GIOCondition cond,
if (server->confirm)
server->confirm(cli_io, server->user_data);
- else
+ else {
+ adjust_buffers(cli_io);
server->connect(cli_io, NULL, server->user_data);
+ }
g_io_channel_unref(cli_io);
--
1.7.7.6
^ permalink raw reply related [flat|nested] 2+ messages in thread
* Re: [PATCH obexd] btio: Adjust socket buffers to be at least as big as MTU
2012-02-09 14:46 [PATCH obexd] btio: Adjust socket buffers to be at least as big as MTU Luiz Augusto von Dentz
@ 2012-02-09 15:36 ` Luiz Augusto von Dentz
0 siblings, 0 replies; 2+ messages in thread
From: Luiz Augusto von Dentz @ 2012-02-09 15:36 UTC (permalink / raw)
To: linux-bluetooth
Hi,
On Thu, Feb 9, 2012 at 4:46 PM, Luiz Augusto von Dentz
<luiz.dentz@gmail.com> wrote:
> From: Luiz Augusto von Dentz <luiz.von.dentz@intel.com>
>
> ---
> btio/btio.c | 50 ++++++++++++++++++++++++++++++++++++++++++++++----
> 1 files changed, 46 insertions(+), 4 deletions(-)
>
> diff --git a/btio/btio.c b/btio/btio.c
> index 9781ec4..be81faf 100644
> --- a/btio/btio.c
> +++ b/btio/btio.c
> @@ -119,6 +119,34 @@ static gboolean check_nval(GIOChannel *io)
> return FALSE;
> }
>
> +static void adjust_buffers(GIOChannel *io)
> +{
> + int sk = g_io_channel_unix_get_fd(io);
> + int omtu = 0, imtu = 0, sndbuf = 0, rcvbuf = 0;
> + socklen_t len = sizeof(int);
> +
> + if (!bt_io_get(io, BT_IO_L2CAP, NULL, BT_IO_OPT_OMTU, &omtu,
> + BT_IO_OPT_IMTU, &imtu,
> + BT_IO_OPT_INVALID))
> + return;
> +
> + if (getsockopt(sk, SOL_SOCKET, SO_SNDBUF, &sndbuf, &len) < 0)
> + return;
> +
> + if (sndbuf < omtu) {
> + sndbuf = omtu;
> + setsockopt(sk, SOL_SOCKET, SO_SNDBUF, &sndbuf, len);
> + }
> +
> + if (getsockopt(sk, SOL_SOCKET, SO_RCVBUF, &rcvbuf, &len) < 0)
> + return;
> +
> + if (rcvbuf < imtu) {
> + rcvbuf = imtu;
> + setsockopt(sk, SOL_SOCKET, SO_RCVBUF, &rcvbuf, len);
> + }
> +}
> +
> static gboolean accept_cb(GIOChannel *io, GIOCondition cond,
> gpointer user_data)
> {
> @@ -129,10 +157,15 @@ static gboolean accept_cb(GIOChannel *io, GIOCondition cond,
> if ((cond & G_IO_NVAL) || check_nval(io))
> return FALSE;
>
> - if (cond & (G_IO_HUP | G_IO_ERR))
> + if (cond & (G_IO_HUP | G_IO_ERR)) {
> g_set_error(&err, BT_IO_ERROR, BT_IO_ERROR_DISCONNECTED,
> "HUP or ERR on socket");
> + goto done;
> + }
>
> + adjust_buffers(io);
> +
> +done:
> accept->connect(io, err, accept->user_data);
>
> g_clear_error(&err);
> @@ -159,14 +192,21 @@ static gboolean connect_cb(GIOChannel *io, GIOCondition cond,
> else
> err = -sk_err;
>
> - if (err < 0)
> + if (err < 0) {
> g_set_error(&gerr, BT_IO_ERROR,
> BT_IO_ERROR_CONNECT_FAILED, "%s (%d)",
> strerror(-err), -err);
> - } else if (cond & (G_IO_HUP | G_IO_ERR))
> + goto done;
> + }
> + } else if (cond & (G_IO_HUP | G_IO_ERR)) {
> g_set_error(&gerr, BT_IO_ERROR, BT_IO_ERROR_CONNECT_FAILED,
> "HUP or ERR on socket");
> + goto done;
> + }
> +
> + adjust_buffers(io);
>
> +done:
> conn->connect(io, gerr, conn->user_data);
>
> if (gerr)
> @@ -199,8 +239,10 @@ static gboolean server_cb(GIOChannel *io, GIOCondition cond,
>
> if (server->confirm)
> server->confirm(cli_io, server->user_data);
> - else
> + else {
> + adjust_buffers(cli_io);
> server->connect(cli_io, NULL, server->user_data);
> + }
>
> g_io_channel_unref(cli_io);
>
> --
> 1.7.7.6
Maybe I should have sent this as an RFC since this could be done in
kernel automatically as it could be considered broken in case of
SOCK_SEQPACKET if socket buffer cannot hold a write/read of MTU size.
This is not actually a new problem as there exist a workaround in
avdtp.c to adjust the socket buffer too, but it became more evident
with introduction of gobex which can use SOCK_SEQPACKET with a
considerable big MTU (up to 64k) which will fail if there is not
enough space to stuff full packets.
--
Luiz Augusto von Dentz
^ permalink raw reply [flat|nested] 2+ messages in thread
end of thread, other threads:[~2012-02-09 15:36 UTC | newest]
Thread overview: 2+ messages (download: mbox.gz follow: Atom feed
-- links below jump to the message on this page --
2012-02-09 14:46 [PATCH obexd] btio: Adjust socket buffers to be at least as big as MTU Luiz Augusto von Dentz
2012-02-09 15:36 ` Luiz Augusto von Dentz
This is a public inbox, see mirroring instructions
for how to clone and mirror all data and code used for this inbox