]> git.ipfire.org Git - thirdparty/cups.git/blame - cups/request.c
Merge changes from CUPS 1.5svn-r9022.
[thirdparty/cups.git] / cups / request.c
CommitLineData
ecdc0628 1/*
b19ccc9e 2 * "$Id: request.c 7946 2008-09-16 23:27:54Z mike $"
ecdc0628 3 *
4 * IPP utilities for the Common UNIX Printing System (CUPS).
5 *
5a6b583a 6 * Copyright 2007-2010 by Apple Inc.
b86bc4cf 7 * Copyright 1997-2007 by Easy Software Products.
ecdc0628 8 *
9 * These coded instructions, statements, and computer programs are the
bc44d920 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/".
ecdc0628 14 *
15 * This file is subject to the Apple OS-Developed Software exception.
16 *
17 * Contents:
18 *
3d052e43
MS
19 * cupsDoFileRequest() - Do an IPP request with a file.
20 * cupsDoIORequest() - Do an IPP request with file descriptors.
21 * cupsDoRequest() - Do an IPP request.
22 * cupsGetResponse() - Get a response to an IPP request.
23 * cupsReadResponseData() - Read additional data after the IPP response.
24 * cupsSendRequest() - Send an IPP request.
25 * cupsWriteRequestData() - Write additional data after an IPP request.
26 * _cupsSetError() - Set the last IPP status code and status-message.
27 * _cupsSetHTTPError() - Set the last error using the HTTP status.
ecdc0628 28 */
29
30/*
31 * Include necessary headers...
32 */
33
34#include "globals.h"
35#include "debug.h"
36#include <stdlib.h>
37#include <errno.h>
38#include <fcntl.h>
39#include <sys/stat.h>
40#if defined(WIN32) || defined(__EMX__)
41# include <io.h>
42#else
43# include <unistd.h>
44#endif /* WIN32 || __EMX__ */
b94498cf 45#ifndef O_BINARY
46# define O_BINARY 0
47#endif /* O_BINARY */
ecdc0628 48
49
50/*
51 * 'cupsDoFileRequest()' - Do an IPP request with a file.
52 *
53 * This function sends the IPP request to the specified server, retrying
568fa3fa 54 * and authenticating as necessary. The request is freed with @link ippDelete@
ecdc0628 55 * after receiving a valid IPP response.
56 */
57
58ipp_t * /* O - Response data */
568fa3fa 59cupsDoFileRequest(http_t *http, /* I - Connection to server or @code CUPS_HTTP_DEFAULT@ */
ecdc0628 60 ipp_t *request, /* I - IPP request */
61 const char *resource, /* I - HTTP resource for POST */
568fa3fa 62 const char *filename) /* I - File to send or @code NULL@ for none */
b94498cf 63{
64 ipp_t *response; /* IPP response data */
65 int infile; /* Input file */
66
67
a603edef 68 DEBUG_printf(("cupsDoFileRequest(http=%p, request=%p(%s), resource=\"%s\", "
e07d4801 69 "filename=\"%s\")", http, request,
a603edef 70 request ? ippOpString(request->request.op.operation_id) : "?",
e07d4801 71 resource, filename));
a603edef 72
b94498cf 73 if (filename)
74 {
75 if ((infile = open(filename, O_RDONLY | O_BINARY)) < 0)
76 {
77 /*
78 * Can't get file information!
79 */
80
81 _cupsSetError(errno == ENOENT ? IPP_NOT_FOUND : IPP_NOT_AUTHORIZED,
749b1e90 82 NULL, 0);
b94498cf 83
84 ippDelete(request);
85
86 return (NULL);
87 }
88 }
89 else
90 infile = -1;
91
92 response = cupsDoIORequest(http, request, resource, infile, -1);
93
94 if (infile >= 0)
95 close(infile);
96
97 return (response);
98}
99
100
101/*
102 * 'cupsDoIORequest()' - Do an IPP request with file descriptors.
103 *
104 * This function sends the IPP request to the specified server, retrying
105 * and authenticating as necessary. The request is freed with ippDelete()
106 * after receiving a valid IPP response.
107 *
108 * If "infile" is a valid file descriptor, cupsDoIORequest() copies
109 * all of the data from the file after the IPP request message.
110 *
111 * If "outfile" is a valid file descriptor, cupsDoIORequest() copies
112 * all of the data after the IPP response message to the file.
113 *
426c6a59 114 * @since CUPS 1.3/Mac OS X 10.5@
b94498cf 115 */
116
117ipp_t * /* O - Response data */
568fa3fa 118cupsDoIORequest(http_t *http, /* I - Connection to server or @code CUPS_HTTP_DEFAULT@ */
b94498cf 119 ipp_t *request, /* I - IPP request */
120 const char *resource, /* I - HTTP resource for POST */
121 int infile, /* I - File to read from or -1 for none */
122 int outfile) /* I - File to write to or -1 for none */
ecdc0628 123{
3d052e43
MS
124 ipp_t *response = NULL; /* IPP response data */
125 size_t length = 0; /* Content-Length value */
ecdc0628 126 http_status_t status; /* Status of HTTP request */
ecdc0628 127 struct stat fileinfo; /* File information */
128 int bytes; /* Number of bytes read/written */
a74454a7 129 char buffer[32768]; /* Output buffer */
ecdc0628 130
131
a603edef 132 DEBUG_printf(("cupsDoIORequest(http=%p, request=%p(%s), resource=\"%s\", "
e07d4801 133 "infile=%d, outfile=%d)", http, request,
a603edef 134 request ? ippOpString(request->request.op.operation_id) : "?",
e07d4801 135 resource, infile, outfile));
3d052e43
MS
136
137 /*
138 * Range check input...
139 */
ecdc0628 140
3d052e43 141 if (!request || !resource)
ecdc0628 142 {
3d052e43 143 ippDelete(request);
ecdc0628 144
749b1e90 145 _cupsSetError(IPP_INTERNAL_ERROR, strerror(EINVAL), 0);
ecdc0628 146
147 return (NULL);
148 }
149
3d052e43
MS
150 /*
151 * Get the default connection as needed...
152 */
153
154 if (!http)
a603edef
MS
155 if ((http = _cupsConnect()) == NULL)
156 return (NULL);
3d052e43 157
ecdc0628 158 /*
159 * See if we have a file to send...
160 */
161
b94498cf 162 if (infile >= 0)
ecdc0628 163 {
b94498cf 164 if (fstat(infile, &fileinfo))
ecdc0628 165 {
166 /*
167 * Can't get file information!
168 */
169
3d052e43 170 _cupsSetError(errno == EBADF ? IPP_NOT_FOUND : IPP_NOT_AUTHORIZED,
749b1e90 171 NULL, 0);
ecdc0628 172
173 ippDelete(request);
174
175 return (NULL);
176 }
177
178#ifdef WIN32
179 if (fileinfo.st_mode & _S_IFDIR)
180#else
181 if (S_ISDIR(fileinfo.st_mode))
182#endif /* WIN32 */
183 {
184 /*
185 * Can't send a directory...
186 */
187
188 ippDelete(request);
189
749b1e90 190 _cupsSetError(IPP_NOT_POSSIBLE, strerror(EISDIR), 0);
ecdc0628 191
192 return (NULL);
193 }
3d052e43
MS
194
195#ifndef WIN32
196 if (!S_ISREG(fileinfo.st_mode))
197 length = 0; /* Chunk when piping */
198 else
199#endif /* !WIN32 */
200 length = ippLength(request) + fileinfo.st_size;
201 }
202 else
203 length = ippLength(request);
204
e07d4801 205 DEBUG_printf(("2cupsDoIORequest: Request length=%ld, total length=%ld",
52f6f666
MS
206 (long)ippLength(request), (long)length));
207
b9faaae1
MS
208 /*
209 * Clear any "Local" authentication data since it is probably stale...
210 */
211
212 if (http->authstring && !strncmp(http->authstring, "Local ", 6))
213 httpSetAuthString(http, NULL, NULL);
214
3d052e43
MS
215 /*
216 * Loop until we can send the request without authorization problems.
217 */
218
219 while (response == NULL)
220 {
e07d4801 221 DEBUG_puts("2cupsDoIORequest: setup...");
3d052e43
MS
222
223 /*
224 * Send the request...
225 */
226
227 status = cupsSendRequest(http, request, resource, length);
228
e07d4801 229 DEBUG_printf(("2cupsDoIORequest: status=%d", status));
3d052e43
MS
230
231 if (status == HTTP_CONTINUE && request->state == IPP_DATA && infile >= 0)
232 {
e07d4801 233 DEBUG_puts("2cupsDoIORequest: file write...");
3d052e43
MS
234
235 /*
236 * Send the file with the request...
237 */
238
239#ifndef WIN32
240 if (S_ISREG(fileinfo.st_mode))
241#endif /* WIN32 */
242 lseek(infile, 0, SEEK_SET);
243
244 while ((bytes = (int)read(infile, buffer, sizeof(buffer))) > 0)
245 {
246 if (httpCheck(http))
247 {
248 if ((status = httpUpdate(http)) != HTTP_CONTINUE)
249 break;
250 }
251
252 if (httpWrite2(http, buffer, bytes) < bytes)
253 break;
254 }
255 }
256
257 /*
258 * Get the server's response...
259 */
260
261 if (status == HTTP_CONTINUE || status == HTTP_OK)
262 {
263 response = cupsGetResponse(http, resource);
264 status = http->status;
265 }
5a6b583a
MS
266 else
267 httpFlush(http);
3d052e43 268
f11a948a
MS
269 DEBUG_printf(("2cupsDoIORequest: status=%d", status));
270
5a6b583a
MS
271 if (status == HTTP_ERROR ||
272 (status >= HTTP_BAD_REQUEST && status != HTTP_UNAUTHORIZED &&
273 status != HTTP_UPGRADE_REQUIRED))
ee571f26
MS
274 {
275 _cupsSetHTTPError(status);
568fa3fa 276 break;
ee571f26 277 }
568fa3fa 278
3d052e43
MS
279 if (response)
280 {
281 if (outfile >= 0)
282 {
283 /*
284 * Write trailing data to file...
285 */
286
287 while ((bytes = (int)httpRead2(http, buffer, sizeof(buffer))) > 0)
288 if (write(outfile, buffer, bytes) < bytes)
289 break;
290 }
291 else
292 {
293 /*
294 * Flush any remaining data...
295 */
296
297 httpFlush(http);
298 }
299 }
300 }
301
302 /*
303 * Delete the original request and return the response...
304 */
305
306 ippDelete(request);
307
308 return (response);
309}
310
311
312/*
313 * 'cupsDoRequest()' - Do an IPP request.
314 *
315 * This function sends the IPP request to the specified server, retrying
316 * and authenticating as necessary. The request is freed with ippDelete()
317 * after receiving a valid IPP response.
318 */
319
320ipp_t * /* O - Response data */
568fa3fa 321cupsDoRequest(http_t *http, /* I - Connection to server or @code CUPS_HTTP_DEFAULT@ */
3d052e43
MS
322 ipp_t *request, /* I - IPP request */
323 const char *resource) /* I - HTTP resource for POST */
324{
e07d4801 325 DEBUG_printf(("cupsDoRequest(http=%p, request=%p(%s), resource=\"%s\")",
a603edef
MS
326 http, request,
327 request ? ippOpString(request->request.op.operation_id) : "?",
e07d4801 328 resource));
a603edef 329
b19ccc9e 330 return (cupsDoIORequest(http, request, resource, -1, -1));
3d052e43
MS
331}
332
333
334/*
335 * 'cupsGetResponse()' - Get a response to an IPP request.
336 *
337 * Use this function to get the response for an IPP request sent using
338 * cupsSendDocument() or cupsSendRequest(). For requests that return
339 * additional data, use httpRead() after getting a successful response.
340 *
178cb736 341 * @since CUPS 1.4/Mac OS X 10.6@
3d052e43
MS
342 */
343
568fa3fa
MS
344ipp_t * /* O - Response or @code NULL@ on HTTP error */
345cupsGetResponse(http_t *http, /* I - Connection to server or @code CUPS_HTTP_DEFAULT@ */
3d052e43
MS
346 const char *resource) /* I - HTTP resource for POST */
347{
348 http_status_t status; /* HTTP status */
349 ipp_state_t state; /* IPP read state */
350 ipp_t *response = NULL; /* IPP response */
351
352
e07d4801 353 DEBUG_printf(("cupsGetResponse(http=%p, resource=\"%s\")", http, resource));
3d052e43
MS
354
355 /*
356 * Connect to the default server as needed...
357 */
358
359 if (!http)
360 http = _cupsConnect();
361
362 if (!http || (http->state != HTTP_POST_RECV && http->state != HTTP_POST_SEND))
363 return (NULL);
364
365 /*
366 * Check for an unfinished chunked request...
367 */
368
369 if (http->data_encoding == HTTP_ENCODE_CHUNKED)
370 {
371 /*
372 * Send a 0-length chunk to finish off the request...
373 */
374
e07d4801 375 DEBUG_puts("2cupsGetResponse: Finishing chunked POST...");
3d052e43
MS
376
377 if (httpWrite2(http, "", 0) < 0)
378 return (NULL);
379 }
380
381 /*
382 * Wait for a response from the server...
383 */
384
e07d4801 385 DEBUG_printf(("2cupsGetResponse: Update loop, http->status=%d...",
1ff0402e 386 http->status));
3d052e43 387
1ff0402e
MS
388 status = http->status;
389 while (status == HTTP_CONTINUE)
390 status = httpUpdate(http);
3d052e43 391
e07d4801 392 DEBUG_printf(("2cupsGetResponse: status=%d", status));
3d052e43
MS
393
394 if (status == HTTP_OK)
395 {
396 /*
397 * Get the IPP response...
398 */
399
400 response = ippNew();
401
402 while ((state = ippRead(http, response)) != IPP_DATA)
403 if (state == IPP_ERROR)
404 break;
405
406 if (state == IPP_ERROR)
407 {
408 /*
409 * Delete the response...
410 */
411
e07d4801 412 DEBUG_puts("1cupsGetResponse: IPP read error!");
3d052e43
MS
413
414 ippDelete(response);
415 response = NULL;
416
749b1e90 417 _cupsSetError(IPP_SERVICE_UNAVAILABLE, NULL, 0);
3d052e43
MS
418 }
419 }
420 else if (status != HTTP_ERROR)
421 {
422 /*
423 * Flush any error message...
424 */
425
426 httpFlush(http);
427
428 /*
429 * Then handle encryption and authentication...
430 */
431
432 if (status == HTTP_UNAUTHORIZED)
433 {
434 /*
435 * See if we can do authentication...
436 */
437
e07d4801 438 DEBUG_puts("2cupsGetResponse: Need authorization...");
568fa3fa 439
e07d4801 440 if (!cupsDoAuthentication(http, "POST", resource))
3d052e43 441 httpReconnect(http);
f11a948a
MS
442 else
443 status = HTTP_AUTHORIZATION_CANCELED;
3d052e43
MS
444 }
445
446#ifdef HAVE_SSL
447 else if (status == HTTP_UPGRADE_REQUIRED)
448 {
449 /*
450 * Force a reconnect with encryption...
451 */
452
e07d4801 453 DEBUG_puts("2cupsGetResponse: Need encryption...");
3d052e43
MS
454
455 if (!httpReconnect(http))
456 httpEncryption(http, HTTP_ENCRYPT_REQUIRED);
457 }
458#endif /* HAVE_SSL */
459 }
460
461 if (response)
462 {
463 ipp_attribute_t *attr; /* status-message attribute */
464
465
466 attr = ippFindAttribute(response, "status-message", IPP_TAG_TEXT);
467
e07d4801 468 DEBUG_printf(("1cupsGetResponse: status-code=%s, status-message=\"%s\"",
a603edef
MS
469 ippErrorString(response->request.status.status_code),
470 attr ? attr->values[0].string.text : ""));
471
3d052e43 472 _cupsSetError(response->request.status.status_code,
749b1e90
MS
473 attr ? attr->values[0].string.text :
474 ippErrorString(response->request.status.status_code), 0);
3d052e43
MS
475 }
476 else if (status != HTTP_OK)
477 _cupsSetHTTPError(status);
478
479 return (response);
480}
481
482
483/*
484 * 'cupsReadResponseData()' - Read additional data after the IPP response.
485 *
486 * This function is used after cupsGetResponse() to read the PPD or document
487 * files for CUPS_GET_PPD and CUPS_GET_DOCUMENT requests, respectively.
488 *
178cb736 489 * @since CUPS 1.4/Mac OS X 10.6@
3d052e43
MS
490 */
491
492ssize_t /* O - Bytes read, 0 on EOF, -1 on error */
493cupsReadResponseData(
568fa3fa 494 http_t *http, /* I - Connection to server or @code CUPS_HTTP_DEFAULT@ */
3d052e43
MS
495 char *buffer, /* I - Buffer to use */
496 size_t length) /* I - Number of bytes to read */
497{
498 /*
499 * Get the default connection as needed...
500 */
501
a603edef 502 DEBUG_printf(("cupsReadResponseData(http=%p, buffer=%p, "
e07d4801 503 "length=" CUPS_LLFMT ")", http, buffer, CUPS_LLCAST length));
a603edef 504
3d052e43
MS
505 if (!http)
506 {
507 _cups_globals_t *cg = _cupsGlobals();
508 /* Pointer to library globals */
509
510 if ((http = cg->http) == NULL)
511 {
749b1e90 512 _cupsSetError(IPP_INTERNAL_ERROR, _("No active connection"), 1);
3d052e43
MS
513 return (-1);
514 }
ecdc0628 515 }
ecdc0628 516
3d052e43
MS
517 /*
518 * Then read from the HTTP connection...
519 */
520
521 return (httpRead2(http, buffer, length));
522}
523
524
525/*
526 * 'cupsSendRequest()' - Send an IPP request.
527 *
528 * Use httpWrite() to write any additional data (document, PPD file, etc.)
529 * for the request, cupsGetResponse() to get the IPP response, and httpRead()
530 * to read any additional data following the response. Only one request can be
531 * sent/queued at a time.
532 *
533 * Unlike cupsDoFileRequest(), cupsDoIORequest(), and cupsDoRequest(), the
534 * request is not freed.
535 *
178cb736 536 * @since CUPS 1.4/Mac OS X 10.6@
3d052e43
MS
537 */
538
539http_status_t /* O - Initial HTTP status */
568fa3fa 540cupsSendRequest(http_t *http, /* I - Connection to server or @code CUPS_HTTP_DEFAULT@ */
3d052e43
MS
541 ipp_t *request, /* I - IPP request */
542 const char *resource, /* I - Resource path */
ae71f5de 543 size_t length) /* I - Length of data to follow or @code CUPS_LENGTH_VARIABLE@ */
3d052e43
MS
544{
545 http_status_t status; /* Status of HTTP request */
546 int got_status; /* Did we get the status? */
547 ipp_state_t state; /* State of IPP processing */
548 http_status_t expect; /* Expect: header to use */
549
550
a603edef 551 DEBUG_printf(("cupsSendRequest(http=%p, request=%p(%s), resource=\"%s\", "
e07d4801 552 "length=" CUPS_LLFMT ")", http, request,
a603edef 553 request ? ippOpString(request->request.op.operation_id) : "?",
e07d4801 554 resource, CUPS_LLCAST length));
3d052e43
MS
555
556 /*
557 * Range check input...
558 */
559
560 if (!request || !resource)
561 {
749b1e90 562 _cupsSetError(IPP_INTERNAL_ERROR, strerror(EINVAL), 0);
3d052e43
MS
563
564 return (HTTP_ERROR);
565 }
566
567 /*
568 * Get the default connection as needed...
569 */
570
571 if (!http)
a603edef
MS
572 if ((http = _cupsConnect()) == NULL)
573 return (HTTP_SERVICE_UNAVAILABLE);
3d052e43 574
7594b224 575#ifdef HAVE_SSL
576 /*
577 * See if we have an auth-info attribute and are communicating over
578 * a non-local link. If so, encrypt the link so that we can pass
579 * the authentication information securely...
580 */
581
582 if (ippFindAttribute(request, "auth-info", IPP_TAG_TEXT) &&
583 !httpAddrLocalhost(http->hostaddr) && !http->tls &&
584 httpEncryption(http, HTTP_ENCRYPT_REQUIRED))
b19ccc9e
MS
585 {
586 _cupsSetError(IPP_SERVICE_UNAVAILABLE, NULL, 0);
ee571f26 587 return (HTTP_SERVICE_UNAVAILABLE);
b19ccc9e 588 }
7594b224 589#endif /* HAVE_SSL */
590
1ff0402e
MS
591 /*
592 * Reconnect if the last response had a "Connection: close"...
593 */
594
595 if (!strcasecmp(http->fields[HTTP_FIELD_CONNECTION], "close"))
596 if (httpReconnect(http))
b19ccc9e
MS
597 {
598 _cupsSetError(IPP_SERVICE_UNAVAILABLE, NULL, 0);
1ff0402e 599 return (HTTP_SERVICE_UNAVAILABLE);
b19ccc9e 600 }
1ff0402e 601
ecdc0628 602 /*
603 * Loop until we can send the request without authorization problems.
604 */
605
3d052e43 606 expect = HTTP_CONTINUE;
ecdc0628 607
3d052e43 608 for (;;)
ecdc0628 609 {
e07d4801 610 DEBUG_puts("2cupsSendRequest: Setup...");
ecdc0628 611
612 /*
613 * Setup the HTTP variables needed...
614 */
615
ecdc0628 616 httpClearFields(http);
617 httpSetLength(http, length);
618 httpSetField(http, HTTP_FIELD_CONTENT_TYPE, "application/ipp");
619 httpSetField(http, HTTP_FIELD_AUTHORIZATION, http->authstring);
f301802f 620 httpSetExpect(http, expect);
ecdc0628 621
e07d4801 622 DEBUG_printf(("2cupsSendRequest: authstring=\"%s\"", http->authstring));
ecdc0628 623
624 /*
625 * Try the request...
626 */
627
e07d4801 628 DEBUG_puts("2cupsSendRequest: Sending HTTP POST...");
ecdc0628 629
630 if (httpPost(http, resource))
631 {
632 if (httpReconnect(http))
b19ccc9e
MS
633 {
634 _cupsSetError(IPP_SERVICE_UNAVAILABLE, NULL, 0);
ee571f26 635 return (HTTP_SERVICE_UNAVAILABLE);
b19ccc9e 636 }
ecdc0628 637 else
638 continue;
639 }
640
641 /*
d6ae789d 642 * Send the IPP data...
ecdc0628 643 */
644
e07d4801 645 DEBUG_puts("2cupsSendRequest: Writing IPP request...");
b423cd4c 646
d6ae789d 647 request->state = IPP_IDLE;
648 status = HTTP_CONTINUE;
649 got_status = 0;
650
651 while ((state = ippWrite(http, request)) != IPP_DATA)
652 if (state == IPP_ERROR)
653 break;
654 else if (httpCheck(http))
655 {
656 got_status = 1;
657
658 if ((status = httpUpdate(http)) != HTTP_CONTINUE)
659 break;
660 }
661
3d052e43
MS
662 /*
663 * Wait up to 1 second to get the 100-continue response as needed...
664 */
ecdc0628 665
3d052e43
MS
666 if (!got_status && expect == HTTP_CONTINUE)
667 {
e07d4801 668 DEBUG_puts("2cupsSendRequest: Waiting for 100-continue...");
a603edef 669
d6ae789d 670 if (httpWait(http, 1000))
671 status = httpUpdate(http);
672 }
673 else if (httpCheck(http))
674 status = httpUpdate(http);
ecdc0628 675
e07d4801 676 DEBUG_printf(("2cupsSendRequest: status=%d", status));
a603edef 677
ecdc0628 678 /*
3d052e43 679 * Process the current HTTP status...
ecdc0628 680 */
681
3d052e43 682 switch (status)
ecdc0628 683 {
3d052e43
MS
684 case HTTP_ERROR :
685 case HTTP_CONTINUE :
686 case HTTP_OK :
687 return (status);
ecdc0628 688
3d052e43
MS
689 case HTTP_UNAUTHORIZED :
690 if (!cupsDoAuthentication(http, "POST", resource))
f11a948a 691 {
3d052e43 692 if (httpReconnect(http))
b19ccc9e
MS
693 {
694 _cupsSetError(IPP_SERVICE_UNAVAILABLE, NULL, 0);
695 return (HTTP_SERVICE_UNAVAILABLE);
696 }
f11a948a
MS
697 }
698 else
699 status = HTTP_AUTHORIZATION_CANCELED;
ecdc0628 700
3d052e43 701 return (status);
89d46774 702
ecdc0628 703#ifdef HAVE_SSL
3d052e43
MS
704 case HTTP_UPGRADE_REQUIRED :
705 /*
706 * Flush any error message, reconnect, and then upgrade with
707 * encryption...
708 */
ecdc0628 709
3d052e43 710 if (httpReconnect(http))
b19ccc9e
MS
711 {
712 _cupsSetError(IPP_SERVICE_UNAVAILABLE, NULL, 0);
713 return (HTTP_SERVICE_UNAVAILABLE);
714 }
ecdc0628 715
3d052e43 716 httpEncryption(http, HTTP_ENCRYPT_REQUIRED);
ecdc0628 717
3d052e43 718 return (status);
ecdc0628 719#endif /* HAVE_SSL */
f301802f 720
3d052e43
MS
721 case HTTP_EXPECTATION_FAILED :
722 /*
723 * Don't try using the Expect: header the next time around...
724 */
ecdc0628 725
3d052e43 726 expect = (http_status_t)0;
52f6f666
MS
727
728 if (httpReconnect(http))
729 {
730 _cupsSetError(IPP_SERVICE_UNAVAILABLE, NULL, 0);
731 return (HTTP_SERVICE_UNAVAILABLE);
732 }
a603edef 733 break;
ecdc0628 734
3d052e43
MS
735 default :
736 /*
737 * Some other error...
738 */
ecdc0628 739
3d052e43 740 return (status);
b94498cf 741 }
742 }
3d052e43
MS
743}
744
745
746/*
747 * 'cupsWriteRequestData()' - Write additional data after an IPP request.
748 *
568fa3fa
MS
749 * This function is used after @link cupsSendRequest@ to provide a PPD and
750 * after @link cupsStartDocument@ to provide a document file.
3d052e43 751 *
178cb736 752 * @since CUPS 1.4/Mac OS X 10.6@
3d052e43 753 */
ecdc0628 754
568fa3fa 755http_status_t /* O - @code HTTP_CONTINUE@ if OK or HTTP status on error */
3d052e43 756cupsWriteRequestData(
568fa3fa 757 http_t *http, /* I - Connection to server or @code CUPS_HTTP_DEFAULT@ */
3d052e43
MS
758 const char *buffer, /* I - Bytes to write */
759 size_t length) /* I - Number of bytes to write */
760{
38e73f87
MS
761 int wused; /* Previous bytes in buffer */
762
763
ecdc0628 764 /*
3d052e43 765 * Get the default connection as needed...
ecdc0628 766 */
ecdc0628 767
a603edef 768 DEBUG_printf(("cupsWriteRequestData(http=%p, buffer=%p, "
e07d4801 769 "length=" CUPS_LLFMT ")", http, buffer, CUPS_LLCAST length));
a603edef 770
3d052e43 771 if (!http)
ecdc0628 772 {
3d052e43
MS
773 _cups_globals_t *cg = _cupsGlobals();
774 /* Pointer to library globals */
ecdc0628 775
3d052e43
MS
776 if ((http = cg->http) == NULL)
777 {
749b1e90 778 _cupsSetError(IPP_INTERNAL_ERROR, _("No active connection"), 1);
3d052e43
MS
779 return (HTTP_ERROR);
780 }
ecdc0628 781 }
ecdc0628 782
3d052e43
MS
783 /*
784 * Then write to the HTTP connection...
785 */
ecdc0628 786
38e73f87
MS
787 wused = http->wused;
788
3d052e43
MS
789 if (httpWrite2(http, buffer, length) < 0)
790 return (HTTP_ERROR);
ecdc0628 791
3d052e43
MS
792 /*
793 * Finally, check if we have any pending data from the server...
794 */
ecdc0628 795
f11a948a 796 if (length >= HTTP_MAX_BUFFER ||
38e73f87
MS
797 http->wused < wused ||
798 (wused > 0 && http->wused == length))
799 {
800 /*
801 * We've written something to the server, so check for response data...
802 */
803
804 if (_httpWait(http, 0, 1))
805 return (httpUpdate(http));
806 }
807
808 return (HTTP_CONTINUE);
ecdc0628 809}
810
811
812/*
813 * '_cupsSetError()' - Set the last IPP status code and status-message.
814 */
815
816void
817_cupsSetError(ipp_status_t status, /* I - IPP status code */
749b1e90
MS
818 const char *message, /* I - status-message value */
819 int localize) /* I - Localize the message? */
ecdc0628 820{
821 _cups_globals_t *cg; /* Global data */
822
823
749b1e90
MS
824 if (!message && errno)
825 {
826 message = strerror(errno);
827 localize = 0;
828 }
829
ecdc0628 830 cg = _cupsGlobals();
831 cg->last_error = status;
832
833 if (cg->last_status_message)
834 {
749b1e90 835 _cupsStrFree(cg->last_status_message);
ecdc0628 836
837 cg->last_status_message = NULL;
838 }
839
840 if (message)
749b1e90
MS
841 {
842 if (localize)
843 {
844 /*
845 * Get the message catalog...
846 */
847
848 if (!cg->lang_default)
849 cg->lang_default = cupsLangDefault();
850
851 cg->last_status_message = _cupsStrAlloc(_cupsLangString(cg->lang_default,
852 message));
853 }
854 else
855 cg->last_status_message = _cupsStrAlloc(message);
856 }
a603edef 857
e07d4801
MS
858 DEBUG_printf(("4_cupsSetError: last_error=%s, last_status_message=\"%s\"",
859 ippErrorString(cg->last_error), cg->last_status_message));
ecdc0628 860}
861
862
863/*
355e94dc
MS
864 * '_cupsSetHTTPError()' - Set the last error using the HTTP status.
865 */
866
867void
868_cupsSetHTTPError(http_status_t status) /* I - HTTP status code */
869{
870 switch (status)
871 {
872 case HTTP_NOT_FOUND :
749b1e90 873 _cupsSetError(IPP_NOT_FOUND, httpStatus(status), 0);
355e94dc
MS
874 break;
875
876 case HTTP_UNAUTHORIZED :
f11a948a 877 case HTTP_AUTHORIZATION_CANCELED :
749b1e90 878 _cupsSetError(IPP_NOT_AUTHORIZED, httpStatus(status), 0);
355e94dc
MS
879 break;
880
881 case HTTP_FORBIDDEN :
749b1e90 882 _cupsSetError(IPP_FORBIDDEN, httpStatus(status), 0);
355e94dc
MS
883 break;
884
885 case HTTP_BAD_REQUEST :
749b1e90 886 _cupsSetError(IPP_BAD_REQUEST, httpStatus(status), 0);
355e94dc
MS
887 break;
888
889 case HTTP_REQUEST_TOO_LARGE :
749b1e90 890 _cupsSetError(IPP_REQUEST_VALUE, httpStatus(status), 0);
355e94dc
MS
891 break;
892
893 case HTTP_NOT_IMPLEMENTED :
749b1e90 894 _cupsSetError(IPP_OPERATION_NOT_SUPPORTED, httpStatus(status), 0);
355e94dc
MS
895 break;
896
897 case HTTP_NOT_SUPPORTED :
749b1e90 898 _cupsSetError(IPP_VERSION_NOT_SUPPORTED, httpStatus(status), 0);
355e94dc
MS
899 break;
900
901 default :
e07d4801
MS
902 DEBUG_printf(("4_cupsSetHTTPError: HTTP error %d mapped to "
903 "IPP_SERVICE_UNAVAILABLE!", status));
749b1e90 904 _cupsSetError(IPP_SERVICE_UNAVAILABLE, httpStatus(status), 0);
355e94dc
MS
905 break;
906 }
907}
908
909
910/*
b19ccc9e 911 * End of "$Id: request.c 7946 2008-09-16 23:27:54Z mike $".
ecdc0628 912 */