A brief file description. More...
#include "P_ClusterCacheInternal.h"
#include "P_CacheInternal.h"
#include "P_ClusterHandler.h"
Go to the source code of this file.
Functions | |
Action * | Cluster_lookup (Continuation *cont, CacheKey *key, CacheFragType frag_type, char *hostname, int host_len) |
Action * | Cluster_read (ClusterMachine *owner_machine, int opcode, Continuation *cont, MIOBuffer *buf, CacheURL *url, CacheHTTPHdr *request, CacheLookupHttpConfig *params, CacheKey *key, time_t pin_in_cache, CacheFragType frag_type, char *hostname, int host_len) |
Action * | Cluster_write (Continuation *cont, int expected_size, MIOBuffer *buf, ClusterMachine *m, INK_MD5 *url_md5, CacheFragType ft, int options, time_t pin_in_cache, int opcode, CacheKey *key, CacheURL *url, CacheHTTPHdr *request, CacheHTTPInfo *old_info, char *hostname, int host_len) |
Action * | Cluster_link (ClusterMachine *m, Continuation *cont, CacheKey *from, CacheKey *to, CacheFragType type, char *hostname, int host_len) |
Action * | Cluster_deref (ClusterMachine *m, Continuation *cont, CacheKey *key, CacheFragType type, char *hostname, int host_len) |
Action * | Cluster_remove (ClusterMachine *m, Continuation *cont, CacheKey *key, bool rm_user_agents, bool rm_link, CacheFragType frag_type, char *hostname, int host_len) |
A brief file description.
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file to you under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Definition in file P_ClusterInline.h.
Action* Cluster_deref | ( | ClusterMachine * | m, | |
Continuation * | cont, | |||
CacheKey * | key, | |||
CacheFragType | type, | |||
char * | hostname, | |||
int | host_len | |||
) | [inline] |
Definition at line 316 of file P_ClusterInline.h.
References a, ALLOCA_DOUBLE, CACHE_DEREF, CACHE_EVENT_DEREF_FAILED, CacheOpMsg_short::CACHE_OP_SHORT_MESSAGE_VERSION, CacheContinuation::callback_failure(), clusterProcessor, DEFAULT_MAX_BUFFER_SIZE, ClusterProcessor::disable_remote_cluster_ops(), CacheContinuation::do_op(), CacheOpArgs_Deref::frag_type, ink_release_assert, CacheOpArgs_Deref::md5, memcpy, ClusterMachine::msg_proto_major, op_to_sizeof_fixedlen_msg(), and CacheOpMsg_short::protoToVersion().
Action* Cluster_link | ( | ClusterMachine * | m, | |
Continuation * | cont, | |||
CacheKey * | from, | |||
CacheKey * | to, | |||
CacheFragType | type, | |||
char * | hostname, | |||
int | host_len | |||
) | [inline] |
Definition at line 272 of file P_ClusterInline.h.
References a, ALLOCA_DOUBLE, CACHE_EVENT_LINK_FAILED, CACHE_LINK, CacheOpMsg_short_2::CACHE_OP_SHORT_2_MESSAGE_VERSION, CacheContinuation::callback_failure(), clusterProcessor, DEFAULT_MAX_BUFFER_SIZE, ClusterProcessor::disable_remote_cluster_ops(), CacheContinuation::do_op(), CacheOpArgs_Link::frag_type, CacheOpArgs_Link::from, ink_release_assert, memcpy, ClusterMachine::msg_proto_major, op_to_sizeof_fixedlen_msg(), CacheOpMsg_short_2::protoToVersion(), and CacheOpArgs_Link::to.
Action* Cluster_lookup | ( | Continuation * | cont, | |
CacheKey * | key, | |||
CacheFragType | frag_type, | |||
char * | hostname, | |||
int | host_len | |||
) | [inline] |
Definition at line 36 of file P_ClusterInline.h.
References a, CacheContinuation::action, CACHE_EVENT_LOOKUP_FAILED, cache_hash(), CacheContinuation::cacheContAllocator_alloc(), CacheContinuation::cacheContAllocator_free(), CacheContinuation::callback_failure(), cluster_machine_at_depth(), clusterProcessor, ClusterProcessor::disable_remote_cluster_ops(), CacheContinuation::do_remote_lookup(), and Continuation::mutex.
Referenced by CacheProcessor::lookup().
Action* Cluster_read | ( | ClusterMachine * | owner_machine, | |
int | opcode, | |||
Continuation * | cont, | |||
MIOBuffer * | buf, | |||
CacheURL * | url, | |||
CacheHTTPHdr * | request, | |||
CacheLookupHttpConfig * | params, | |||
CacheKey * | key, | |||
time_t | pin_in_cache, | |||
CacheFragType | frag_type, | |||
char * | hostname, | |||
int | host_len | |||
) | [inline] |
Definition at line 62 of file P_ClusterInline.h.
References a, ALLOCA_DOUBLE, CACHE_EVENT_OPEN_READ_FAILED, CacheOpMsg_long::CACHE_OP_LONG_MESSAGE_VERSION, CACHE_OPEN_READ_BUFFER_LONG, CACHE_OPEN_READ_LONG, CacheContinuation::callback_failure(), clusterProcessor, DEFAULT_MAX_BUFFER_SIZE, ClusterProcessor::disable_remote_cluster_ops(), CacheContinuation::do_op(), CacheOpArgs_General::frag_type, ink_release_assert, CacheLookupHttpConfig::marshal(), CacheLookupHttpConfig::marshal_length(), memcpy, ClusterMachine::msg_proto_major, op_to_sizeof_fixedlen_msg(), CacheOpArgs_General::pin_in_cache, CacheOpMsg_long::protoToVersion(), and CacheOpArgs_General::url_md5.
Action* Cluster_remove | ( | ClusterMachine * | m, | |
Continuation * | cont, | |||
CacheKey * | key, | |||
bool | rm_user_agents, | |||
bool | rm_link, | |||
CacheFragType | frag_type, | |||
char * | hostname, | |||
int | host_len | |||
) | [inline] |
Definition at line 358 of file P_ClusterInline.h.
References a, ALLOCA_DOUBLE, CACHE_EVENT_REMOVE_FAILED, CacheOpMsg_short::CACHE_OP_SHORT_MESSAGE_VERSION, CACHE_REMOVE, CacheContinuation::callback_failure(), CacheOpArgs_General::cfl_flags, CFL_REMOVE_LINK, CFL_REMOVE_USER_AGENTS, clusterProcessor, DEFAULT_MAX_BUFFER_SIZE, ClusterProcessor::disable_remote_cluster_ops(), CacheContinuation::do_op(), CacheOpArgs_General::frag_type, ink_release_assert, memcpy, ClusterMachine::msg_proto_major, op_to_sizeof_fixedlen_msg(), CacheOpMsg_short::protoToVersion(), and CacheOpArgs_General::url_md5.
Referenced by CacheProcessor::remove().
Action* Cluster_write | ( | Continuation * | cont, | |
int | expected_size, | |||
MIOBuffer * | buf, | |||
ClusterMachine * | m, | |||
INK_MD5 * | url_md5, | |||
CacheFragType | ft, | |||
int | options, | |||
time_t | pin_in_cache, | |||
int | opcode, | |||
CacheKey * | key, | |||
CacheURL * | url, | |||
CacheHTTPHdr * | request, | |||
CacheHTTPInfo * | old_info, | |||
char * | hostname, | |||
int | host_len | |||
) | [inline] |
Definition at line 164 of file P_ClusterInline.h.
References a, ALLOCA_DOUBLE, CACHE_ALLOW_MULTIPLE_WRITES, CACHE_EVENT_OPEN_WRITE_FAILED, CacheOpMsg_long::CACHE_OP_LONG_MESSAGE_VERSION, CACHE_OPEN_WRITE, CACHE_OPEN_WRITE_LONG, CACHE_WRITE_OPT_OVERWRITE, CacheContinuation::callback_failure(), CFL_ALLOW_MULTIPLE_WRITES, CacheOpArgs_General::cfl_flags, CFL_LOPENWRITE_HAVE_OLDINFO, CFL_OVERWRITE_ON_WRITE, clusterProcessor, DEFAULT_MAX_BUFFER_SIZE, ClusterProcessor::disable_remote_cluster_ops(), CacheContinuation::do_op(), CacheOpArgs_General::frag_type, ink_release_assert, memcpy, ClusterMachine::msg_proto_major, op_to_sizeof_fixedlen_msg(), CacheOpArgs_General::pin_in_cache, CacheOpMsg_long::protoToVersion(), and CacheOpArgs_General::url_md5.
Referenced by CacheProcessor::open_write().