[thirdparty/cups.git] / scheduler / dirsvc.c

/*
 * "$Id: dirsvc.c,v 1.45 2000/01/27 02:25:45 mike Exp $"
 *
 *   Directory services routines for the Common UNIX Printing System (CUPS).
 *
 *   Copyright 1997-2000 by Easy Software Products, all rights reserved.
 *
 *   These coded instructions, statements, and computer programs are the
 *   property of Easy Software Products and are protected by Federal
 *   copyright law.  Distribution and use rights are outlined in the file
 *   "LICENSE.txt" which should have been included with this file.  If this
 *   file is missing or damaged please contact Easy Software Products
 *   at:
 *
 *       Attn: CUPS Licensing Information
 *       Easy Software Products
 *       44141 Airport View Drive, Suite 204
 *       Hollywood, Maryland 20636-3111 USA
 *
 *       Voice: (301) 373-9603
 *       EMail: cups-info@cups.org
 *         WWW: http://www.cups.org
 *
 * Contents:
 *
 *   StartBrowsing()    - Start sending and receiving broadcast information.
 *   StopBrowsing()     - Stop sending and receiving broadcast information.
 *   UpdateBrowseList() - Update the browse lists for any new browse data.
 *   SendBrowseList()   - Send new browsing information.
 */

/*
 * Include necessary headers...
 */

#include "cupsd.h"


/*
 * 'StartBrowsing()' - Start sending and receiving broadcast information.
 */

void
StartBrowsing(void)
{
  int			val;	/* Socket option value */
  struct sockaddr_in	addr;	/* Broadcast address */


  if (!Browsing)
    return;

 /*
  * Create the broadcast socket...
  */

  if ((BrowseSocket = socket(AF_INET, SOCK_DGRAM, 0)) < 0)
  {
    LogMessage(LOG_ERROR, "StartBrowsing: Unable to create broadcast socket - %s.",
               strerror(errno));
    return;
  }

 /*
  * Set the "broadcast" flag...
  */

  val = 1;
  if (setsockopt(BrowseSocket, SOL_SOCKET, SO_BROADCAST, &val, sizeof(val)))
  {
    LogMessage(LOG_ERROR, "StartBrowsing: Unable to set broadcast mode - %s.",
               strerror(errno));

#if defined(WIN32) || defined(__EMX__)
    closesocket(BrowseSocket);
#else
    close(BrowseSocket);
#endif /* WIN32 || __EMX__ */

    BrowseSocket = -1;
    return;
  }

 /*
  * Bind the socket to browse port...
  */

  memset(&addr, 0, sizeof(addr));
  addr.sin_addr.s_addr = htonl(INADDR_ANY);
  addr.sin_family      = AF_INET;
  addr.sin_port        = htons(BrowsePort);

  if (bind(BrowseSocket, (struct sockaddr *)&addr, sizeof(addr)))
  {
    LogMessage(LOG_ERROR, "StartBrowsing: Unable to bind broadcast socket - %s.",
               strerror(errno));

#if defined(WIN32) || defined(__EMX__)
    closesocket(BrowseSocket);
#else
    close(BrowseSocket);
#endif /* WIN32 || __EMX__ */

    BrowseSocket = -1;
    return;
  }

 /*
  * Finally, add the socket to the input selection set...
  */

  FD_SET(BrowseSocket, &InputSet);
}


/*
 * 'StopBrowsing()' - Stop sending and receiving broadcast information.
 */

void
StopBrowsing(void)
{
  if (!Browsing)
    return;

 /*
  * Close the socket and remove it from the input selection set.
  */

  if (BrowseSocket >= 0)
  {
#if defined(WIN32) || defined(__EMX__)
    closesocket(BrowseSocket);
#else
    close(BrowseSocket);
#endif /* WIN32 || __EMX__ */

    FD_CLR(BrowseSocket, &InputSet);
  }
}


/*
 * 'UpdateBrowseList()' - Update the browse lists for any new browse data.
 */

