Attachment 153536 Details for Bug 237662 – cups-dbus-notifier.patch

[patch] cups-dbus-notifier.patch

cups-dbus-notifier.patch (text/plain), 10.55 KB, created by Tim Waugh on 2007-04-26 17:55:52 UTC

(hide)

Description:

Filename:

MIME Type:

Creator: Tim Waugh

Created: 2007-04-26 17:55:52 UTC

Size: 10.55 KB

patch

obsolete

>--- /dev/null	2007-04-26 08:57:16.016726874 +0100
>+++ cups-1.2.10/notifier/dbus.c	2007-04-26 18:53:16.000000000 +0100
>@@ -0,0 +1,363 @@
>+/*
>+ *   D-Bus notifier for the Common UNIX Printing System (CUPS).
>+ *
>+ *   Copyright (C) 2007 Red Hat, Inc.
>+ *   Copyright (C) 2007 Tim Waugh <twaugh@redhat.com>
>+ *   Copyright 1997-2005 by Easy Software Products.
>+ *
>+ */
>+
>+#include <cups/cups.h>
>+#include <cups/string.h>
>+#include <signal.h>
>+
>+#ifdef HAVE_DBUS
>+#  include <dbus/dbus.h>
>+#  ifdef HAVE_DBUS_MESSAGE_ITER_INIT_APPEND
>+#    define dbus_message_append_iter_init dbus_message_iter_init_append
>+#    define dbus_message_iter_append_string(i,v) dbus_message_iter_append_basic(i, DBUS_TYPE_STRING, v)
>+#    define dbus_message_iter_append_uint32(i,v) dbus_message_iter_append_basic(i, DBUS_TYPE_UINT32, v)
>+#    define dbus_message_iter_append_boolean(i,v) dbus_message_iter_append_basic(i, DBUS_TYPE_BOOLEAN, v)
>+#  endif /* HAVE_DBUS_MESSAGE_ITER_INIT_APPEND */
>+#endif /* HAVE_DBUS */
>+
>+#ifndef HAVE_DBUS
>+int
>+main(int  argc,
>+     char *argv[])
>+{
>+  return (1);
>+}
>+
>+#else /* HAVE_DBUS */
>+
>+int
>+main(int  argc,
>+     char *argv[])
>+{
>+  ipp_t			*msg = NULL;	/* Event message from scheduler */
>+  ipp_state_t		state;		/* IPP event state */
>+#if defined(HAVE_SIGACTION) && !defined(HAVE_SIGSET)
>+  struct sigaction	action;		/* POSIX sigaction data */
>+#endif /* HAVE_SIGACTION && !HAVE_SIGSET */
>+  DBusConnection	*con = NULL;	/* Connection to DBUS server */
>+  DBusError		error;		/* Error, if any */
>+  DBusMessage		*message;	/* Message to send */
>+  DBusMessageIter	iter;		/* Iterator for message data */
>+
>+ /*
>+  * Don't buffer stderr...
>+  */
>+
>+  setbuf(stderr, NULL);
>+
>+ /*
>+  * Ignore SIGPIPE signals...
>+  */
>+
>+#ifdef HAVE_SIGSET
>+  sigset(SIGPIPE, SIG_IGN);
>+#elif defined(HAVE_SIGACTION)
>+  memset(&action, 0, sizeof(action));
>+  action.sa_handler = SIG_IGN;
>+  sigaction(SIGPIPE, &action, NULL);
>+#else
>+  signal(SIGPIPE, SIG_IGN);
>+#endif /* HAVE_SIGSET */
>+
>+ /*
>+  * Validate command-line options...
>+  */
>+
>+  if (argc != 3)
>+  {
>+    fputs("Usage: dbus dbus: notify-user-data\n", stderr);
>+    return (1);
>+  }
>+
>+  if (strcmp(argv[1], "dbus:"))
>+  {
>+    fprintf(stderr, "ERROR: Bad URI \"%s\"!\n", argv[1]);
>+    return (1);
>+  }
>+
>+ /*
>+  * Loop forever until we run out of events...
>+  */
>+
>+  for (;;)
>+  {
>+    ipp_attribute_t *attr;
>+    const char *event;
>+    const char *signame = NULL;
>+    char *printer_reasons = NULL;
>+    const char *nul = "";
>+    int no = 0;
>+    enum {
>+      PARAMS_NONE,
>+      PARAMS_PRINTER,
>+      PARAMS_JOB
>+    } params = PARAMS_NONE;
>+
>+   /*
>+    * Free the memory used for the last event...
>+    */
>+
>+    if (msg)
>+      ippDelete(msg);
>+
>+   /*
>+    * Get the next event...
>+    */
>+
>+    msg = ippNew();
>+    while ((state = ippReadFile(0, msg)) != IPP_DATA)
>+    {
>+      if (state <= IPP_IDLE)
>+        break;
>+    }
>+
>+    fprintf(stderr, "DEBUG: state=%d\n", state);
>+
>+    if (state == IPP_ERROR)
>+      fputs("DEBUG: ippReadFile() returned IPP_ERROR!\n", stderr);
>+
>+    if (state <= IPP_IDLE)
>+    {
>+     /*
>+      * Out of messages, free memory and then exit...
>+      */
>+
>+      ippDelete(msg);
>+      return (0);
>+    }
>+
>+   /*
>+    * Verify connection to DBUS server...
>+    */
>+    if (con && !dbus_connection_get_is_connected(con))
>+    {
>+      dbus_connection_unref(con);
>+      con = NULL;
>+    }
>+
>+    if (!con)
>+    {
>+      dbus_error_init(&error);
>+
>+      con = dbus_bus_get(DBUS_BUS_SYSTEM, &error);
>+      if (!con)
>+      {
>+	dbus_error_free (&error);
>+      }
>+      else
>+	fprintf(stderr, "DEBUG: connected to D-BUS\n", state);
>+    }
>+
>+    if (!con)
>+      continue;
>+
>+    attr = ippFindAttribute (msg, "notify-subscribed-event",
>+			     IPP_TAG_KEYWORD);
>+    if (!attr)
>+      continue;
>+
>+    event = attr->values[0].string.text;
>+    if (!strncmp (event, "server-", 7))
>+    {
>+      const char *word2 = event + 7;
>+      if (!strcmp (word2, "restarted"))
>+	signame = "ServerRestarted";
>+      else if (!strcmp (word2, "started"))
>+	signame = "ServerStarted";
>+      else if (!strcmp (word2, "stopped"))
>+	signame = "ServerStopped";
>+      else if (!strcmp (word2, "audit"))
>+	signame = "ServerAudit";
>+      else
>+	continue;
>+    }
>+    else if (!strncmp (event, "printer-", 8))
>+    {
>+      const char *word2 = event + 8;
>+      params = PARAMS_PRINTER;
>+      if (!strcmp (word2, "restarted"))
>+	signame = "PrinterRestarted";
>+      else if (!strcmp (word2, "shutdown"))
>+	signame = "PrinterShutdown";
>+      else if (!strcmp (word2, "stopped"))
>+	signame = "PrinterStopped";
>+      else if (!strcmp (word2, "finishings-changed"))
>+	signame = "PrinterFinishingsChanged";
>+      else if (!strcmp (word2, "media-changed"))
>+	signame = "PrinterMediaChanged";
>+      else if (!strcmp (word2, "added"))
>+	signame = "PrinterAdded";
>+      else if (!strcmp (word2, "deleted"))
>+	signame = "PrinterDeleted";
>+      else if (!strcmp (word2, "modified"))
>+	signame = "PrinterModified";
>+      else if (!strcmp (word2, "state-changed"))
>+	signame = "PrinterStateChanged";
>+      else if (!strcmp (word2, "config-changed"))
>+	signame = "PrinterConfigChanged";
>+      else if (!strcmp (word2, "changed"))
>+	signame = "PrinterChanged";
>+      else
>+	continue;
>+    }
>+    else if (!strncmp (event, "job-", 4))
>+    {
>+      const char *word2 = event + 4;
>+      params = PARAMS_JOB;
>+      if (!strcmp (word2, "created"))
>+	signame = "JobCreated";
>+      else if (!strcmp (word2, "completed"))
>+	signame = "JobCompleted";
>+      else if (!strcmp (word2, "stopped"))
>+	signame = "JobStopped";
>+      else if (!strcmp (word2, "config-changed"))
>+	signame = "JobConfigChanged";
>+      else if (!strcmp (word2, "progress"))
>+	signame = "JobProgress";
>+      else if (!strcmp (word2, "state"))
>+	signame = "JobState";
>+      else
>+	continue;
>+    }
>+    else
>+      continue;
>+
>+    /*
>+     * Create and send the new message...
>+     */
>+    
>+    fprintf(stderr, "DEBUG: %s\n", signame);
>+    message = dbus_message_new_signal("/org/cups/cupsd",
>+				      "org.cups.cupsd",
>+				      signame);
>+
>+    if (params > PARAMS_NONE)
>+      dbus_message_append_iter_init(message, &iter);
>+
>+    if (params >= PARAMS_PRINTER)
>+    {
>+      char *p;
>+      size_t reasons_length;
>+      int i;
>+
>+      /* STRING printer-uri or "" */
>+      fprintf(stderr, "DEBUG: STRING printer-uri\n");
>+      attr = ippFindAttribute (msg, "notify-printer-uri", IPP_TAG_URI);
>+      if (!attr)
>+      {
>+	dbus_message_iter_append_string(&iter, &nul);	/* printer-uri */
>+	dbus_message_iter_append_string(&iter, &nul);	/* printer-name */
>+	dbus_message_iter_append_uint32(&iter, &no);	/* printer-state */
>+	dbus_message_iter_append_string(&iter, &nul);	/* printer-state-reasons */
>+	dbus_message_iter_append_boolean(&iter, &no);	/* printer-is-accepting-jobs */
>+      }
>+      else
>+      {
>+	dbus_message_iter_append_string(&iter, &(attr->values[0].string.text));
>+
>+	/* STRING printer-name */
>+	fprintf(stderr, "DEBUG: STRING printer-name\n");
>+	attr = ippFindAttribute (msg, "printer-name", IPP_TAG_NAME);
>+	if (!attr)
>+	  goto bail;
>+	dbus_message_iter_append_string(&iter, &(attr->values[0].string.text));
>+
>+	/* UINT32 printer-state */
>+	fprintf(stderr, "DEBUG: UINT32 printer-state\n");
>+	attr = ippFindAttribute (msg, "printer-state", IPP_TAG_ENUM);
>+	if (!attr)
>+	  goto bail;
>+	dbus_message_iter_append_uint32(&iter, &(attr->values[0].integer));
>+
>+	/* STRING printer-state-reasons */
>+	fprintf(stderr, "DEBUG: STRING printer-state-reasons\n");
>+	attr = ippFindAttribute (msg, "printer-state-reasons",
>+				 IPP_TAG_KEYWORD);
>+	if (!attr)
>+	  goto bail;
>+	for (reasons_length = 0, i = 0; i < attr->num_values; i++)
>+	  /* All need commas except the last, which needs a nul byte. */
>+	  reasons_length += 1 + strlen (attr->values[i].string.text);
>+	printer_reasons = malloc (reasons_length);
>+	if (printer_reasons == NULL)
>+	  goto bail;
>+	p = printer_reasons;
>+	for (i = 0; i < attr->num_values; i++)
>+	{
>+	  reasons_length = strlen (attr->values[i].string.text);
>+	  strcpy (p, attr->values[i].string.text);
>+	  p += reasons_length;
>+	  if (i)
>+	    *p++ = ',';
>+	}
>+	dbus_message_iter_append_string(&iter, &printer_reasons);
>+
>+	/* BOOL printer-is-accepting-jobs */
>+	fprintf(stderr, "DEBUG: BOOLEAN printer-is-accepting-jobs\n");
>+	attr = ippFindAttribute (msg, "printer-is-accepting-jobs",
>+				 IPP_TAG_BOOLEAN);
>+	if (!attr)
>+	  goto bail;
>+	fprintf(stderr, "DEBUG: printer-is-accepting-jobs: %d\n",
>+		attr->values[i].boolean);
>+	dbus_message_iter_append_boolean(&iter, &(attr->values[i].boolean));
>+      }
>+    }
>+
>+    if (params >= PARAMS_JOB)
>+    {
>+      /* UINT32 job-id */
>+      fprintf(stderr, "DEBUG: UINT32 job-id\n");
>+      attr = ippFindAttribute (msg, "notify-job-id", IPP_TAG_INTEGER);
>+      if (!attr)
>+	goto bail;
>+      dbus_message_iter_append_uint32(&iter, &(attr->values[0].integer));
>+
>+      /* UINT32 job-state */
>+      fprintf(stderr, "DEBUG: UINT32 job-state\n");
>+      attr = ippFindAttribute (msg, "job-state", IPP_TAG_ENUM);
>+      if (!attr)
>+	goto bail;
>+      dbus_message_iter_append_uint32(&iter, &(attr->values[0].integer));
>+
>+      /* STRING job-state-reasons */
>+      fprintf(stderr, "DEBUG: STRING job-state-reasons\n");
>+      attr = ippFindAttribute (msg, "job-state-reasons", IPP_TAG_KEYWORD);
>+      if (!attr)
>+	goto bail;
>+      dbus_message_iter_append_string(&iter, &(attr->values[0].string.text));
>+
>+      /* STRING job-name or "" */
>+      fprintf(stderr, "DEBUG: STRING job-name\n");
>+      attr = ippFindAttribute (msg, "job-name", IPP_TAG_NAME);
>+      if (attr)
>+	dbus_message_iter_append_string(&iter, &(attr->values[0].string.text));
>+      else
>+	dbus_message_iter_append_string(&iter, &nul);
>+
>+      /* UINT32 job-impressions-completed */
>+      fprintf(stderr, "DEBUG: UINT32 job-impressions-completed\n");
>+      attr = ippFindAttribute (msg, "job-impressions-completed",
>+			       IPP_TAG_INTEGER);
>+      if (!attr)
>+	goto bail;
>+      dbus_message_iter_append_uint32(&iter, &(attr->values[0].integer));
>+    }
>+
>+    dbus_connection_send(con, message, NULL);
>+    dbus_connection_flush(con);
>+
>+  bail:
>+    if (printer_reasons)
>+      free (printer_reasons);
>+    dbus_message_unref(message);
>+  }
>+}
>+
>+#endif /* HAVE_DBUS */
>--- cups-1.2.10/notifier/Makefile.dbus-notifier	2006-03-05 16:48:12.000000000 +0000
>+++ cups-1.2.10/notifier/Makefile	2007-04-26 18:02:22.000000000 +0100
>@@ -25,8 +25,8 @@
> include ../Makedefs
> 
> 
>-TARGETS =	mailto testnotify
>-OBJS	=	mailto.o testnotify.o
>+TARGETS =	mailto testnotify dbus
>+OBJS	=	mailto.o testnotify.o dbus.o
> 
> 
> #
>@@ -85,6 +85,15 @@
> 
> 
> #
>+# dbus
>+#
>+
>+dbus:	dbus.o ../cups/$(LIBCUPS)
>+	echo Linking $@...
>+	$(CC) $(LDFLAGS) -o dbus dbus.o $(LIBS) $(DBUSLIBS)
>+
>+
>+#
> # testnotify
> #
>

Actions: View | Diff

Attachments on bug 237662: 153536 | 153613 | 153707 | 154538