Branch data     Line data    Source code

       1                 :            : /* SPDX-License-Identifier: LGPL-2.1+ */
       2                 :            : 
       3                 :            : #include "alloc-util.h"
       4                 :            : #include "format-util.h"
       5                 :            : #include "journald-server.h"
       6                 :            : #include "journald-wall.h"
       7                 :            : #include "process-util.h"
       8                 :            : #include "string-util.h"
       9                 :            : #include "utmp-wtmp.h"
      10                 :            : 
      11                 :          0 : void server_forward_wall(
      12                 :            :                 Server *s,
      13                 :            :                 int priority,
      14                 :            :                 const char *identifier,
      15                 :            :                 const char *message,
      16                 :            :                 const struct ucred *ucred) {
      17                 :            : 
      18   [ #  #  #  # ]:          0 :         _cleanup_free_ char *ident_buf = NULL, *l_buf = NULL;
      19                 :            :         const char *l;
      20                 :            :         int r;
      21                 :            : 
      22         [ #  # ]:          0 :         assert(s);
      23         [ #  # ]:          0 :         assert(message);
      24                 :            : 
      25         [ #  # ]:          0 :         if (LOG_PRI(priority) > s->max_level_wall)
      26                 :          0 :                 return;
      27                 :            : 
      28         [ #  # ]:          0 :         if (ucred) {
      29         [ #  # ]:          0 :                 if (!identifier) {
      30                 :          0 :                         get_process_comm(ucred->pid, &ident_buf);
      31                 :          0 :                         identifier = ident_buf;
      32                 :            :                 }
      33                 :            : 
      34         [ #  # ]:          0 :                 if (asprintf(&l_buf, "%s["PID_FMT"]: %s", strempty(identifier), ucred->pid, message) < 0) {
      35                 :          0 :                         log_oom();
      36                 :          0 :                         return;
      37                 :            :                 }
      38                 :            : 
      39                 :          0 :                 l = l_buf;
      40                 :            : 
      41         [ #  # ]:          0 :         } else if (identifier) {
      42                 :            : 
      43                 :          0 :                 l = l_buf = strjoin(identifier, ": ", message);
      44         [ #  # ]:          0 :                 if (!l_buf) {
      45                 :          0 :                         log_oom();
      46                 :          0 :                         return;
      47                 :            :                 }
      48                 :            :         } else
      49                 :          0 :                 l = message;
      50                 :            : 
      51                 :          0 :         r = utmp_wall(l, "systemd-journald", NULL, NULL, NULL);
      52         [ #  # ]:          0 :         if (r < 0)
      53         [ #  # ]:          0 :                 log_debug_errno(r, "Failed to send wall message: %m");
      54                 :            : }