void
UpdateBrowseList(void)
{
  int		i;			/* Looping var */
  int		len,			/* Length of name string */
		offset;			/* Offset in name string */
  int		bytes;			/* Number of bytes left */
  char		packet[1540];		/* Broadcast packet */
  cups_ptype_t	type;			/* Printer type */
  ipp_pstate_t	state;			/* Printer state */
  char		uri[HTTP_MAX_URI],	/* Printer URI */
		method[HTTP_MAX_URI],	/* Method portion of URI */
		username[HTTP_MAX_URI],	/* Username portion of URI */
		host[HTTP_MAX_URI],	/* Host portion of URI */
		resource[HTTP_MAX_URI];	/* Resource portion of URI */
  int		port;			/* Port portion of URI */
  char		name[IPP_MAX_NAME],	/* Name of printer */
		*hptr,			/* Pointer into hostname */
		*sptr;			/* Pointer into ServerName */
  printer_t	*p,			/* Printer information */
		*pclass,		/* Printer class */
		*first;			/* First printer in class */


 /*
  * Read a packet from the browse socket...
  */

#ifdef DEBUG
  struct sockaddr_in	addr;


  len = sizeof(addr);
  if ((bytes = recvfrom(BrowseSocket, packet, sizeof(packet), 0, 
                        (struct sockaddr *)&addr, &len)) <= 0)
  {
    LogMessage(LOG_ERROR, "Browse recv failed - %s.",
               strerror(errno));
    LogMessage(LOG_ERROR, "Browsing turned off.");

    StopBrowsing();
    Browsing = 0;
    return;
  }

  packet[bytes] = '\0';
  printf("UpdateBrowseList: (%d bytes from %08x) %s", bytes,
         ntohl(addr.sin_addr.s_addr), packet);
#else
  if ((bytes = recv(BrowseSocket, packet, sizeof(packet), 0)) <= 0)
  {
    LogMessage(LOG_ERROR, "Browse recv failed - %s.",
               strerror(errno));
    LogMessage(LOG_ERROR, "Browsing turned off.");

    StopBrowsing();
    Browsing = 0;
    return;
  }

  packet[bytes] = '\0';
#endif /* DEBUG */

  if (sscanf(packet, "%x%x%1023s", &type, &state, uri) != 3)
  {
    LogMessage(LOG_WARN, "UpdateBrowseList: Garbled browse packet - %s",
               packet);
    return;
  }

  DEBUG_printf(("type=%x, state=%x, uri=\"%s\"\n", type, state, uri));

 /*
  * Pull the URI apart to see if this is a local or remote printer...
  */

  httpSeparate(uri, method, username, host, &port, resource);

  DEBUG_printf(("host=\"%s\", ServerName=\"%s\"\n", host, ServerName));

  if (strcasecmp(host, ServerName) == 0)
    return;

 /*
  * OK, this isn't a local printer; see if we already have it listed in
  * the Printers list, and add it if not...
  */

  hptr = strchr(host, '.');
  sptr = strchr(ServerName, '.');

  if (hptr != NULL && sptr != NULL &&
      strcasecmp(hptr, sptr) == 0)
    *hptr = '\0';

  if (type & CUPS_PRINTER_CLASS)
  {
   /*
    * Remote destination is a class...
    */

    if (strncmp(resource, "/classes/", 9) == 0)
      snprintf(name, sizeof(name), "%s@%s", resource + 9, host);
    else
      return;

    if ((p = FindClass(name)) == NULL)
    {
     /*
      * Class doesn't exist; add it...
      */

      p = AddClass(name);

     /*
      * Force the URI to point to the real server...
      */

      p->type = type;
      strcpy(p->uri, uri);
      strcpy(p->device_uri, uri);
      strcpy(p->hostname, host);
      SetPrinterAttrs(p);
    }
  }
  else
  {
   /*
    * Remote destination is a printer...
    */

    if (strncmp(resource, "/printers/", 10) == 0)
      snprintf(name, sizeof(name), "%s@%s", resource + 10, host);
    else
      return;

    if ((p = FindPrinter(name)) == NULL)
    {
     /*
      * Printer doesn't exist; add it...
      */

      p = AddPrinter(name);

     /*
      * Force the URI to point to the real server...
      */

      p->type = type;
      strcpy(p->uri, uri);
      strcpy(p->device_uri, uri);
      strcpy(p->hostname, host);
      SetPrinterAttrs(p);
    }
  }

 /*
  * Update the state...
  */

  p->type        = type;
  p->state       = state;
  p->accepting   = state != IPP_PRINTER_STOPPED;
  p->browse_time = time(NULL);

 /*
  * See if we have a default printer...  If not, make the first printer the
  * default.
  */

  if (DefaultPrinter == NULL && Printers != NULL)
    DefaultPrinter = Printers;

 /*
  * Do auto-classing if needed...
  */

  if (ImplicitClasses)
  {
   /*
    * Loop through all available printers and create classes as needed...
    */

    for (p = Printers, len = 0, offset = 0; p != NULL; p = p->next)
    {
     /*
      * Skip classes...
      */

      if (p->type & CUPS_PRINTER_CLASS)
      {
        len = 0;
        continue;
      }

     /*
      * If len == 0, get the length of this printer name up to the "@"
      * sign (if any).
      */

      if (len > 0 &&
	  strncasecmp(p->name, name + offset, len) == 0 &&
	  (p->name[len] == '\0' || p->name[len] == '@'))
      {
       /*
	* We have more than one printer with the same name; see if
	* we have a class, and if this printer is a member...
	*/

        if ((pclass = FindClass(name)) == NULL)
	{
	 /*
	  * Need to add the class...
	  */

	  pclass = AddClass(name);
	  pclass->type      |= CUPS_PRINTER_IMPLICIT;
	  pclass->accepting = 1;
	  pclass->state     = IPP_PRINTER_IDLE;

          SetPrinterAttrs(pclass);

          DEBUG_printf(("Added new class \"%s\", type = %x\n", name,
	                pclass->type));
	}

        if (first != NULL)
	{
          for (i = 0; i < pclass->num_printers; i ++)
	    if (pclass->printers[i] == first)
	      break;

          if (i >= pclass->num_printers)
	    AddPrinterToClass(pclass, first);

	  first = NULL;
	}

        for (i = 0; i < pclass->num_printers; i ++)
	  if (pclass->printers[i] == p)
	    break;

        if (i >= pclass->num_printers)
	  AddPrinterToClass(pclass, p);
      }
      else
      {
       /*
        * First time around; just get name length and mark it as first
	* in the list...
	*/

	if ((hptr = strchr(p->name, '@')) != NULL)
	  len = hptr - p->name;
	else
	  len = strlen(p->name);

        strncpy(name, p->name, len);
	name[len] = '\0';
	offset    = 0;

	if (FindPrinter(name) != NULL)
	{
	 /*
	  * Can't use same name as printer; add "Any" to the front of the
	  * name...
	  */

          strcpy(name, "Any");
          strncpy(name + 3, p->name, len);
	  name[len + 3] = '\0';
	  offset        = 3;
	}

	first = p;
      }
    }
  }
}


