Function cupsdAddSubscription

scheduler/subscriptions.c:260–408

 */

cupsd_subscription_t *			/* O - New subscription object */
cupsdAddSubscription(
    unsigned	    mask,		/* I - Event mask */
    cupsd_printer_t *dest,		/* I - Printer, if any */
    cupsd_job_t	    *job,		/* I - Job, if any */
    const char	    *uri,		/* I - notify-recipient-uri, if any */
    int		    sub_id)		/* I - notify-subscription-id or 0 */
{
  cupsd_subscription_t	*temp;		/* New subscription object */


  cupsdLogMessage(CUPSD_LOG_DEBUG,
		  "cupsdAddSubscription(mask=%x, dest=%p(%s), job=%p(%d), "
		  "uri=\"%s\")",
		  mask, (void *)dest, dest ? dest->name : "", (void *)job, job ? job->id : 0,
		  uri ? uri : "(null)");

  _cupsRWLockWrite(&SubscriptionsLock);

  if (!Subscriptions)
    Subscriptions = cupsArrayNew((cups_array_func_t)cupsd_compare_subscriptions,
				 NULL);

  if (!Subscriptions)
  {
    cupsdLogMessage(CUPSD_LOG_CRIT,
		    "Unable to allocate memory for subscriptions - %s",
		    strerror(errno));
    _cupsRWUnlock(&SubscriptionsLock);
    return (NULL);
  }

 /*
  * Limit the number of subscriptions...
  */

  if (MaxSubscriptions > 0 && cupsArrayCount(Subscriptions) >= MaxSubscriptions)
  {
    cupsdLogMessage(CUPSD_LOG_DEBUG,
		    "cupsdAddSubscription: Reached MaxSubscriptions %d "
		    "(count=%d)", MaxSubscriptions,
		    cupsArrayCount(Subscriptions));
    _cupsRWUnlock(&SubscriptionsLock);
    return (NULL);
  }

  if (MaxSubscriptionsPerJob > 0 && job)
  {
    int count;				/* Number of job subscriptions */

    for (temp = (cupsd_subscription_t *)cupsArrayFirst(Subscriptions),
	     count = 0;
	 temp;
	 temp = (cupsd_subscription_t *)cupsArrayNext(Subscriptions))
      if (temp->job == job)
	count ++;

    if (count >= MaxSubscriptionsPerJob)