sd-bus: if we receive an invalid dbus message, ignore and proceeed

[thirdparty/systemd.git] / src / libsystemd / sd-bus / bus-socket.c

diff --git a/src/libsystemd/sd-bus/bus-socket.c b/src/libsystemd/sd-bus/bus-socket.c
index 30d6455b6fc76344ecdde97a402690e3e5548726..441b4a816f3af989459fc4024378fd0b413c2736 100644 (file)
--- a/src/libsystemd/sd-bus/bus-socket.c
+++ b/src/libsystemd/sd-bus/bus-socket.c
@@ -1072,7 +1072,7 @@ static int bus_socket_read_message_need(sd_bus *bus, size_t *need) {
 }
 
 static int bus_socket_make_message(sd_bus *bus, size_t size) {
 }
 
 static int bus_socket_make_message(sd_bus *bus, size_t size) {

-        sd_bus_message *t;
+        sd_bus_message *t = NULL;

         void *b;
         int r;
 
         void *b;
         int r;
 


@@ -1097,7 +1097,9 @@ static int bus_socket_make_message(sd_bus *bus, size_t size) {
                                     bus->fds, bus->n_fds,
                                     NULL,
                                     &t);
                                     bus->fds, bus->n_fds,
                                     NULL,
                                     &t);

-        if (r < 0) {
+        if (r == -EBADMSG)
+                log_debug_errno(r, "Received invalid message from connection %s, dropping.", strna(bus->description));
+        else if (r < 0) {

                 free(b);
                 return r;
         }
                 free(b);
                 return r;
         }


@@ -1108,7 +1110,8 @@ static int bus_socket_make_message(sd_bus *bus, size_t size) {
         bus->fds = NULL;
         bus->n_fds = 0;
 
         bus->fds = NULL;
         bus->n_fds = 0;
 

-        bus->rqueue[bus->rqueue_size++] = t;
+        if (t)
+                bus->rqueue[bus->rqueue_size++] = t;

 
         return 1;
 }
 
         return 1;
 }