/*
 * 'SendBrowseList()' - Send new browsing information.
 */

void
SendBrowseList(void)
{
  int			i;	/* Looping var */
  printer_t		*p,	/* Current printer */
			*np;	/* Next printer */
  time_t		ut,	/* Minimum update time */
			to;	/* Timeout time */
  int			bytes;	/* Length of packet */
  char			packet[1540];
				/* Browse data packet */


 /*
  * Compute the update time...
  */

  ut = time(NULL) - BrowseInterval;
  to = time(NULL) - BrowseTimeout;

 /*
  * Loop through all of the printers and send local updates as needed...
  */

  for (p = Printers; p != NULL; p = np)
  {
    np = p->next;

    if (p->type & CUPS_PRINTER_REMOTE)
    {
     /*
      * See if this printer needs to be timed out...
      */

      if (p->browse_time < to)
      {
        LogMessage(LOG_INFO, "Remote destination \"%s\" has timed out; deleting it...",
	           p->name);
        DeletePrinter(p);
      }
    }
    else if (p->browse_time < ut && !(p->type & CUPS_PRINTER_IMPLICIT))
    {
     /*
      * Need to send an update...
      */

      p->browse_time = time(NULL);

      sprintf(packet, "%x %x %s\n", p->type | CUPS_PRINTER_REMOTE, p->state,
              p->uri);
      bytes = strlen(packet);
      DEBUG_printf(("SendBrowseList: (%d bytes) %s", bytes, packet));

     /*
      * Send a packet to each browse address...
      */

      for (i = 0; i < NumBrowsers; i ++)
	if (sendto(BrowseSocket, packet, bytes, 0,
	           (struct sockaddr *)Browsers + i, sizeof(Browsers[0])) <= 0)
	  LogMessage(LOG_ERROR, "SendBrowseList: sendto failed for browser %d - %s.",
	             i + 1, strerror(errno));
    }
  }
}


