]>
git.ipfire.org Git - thirdparty/cups.git/blob - scheduler/statbuf.c
4 * Status buffer routines for the CUPS scheduler.
6 * Copyright 2007-2012 by Apple Inc.
7 * Copyright 1997-2006 by Easy Software Products, all rights reserved.
9 * These coded instructions, statements, and computer programs are the
10 * property of Apple Inc. and are protected by Federal copyright
11 * law. Distribution and use rights are outlined in the file "LICENSE.txt"
12 * which should have been included with this file. If this file is
13 * file is missing or damaged, see the license at "http://www.cups.org/".
17 * cupsdStatBufDelete() - Destroy a status buffer.
18 * cupsdStatBufNew() - Create a new status buffer.
19 * cupsdStatBufUpdate() - Update the status buffer.
23 * Include necessary headers...
31 * 'cupsdStatBufDelete()' - Destroy a status buffer.
35 cupsdStatBufDelete(cupsd_statbuf_t
*sb
) /* I - Status buffer */
38 * Range check input...
45 * Close the status pipe and free memory used...
55 * 'cupsdStatBufNew()' - Create a new status buffer.
58 cupsd_statbuf_t
* /* O - New status buffer */
59 cupsdStatBufNew(int fd
, /* I - File descriptor of pipe */
60 const char *prefix
, /* I - Printf-style prefix string */
61 ...) /* I - Additional args as needed */
63 cupsd_statbuf_t
*sb
; /* New status buffer */
64 va_list ap
; /* Argument list */
68 * Range check input...
75 * Allocate the status buffer...
78 if ((sb
= calloc(1, sizeof(cupsd_statbuf_t
))) != NULL
)
81 * Assign the file descriptor...
87 * Format the prefix string, if any. This is usually "[Job 123]"
88 * or "[Sub 123]", and so forth.
94 * Printf-style prefix string...
98 vsnprintf(sb
->prefix
, sizeof(sb
->prefix
), prefix
, ap
);
104 * No prefix string...
107 sb
->prefix
[0] = '\0';
116 * 'cupsdStatBufUpdate()' - Update the status buffer.
119 char * /* O - Line from buffer, "", or NULL */
121 cupsd_statbuf_t
*sb
, /* I - Status buffer */
122 int *loglevel
, /* O - Log level */
123 char *line
, /* I - Line buffer */
124 int linelen
) /* I - Size of line buffer */
126 int bytes
; /* Number of bytes read */
127 char *lineptr
, /* Pointer to end of line in buffer */
128 *message
; /* Pointer to message text */
132 * Check if the buffer already contains a full line...
135 if ((lineptr
= strchr(sb
->buffer
, '\n')) == NULL
)
138 * No, read more data...
141 if ((bytes
= read(sb
->fd
, sb
->buffer
+ sb
->bufused
,
142 CUPSD_SB_BUFFER_SIZE
- sb
->bufused
- 1)) > 0)
144 sb
->bufused
+= bytes
;
145 sb
->buffer
[sb
->bufused
] = '\0';
148 * Guard against a line longer than the max buffer size...
151 if ((lineptr
= strchr(sb
->buffer
, '\n')) == NULL
&&
152 sb
->bufused
== (CUPSD_SB_BUFFER_SIZE
- 1))
153 lineptr
= sb
->buffer
+ sb
->bufused
;
155 else if (bytes
< 0 && errno
== EINTR
)
158 * Return an empty line if we are interrupted...
161 *loglevel
= CUPSD_LOG_NONE
;
169 * End-of-file, so use the whole buffer...
172 lineptr
= sb
->buffer
+ sb
->bufused
;
177 * Final check for end-of-file...
180 if (sb
->bufused
== 0 && bytes
== 0)
190 *loglevel
= CUPSD_LOG_NONE
;
197 * Terminate the line and process it...
203 * Figure out the logging level...
206 if (!strncmp(sb
->buffer
, "EMERG:", 6))
208 *loglevel
= CUPSD_LOG_EMERG
;
209 message
= sb
->buffer
+ 6;
211 else if (!strncmp(sb
->buffer
, "ALERT:", 6))
213 *loglevel
= CUPSD_LOG_ALERT
;
214 message
= sb
->buffer
+ 6;
216 else if (!strncmp(sb
->buffer
, "CRIT:", 5))
218 *loglevel
= CUPSD_LOG_CRIT
;
219 message
= sb
->buffer
+ 5;
221 else if (!strncmp(sb
->buffer
, "ERROR:", 6))
223 *loglevel
= CUPSD_LOG_ERROR
;
224 message
= sb
->buffer
+ 6;
226 else if (!strncmp(sb
->buffer
, "WARNING:", 8))
228 *loglevel
= CUPSD_LOG_WARN
;
229 message
= sb
->buffer
+ 8;
231 else if (!strncmp(sb
->buffer
, "NOTICE:", 7))
233 *loglevel
= CUPSD_LOG_NOTICE
;
234 message
= sb
->buffer
+ 7;
236 else if (!strncmp(sb
->buffer
, "INFO:", 5))
238 *loglevel
= CUPSD_LOG_INFO
;
239 message
= sb
->buffer
+ 5;
241 else if (!strncmp(sb
->buffer
, "DEBUG:", 6))
243 *loglevel
= CUPSD_LOG_DEBUG
;
244 message
= sb
->buffer
+ 6;
246 else if (!strncmp(sb
->buffer
, "DEBUG2:", 7))
248 *loglevel
= CUPSD_LOG_DEBUG2
;
249 message
= sb
->buffer
+ 7;
251 else if (!strncmp(sb
->buffer
, "PAGE:", 5))
253 *loglevel
= CUPSD_LOG_PAGE
;
254 message
= sb
->buffer
+ 5;
256 else if (!strncmp(sb
->buffer
, "STATE:", 6))
258 *loglevel
= CUPSD_LOG_STATE
;
259 message
= sb
->buffer
+ 6;
261 else if (!strncmp(sb
->buffer
, "JOBSTATE:", 9))
263 *loglevel
= CUPSD_LOG_JOBSTATE
;
264 message
= sb
->buffer
+ 9;
266 else if (!strncmp(sb
->buffer
, "ATTR:", 5))
268 *loglevel
= CUPSD_LOG_ATTR
;
269 message
= sb
->buffer
+ 5;
271 else if (!strncmp(sb
->buffer
, "PPD:", 4))
273 *loglevel
= CUPSD_LOG_PPD
;
274 message
= sb
->buffer
+ 4;
278 *loglevel
= CUPSD_LOG_DEBUG
;
279 message
= sb
->buffer
;
283 * Skip leading whitespace in the message...
286 while (isspace(*message
& 255))
290 * Send it to the log file as needed...
295 if (*loglevel
> CUPSD_LOG_NONE
&&
296 (*loglevel
!= CUPSD_LOG_INFO
|| LogLevel
>= CUPSD_LOG_DEBUG
))
299 * General status message; send it to the error_log file...
302 if (message
[0] == '[')
303 cupsdLogMessage(*loglevel
, "%s", message
);
305 cupsdLogMessage(*loglevel
, "%s %s", sb
->prefix
, message
);
307 else if (*loglevel
< CUPSD_LOG_NONE
&& LogLevel
>= CUPSD_LOG_DEBUG
)
308 cupsdLogMessage(CUPSD_LOG_DEBUG2
, "%s %s", sb
->prefix
, sb
->buffer
);
312 * Copy the message to the line buffer...
315 strlcpy(line
, message
, linelen
);
318 * Copy over the buffer data we've used up...
321 if (lineptr
< sb
->buffer
+ sb
->bufused
)
322 _cups_strcpy(sb
->buffer
, lineptr
);
324 sb
->bufused
-= lineptr
- sb
->buffer
;