Home
last modified time | relevance | path

Searched refs:cacheProcessor (Results 1 – 12 of 12) sorted by relevance

/dports/www/trafficserver/trafficserver-9.1.1/iocore/cache/
H A DCacheTest.cc294 if (cacheProcessor.IsCacheEnabled() != CACHE_INITIALIZED) { in EXCLUSIVE_REGRESSION_TEST()
302 …CACHE_SM(t, write_test, { cacheProcessor.open_write(this, &key, CACHE_FRAG_TYPE_NONE, 100, CACHE_W… in EXCLUSIVE_REGRESSION_TEST()
308 CACHE_SM(t, lookup_test, { cacheProcessor.lookup(this, &key); }); in EXCLUSIVE_REGRESSION_TEST()
312 CACHE_SM(t, read_test, { cacheProcessor.open_read(this, &key); }); in EXCLUSIVE_REGRESSION_TEST()
318 CACHE_SM(t, remove_test, { cacheProcessor.remove(this, &key); }); in EXCLUSIVE_REGRESSION_TEST()
322 CACHE_SM(t, lookup_fail_test, { cacheProcessor.lookup(this, &key); }); in EXCLUSIVE_REGRESSION_TEST()
326 CACHE_SM(t, read_fail_test, { cacheProcessor.open_read(this, &key); }); in EXCLUSIVE_REGRESSION_TEST()
330 CACHE_SM(t, remove_fail_test, { cacheProcessor.remove(this, &key); }); in EXCLUSIVE_REGRESSION_TEST()
368 t, replace_read_test, { cacheProcessor.open_read(this, &key); } int open_read_callout() { in EXCLUSIVE_REGRESSION_TEST()
391 t, pread_test, { cacheProcessor.open_read(this, &key); } int open_read_callout() { in EXCLUSIVE_REGRESSION_TEST()
[all …]
H A DCachePages.cc466 …Action *lookup_result = cacheProcessor.open_read(this, &key.hash, CACHE_FRAG_TYPE_HTTP, key.hostna… in lookup_url()
508 cacheProcessor.remove(this, &key, CACHE_FRAG_TYPE_HTTP); in delete_url()
566 cacheProcessor.scan(this); in lookup_regex()
577 cacheProcessor.scan(this); in delete_regex()
588 cacheProcessor.scan(this); in invalidate_regex()
H A DCache.cc104 CacheProcessor cacheProcessor; variable
236 if (cacheProcessor.initialized == CACHE_INITIALIZED) { in cache_stats_bytes_used_cb()
902 … cacheProcessor.min_stripe_version = cacheProcessor.max_stripe_version = gvol[0]->header->version; in cacheInitialized()
907 if (v->header->version < cacheProcessor.min_stripe_version) { in cacheInitialized()
908 cacheProcessor.min_stripe_version = v->header->version; in cacheInitialized()
910 if (cacheProcessor.max_stripe_version < v->header->version) { in cacheInitialized()
911 cacheProcessor.max_stripe_version = v->header->version; in cacheInitialized()
2034 cacheProcessor.mark_storage_offline(d); // take it out of service in handle_disk_failure()
2054 cacheProcessor.cacheInitialized(); in open_done()
2068 if (ready == CACHE_INIT_FAILED && cacheProcessor.waitForCache() >= 2) { in open_done()
[all …]
H A DCacheDisk.cc210 if (cacheProcessor.start_done) { in openDone()
212 cacheProcessor.diskInitialized(); in openDone()
H A DI_Cache.h223 extern inkcoreapi CacheProcessor cacheProcessor;
H A DCacheVol.cc321 cacheProcessor.remove(this, &doc->first_key, CACHE_FRAG_TYPE_HTTP, hname, hlen); in scanObject()
/dports/www/trafficserver/trafficserver-9.1.1/src/traffic_server/
H A Dtraffic_server.cc762 if (cacheProcessor.min_stripe_version._major < 23) { in CB_After_Cache_Init()
764 cacheProcessor.min_stripe_version._major, cacheProcessor.min_stripe_version._minor); in CB_After_Cache_Init()
793 if (cacheProcessor.IsCacheEnabled() == CACHE_INITIALIZED) { in CB_cmd_cache_clear()
806 if (cacheProcessor.IsCacheEnabled() == CACHE_INITIALIZED) { in CB_cmd_cache_check()
807 res = cacheProcessor.dir_check(false) < 0 || res; in CB_cmd_cache_check()
808 cacheProcessor.stop(); in CB_cmd_cache_check()
831 cacheProcessor.afterInitCallbackSet(&CB_cmd_cache_check); in cmd_check_internal()
832 if (cacheProcessor.start_internal(PROCESSOR_CHECK) < 0) { in cmd_check_internal()
887 cacheProcessor.afterInitCallbackSet(&CB_cmd_cache_clear); in cmd_clear()
2092 cacheProcessor.afterInitCallbackSet(&CB_After_Cache_Init); in main()
[all …]
H A DInkAPI.cc7521 *is_ready = cacheProcessor.IsCacheReady(frag_type); in TSCacheDataTypeReady()
7537 …return (TSAction)cacheProcessor.open_read(i, &info->cache_key, info->frag_type, info->hostname, in… in TSCacheRead()
7551 …return (TSAction)cacheProcessor.open_write(i, &info->cache_key, info->frag_type, 0, false, info->p… in TSCacheWrite()
7566 …return (TSAction)cacheProcessor.remove(i, &info->cache_key, info->frag_type, info->hostname, info-… in TSCacheRemove()
7581 return (TSAction)cacheProcessor.scan(i, info->hostname, info->len, KB_per_second); in TSCacheScan()
7583 return reinterpret_cast<TSAction>(cacheProcessor.scan(i, nullptr, 0, KB_per_second)); in TSCacheScan()
/dports/www/trafficserver/trafficserver-9.1.1/iocore/cache/test/
H A Dmain.cc81 cacheProcessor.start(); in init_cache()
213 …cacheProcessor.open_write(this, 0, &key, static_cast<CacheHTTPHdr *>(this->info.request_get()), ol… in start_test()
274 …cacheProcessor.open_read(this, &key, static_cast<CacheHTTPHdr *>(this->info.request_get()), &this-… in start_test()
/dports/www/trafficserver/trafficserver-9.1.1/proxy/http/
H A DHttpCacheSM.cc279 …Action *action_handle = cacheProcessor.open_read(this, &key, this->read_request_hdr, this->http_pa… in do_cache_open_read()
371 cacheProcessor.open_write(this, 0, key, request, in open_write()
H A DHttpSM.cc4750 pending_action = cacheProcessor.remove(cont, &key); in do_cache_delete_all_alts()
/dports/www/trafficserver/trafficserver-9.1.1/plugins/experimental/memcache/
H A Dtsmemcache.cc476 pending_action = cacheProcessor.open_read(this, &cache_key); in get_item()
484 pending_action = cacheProcessor.open_write(this, &cache_key, CACHE_FRAG_TYPE_NONE, header.nbytes, in set_item()
493 pending_action = cacheProcessor.remove(this, &cache_key, CACHE_FRAG_TYPE_NONE); in delete_item()