/*
 * End of "$Id: dirsvc.c,v 1.45 2000/01/27 02:25:45 mike Exp $".
 */
Commit	Line	Data
a129ddbd	1	/*
1ea7d40f	2	* "$Id: dirsvc.c,v 1.45 2000/01/27 02:25:45 mike Exp $"
a129ddbd	3	*
d6de4648	4	* Directory services routines for the Common UNIX Printing System (CUPS).
a129ddbd	5	*
71fe22b7	6	* Copyright 1997-2000 by Easy Software Products, all rights reserved.
a129ddbd	7	*
	8	* These coded instructions, statements, and computer programs are the
	9	* property of Easy Software Products and are protected by Federal
	10	* copyright law. Distribution and use rights are outlined in the file
	11	* "LICENSE.txt" which should have been included with this file. If this
	12	* file is missing or damaged please contact Easy Software Products
	13	* at:
	14	*
	15	* Attn: CUPS Licensing Information
	16	* Easy Software Products
8784b6a6	17	* 44141 Airport View Drive, Suite 204
a129ddbd	18	* Hollywood, Maryland 20636-3111 USA
	19	*
	20	* Voice: (301) 373-9603
	21	* EMail: cups-info@cups.org
	22	* WWW: http://www.cups.org
	23	*
	24	* Contents:
	25	*
cbbfcc63	26	* StartBrowsing() - Start sending and receiving broadcast information.
	27	* StopBrowsing() - Stop sending and receiving broadcast information.
	28	* UpdateBrowseList() - Update the browse lists for any new browse data.
	29	* SendBrowseList() - Send new browsing information.
a129ddbd	30	*/
	31
	32	/*
	33	* Include necessary headers...
	34	*/
	35
fd8b1cf8	36	#include "cupsd.h"
	37
	38
d6de4648	39	/*
	40	* 'StartBrowsing()' - Start sending and receiving broadcast information.
	41	*/
	42
