]> git.ipfire.org Git - thirdparty/cups.git/blame - scheduler/dirsvc.c
Added tests to templates.
[thirdparty/cups.git] / scheduler / dirsvc.c
CommitLineData
a129ddbd 1/*
16b0a852 2 * "$Id: dirsvc.c,v 1.40 1999/07/30 13:31:52 mike Exp $"
a129ddbd 3 *
d6de4648 4 * Directory services routines for the Common UNIX Printing System (CUPS).
a129ddbd 5 *
a9de544f 6 * Copyright 1997-1999 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 43void
44StartBrowsing(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 120void
121StopBrowsing(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)
131 {
d6de4648 132#if defined(WIN32) || defined(__EMX__)
3c7bb4a2 133 closesocket(BrowseSocket);
d6de4648 134#else
3c7bb4a2 135 close(BrowseSocket);
d6de4648 136#endif /* WIN32 || __EMX__ */
137
3c7bb4a2 138 FD_CLR(BrowseSocket, &InputSet);
139 }
fd8b1cf8 140}
141
142
d6de4648 143/*
144 * 'UpdateBrowseList()' - Update the browse lists for any new browse data.
145 */
146
fd8b1cf8 147void
148UpdateBrowseList(void)
149{
8b43895a 150 int i; /* Looping var */
eef5ad1b 151 int len, /* Length of name string */
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
176 struct sockaddr_in addr;
18d7d592 177
178
179 len = sizeof(addr);
16b0a852 180 if ((bytes = recvfrom(BrowseSocket, packet, sizeof(packet), 0,
181 (struct sockaddr *)&addr, &len)) <= 0)
18d7d592 182 {
183 LogMessage(LOG_ERROR, "UpdateBrowseList: recv failed - %s.",
184 strerror(errno));
185 return;
186 }
187
188 packet[bytes] = '\0';
189 printf("UpdateBrowseList: (%d bytes from %08x) %s", bytes,
190 ntohl(addr.sin_addr.s_addr), packet);
191#else
d6de4648 192 if ((bytes = recv(BrowseSocket, packet, sizeof(packet), 0)) <= 0)
f9bacabb 193 {
8828fd5f 194 LogMessage(LOG_ERROR, "UpdateBrowseList: recv failed - %s.",
195 strerror(errno));
d6de4648 196 return;
f9bacabb 197 }
d6de4648 198
199 packet[bytes] = '\0';
18d7d592 200#endif /* DEBUG */
d6de4648 201
202 if (sscanf(packet, "%x%x%s", &type, &state, uri) != 3)
203 {
204 LogMessage(LOG_WARN, "UpdateBrowseList: Garbled browse packet - %s",
205 packet);
206 return;
207 }
208
a8b216d5 209 DEBUG_printf(("type=%x, state=%x, uri=\"%s\"\n", type, state, uri));
210
d6de4648 211 /*
212 * Pull the URI apart to see if this is a local or remote printer...
213 */
214
215 httpSeparate(uri, method, username, host, &port, resource);
216
a8b216d5 217 DEBUG_printf(("host=\"%s\", ServerName=\"%s\"\n", host, ServerName));
218
d6de4648 219 if (strcasecmp(host, ServerName) == 0)
220 return;
221
222 /*
223 * OK, this isn't a local printer; see if we already have it listed in
224 * the Printers list, and add it if not...
225 */
226
8b43895a 227 hptr = strchr(host, '.');
228 sptr = strchr(ServerName, '.');
229
230 if (hptr != NULL && sptr != NULL &&
231 strcasecmp(hptr, sptr) == 0)
232 *hptr = '\0';
d6de4648 233
c7fa9d06 234 if (type & CUPS_PRINTER_CLASS)
d6de4648 235 {
236 /*
c7fa9d06 237 * Remote destination is a class...
d6de4648 238 */
239
c7fa9d06 240 if (strncmp(resource, "/classes/", 9) == 0)
a71f40c4 241 sprintf(name, "%s@%s", resource + 9, host);
c7fa9d06 242 else
243 return;
244
245 if ((p = FindClass(name)) == NULL)
a71f40c4 246 if ((p = FindClass(resource + 9)) != NULL)
eef5ad1b 247 {
a71f40c4 248 if (strcasecmp(p->hostname, host) != 0)
249 {
250 /*
251 * Nope, this isn't the same host; if the hostname isn't the local host,
252 * add it to the other class and then find a class using the full host
253 * name...
254 */
255
18d7d592 256 if (p->type & CUPS_PRINTER_REMOTE)
a71f40c4 257 {
258 strcat(p->name, "@");
259 strcat(p->name, p->hostname);
23050703 260 SetPrinterAttrs(p);
1cab4605 261 SortPrinters();
a71f40c4 262 }
263
264 p = NULL;
265 }
eef5ad1b 266 }
267 else
268 strcpy(name, resource + 9);
a71f40c4 269
270 if (p == NULL)
c7fa9d06 271 {
272 /*
273 * Class doesn't exist; add it...
274 */
d6de4648 275
782359ca 276 p = AddClass(name);
c7fa9d06 277
278 /*
782359ca 279 * Force the URI to point to the real server...
c7fa9d06 280 */
281
5057ad3b 282 p->type = type;
c7fa9d06 283 strcpy(p->uri, uri);
284 strcpy(p->device_uri, uri);
67a6c918 285 strcpy(p->hostname, host);
5057ad3b 286 SetPrinterAttrs(p);
c7fa9d06 287 }
288 }
289 else
290 {
d6de4648 291 /*
c7fa9d06 292 * Remote destination is a printer...
d6de4648 293 */
294
c7fa9d06 295 if (strncmp(resource, "/printers/", 10) == 0)
a71f40c4 296 sprintf(name, "%s@%s", resource + 10, host);
c7fa9d06 297 else
298 return;
299
300 if ((p = FindPrinter(name)) == NULL)
a71f40c4 301 if ((p = FindPrinter(resource + 10)) != NULL)
eef5ad1b 302 {
a71f40c4 303 if (strcasecmp(p->hostname, host) != 0)
304 {
305 /*
306 * Nope, this isn't the same host; if the hostname isn't the local host,
307 * add it to the other printer and then find a printer using the full host
308 * name...
309 */
310
18d7d592 311 if (p->type & CUPS_PRINTER_REMOTE)
a71f40c4 312 {
313 strcat(p->name, "@");
314 strcat(p->name, p->hostname);
23050703 315 SetPrinterAttrs(p);
1cab4605 316 SortPrinters();
a71f40c4 317 }
318
319 p = NULL;
320 }
eef5ad1b 321 }
322 else
323 strcpy(name, resource + 10);
a71f40c4 324
325 if (p == NULL)
c7fa9d06 326 {
327 /*
328 * Printer doesn't exist; add it...
329 */
330
331 p = AddPrinter(name);
332
333 /*
5057ad3b 334 * Force the URI to point to the real server...
c7fa9d06 335 */
336
5057ad3b 337 p->type = type;
c7fa9d06 338 strcpy(p->uri, uri);
339 strcpy(p->device_uri, uri);
67a6c918 340 strcpy(p->hostname, host);
5057ad3b 341 SetPrinterAttrs(p);
c7fa9d06 342 }
d6de4648 343 }
344
345 /*
346 * Update the state...
347 */
348
f925c8de 349 p->type = type;
d6de4648 350 p->state = state;
0948b55b 351 p->accepting = state != IPP_PRINTER_STOPPED;
d6de4648 352 p->browse_time = time(NULL);
8b43895a 353
fb00e262 354 /*
4621b86f 355 * See if we have a default printer... If not, make the first printer the
356 * default.
fb00e262 357 */
358
359 if (DefaultPrinter == NULL && Printers != NULL)
360 DefaultPrinter = Printers;
361
8b43895a 362 /*
363 * Do auto-classing if needed...
364 */
365
366 if (ImplicitClasses)
367 {
368 /*
369 * Loop through all available printers and create classes as needed...
370 */
371
eef5ad1b 372 for (p = Printers, len = 0, offset = 0; p != NULL; p = p->next)
8b43895a 373 {
374 /*
375 * Skip classes...
376 */
377
378 if (p->type & CUPS_PRINTER_CLASS)
379 {
380 len = 0;
381 continue;
382 }
383
384 /*
385 * If len == 0, get the length of this printer name up to the "@"
386 * sign (if any).
387 */
388
389 if (len > 0 &&
eef5ad1b 390 strncasecmp(p->name, name + offset, len) == 0 &&
8b43895a 391 (p->name[len] == '\0' || p->name[len] == '@'))
392 {
393 /*
394 * We have more than one printer with the same name; see if
395 * we have a class, and if this printer is a member...
396 */
397
398 if ((pclass = FindClass(name)) == NULL)
18d7d592 399 {
4139b718 400 /*
401 * Need to add the class...
402 */
403
8b43895a 404 pclass = AddClass(name);
4139b718 405 pclass->type |= CUPS_PRINTER_IMPLICIT;
406 pclass->accepting = 1;
407 pclass->state = IPP_PRINTER_IDLE;
408
409 SetPrinterAttrs(pclass);
20da3efb 410
411 DEBUG_printf(("Added new class \"%s\", type = %x\n", name,
412 pclass->type));
18d7d592 413 }
8b43895a 414
415 if (first != NULL)
416 {
417 for (i = 0; i < pclass->num_printers; i ++)
418 if (pclass->printers[i] == first)
419 break;
420
421 if (i >= pclass->num_printers)
422 AddPrinterToClass(pclass, first);
423
424 first = NULL;
425 }
426
427 for (i = 0; i < pclass->num_printers; i ++)
428 if (pclass->printers[i] == p)
429 break;
430
431 if (i >= pclass->num_printers)
432 AddPrinterToClass(pclass, p);
433 }
434 else
435 {
436 /*
437 * First time around; just get name length and mark it as first
438 * in the list...
439 */
440
441 if ((hptr = strchr(p->name, '@')) != NULL)
442 len = hptr - p->name;
443 else
444 len = strlen(p->name);
445
782359ca 446 strncpy(name, p->name, len);
447 name[len] = '\0';
eef5ad1b 448 offset = 0;
782359ca 449
450 if (FindPrinter(name) != NULL)
451 {
452 /*
453 * Can't use same name as printer; add "Any" to the front of the
454 * name...
455 */
456
457 strcpy(name, "Any");
458 strncpy(name + 3, p->name, len);
459 name[len + 3] = '\0';
eef5ad1b 460 offset = 3;
782359ca 461 }
462
8b43895a 463 first = p;
464 }
465 }
466 }
fd8b1cf8 467}
468
469
d6de4648 470/*
471 * 'SendBrowseList()' - Send new browsing information.
472 */
473
fd8b1cf8 474void
475SendBrowseList(void)
476{
d6de4648 477 int i; /* Looping var */
478 printer_t *p, /* Current printer */
479 *np; /* Next printer */
f9d6449d 480 time_t ut, /* Minimum update time */
481 to; /* Timeout time */
d6de4648 482 int bytes; /* Length of packet */
483 char packet[1540];
484 /* Browse data packet */
485
486
487 /*
488 * Compute the update time...
489 */
490
f9d6449d 491 ut = time(NULL) - BrowseInterval;
492 to = time(NULL) - BrowseTimeout;
d6de4648 493
494 /*
495 * Loop through all of the printers and send local updates as needed...
496 */
497
498 for (p = Printers; p != NULL; p = np)
499 {
500 np = p->next;
501
502 if (p->type & CUPS_PRINTER_REMOTE)
503 {
504 /*
505 * See if this printer needs to be timed out...
506 */
507
f9d6449d 508 if (p->browse_time < to)
e63d9801 509 {
510 DEBUG_printf(("Printer \"%s\" has timed out (%d < %d...)\n",
511 p->name, p->browse_time, to));
d6de4648 512 DeletePrinter(p);
e63d9801 513 }
d6de4648 514 }
18d7d592 515 else if (p->browse_time < ut && !(p->type & CUPS_PRINTER_IMPLICIT))
d6de4648 516 {
517 /*
518 * Need to send an update...
519 */
520
521 p->browse_time = time(NULL);
522
ae5f9b38 523 sprintf(packet, "%x %x %s\n", p->type | CUPS_PRINTER_REMOTE, p->state,
524 p->uri);
d6de4648 525 bytes = strlen(packet);
8828fd5f 526 DEBUG_printf(("SendBrowseList: (%d bytes) %s", bytes, packet));
d6de4648 527
528 /*
529 * Send a packet to each browse address...
530 */
531
532 for (i = 0; i < NumBrowsers; i ++)
16b0a852 533 if (sendto(BrowseSocket, packet, bytes, 0,
534 (struct sockaddr *)Browsers + i, sizeof(Browsers[0])) <= 0)
8828fd5f 535 LogMessage(LOG_ERROR, "SendBrowseList: sendto failed for browser %d - %s.",
fd3ece61 536 i + 1, strerror(errno));
d6de4648 537 }
538 }
fd8b1cf8 539}
a129ddbd 540
541
542/*
16b0a852 543 * End of "$Id: dirsvc.c,v 1.40 1999/07/30 13:31:52 mike Exp $".
a129ddbd 544 */