]>
Commit | Line | Data |
---|---|---|
26cc52cb | 1 | /* |
bbc27441 AJ |
2 | * Copyright (C) 1996-2014 The Squid Software Foundation and contributors |
3 | * | |
4 | * Squid software is distributed under GPLv2+ license and includes | |
5 | * contributions from numerous individuals and organizations. | |
6 | * Please see the COPYING and CONTRIBUTORS files for details. | |
26cc52cb AR |
7 | */ |
8 | ||
bbc27441 AJ |
9 | /* DEBUG: section 93 ICAP (RFC 3507) Client */ |
10 | ||
582c2af2 | 11 | #include "squid.h" |
1adcebc3 | 12 | #include "adaptation/Answer.h" |
83c51da9 | 13 | #include "adaptation/icap/Config.h" |
582c2af2 FC |
14 | #include "adaptation/icap/Options.h" |
15 | #include "adaptation/icap/OptXact.h" | |
3d93a84d | 16 | #include "base/TextException.h" |
582c2af2 | 17 | #include "comm.h" |
a5bac1d2 | 18 | #include "HttpHeaderTools.h" |
582c2af2 | 19 | #include "HttpReply.h" |
3ff65596 | 20 | #include "HttpRequest.h" |
582c2af2 | 21 | #include "SquidTime.h" |
26cc52cb AR |
22 | |
23 | CBDATA_NAMESPACED_CLASS_INIT(Adaptation::Icap, OptXact); | |
24 | CBDATA_NAMESPACED_CLASS_INIT(Adaptation::Icap, OptXactLauncher); | |
25 | ||
4299f876 | 26 | Adaptation::Icap::OptXact::OptXact(Adaptation::Icap::ServiceRep::Pointer &aService): |
f53969cc SM |
27 | AsyncJob("Adaptation::Icap::OptXact"), |
28 | Adaptation::Icap::Xaction("Adaptation::Icap::OptXact", aService), | |
29 | readAll(false) | |
26cc52cb AR |
30 | { |
31 | } | |
32 | ||
33 | void Adaptation::Icap::OptXact::start() | |
34 | { | |
35 | Adaptation::Icap::Xaction::start(); | |
36 | ||
37 | openConnection(); | |
38 | } | |
39 | ||
40 | void Adaptation::Icap::OptXact::handleCommConnected() | |
41 | { | |
42 | scheduleRead(); | |
43 | ||
44 | MemBuf requestBuf; | |
45 | requestBuf.init(); | |
46 | makeRequest(requestBuf); | |
192378eb | 47 | debugs(93, 9, HERE << "request " << status() << ":\n" << |
26cc52cb | 48 | (requestBuf.terminate(), requestBuf.content())); |
3ff65596 | 49 | icap_tio_start = current_time; |
26cc52cb AR |
50 | scheduleWrite(requestBuf); |
51 | } | |
52 | ||
53 | void Adaptation::Icap::OptXact::makeRequest(MemBuf &buf) | |
54 | { | |
55 | const Adaptation::Service &s = service(); | |
56 | const String uri = s.cfg().uri; | |
57 | buf.Printf("OPTIONS " SQUIDSTRINGPH " ICAP/1.0\r\n", SQUIDSTRINGPRINT(uri)); | |
58 | const String host = s.cfg().host; | |
59 | buf.Printf("Host: " SQUIDSTRINGPH ":%d\r\n", SQUIDSTRINGPRINT(host), s.cfg().port); | |
77f6d1d2 NH |
60 | |
61 | if (!TheConfig.reuse_connections) | |
62 | buf.Printf("Connection: close\r\n"); | |
63 | ||
83c51da9 CT |
64 | if (TheConfig.allow206_enable) |
65 | buf.Printf("Allow: 206\r\n"); | |
26cc52cb | 66 | buf.append(ICAP::crlf, 2); |
3ff65596 AR |
67 | |
68 | // XXX: HttpRequest cannot fully parse ICAP Request-Line | |
955394ce | 69 | Http::StatusCode reqStatus; |
b0365bd9 | 70 | Must(icapRequest->parse(&buf, true, &reqStatus) > 0); |
26cc52cb AR |
71 | } |
72 | ||
73 | void Adaptation::Icap::OptXact::handleCommWrote(size_t size) | |
74 | { | |
192378eb | 75 | debugs(93, 9, HERE << "finished writing " << size << |
26cc52cb AR |
76 | "-byte request " << status()); |
77 | } | |
78 | ||
79 | // comm module read a portion of the ICAP response for us | |
80 | void Adaptation::Icap::OptXact::handleCommRead(size_t) | |
81 | { | |
c7d51c86 | 82 | if (parseResponse()) { |
0a1ac29e AR |
83 | Must(icapReply != NULL); |
84 | // We read everything if there is no response body. If there is a body, | |
85 | // we cannot parse it because we do not support any opt-body-types, so | |
86 | // we leave readAll false which forces connection closure. | |
87 | readAll = !icapReply->header.getByNameListMember("Encapsulated", | |
5be49f98 | 88 | "opt-body", ',').size(); |
0a1ac29e | 89 | debugs(93, 7, HERE << "readAll=" << readAll); |
3ff65596 AR |
90 | icap_tio_finish = current_time; |
91 | setOutcome(xoOpt); | |
b248c2a3 | 92 | sendAnswer(Answer::Forward(icapReply.getRaw())); |
26cc52cb AR |
93 | Must(done()); // there should be nothing else to do |
94 | return; | |
95 | } | |
96 | ||
97 | scheduleRead(); | |
98 | } | |
99 | ||
c7d51c86 | 100 | bool Adaptation::Icap::OptXact::parseResponse() |
26cc52cb AR |
101 | { |
102 | debugs(93, 5, HERE << "have " << readBuf.contentSize() << " bytes to parse" << | |
103 | status()); | |
104 | debugs(93, 5, HERE << "\n" << readBuf.content()); | |
105 | ||
c7d51c86 | 106 | HttpReply::Pointer r(new HttpReply); |
26cc52cb AR |
107 | r->protoPrefix = "ICAP/"; // TODO: make an IcapReply class? |
108 | ||
b248c2a3 | 109 | if (!parseHttpMsg(r.getRaw())) // throws on errors |
c7d51c86 | 110 | return false; |
26cc52cb AR |
111 | |
112 | if (httpHeaderHasConnDir(&r->header, "close")) | |
113 | reuseConnection = false; | |
114 | ||
c7d51c86 AR |
115 | icapReply = r; |
116 | return true; | |
26cc52cb AR |
117 | } |
118 | ||
3ff65596 AR |
119 | void Adaptation::Icap::OptXact::swanSong() |
120 | { | |
121 | Adaptation::Icap::Xaction::swanSong(); | |
122 | } | |
123 | ||
124 | void Adaptation::Icap::OptXact::finalizeLogInfo() | |
125 | { | |
126 | // al.cache.caddr = 0; | |
127 | al.icap.reqMethod = Adaptation::methodOptions; | |
bae917ac | 128 | |
b248c2a3 | 129 | if (icapReply != NULL && al.icap.bytesRead > icapReply->hdr_sz) |
bae917ac CT |
130 | al.icap.bodyBytesRead = al.icap.bytesRead - icapReply->hdr_sz; |
131 | ||
3ff65596 AR |
132 | Adaptation::Icap::Xaction::finalizeLogInfo(); |
133 | } | |
134 | ||
26cc52cb AR |
135 | /* Adaptation::Icap::OptXactLauncher */ |
136 | ||
4299f876 | 137 | Adaptation::Icap::OptXactLauncher::OptXactLauncher(Adaptation::ServicePointer aService): |
f53969cc SM |
138 | AsyncJob("Adaptation::Icap::OptXactLauncher"), |
139 | Adaptation::Icap::Launcher("Adaptation::Icap::OptXactLauncher", aService) | |
26cc52cb AR |
140 | { |
141 | } | |
142 | ||
143 | Adaptation::Icap::Xaction *Adaptation::Icap::OptXactLauncher::createXaction() | |
144 | { | |
145 | Adaptation::Icap::ServiceRep::Pointer s = | |
146 | dynamic_cast<Adaptation::Icap::ServiceRep*>(theService.getRaw()); | |
147 | Must(s != NULL); | |
4299f876 | 148 | return new Adaptation::Icap::OptXact(s); |
26cc52cb | 149 | } |
f53969cc | 150 |