fd8b1cf8	43	void
	44	StartBrowsing(void)
	45	{
d6de4648	46	int val; /* Socket option value */
	47	struct sockaddr_in addr; /* Broadcast address */
	48
	49
8828fd5f	50	if (!Browsing)
d6de4648	51	return;
	52
	53	/*
	54	* Create the broadcast socket...
	55	*/
	56
900b10ea	57	if ((BrowseSocket = socket(AF_INET, SOCK_DGRAM, 0)) < 0)
d6de4648	58	{
	59	LogMessage(LOG_ERROR, "StartBrowsing: Unable to create broadcast socket - %s.",
	60	strerror(errno));
	61	return;
	62	}
	63
	64	/*
900b10ea	65	* Set the "broadcast" flag...
d6de4648	66	*/
	67
	68	val = 1;
e9e40963	69	if (setsockopt(BrowseSocket, SOL_SOCKET, SO_BROADCAST, &val, sizeof(val)))
fd3ece61	70	{
	71	LogMessage(LOG_ERROR, "StartBrowsing: Unable to set broadcast mode - %s.",
	72	strerror(errno));
	73
	74	#if defined(WIN32) \|\| defined(__EMX__)
	75	closesocket(BrowseSocket);
	76	#else
	77	close(BrowseSocket);
	78	#endif /* WIN32 \|\| __EMX__ */
	79
	80	BrowseSocket = -1;
	81	return;
	82	}
d6de4648	83
d6de4648	84	/*
	85	* Bind the socket to browse port...
	86	*/
	87
d6de4648	88	memset(&addr, 0, sizeof(addr));
	89	addr.sin_addr.s_addr = htonl(INADDR_ANY);
	90	addr.sin_family = AF_INET;
	91	addr.sin_port = htons(BrowsePort);
	92
16b0a852	93	if (bind(BrowseSocket, (struct sockaddr *)&addr, sizeof(addr)))
d6de4648	94	{
	95	LogMessage(LOG_ERROR, "StartBrowsing: Unable to bind broadcast socket - %s.",
	96	strerror(errno));
	97
	98	#if defined(WIN32) \|\| defined(__EMX__)
	99	closesocket(BrowseSocket);
	100	#else
	101	close(BrowseSocket);
	102	#endif /* WIN32 \|\| __EMX__ */
	103
	104	BrowseSocket = -1;
	105	return;
	106	}
	107
	108	/*
	109	* Finally, add the socket to the input selection set...
	110	*/
	111
	112	FD_SET(BrowseSocket, &InputSet);
fd8b1cf8	113	}
	114
	115
d6de4648	116	/*
	117	* 'StopBrowsing()' - Stop sending and receiving broadcast information.
	118	*/
	119
fd8b1cf8	120	void
	121	StopBrowsing(void)
	122	{
8828fd5f	123	if (!Browsing)
d6de4648	124	return;
	125
	126	/*
	127	* Close the socket and remove it from the input selection set.
	128	*/
	129
3c7bb4a2	130	if (BrowseSocket >= 0)
3c7bb4a2	131	{
d6de4648	132	#if defined(WIN32) \|\| defined(__EMX__)
3c7bb4a2	133	closesocket(BrowseSocket);
d6de4648	134	#else
3c7bb4a2	135	close(BrowseSocket);
d6de4648	136	#endif /* WIN32 \|\| __EMX__ */
d6de4648	137
3c7bb4a2	138	FD_CLR(BrowseSocket, &InputSet);
3c7bb4a2	139	}
fd8b1cf8	140	}
	141
	142
d6de4648	143	/*
	144	* 'UpdateBrowseList()' - Update the browse lists for any new browse data.
	145	*/
	146
