A brief file description. More...
#include "P_ClusterCache.h"#include "I_OneWayTunnel.h"
Go to the source code of this file.
Data Structures | |
| struct | CacheContinuation |
| struct | CacheOpArgs_General |
| struct | CacheOpArgs_Link |
| struct | CacheOpArgs_Deref |
| struct | CacheLookupMsg |
| struct | CacheOpMsg_long |
| struct | CacheOpMsg_short |
| struct | CacheOpMsg_short_2 |
| struct | CacheOpReplyMsg |
Defines | |
| #define | CACHE_USE_OPEN_VIO 0 |
| #define | DO_REPLICATION 0 |
| #define | META_DATA_FAST_ALLOC_LIMIT 1 |
| #define | CACHE_CLUSTER_TIMEOUT HRTIME_MSECONDS(5000) |
| #define | CACHE_RETRY_PERIOD HRTIME_MSECONDS(10) |
| #define | REMOTE_CONNECT_HASH (16 * 1024) |
| #define | FOLDHASH(_ip, _seq) (_seq % REMOTE_CONNECT_HASH) |
| #define | ALIGN_DOUBLE(_p) ((((uintptr_t) (_p)) + 7) & ~7) |
| #define | ALLOCA_DOUBLE(_sz) ALIGN_DOUBLE(alloca((_sz) + 8)) |
| #define | TEST(_x) |
| #define | TTEST(_x) |
| #define | TIMEOUT_TEST(_x) |
| #define | PROBE_LOCAL_CACHE_FIRST DO_REPLICATION |
| #define | PROBE_LOCAL_CACHE_LAST false |
| #define | CFL_OVERWRITE_ON_WRITE (1 << 1) |
| #define | CFL_REMOVE_USER_AGENTS (1 << 2) |
| #define | CFL_REMOVE_LINK (1 << 3) |
| #define | CFL_LOPENWRITE_HAVE_OLDINFO (1 << 4) |
| #define | CFL_ALLOW_MULTIPLE_WRITES (1 << 5) |
| #define | CFL_MAX (1 << 15) |
Typedefs | |
| typedef int(CacheContinuation::* | CacheContHandler )(int, void *) |
Functions | |
| int | maxval (int a, int b) |
| int | op_to_sizeof_fixedlen_msg (int op) |
| static bool | event_is_lookup (int event) |
| static bool | event_is_open (int event) |
| static bool | op_is_read (int opcode) |
| static bool | op_is_shortform (int opcode) |
| static int | op_failure (int opcode) |
| static int | op_needs_marshalled_coi (int opcode) |
| static int | event_reply_may_have_moi (int event) |
| static int | event_is_failure (int event) |
Variables | |
| int | cache_migrate_on_demand |
| int | ET_CLUSTER |
Detailed Description
A brief file description.
License
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_ClusterCacheInternal.h.
Define Documentation
| #define ALIGN_DOUBLE | ( | _p | ) | ((((uintptr_t) (_p)) + 7) & ~7) |
Definition at line 52 of file P_ClusterCacheInternal.h.
Referenced by CacheOpReplyMsg::sizeof_fixedlen_msg(), CacheOpMsg_short_2::sizeof_fixedlen_msg(), CacheOpMsg_short::sizeof_fixedlen_msg(), CacheOpMsg_long::sizeof_fixedlen_msg(), and CacheLookupMsg::sizeof_fixedlen_msg().
| #define ALLOCA_DOUBLE | ( | _sz | ) | ALIGN_DOUBLE(alloca((_sz) + 8)) |
Definition at line 53 of file P_ClusterCacheInternal.h.
Referenced by Cluster_deref(), Cluster_link(), Cluster_read(), Cluster_remove(), Cluster_write(), CacheContinuation::do_op(), CacheContinuation::do_remote_lookup(), CacheContinuation::replyLookupEvent(), CacheContinuation::replyOpEvent(), and ClusterVConnection::set_http_info().
| #define CACHE_CLUSTER_TIMEOUT HRTIME_MSECONDS(5000) |
Definition at line 44 of file P_ClusterCacheInternal.h.
| #define CACHE_RETRY_PERIOD HRTIME_MSECONDS(10) |
Definition at line 45 of file P_ClusterCacheInternal.h.
Referenced by cache_op_result_ClusterFunction(), CacheContinuation::do_op(), CacheContinuation::do_remote_lookup(), CacheContinuation::handleReplyEvent(), CacheContinuation::localVCsetupEvent(), and CacheContinuation::remoteOpEvent().
| #define CACHE_USE_OPEN_VIO 0 |
Definition at line 37 of file P_ClusterCacheInternal.h.
| #define CFL_ALLOW_MULTIPLE_WRITES (1 << 5) |
Definition at line 355 of file P_ClusterCacheInternal.h.
Referenced by cache_op_ClusterFunction(), and Cluster_write().
| #define CFL_LOPENWRITE_HAVE_OLDINFO (1 << 4) |
Definition at line 354 of file P_ClusterCacheInternal.h.
Referenced by cache_op_ClusterFunction(), and Cluster_write().
| #define CFL_MAX (1 << 15) |
Definition at line 356 of file P_ClusterCacheInternal.h.
| #define CFL_OVERWRITE_ON_WRITE (1 << 1) |
Definition at line 351 of file P_ClusterCacheInternal.h.
Referenced by cache_op_ClusterFunction(), and Cluster_write().
| #define CFL_REMOVE_LINK (1 << 3) |
Definition at line 353 of file P_ClusterCacheInternal.h.
Referenced by cache_op_ClusterFunction(), and Cluster_remove().
| #define CFL_REMOVE_USER_AGENTS (1 << 2) |
Definition at line 352 of file P_ClusterCacheInternal.h.
Referenced by cache_op_ClusterFunction(), and Cluster_remove().
| #define DO_REPLICATION 0 |
Definition at line 38 of file P_ClusterCacheInternal.h.
| #define FOLDHASH | ( | _ip, | ||
| _seq | ||||
| ) | (_seq % REMOTE_CONNECT_HASH) |
Definition at line 51 of file P_ClusterCacheInternal.h.
Referenced by cache_op_result_ClusterFunction(), CacheContinuation::do_op(), CacheContinuation::do_remote_lookup(), find_cache_continuation(), CacheContinuation::handleReplyEvent(), CacheContinuation::localVCsetupEvent(), CacheContinuation::remoteOpEvent(), and CacheContinuation::remove_and_delete().
| #define META_DATA_FAST_ALLOC_LIMIT 1 |
Definition at line 43 of file P_ClusterCacheInternal.h.
| #define PROBE_LOCAL_CACHE_FIRST DO_REPLICATION |
Definition at line 81 of file P_ClusterCacheInternal.h.
Referenced by CacheContinuation::remoteOpEvent().
| #define PROBE_LOCAL_CACHE_LAST false |
Definition at line 82 of file P_ClusterCacheInternal.h.
Referenced by CacheContinuation::remoteOpEvent().
| #define REMOTE_CONNECT_HASH (16 * 1024) |
Definition at line 46 of file P_ClusterCacheInternal.h.
| #define TEST | ( | _x | ) |
Definition at line 59 of file P_ClusterCacheInternal.h.
| #define TIMEOUT_TEST | ( | _x | ) |
Definition at line 68 of file P_ClusterCacheInternal.h.
| #define TTEST | ( | _x | ) |
Definition at line 65 of file P_ClusterCacheInternal.h.
Typedef Documentation
| typedef int(CacheContinuation::* CacheContHandler)(int, void *) |
Definition at line 89 of file P_ClusterCacheInternal.h.
Function Documentation
| static int event_is_failure | ( | int | event | ) | [inline, static] |
Definition at line 812 of file P_ClusterCacheInternal.h.
References CACHE_EVENT_DEREF_FAILED, CACHE_EVENT_LINK_FAILED, CACHE_EVENT_LOOKUP_FAILED, CACHE_EVENT_OPEN_READ_FAILED, CACHE_EVENT_OPEN_WRITE_FAILED, CACHE_EVENT_REMOVE_FAILED, and CACHE_EVENT_UPDATE_FAILED.
| static bool event_is_lookup | ( | int | event | ) | [inline, static] |
Definition at line 689 of file P_ClusterCacheInternal.h.
References CACHE_EVENT_LOOKUP, and CACHE_EVENT_LOOKUP_FAILED.
| static bool event_is_open | ( | int | event | ) | [inline, static] |
Definition at line 701 of file P_ClusterCacheInternal.h.
References CACHE_EVENT_OPEN_READ, and CACHE_EVENT_OPEN_WRITE.
Referenced by cache_op_result_ClusterFunction(), CacheContinuation::remoteOpEvent(), and CacheContinuation::replyOpEvent().
| static int event_reply_may_have_moi | ( | int | event | ) | [inline, static] |
Definition at line 794 of file P_ClusterCacheInternal.h.
References CACHE_EVENT_DEREF_FAILED, CACHE_EVENT_LINK, CACHE_EVENT_LINK_FAILED, CACHE_EVENT_OPEN_READ, CACHE_EVENT_OPEN_READ_FAILED, CACHE_EVENT_OPEN_WRITE_FAILED, CACHE_EVENT_REMOVE_FAILED, and CACHE_EVENT_UPDATE_FAILED.
Referenced by cache_op_result_ClusterFunction().
| int maxval | ( | int | a, | |
| int | b | |||
| ) | [inline] |
Definition at line 637 of file P_ClusterCacheInternal.h.
| static int op_failure | ( | int | opcode | ) | [inline, static] |
Definition at line 741 of file P_ClusterCacheInternal.h.
References CACHE_DEREF, CACHE_LINK, CACHE_OPEN_READ, CACHE_OPEN_READ_BUFFER, CACHE_OPEN_READ_BUFFER_LONG, CACHE_OPEN_READ_LONG, CACHE_OPEN_WRITE, CACHE_OPEN_WRITE_BUFFER, CACHE_OPEN_WRITE_BUFFER_LONG, CACHE_OPEN_WRITE_LONG, CACHE_REMOVE, and CACHE_UPDATE.
Referenced by CacheContinuation::do_op().
| static bool op_is_read | ( | int | opcode | ) | [inline, static] |
Definition at line 713 of file P_ClusterCacheInternal.h.
References CACHE_OPEN_READ, CACHE_OPEN_READ_BUFFER, CACHE_OPEN_READ_BUFFER_LONG, and CACHE_OPEN_READ_LONG.
Referenced by CacheContinuation::localVCsetupEvent(), CacheContinuation::replyOpEvent(), and CacheContinuation::setup_local_vc().
| static bool op_is_shortform | ( | int | opcode | ) | [inline, static] |
Definition at line 727 of file P_ClusterCacheInternal.h.
References CACHE_OPEN_READ, CACHE_OPEN_READ_BUFFER, CACHE_OPEN_WRITE, and CACHE_OPEN_WRITE_BUFFER.
Referenced by CacheContinuation::localVCsetupEvent(), and CacheContinuation::setup_local_vc().
| static int op_needs_marshalled_coi | ( | int | opcode | ) | [inline, static] |
Definition at line 769 of file P_ClusterCacheInternal.h.
References CACHE_DEREF, CACHE_LINK, CACHE_OPEN_READ, CACHE_OPEN_READ_BUFFER, CACHE_OPEN_READ_BUFFER_LONG, CACHE_OPEN_READ_LONG, CACHE_OPEN_WRITE, CACHE_OPEN_WRITE_BUFFER, CACHE_OPEN_WRITE_BUFFER_LONG, CACHE_OPEN_WRITE_LONG, CACHE_REMOVE, and CACHE_UPDATE.
Referenced by CacheContinuation::do_op(), and CacheContinuation::localVCsetupEvent().
| int op_to_sizeof_fixedlen_msg | ( | int | op | ) | [inline] |
Definition at line 643 of file P_ClusterCacheInternal.h.
References CACHE_DEREF, CACHE_LINK, CACHE_LOOKUP_OP, CACHE_OPEN_READ, CACHE_OPEN_READ_BUFFER, CACHE_OPEN_READ_BUFFER_LONG, CACHE_OPEN_READ_LONG, CACHE_OPEN_WRITE, CACHE_OPEN_WRITE_BUFFER, CACHE_OPEN_WRITE_BUFFER_LONG, CACHE_OPEN_WRITE_LONG, CACHE_REMOVE, CACHE_UPDATE, ink_release_assert, CacheOpMsg_short_2::sizeof_fixedlen_msg(), CacheOpMsg_long::sizeof_fixedlen_msg(), CacheOpMsg_short::sizeof_fixedlen_msg(), and CacheLookupMsg::sizeof_fixedlen_msg().
Referenced by cache_lookup_ClusterFunction(), cache_op_ClusterFunction(), Cluster_deref(), Cluster_link(), Cluster_read(), Cluster_remove(), Cluster_write(), CacheContinuation::do_op(), and CacheContinuation::do_remote_lookup().
Variable Documentation
Definition at line 54 of file ClusterCache.cc.
Referenced by CacheContinuation::do_remote_lookup().
| int ET_CLUSTER |
Definition at line 40 of file ClusterProcessor.cc.
Referenced by ClusterAccept::ClusterAcceptEvent(), ClusterAccept::ClusterAcceptMachine(), ClusterProcessor::connect(), ClusterHandler::connectClusterEvent(), ClusterState::IOComplete(), CacheContinuation::is_ClusterThread(), ClusterHandler::protoZombieEvent(), ClusterProcessor::start(), ClusterHandler::startClusterEvent(), TSContSchedule(), and ClusterHandler::zombify().
