Re: Non-blocking socket communication with GIO

[Gergely Polonkai <gergely polonkai eu>]

Hello,

yes, the first two bytes of the response is the message length. If i explicitly read exactly two bytes (to get the message length) and then explicitly read that many bytes to get the response, i’m fine.

What is not working as i expected is the polling. I thought that if i

* set the socket to non-blocking (g_socket_set_blocking())

* create a source for the socket with the G_IO_IN and G_IO_PRI flags (inbound data + priority inbound data, although i’m pretty sure priority inbound doesn’t happen on this protocol)

* set a callback function with g_source_set_callback()

then my callback will be called whenever there is data available. At least that’s what i’d do if i’d be using plain Linux sockets, using select()/poll()/epoll().

Best,

Gergely

mið., 23. jan. 2019 kl. 10:48 skrifaði Göran Hasse <gorhas raditex nu>:

Den 2019-01-10 kl. 15:02, skrev Gergely Polonkai:
>
> Hello,

Hello,

First. If you ar using a binary protocol - how do you recognise the
frame?

All socket reading sould recognice a frame header, where the size of
the frame is stated and then read that amount of bytes. An alternative
is to read one byte at a time and try to figure out when you have a
frame end.

/gh


>
> i’m working on an app that communicates with a network service using a
> custom binary protocol.  For that i have a GSocketClient.  The
> destination can, in theory, be either a TCP/IP or a UNIX socket (only
> TCP/IP is implemented yet).  I initiate the connection like this:
>
>      scuttler->socket_client = g_socket_client_new();
>
>      address = g_inet_address_new_from_string("127.0.0.1");
>      destination = g_inet_socket_address_new(address, 8008);
>      g_object_unref(address);
>
>      g_task_set_task_data(task, g_object_ref(scuttler), (GDestroyNotify)g_object_unref);
>
>      g_socket_client_connect_async(scuttler->socket_client, G_SOCKET_CONNECTABLE(destination), cancellable, connection_finished, task);
>
> Then, in connecion_finished(), among other things, i do this:
>
>      scuttler->connection = connection;
>
>      if (!ssb_scuttler_shs_connect(scuttler, &err)) {
>          g_task_return_error(task, err);
>          g_object_unref(task);
>
>          return;
>      }
>
>      socket = g_socket_connection_get_socket(connection);
>      g_socket_set_blocking(socket, FALSE);
>      socket_source = g_socket_create_source(socket, G_IO_IN | G_IO_PRI, NULL);
>      g_source_set_callback(socket_source,
>                            (GSourceFunc)read_inbound,
>                            g_object_ref(scuttler), g_object_unref);
>      g_source_attach(socket_source, g_main_context_get_thread_default());
>
> However, my read_inbound() function never gets called, even though my
> request ends up in the server (i can see it in the logs).  Am i missing
> something fundamental here?
>
> (Also, this is not really GTK, but more like GLib/GIO specific; if there
> is a better mailing list to send this, please advise.)
>
> Best,
> Gergely
> _______________________________________________
> gtk-list mailing list
> gtk-list gnome org
> https://mail.gnome.org/mailman/listinfo/gtk-list
>


--
-----------------------------
Göran Hasse
Raditex Control AB
http://www.rscada.se http://www.raditex.nu
Boo 229, 715 91 ODENSBACKEN
Phone: +46 19 450105
Mobile: 070-5530148