fd8b1cf8	147	void
	148	UpdateBrowseList(void)
	149	{
8b43895a	150	int i; /* Looping var */
eef5ad1b	151	int len, /* Length of name string */
eef5ad1b	152	offset; /* Offset in name string */
d6de4648	153	int bytes; /* Number of bytes left */
	154	char packet[1540]; /* Broadcast packet */
	155	cups_ptype_t type; /* Printer type */
	156	ipp_pstate_t state; /* Printer state */
	157	char uri[HTTP_MAX_URI], /* Printer URI */
	158	method[HTTP_MAX_URI], /* Method portion of URI */
	159	username[HTTP_MAX_URI], /* Username portion of URI */
	160	host[HTTP_MAX_URI], /* Host portion of URI */
	161	resource[HTTP_MAX_URI]; /* Resource portion of URI */
	162	int port; /* Port portion of URI */
	163	char name[IPP_MAX_NAME], /* Name of printer */
8b43895a	164	hptr, / Pointer into hostname */
	165	sptr; / Pointer into ServerName */
	166	printer_t p, / Printer information */
	167	pclass, / Printer class */
	168	first; / First printer in class */
d6de4648	169
	170
	171	/*
	172	* Read a packet from the browse socket...
	173	*/
	174
18d7d592	175	#ifdef DEBUG
18d7d592	176	struct sockaddr_in addr;
18d7d592	177
	178
	179	len = sizeof(addr);
16b0a852	180	if ((bytes = recvfrom(BrowseSocket, packet, sizeof(packet), 0,
16b0a852	181	(struct sockaddr *)&addr, &len)) <= 0)
18d7d592	182	{
1a5606a3	183	LogMessage(LOG_ERROR, "Browse recv failed - %s.",
18d7d592	184	strerror(errno));
1a5606a3	185	LogMessage(LOG_ERROR, "Browsing turned off.");
	186
	187	StopBrowsing();
	188	Browsing = 0;
18d7d592	189	return;
	190	}
	191
	192	packet[bytes] = '\0';
	193	printf("UpdateBrowseList: (%d bytes from %08x) %s", bytes,
	194	ntohl(addr.sin_addr.s_addr), packet);
	195	#else
d6de4648	196	if ((bytes = recv(BrowseSocket, packet, sizeof(packet), 0)) <= 0)
f9bacabb	197	{
1a5606a3	198	LogMessage(LOG_ERROR, "Browse recv failed - %s.",
8828fd5f	199	strerror(errno));
1a5606a3	200	LogMessage(LOG_ERROR, "Browsing turned off.");
	201
	202	StopBrowsing();
	203	Browsing = 0;
d6de4648	204	return;
f9bacabb	205	}
d6de4648	206
d6de4648	207	packet[bytes] = '\0';
18d7d592	208	#endif /* DEBUG */
d6de4648	209
970017a4	210	if (sscanf(packet, "%x%x%1023s", &type, &state, uri) != 3)
d6de4648	211	{
	212	LogMessage(LOG_WARN, "UpdateBrowseList: Garbled browse packet - %s",
	213	packet);
	214	return;
	215	}
	216
a8b216d5	217	DEBUG_printf(("type=%x, state=%x, uri=\"%s\"\n", type, state, uri));
a8b216d5	218
d6de4648	219	/*
	220	* Pull the URI apart to see if this is a local or remote printer...
	221	*/
	222
	223	httpSeparate(uri, method, username, host, &port, resource);
	224
a8b216d5	225	DEBUG_printf(("host=\"%s\", ServerName=\"%s\"\n", host, ServerName));
a8b216d5	226
d6de4648	227	if (strcasecmp(host, ServerName) == 0)
	228	return;
	229
	230	/*
	231	* OK, this isn't a local printer; see if we already have it listed in
	232	* the Printers list, and add it if not...
	233	*/
	234
8b43895a	235	hptr = strchr(host, '.');
	236	sptr = strchr(ServerName, '.');
	237
	238	if (hptr != NULL && sptr != NULL &&
	239	strcasecmp(hptr, sptr) == 0)
	240	*hptr = '\0';
d6de4648	241
c7fa9d06	242	if (type & CUPS_PRINTER_CLASS)
d6de4648	243	{
d6de4648	244	/*
c7fa9d06	245	* Remote destination is a class...
d6de4648	246	*/
d6de4648	247
c7fa9d06	248	if (strncmp(resource, "/classes/", 9) == 0)
970017a4	249	snprintf(name, sizeof(name), "%s@%s", resource + 9, host);
c7fa9d06	250	else
	251	return;
	252
	253	if ((p = FindClass(name)) == NULL)
	254	{
	255	/*
	256	* Class doesn't exist; add it...
	257	*/
d6de4648	258
782359ca	259	p = AddClass(name);
c7fa9d06	260
c7fa9d06	261	/*
782359ca	262	* Force the URI to point to the real server...
c7fa9d06	263	*/
c7fa9d06	264
5057ad3b	265	p->type = type;
c7fa9d06	266	strcpy(p->uri, uri);
c7fa9d06	267	strcpy(p->device_uri, uri);
67a6c918	268	strcpy(p->hostname, host);
5057ad3b	269	SetPrinterAttrs(p);
c7fa9d06	270	}
	271	}
	272	else
	273	{
d6de4648	274	/*
c7fa9d06	275	* Remote destination is a printer...
d6de4648	276	*/
d6de4648	277
c7fa9d06	278	if (strncmp(resource, "/printers/", 10) == 0)
970017a4	279	snprintf(name, sizeof(name), "%s@%s", resource + 10, host);
c7fa9d06	280	else
	281	return;
	282
	283	if ((p = FindPrinter(name)) == NULL)
	284	{
	285	/*
	286	* Printer doesn't exist; add it...
	287	*/
	288
	289	p = AddPrinter(name);
	290
	291	/*
5057ad3b	292	* Force the URI to point to the real server...
c7fa9d06	293	*/
c7fa9d06	294
5057ad3b	295	p->type = type;
c7fa9d06	296	strcpy(p->uri, uri);
c7fa9d06	297	strcpy(p->device_uri, uri);
67a6c918	298	strcpy(p->hostname, host);
5057ad3b	299	SetPrinterAttrs(p);
c7fa9d06	300	}
d6de4648	301	}
	302
	303	/*
	304	* Update the state...
	305	*/
	306
f925c8de	307	p->type = type;
d6de4648	308	p->state = state;
0948b55b	309	p->accepting = state != IPP_PRINTER_STOPPED;
d6de4648	310	p->browse_time = time(NULL);
8b43895a	311
fb00e262	312	/*
4621b86f	313	* See if we have a default printer... If not, make the first printer the
4621b86f	314	* default.
fb00e262	315	*/
	316
	317	if (DefaultPrinter == NULL && Printers != NULL)
	318	DefaultPrinter = Printers;
	319
8b43895a	320	/*
	321	* Do auto-classing if needed...
	322	*/
	323
	324	if (ImplicitClasses)
	325	{
	326	/*
	327	* Loop through all available printers and create classes as needed...
	328	*/
	329
eef5ad1b	330	for (p = Printers, len = 0, offset = 0; p != NULL; p = p->next)
8b43895a	331	{
	332	/*
	333	* Skip classes...
	334	*/
	335
	336	if (p->type & CUPS_PRINTER_CLASS)
	337	{
	338	len = 0;
	339	continue;
	340	}
	341
	342	/*
	343	* If len == 0, get the length of this printer name up to the "@"
	344	* sign (if any).
	345	*/
	346
	347	if (len > 0 &&
eef5ad1b	348	strncasecmp(p->name, name + offset, len) == 0 &&
8b43895a	349	(p->name[len] == '\0' \|\| p->name[len] == '@'))
	350	{
	351	/*
	352	* We have more than one printer with the same name; see if
	353	* we have a class, and if this printer is a member...
	354	*/
	355
	356	if ((pclass = FindClass(name)) == NULL)
18d7d592	357	{
4139b718	358	/*
	359	* Need to add the class...
	360	*/
	361
8b43895a	362	pclass = AddClass(name);
4139b718	363	pclass->type \|= CUPS_PRINTER_IMPLICIT;
	364	pclass->accepting = 1;
	365	pclass->state = IPP_PRINTER_IDLE;
	366
	367	SetPrinterAttrs(pclass);
20da3efb	368
	369	DEBUG_printf(("Added new class \"%s\", type = %x\n", name,
	370	pclass->type));
18d7d592	371	}
8b43895a	372
	373	if (first != NULL)
	374	{
	375	for (i = 0; i < pclass->num_printers; i ++)
	376	if (pclass->printers[i] == first)
	377	break;
	378
	379	if (i >= pclass->num_printers)
	380	AddPrinterToClass(pclass, first);
	381
	382	first = NULL;
	383	}
	384
	385	for (i = 0; i < pclass->num_printers; i ++)
	386	if (pclass->printers[i] == p)
	387	break;
	388
	389	if (i >= pclass->num_printers)
	390	AddPrinterToClass(pclass, p);
	391	}
	392	else
	393	{
	394	/*
	395	* First time around; just get name length and mark it as first
	396	* in the list...
	397	*/
	398
	399	if ((hptr = strchr(p->name, '@')) != NULL)
	400	len = hptr - p->name;
	401	else
	402	len = strlen(p->name);
	403
782359ca	404	strncpy(name, p->name, len);
782359ca	405	name[len] = '\0';
eef5ad1b	406	offset = 0;
782359ca	407
	408	if (FindPrinter(name) != NULL)
	409	{
	410	/*
	411	* Can't use same name as printer; add "Any" to the front of the
	412	* name...
	413	*/
	414
	415	strcpy(name, "Any");
	416	strncpy(name + 3, p->name, len);
	417	name[len + 3] = '\0';
eef5ad1b	418	offset = 3;
782359ca	419	}
782359ca	420
8b43895a	421	first = p;
	422	}
	423	}
	424	}
fd8b1cf8	425	}
	426
	427
