source: vendor/3.5.2/source3/printing/lpq_parse.c

Last change on this file was 414, checked in by Herwig Bauernfeind, 16 years ago

Samba 3.5.0: Initial import
File size: 29.0 KB
Line 
1/*
2 Unix SMB/CIFS implementation.
3 lpq parsing routines
4 Copyright (C) Andrew Tridgell 2000
5
6 This program is free software; you can redistribute it and/or modify
7 it under the terms of the GNU General Public License as published by
8 the Free Software Foundation; either version 3 of the License, or
9 (at your option) any later version.
10
11 This program is distributed in the hope that it will be useful,
12 but WITHOUT ANY WARRANTY; without even the implied warranty of
13 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14 GNU General Public License for more details.
15
16 You should have received a copy of the GNU General Public License
17 along with this program. If not, see <http://www.gnu.org/licenses/>.
18*/
19
20#include "includes.h"
21
22static const char *Months[13] = { "Jan", "Feb", "Mar", "Apr", "May", "Jun",
23 "Jul", "Aug", "Sep", "Oct", "Nov", "Dec", "Err"};
24
25
26/*******************************************************************
27 Process time fields
28********************************************************************/
29
30static time_t EntryTime(char *tok[], int ptr, int count, int minimum)
31{
32 time_t jobtime,jobtime1;
33
34 jobtime = time(NULL); /* default case: take current time */
35 if (count >= minimum) {
36 struct tm *t;
37 int i, day, hour, min, sec;
38
39 for (i=0; i<13; i++) {
40 if (!strncmp(tok[ptr], Months[i],3)) {
41 break; /* Find month */
42 }
43 }
44
45 if (i<12) {
46 fstring c;
47 t = localtime(&jobtime);
48 if (!t) {
49 return (time_t)-1;
50 }
51 day = atoi(tok[ptr+1]);
52 fstrcpy(c,tok[ptr+2]);
53 *(c+2)=0;
54 hour = atoi(c);
55 *(c+5)=0;
56 min = atoi(c+3);
57 if(*(c+6) != 0) {
58 sec = atoi(c+6);
59 } else {
60 sec=0;
61 }
62
63 if ((t->tm_mon < i)|| ((t->tm_mon == i)&&
64 ((t->tm_mday < day)||
65 ((t->tm_mday == day)&&
66 (t->tm_hour*60+t->tm_min < hour*60+min))))) {
67 t->tm_year--; /* last year's print job */
68 }
69
70 t->tm_mon = i;
71 t->tm_mday = day;
72 t->tm_hour = hour;
73 t->tm_min = min;
74 t->tm_sec = sec;
75 jobtime1 = mktime(t);
76 if (jobtime1 != (time_t)-1) {
77 jobtime = jobtime1;
78 }
79 }
80 }
81 return jobtime;
82}
83
84/****************************************************************************
85parse a lpq line
86
87here is an example of lpq output under bsd
88
89Warning: no daemon present
90Rank Owner Job Files Total Size
911st tridge 148 README 8096 bytes
92
93here is an example of lpq output under osf/1
94
95Warning: no daemon present
96Rank Pri Owner Job Files Total Size
971st 0 tridge 148 README 8096 bytes
98
99
100<allan@umich.edu> June 30, 1998.
101Modified to handle file names with spaces, like the parse_lpq_lprng code
102further below.
103****************************************************************************/
104
105static bool parse_lpq_bsd(char *line,print_queue_struct *buf,bool first)
106{
107#ifdef OSF1
108#define RANKTOK 0
109#define PRIOTOK 1
110#define USERTOK 2
111#define JOBTOK 3
112#define FILETOK 4
113#define TOTALTOK (count - 2)
114#define NTOK 6
115#define MAXTOK 128
116#else /* OSF1 */
117#define RANKTOK 0
118#define USERTOK 1
119#define JOBTOK 2
120#define FILETOK 3
121#define TOTALTOK (count - 2)
122#define NTOK 5
123#define MAXTOK 128
124#endif /* OSF1 */
125
126 char *tok[MAXTOK];
127 int count = 0;
128 TALLOC_CTX *ctx = talloc_tos();
129 char *line2 = NULL;
130 char *saveptr;
131
132 line2 = talloc_strdup(ctx, line);
133 if (!line2) {
134 return false;
135 }
136
137#ifdef OSF1
138 {
139 size_t length;
140 length = strlen(line2);
141 if (line2[length-3] == ':') {
142 return False;
143 }
144 }
145#endif /* OSF1 */
146
147 /* FIXME: Use next_token_talloc rather than strtok! */
148 tok[0] = strtok_r(line2," \t", &saveptr);
149 count++;
150
151 while ((count < MAXTOK)
152 && ((tok[count] = strtok_r(NULL, " \t", &saveptr)) != NULL)) {
153 count++;
154 }
155
156 /* we must get at least NTOK tokens */
157 if (count < NTOK) {
158 return False;
159 }
160
161 /* the Job and Total columns must be integer */
162 if (!isdigit((int)*tok[JOBTOK]) || !isdigit((int)*tok[TOTALTOK])) {
163 return False;
164 }
165
166 buf->job = atoi(tok[JOBTOK]);
167 buf->size = atoi(tok[TOTALTOK]);
168 buf->status = strequal(tok[RANKTOK],"active")?LPQ_PRINTING:LPQ_QUEUED;
169 buf->time = time(NULL);
170 fstrcpy(buf->fs_user,tok[USERTOK]);
171 fstrcpy(buf->fs_file,tok[FILETOK]);
172
173 if ((FILETOK + 1) != TOTALTOK) {
174 int i;
175
176 for (i = (FILETOK + 1); i < TOTALTOK; i++) {
177 /* FIXME: Using fstrcat rather than other means is a bit
178 * inefficient; this might be a problem for enormous queues with
179 * many fields. */
180 fstrcat(buf->fs_file, " ");
181 fstrcat(buf->fs_file, tok[i]);
182 }
183 /* Ensure null termination. */
184 buf->fs_file[sizeof(buf->fs_file)-1] = '\0';
185 }
186
187#ifdef PRIOTOK
188 buf->priority = atoi(tok[PRIOTOK]);
189#else
190 buf->priority = 1;
191#endif
192 return True;
193}
194
195/*
196<magnus@hum.auc.dk>
197LPRng_time modifies the current date by inserting the hour and minute from
198the lpq output. The lpq time looks like "23:15:07"
199
200<allan@umich.edu> June 30, 1998.
201Modified to work with the re-written parse_lpq_lprng routine.
202
203<J.P.M.v.Itegem@tue.nl> Dec 17,1999
204Modified to work with lprng 3.16
205With lprng 3.16 The lpq time looks like
206 "23:15:07"
207 "23:15:07.100"
208 "1999-12-16-23:15:07"
209 "1999-12-16-23:15:07.100"
210
211*/
212static time_t LPRng_time(char *time_string)
213{
214 time_t jobtime;
215 struct tm *t;
216
217 jobtime = time(NULL); /* default case: take current time */
218 t = localtime(&jobtime);
219 if (!t) {
220 return (time_t)-1;
221 }
222
223 if ( atoi(time_string) < 24 ){
224 t->tm_hour = atoi(time_string);
225 t->tm_min = atoi(time_string+3);
226 t->tm_sec = atoi(time_string+6);
227 } else {
228 t->tm_year = atoi(time_string)-1900;
229 t->tm_mon = atoi(time_string+5)-1;
230 t->tm_mday = atoi(time_string+8);
231 t->tm_hour = atoi(time_string+11);
232 t->tm_min = atoi(time_string+14);
233 t->tm_sec = atoi(time_string+17);
234 }
235 jobtime = mktime(t);
236
237 return jobtime;
238}
239
240/****************************************************************************
241 parse a lprng lpq line
242 <allan@umich.edu> June 30, 1998.
243 Re-wrote this to handle file names with spaces, multiple file names on one
244 lpq line, etc;
245
246****************************************************************************/
247
248static bool parse_lpq_lprng(char *line,print_queue_struct *buf,bool first)
249{
250#define LPRNG_RANKTOK 0
251#define LPRNG_USERTOK 1
252#define LPRNG_PRIOTOK 2
253#define LPRNG_JOBTOK 3
254#define LPRNG_FILETOK 4
255#define LPRNG_TOTALTOK (num_tok - 2)
256#define LPRNG_TIMETOK (num_tok - 1)
257#define LPRNG_NTOK 7
258#define LPRNG_MAXTOK 128 /* PFMA just to keep us from running away. */
259
260 char *tokarr[LPRNG_MAXTOK];
261 const char *cptr;
262 char *ptr;
263 int num_tok = 0;
264 TALLOC_CTX *frame = talloc_stackframe();
265
266 cptr = line;
267 while((num_tok < LPRNG_MAXTOK) && next_token_talloc(frame, &cptr,
268 &tokarr[num_tok], " \t")) {
269 num_tok++;
270 }
271
272 /* We must get at least LPRNG_NTOK tokens. */
273 if (num_tok < LPRNG_NTOK) {
274 TALLOC_FREE(frame);
275 return False;
276 }
277
278 if (!isdigit((int)*tokarr[LPRNG_JOBTOK]) || !isdigit((int)*tokarr[LPRNG_TOTALTOK])) {
279 TALLOC_FREE(frame);
280 return False;
281 }
282
283 buf->job = atoi(tokarr[LPRNG_JOBTOK]);
284 buf->size = atoi(tokarr[LPRNG_TOTALTOK]);
285
286 if (strequal(tokarr[LPRNG_RANKTOK],"active")) {
287 buf->status = LPQ_PRINTING;
288 } else if (strequal(tokarr[LPRNG_RANKTOK],"done")) {
289 buf->status = LPQ_PRINTED;
290 } else if (isdigit((int)*tokarr[LPRNG_RANKTOK])) {
291 buf->status = LPQ_QUEUED;
292 } else {
293 buf->status = LPQ_PAUSED;
294 }
295
296 buf->priority = *tokarr[LPRNG_PRIOTOK] -'A';
297
298 buf->time = LPRng_time(tokarr[LPRNG_TIMETOK]);
299
300 fstrcpy(buf->fs_user,tokarr[LPRNG_USERTOK]);
301
302 /* The '@hostname' prevents windows from displaying the printing icon
303 * for the current user on the taskbar. Plop in a null.
304 */
305
306 if ((ptr = strchr_m(buf->fs_user,'@')) != NULL) {
307 *ptr = '\0';
308 }
309
310 fstrcpy(buf->fs_file,tokarr[LPRNG_FILETOK]);
311
312 if ((LPRNG_FILETOK + 1) != LPRNG_TOTALTOK) {
313 int i;
314
315 for (i = (LPRNG_FILETOK + 1); i < LPRNG_TOTALTOK; i++) {
316 /* FIXME: Using fstrcat rather than other means is a bit
317 * inefficient; this might be a problem for enormous queues with
318 * many fields. */
319 fstrcat(buf->fs_file, " ");
320 fstrcat(buf->fs_file, tokarr[i]);
321 }
322 /* Ensure null termination. */
323 buf->fs_file[sizeof(buf->fs_file)-1] = '\0';
324 }
325
326 TALLOC_FREE(frame);
327 return True;
328}
329
330/*******************************************************************
331parse lpq on an aix system
332
333Queue Dev Status Job Files User PP % Blks Cp Rnk
334------- ----- --------- --- ------------------ ---------- ---- -- ----- --- ---
335lazer lazer READY
336lazer lazer RUNNING 537 6297doc.A kvintus@IE 0 10 2445 1 1
337 QUEUED 538 C.ps root@IEDVB 124 1 2
338 QUEUED 539 E.ps root@IEDVB 28 1 3
339 QUEUED 540 L.ps root@IEDVB 172 1 4
340 QUEUED 541 P.ps root@IEDVB 22 1 5
341********************************************************************/
342
343static bool parse_lpq_aix(char *line,print_queue_struct *buf,bool first)
344{
345 char *tok[11];
346 int count=0;
347 const char *cline = line;
348 TALLOC_CTX *frame = talloc_stackframe();
349
350 /* handle the case of "(standard input)" as a filename */
351 string_sub(line,"standard input","STDIN",0);
352 all_string_sub(line,"(","\"",0);
353 all_string_sub(line,")","\"",0);
354
355 for (count=0; count<10 &&
356 next_token_talloc(frame,&cline,&tok[count],NULL); count++) {
357 ;
358 }
359
360 /* we must get 6 tokens */
361 if (count < 10) {
362 if ((count == 7) && ((strcmp(tok[0],"QUEUED") == 0) || (strcmp(tok[0],"HELD") == 0))) {
363 /* the 2nd and 5th columns must be integer */
364 if (!isdigit((int)*tok[1]) || !isdigit((int)*tok[4])) {
365 TALLOC_FREE(frame);
366 return False;
367 }
368 buf->size = atoi(tok[4]) * 1024;
369 /* if the fname contains a space then use STDIN */
370 if (strchr_m(tok[2],' ')) {
371 tok[2] = talloc_strdup(frame,"STDIN");
372 if (!tok[2]) {
373 TALLOC_FREE(frame);
374 return false;
375 }
376 }
377
378 /* only take the last part of the filename */
379 {
380 char *p = strrchr_m(tok[2],'/');
381 if (p) {
382 tok[2] = p+1;
383 }
384 }
385
386 buf->job = atoi(tok[1]);
387 buf->status = strequal(tok[0],"HELD")?LPQ_PAUSED:LPQ_QUEUED;
388 buf->priority = 0;
389 buf->time = time(NULL);
390 fstrcpy(buf->fs_user,tok[3]);
391 fstrcpy(buf->fs_file,tok[2]);
392 } else {
393 DEBUG(6,("parse_lpq_aix count=%d\n", count));
394 TALLOC_FREE(frame);
395 return False;
396 }
397 } else {
398 /* the 4th and 9th columns must be integer */
399 if (!isdigit((int)*tok[3]) || !isdigit((int)*tok[8])) {
400 TALLOC_FREE(frame);
401 return False;
402 }
403
404 buf->size = atoi(tok[8]) * 1024;
405 /* if the fname contains a space then use STDIN */
406 if (strchr_m(tok[4],' ')) {
407 tok[4] = talloc_strdup(frame,"STDIN");
408 if (!tok[4]) {
409 TALLOC_FREE(frame);
410 return false;
411 }
412 }
413
414 /* only take the last part of the filename */
415 {
416 char *p = strrchr_m(tok[4],'/');
417 if (p) {
418 tok[4] = p+1;
419 }
420 }
421
422 buf->job = atoi(tok[3]);
423 buf->status = strequal(tok[2],"RUNNING")?LPQ_PRINTING:LPQ_QUEUED;
424 buf->priority = 0;
425 buf->time = time(NULL);
426 fstrcpy(buf->fs_user,tok[5]);
427 fstrcpy(buf->fs_file,tok[4]);
428 }
429
430 TALLOC_FREE(frame);
431 return True;
432}
433
434/****************************************************************************
435parse a lpq line
436here is an example of lpq output under hpux; note there's no space after -o !
437$> lpstat -oljplus
438ljplus-2153 user priority 0 Jan 19 08:14 on ljplus
439 util.c 125697 bytes
440 server.c 110712 bytes
441ljplus-2154 user priority 0 Jan 19 08:14 from client
442 (standard input) 7551 bytes
443****************************************************************************/
444
445static bool parse_lpq_hpux(char *line, print_queue_struct *buf, bool first)
446{
447 /* must read two lines to process, therefore keep some values static */
448 static bool header_line_ok=False, base_prio_reset=False;
449 static char *jobuser;
450 static int jobid;
451 static int jobprio;
452 static time_t jobtime;
453 static int jobstat=LPQ_QUEUED;
454 /* to store minimum priority to print, lpstat command should be invoked
455 with -p option first, to work */
456 static int base_prio;
457 int count;
458 char htab = '\011';
459 const char *cline = line;
460 char *tok[12];
461 TALLOC_CTX *frame = talloc_stackframe();
462
463 /* If a line begins with a horizontal TAB, it is a subline type */
464
465 if (line[0] == htab) { /* subline */
466 /* check if it contains the base priority */
467 if (!strncmp(line,"\tfence priority : ",18)) {
468 base_prio=atoi(&line[18]);
469 DEBUG(4, ("fence priority set at %d\n", base_prio));
470 }
471
472 if (!header_line_ok) {
473 TALLOC_FREE(frame);
474 return False; /* incorrect header line */
475 }
476
477 /* handle the case of "(standard input)" as a filename */
478 string_sub(line,"standard input","STDIN",0);
479 all_string_sub(line,"(","\"",0);
480 all_string_sub(line,")","\"",0);
481
482 for (count=0; count<2 &&
483 next_token_talloc(frame, &cline, &tok[count],NULL);
484 count++) {
485 ;
486 }
487 /* we must get 2 tokens */
488 if (count < 2) {
489 TALLOC_FREE(frame);
490 return False;
491 }
492
493 /* the 2nd column must be integer */
494 if (!isdigit((int)*tok[1])) {
495 TALLOC_FREE(frame);
496 return False;
497 }
498
499 /* if the fname contains a space then use STDIN */
500 if (strchr_m(tok[0],' ')) {
501 tok[0] = talloc_strdup(frame, "STDIN");
502 if (!tok[0]) {
503 TALLOC_FREE(frame);
504 return false;
505 }
506 }
507
508 buf->size = atoi(tok[1]);
509 fstrcpy(buf->fs_file,tok[0]);
510
511 /* fill things from header line */
512 buf->time = jobtime;
513 buf->job = jobid;
514 buf->status = jobstat;
515 buf->priority = jobprio;
516 if (jobuser) {
517 fstrcpy(buf->fs_user,jobuser);
518 } else {
519 buf->fs_user[0] = '\0';
520 }
521
522 TALLOC_FREE(frame);
523 return True;
524 } else { /* header line */
525 header_line_ok=False; /* reset it */
526 if (first) {
527 if (!base_prio_reset) {
528 base_prio=0; /* reset it */
529 base_prio_reset=True;
530 }
531 } else if (base_prio) {
532 base_prio_reset=False;
533 }
534
535 /* handle the dash in the job id */
536 string_sub(line,"-"," ",0);
537
538 for (count=0; count<12 &&
539 next_token_talloc(frame, &cline, &tok[count],NULL);
540 count++) {
541 ;
542 }
543
544 /* we must get 8 tokens */
545 if (count < 8) {
546 TALLOC_FREE(frame);
547 return False;
548 }
549
550 /* first token must be printer name (cannot check ?) */
551 /* the 2nd, 5th & 7th column must be integer */
552 if (!isdigit((int)*tok[1]) || !isdigit((int)*tok[4]) || !isdigit((int)*tok[6])) {
553 TALLOC_FREE(frame);
554 return False;
555 }
556 jobid = atoi(tok[1]);
557 SAFE_FREE(jobuser);
558 jobuser = SMB_STRDUP(tok[2]);
559 jobprio = atoi(tok[4]);
560
561 /* process time */
562 jobtime=EntryTime(tok, 5, count, 8);
563 if (jobprio < base_prio) {
564 jobstat = LPQ_PAUSED;
565 DEBUG (4, ("job %d is paused: prio %d < %d; jobstat=%d\n",
566 jobid, jobprio, base_prio, jobstat));
567 } else {
568 jobstat = LPQ_QUEUED;
569 if ((count >8) && (((strequal(tok[8],"on")) ||
570 ((strequal(tok[8],"from")) &&
571 ((count > 10)&&(strequal(tok[10],"on"))))))) {
572 jobstat = LPQ_PRINTING;
573 }
574 }
575
576 header_line_ok=True; /* information is correct */
577 TALLOC_FREE(frame);
578 return False; /* need subline info to include into queuelist */
579 }
580}
581
582/****************************************************************************
583parse a lpstat line
584
585here is an example of "lpstat -o dcslw" output under sysv
586
587dcslw-896 tridge 4712 Dec 20 10:30:30 on dcslw
588dcslw-897 tridge 4712 Dec 20 10:30:30 being held
589
590****************************************************************************/
591
592static bool parse_lpq_sysv(char *line,print_queue_struct *buf,bool first)
593{
594 char *tok[9];
595 int count=0;
596 char *p;
597 const char *cline = line;
598 TALLOC_CTX *frame = NULL;
599
600 /*
601 * Handle the dash in the job id, but make sure that we skip over
602 * the printer name in case we have a dash in that.
603 * Patch from Dom.Mitchell@palmerharvey.co.uk.
604 */
605
606 /*
607 * Move to the first space.
608 */
609 for (p = line ; !isspace(*p) && *p; p++) {
610 ;
611 }
612
613 /*
614 * Back up until the last '-' character or
615 * start of line.
616 */
617 for (; (p >= line) && (*p != '-'); p--) {
618 ;
619 }
620
621 if((p >= line) && (*p == '-')) {
622 *p = ' ';
623 }
624
625 frame = talloc_stackframe();
626 for (count=0; count<9 &&
627 next_token_talloc(frame, &cline, &tok[count],NULL);
628 count++) {
629 ;
630 }
631
632 /* we must get 7 tokens */
633 if (count < 7) {
634 TALLOC_FREE(frame);
635 return False;
636 }
637
638 /* the 2nd and 4th, 6th columns must be integer */
639 if (!isdigit((int)*tok[1]) || !isdigit((int)*tok[3])) {
640 TALLOC_FREE(frame);
641 return False;
642 }
643 if (!isdigit((int)*tok[5])) {
644 TALLOC_FREE(frame);
645 return False;
646 }
647
648 /* if the user contains a ! then trim the first part of it */
649 if ((p=strchr_m(tok[2],'!'))) {
650 tok[2] = p+1;
651 }
652
653 buf->job = atoi(tok[1]);
654 buf->size = atoi(tok[3]);
655 if (count > 7 && strequal(tok[7],"on")) {
656 buf->status = LPQ_PRINTING;
657 } else if (count > 8 && strequal(tok[7],"being") && strequal(tok[8],"held")) {
658 buf->status = LPQ_PAUSED;
659 } else {
660 buf->status = LPQ_QUEUED;
661 }
662 buf->priority = 0;
663 buf->time = EntryTime(tok, 4, count, 7);
664 fstrcpy(buf->fs_user,tok[2]);
665 fstrcpy(buf->fs_file,tok[2]);
666 TALLOC_FREE(frame);
667 return True;
668}
669
670/****************************************************************************
671parse a lpq line
672
673here is an example of lpq output under qnx
674Spooler: /qnx/spooler, on node 1
675Printer: txt (ready)
6760000: root [job #1 ] active 1146 bytes /etc/profile
6770001: root [job #2 ] ready 2378 bytes /etc/install
6780002: root [job #3 ] ready 1146 bytes -- standard input --
679****************************************************************************/
680
681static bool parse_lpq_qnx(char *line,print_queue_struct *buf,bool first)
682{
683 char *tok[7];
684 int count=0;
685 const char *cline = line;
686 TALLOC_CTX *frame = NULL;
687
688 DEBUG(4,("antes [%s]\n", line));
689
690 /* handle the case of "-- standard input --" as a filename */
691 string_sub(line,"standard input","STDIN",0);
692 DEBUG(4,("despues [%s]\n", line));
693 all_string_sub(line,"-- ","\"",0);
694 all_string_sub(line," --","\"",0);
695 DEBUG(4,("despues 1 [%s]\n", line));
696
697 string_sub(line,"[job #","",0);
698 string_sub(line,"]","",0);
699 DEBUG(4,("despues 2 [%s]\n", line));
700
701 frame = talloc_stackframe();
702 for (count=0; count<7 &&
703 next_token_talloc(frame,&cline,&tok[count],NULL);
704 count++) {
705 ;
706 }
707
708 /* we must get 7 tokens */
709 if (count < 7) {
710 TALLOC_FREE(frame);
711 return False;
712 }
713
714 /* the 3rd and 5th columns must be integer */
715 if (!isdigit((int)*tok[2]) || !isdigit((int)*tok[4])) {
716 TALLOC_FREE(frame);
717 return False;
718 }
719
720 /* only take the last part of the filename */
721 {
722 char *p = strrchr_m(tok[6],'/');
723 if (p) {
724 tok[6] = p+1;
725 }
726 }
727
728 buf->job = atoi(tok[2]);
729 buf->size = atoi(tok[4]);
730 buf->status = strequal(tok[3],"active")?LPQ_PRINTING:LPQ_QUEUED;
731 buf->priority = 0;
732 buf->time = time(NULL);
733 fstrcpy(buf->fs_user,tok[1]);
734 fstrcpy(buf->fs_file,tok[6]);
735 TALLOC_FREE(frame);
736 return True;
737}
738
739/****************************************************************************
740 parse a lpq line for the plp printing system
741 Bertrand Wallrich <Bertrand.Wallrich@loria.fr>
742
743redone by tridge. Here is a sample queue:
744
745Local Printer 'lp2' (fjall):
746 Printing (started at Jun 15 13:33:58, attempt 1).
747 Rank Owner Pr Opt Job Host Files Size Date
748 active tridge X - 6 fjall /etc/hosts 739 Jun 15 13:33
749 3rd tridge X - 7 fjall /etc/hosts 739 Jun 15 13:33
750
751****************************************************************************/
752
753static bool parse_lpq_plp(char *line,print_queue_struct *buf,bool first)
754{
755 char *tok[11];
756 int count=0;
757 const char *cline = line;
758 TALLOC_CTX *frame = talloc_stackframe();
759
760 /* handle the case of "(standard input)" as a filename */
761 string_sub(line,"stdin","STDIN",0);
762 all_string_sub(line,"(","\"",0);
763 all_string_sub(line,")","\"",0);
764
765 for (count=0; count<11 &&
766 next_token_talloc(frame,&cline,&tok[count],NULL);
767 count++) {
768 ;
769 }
770
771 /* we must get 11 tokens */
772 if (count < 11) {
773 TALLOC_FREE(frame);
774 return False;
775 }
776
777 /* the first must be "active" or begin with an integer */
778 if (strcmp(tok[0],"active") && !isdigit((int)tok[0][0])) {
779 TALLOC_FREE(frame);
780 return False;
781 }
782
783 /* the 5th and 8th must be integer */
784 if (!isdigit((int)*tok[4]) || !isdigit((int)*tok[7])) {
785 TALLOC_FREE(frame);
786 return False;
787 }
788
789 /* if the fname contains a space then use STDIN */
790 if (strchr_m(tok[6],' ')) {
791 tok[6] = talloc_strdup(frame, "STDIN");
792 if (!tok[6]) {
793 TALLOC_FREE(frame);
794 return false;
795 }
796 }
797
798 /* only take the last part of the filename */
799 {
800 fstring tmp;
801 char *p = strrchr_m(tok[6],'/');
802 if (p) {
803 fstrcpy(tmp,p+1);
804 fstrcpy(tok[6],tmp);
805 }
806 }
807
808 buf->job = atoi(tok[4]);
809
810 buf->size = atoi(tok[7]);
811 if (strchr_m(tok[7],'K')) {
812 buf->size *= 1024;
813 }
814 if (strchr_m(tok[7],'M')) {
815 buf->size *= 1024*1024;
816 }
817
818 buf->status = strequal(tok[0],"active")?LPQ_PRINTING:LPQ_QUEUED;
819 buf->priority = 0;
820 buf->time = time(NULL);
821 fstrcpy(buf->fs_user,tok[1]);
822 fstrcpy(buf->fs_file,tok[6]);
823 TALLOC_FREE(frame);
824 return True;
825}
826
827/*******************************************************************
828parse lpq on an NT system
829
830 Windows 2000 LPD Server
831 Printer \\10.0.0.2\NP17PCL (Paused)
832
833Owner Status Jobname Job-Id Size Pages Priority
834----------------------------------------------------------------------------
835root (9.99. Printing /usr/lib/rhs/rhs-pr 3 625 0 1
836root (9.99. Paused /usr/lib/rhs/rhs-pr 4 625 0 1
837jmcd Waiting Re: Samba Open Sour 26 32476 1 1
838
839********************************************************************/
840
841static bool parse_lpq_nt(char *line,print_queue_struct *buf,bool first)
842{
843#define LPRNT_OWNSIZ 11
844#define LPRNT_STATSIZ 9
845#define LPRNT_JOBSIZ 19
846#define LPRNT_IDSIZ 6
847#define LPRNT_SIZSIZ 9
848 typedef struct {
849 char owner[LPRNT_OWNSIZ];
850 char space1;
851 char status[LPRNT_STATSIZ];
852 char space2;
853 char jobname[LPRNT_JOBSIZ];
854 char space3;
855 char jobid[LPRNT_IDSIZ];
856 char space4;
857 char size[LPRNT_SIZSIZ];
858 char terminator;
859 } nt_lpq_line;
860
861 char parse_line_char[sizeof(nt_lpq_line)];
862 nt_lpq_line *parse_line = (nt_lpq_line *)parse_line_char;
863#define LPRNT_PRINTING "Printing"
864#define LPRNT_WAITING "Waiting"
865#define LPRNT_PAUSED "Paused"
866
867 memset(parse_line_char, '\0', sizeof(parse_line_char));
868 strncpy(parse_line_char, line, sizeof(parse_line_char) -1);
869
870 if (strlen(parse_line_char) != sizeof(parse_line_char) - 1) {
871 return False;
872 }
873
874 /* Just want the first word in the owner field - the username */
875 if (strchr_m(parse_line->owner, ' ')) {
876 *(strchr_m(parse_line->owner, ' ')) = '\0';
877 } else {
878 parse_line->space1 = '\0';
879 }
880
881 /* Make sure we have an owner */
882 if (!strlen(parse_line->owner)) {
883 return False;
884 }
885
886 /* Make sure the status is valid */
887 parse_line->space2 = '\0';
888 trim_char(parse_line->status, '\0', ' ');
889 if (!strequal(parse_line->status, LPRNT_PRINTING) &&
890 !strequal(parse_line->status, LPRNT_PAUSED) &&
891 !strequal(parse_line->status, LPRNT_WAITING)) {
892 return False;
893 }
894
895 parse_line->space3 = '\0';
896 trim_char(parse_line->jobname, '\0', ' ');
897
898 buf->job = atoi(parse_line->jobid);
899 buf->priority = 0;
900 buf->size = atoi(parse_line->size);
901 buf->time = time(NULL);
902 fstrcpy(buf->fs_user, parse_line->owner);
903 fstrcpy(buf->fs_file, parse_line->jobname);
904 if (strequal(parse_line->status, LPRNT_PRINTING)) {
905 buf->status = LPQ_PRINTING;
906 } else if (strequal(parse_line->status, LPRNT_PAUSED)) {
907 buf->status = LPQ_PAUSED;
908 } else {
909 buf->status = LPQ_QUEUED;
910 }
911
912 return True;
913}
914
915/*******************************************************************
916parse lpq on an OS2 system
917
918JobID File Name Rank Size Status Comment
919----- --------------- ------ -------- ------------ ------------
920 3 Control 1 68 Queued root@psflinu
921 4 /etc/motd 2 11666 Queued root@psflinu
922
923********************************************************************/
924
925static bool parse_lpq_os2(char *line,print_queue_struct *buf,bool first)
926{
927#define LPROS2_IDSIZ 5
928#define LPROS2_JOBSIZ 15
929#define LPROS2_SIZSIZ 8
930#define LPROS2_STATSIZ 12
931#define LPROS2_OWNSIZ 12
932 typedef struct {
933 char jobid[LPROS2_IDSIZ];
934 char space1[2];
935 char jobname[LPROS2_JOBSIZ];
936 char space2[14];
937 char size[LPROS2_SIZSIZ];
938 char space3[4];
939 char status[LPROS2_STATSIZ];
940 char space4[4];
941 char owner[LPROS2_OWNSIZ];
942 char terminator;
943 } os2_lpq_line;
944
945 char parse_line_char[sizeof(os2_lpq_line)];
946 os2_lpq_line *parse_line = (os2_lpq_line *)parse_line_char;
947#define LPROS2_PRINTING "Printing"
948#define LPROS2_WAITING "Queued"
949#define LPROS2_PAUSED "Paused"
950
951 memset(parse_line_char, '\0', sizeof(parse_line_char));
952 strncpy(parse_line_char, line, sizeof(parse_line_char) -1);
953
954 if (strlen(parse_line_char) != sizeof(parse_line_char) - 1) {
955 return False;
956 }
957
958 /* Get the jobid */
959 buf->job = atoi(parse_line->jobid);
960
961 /* Get the job name */
962 parse_line->space2[0] = '\0';
963 trim_char(parse_line->jobname, '\0', ' ');
964 fstrcpy(buf->fs_file, parse_line->jobname);
965
966 buf->priority = 0;
967 buf->size = atoi(parse_line->size);
968 buf->time = time(NULL);
969
970 /* Make sure we have an owner */
971 if (!strlen(parse_line->owner)) {
972 return False;
973 }
974
975 /* Make sure we have a valid status */
976 parse_line->space4[0] = '\0';
977 trim_char(parse_line->status, '\0', ' ');
978 if (!strequal(parse_line->status, LPROS2_PRINTING) &&
979 !strequal(parse_line->status, LPROS2_PAUSED) &&
980 !strequal(parse_line->status, LPROS2_WAITING)) {
981 return False;
982 }
983
984 fstrcpy(buf->fs_user, parse_line->owner);
985 if (strequal(parse_line->status, LPROS2_PRINTING)) {
986 buf->status = LPQ_PRINTING;
987 } else if (strequal(parse_line->status, LPROS2_PAUSED)) {
988 buf->status = LPQ_PAUSED;
989 } else {
990 buf->status = LPQ_QUEUED;
991 }
992
993 return True;
994}
995
996static const char *stat0_strings[] = { "enabled", "online", "idle", "no entries", "free", "ready", NULL };
997static const char *stat1_strings[] = { "offline", "disabled", "down", "off", "waiting", "no daemon", NULL };
998static const char *stat2_strings[] = { "jam", "paper", "error", "responding", "not accepting", "not running", "turned off", NULL };
999
1000#ifdef DEVELOPER
1001
1002/****************************************************************************
1003parse a vlp line
1004****************************************************************************/
1005
1006static bool parse_lpq_vlp(char *line,print_queue_struct *buf,bool first)
1007{
1008 int toknum = 0;
1009 char *tok;
1010 TALLOC_CTX *frame = talloc_stackframe();
1011 const char *cline = line;
1012
1013 /* First line is printer status */
1014
1015 if (!isdigit(line[0])) {
1016 TALLOC_FREE(frame);
1017 return False;
1018 }
1019
1020 /* Parse a print job entry */
1021
1022 while(next_token_talloc(frame, &cline, &tok, NULL)) {
1023 switch (toknum) {
1024 case 0:
1025 buf->job = atoi(tok);
1026 break;
1027 case 1:
1028 buf->size = atoi(tok);
1029 break;
1030 case 2:
1031 buf->status = atoi(tok);
1032 break;
1033 case 3:
1034 buf->time = atoi(tok);
1035 break;
1036 case 4:
1037 fstrcpy(buf->fs_user, tok);
1038 break;
1039 case 5:
1040 fstrcpy(buf->fs_file, tok);
1041 break;
1042 }
1043 toknum++;
1044 }
1045
1046 TALLOC_FREE(frame);
1047 return True;
1048}
1049
1050#endif /* DEVELOPER */
1051
1052/****************************************************************************
1053parse a lpq line. Choose printing style
1054****************************************************************************/
1055
1056bool parse_lpq_entry(enum printing_types printing_type,char *line,
1057 print_queue_struct *buf,
1058 print_status_struct *status,bool first)
1059{
1060 bool ret;
1061
1062 switch (printing_type) {
1063 case PRINT_SYSV:
1064 ret = parse_lpq_sysv(line,buf,first);
1065 break;
1066 case PRINT_AIX:
1067 ret = parse_lpq_aix(line,buf,first);
1068 break;
1069 case PRINT_HPUX:
1070 ret = parse_lpq_hpux(line,buf,first);
1071 break;
1072 case PRINT_QNX:
1073 ret = parse_lpq_qnx(line,buf,first);
1074 break;
1075 case PRINT_LPRNG:
1076 ret = parse_lpq_lprng(line,buf,first);
1077 break;
1078 case PRINT_PLP:
1079 ret = parse_lpq_plp(line,buf,first);
1080 break;
1081 case PRINT_LPRNT:
1082 ret = parse_lpq_nt(line,buf,first);
1083 break;
1084 case PRINT_LPROS2:
1085 ret = parse_lpq_os2(line,buf,first);
1086 break;
1087#ifdef DEVELOPER
1088 case PRINT_VLP:
1089 case PRINT_TEST:
1090 ret = parse_lpq_vlp(line,buf,first);
1091 break;
1092#endif /* DEVELOPER */
1093 default:
1094 ret = parse_lpq_bsd(line,buf,first);
1095 break;
1096 }
1097
1098 /* We don't want the newline in the status message. */
1099 {
1100 char *p = strchr_m(line,'\n');
1101 if (p) {
1102 *p = 0;
1103 }
1104 }
1105
1106 /* in the LPRNG case, we skip lines starting by a space.*/
1107 if (!ret && (printing_type==PRINT_LPRNG) ) {
1108 if (line[0]==' ') {
1109 return ret;
1110 }
1111 }
1112
1113 if (status && !ret) {
1114 /* a few simple checks to see if the line might be a
1115 printer status line:
1116 handle them so that most severe condition is shown */
1117 int i;
1118 strlower_m(line);
1119
1120 switch (status->status) {
1121 case LPSTAT_OK:
1122 for (i=0; stat0_strings[i]; i++) {
1123 if (strstr_m(line,stat0_strings[i])) {
1124 fstrcpy(status->message,line);
1125 status->status=LPSTAT_OK;
1126 return ret;
1127 }
1128 }
1129 /* fallthrough */
1130 case LPSTAT_STOPPED:
1131 for (i=0; stat1_strings[i]; i++) {
1132 if (strstr_m(line,stat1_strings[i])) {
1133 fstrcpy(status->message,line);
1134 status->status=LPSTAT_STOPPED;
1135 return ret;
1136 }
1137 }
1138 /* fallthrough */
1139 case LPSTAT_ERROR:
1140 for (i=0; stat2_strings[i]; i++) {
1141 if (strstr_m(line,stat2_strings[i])) {
1142 fstrcpy(status->message,line);
1143 status->status=LPSTAT_ERROR;
1144 return ret;
1145 }
1146 }
1147 break;
1148 }
1149 }
1150
1151 return ret;
1152}
Note: See TracBrowser for help on using the repository browser.