|
34 | 34 | #include "proxy/http/HttpSM.h" |
35 | 35 | #include "proxy/http/HttpDebugNames.h" |
36 | 36 |
|
| 37 | +#include "iocore/cache/Cache.h" |
| 38 | + |
37 | 39 | #define SM_REMEMBER(sm, e, r) \ |
38 | 40 | { \ |
39 | 41 | sm->history.push_back(MakeSourceLocation(), e, r); \ |
@@ -322,7 +324,7 @@ HttpCacheSM::do_cache_open_read(const HttpCacheKey &key) |
322 | 324 | ink_assert(open_read_cb == false); |
323 | 325 | // Initialising read-while-write-inprogress flag |
324 | 326 | this->readwhilewrite_inprogress = false; |
325 | | - Action *action_handle = cacheProcessor.open_read(this, &key, this->read_request_hdr, &http_params, this->read_pin_in_cache); |
| 327 | + Action *action_handle = cacheProcessor.open_read(this, &key, this->read_request_hdr, &http_params); |
326 | 328 |
|
327 | 329 | if (action_handle != ACTION_RESULT_DONE) { |
328 | 330 | pending_action = action_handle; |
@@ -416,10 +418,9 @@ HttpCacheSM::open_write(const HttpCacheKey *key, URL *url, HTTPHdr *request, Cac |
416 | 418 | return ACTION_RESULT_DONE; |
417 | 419 | } |
418 | 420 |
|
419 | | - Action *action_handle = |
420 | | - cacheProcessor.open_write(this, 0, key, request, |
421 | | - // INKqa11166 |
422 | | - allow_multiple ? (CacheHTTPInfo *)CACHE_ALLOW_MULTIPLE_WRITES : old_info, pin_in_cache); |
| 421 | + // INKqa11166 |
| 422 | + CacheHTTPInfo *info = allow_multiple ? reinterpret_cast<CacheHTTPInfo *>(CACHE_ALLOW_MULTIPLE_WRITES) : old_info; |
| 423 | + Action *action_handle = cacheProcessor.open_write(this, key, info, pin_in_cache); |
423 | 424 |
|
424 | 425 | if (action_handle != ACTION_RESULT_DONE) { |
425 | 426 | pending_action = action_handle; |
|
0 commit comments