d6de4648	428	/*
	429	* 'SendBrowseList()' - Send new browsing information.
	430	*/
	431
fd8b1cf8	432	void
	433	SendBrowseList(void)
	434	{
d6de4648	435	int i; /* Looping var */
	436	printer_t p, / Current printer */
	437	np; / Next printer */
f9d6449d	438	time_t ut, /* Minimum update time */
f9d6449d	439	to; /* Timeout time */
d6de4648	440	int bytes; /* Length of packet */
	441	char packet[1540];
	442	/* Browse data packet */
	443
	444
	445	/*
	446	* Compute the update time...
	447	*/
	448
f9d6449d	449	ut = time(NULL) - BrowseInterval;
f9d6449d	450	to = time(NULL) - BrowseTimeout;
d6de4648	451
	452	/*
	453	* Loop through all of the printers and send local updates as needed...
	454	*/
	455
	456	for (p = Printers; p != NULL; p = np)
	457	{
	458	np = p->next;
	459
	460	if (p->type & CUPS_PRINTER_REMOTE)
	461	{
	462	/*
	463	* See if this printer needs to be timed out...
	464	*/
	465
f9d6449d	466	if (p->browse_time < to)
e63d9801	467	{
d62e9bdd	468	LogMessage(LOG_INFO, "Remote destination \"%s\" has timed out; deleting it...",
d62e9bdd	469	p->name);
d6de4648	470	DeletePrinter(p);
e63d9801	471	}
d6de4648	472	}
18d7d592	473	else if (p->browse_time < ut && !(p->type & CUPS_PRINTER_IMPLICIT))
d6de4648	474	{
	475	/*
	476	* Need to send an update...
	477	*/
	478
	479	p->browse_time = time(NULL);
	480
ae5f9b38	481	sprintf(packet, "%x %x %s\n", p->type \| CUPS_PRINTER_REMOTE, p->state,
ae5f9b38	482	p->uri);
d6de4648	483	bytes = strlen(packet);
8828fd5f	484	DEBUG_printf(("SendBrowseList: (%d bytes) %s", bytes, packet));
d6de4648	485
	486	/*
	487	* Send a packet to each browse address...
	488	*/
	489
	490	for (i = 0; i < NumBrowsers; i ++)
16b0a852	491	if (sendto(BrowseSocket, packet, bytes, 0,
16b0a852	492	(struct sockaddr *)Browsers + i, sizeof(Browsers[0])) <= 0)
8828fd5f	493	LogMessage(LOG_ERROR, "SendBrowseList: sendto failed for browser %d - %s.",
fd3ece61	494	i + 1, strerror(errno));
d6de4648	495	}
d6de4648	496	}
fd8b1cf8	497	}
a129ddbd	498
	499
	500	/*
1ea7d40f	501	* End of "$Id: dirsvc.c,v 1.45 2000/01/27 02:25:45 mike Exp $".
a129ddbd	502	*/