A brief file description. More...

#include "libts.h"
#include "P_EventSystem.h"
#include "I_RecProcess.h"
#include "P_Net.h"
#include "P_Cache.h"
#include "P_ClusterMachine.h"
#include "P_ClusterCache.h"
#include "P_ClusterCacheInternal.h"
#include "P_ClusterInternal.h"
#include "P_ClusterHandler.h"
#include "P_ClusterInline.h"
#include "P_ClusterLib.h"
#include "P_ClusterLoadMonitor.h"
#include "P_TimeTrace.h"

Include dependency graph for P_Cluster.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Defines
#define	ECLUSTER_NO_VC (CLUSTER_ERRNO+0)
#define	ECLUSTER_NO_MACHINE (CLUSTER_ERRNO+1)
#define	ECLUSTER_OP_TIMEOUT (CLUSTER_ERRNO+2)
#define	ECLUSTER_ORB_DATA_READ (CLUSTER_ERRNO+3)
#define	ECLUSTER_ORB_EIO (CLUSTER_ERRNO+4)
#define	ECLUSTER_CHANNEL_INUSE (CLUSTER_ERRNO+5)
#define	ECLUSTER_NOMORE_CHANNELS (CLUSTER_ERRNO+6)
#define	CLUSTER_INCREMENT_DYN_STAT(x) RecIncrRawStat(cluster_rsb, mutex->thread_holding, (int) x, 1);
#define	CLUSTER_DECREMENT_DYN_STAT(x) RecIncrRawStat(cluster_rsb, mutex->thread_holding, (int) x, -1);
#define	CLUSTER_SUM_DYN_STAT(x, y) RecIncrRawStat(cluster_rsb, mutex->thread_holding, (int) x, y);
#define	CLUSTER_SUM_GLOBAL_DYN_STAT(x, y) RecIncrGlobalRawStatSum(cluster_rsb,x,y)
#define	CLUSTER_CLEAR_DYN_STAT(x)
Enumerations
enum	{ CLUSTER_CONNECTIONS_OPEN_STAT, CLUSTER_CONNECTIONS_OPENNED_STAT, CLUSTER_CON_TOTAL_TIME_STAT, CLUSTER_CTRL_MSGS_SENT_STAT, CLUSTER_SLOW_CTRL_MSGS_SENT_STAT, CLUSTER_CTRL_MSGS_RECVD_STAT, CLUSTER_SLOW_CTRL_MSGS_RECVD_STAT, CLUSTER_CTRL_MSGS_SEND_TIME_STAT, CLUSTER_CTRL_MSGS_RECV_TIME_STAT, CLUSTER_READ_BYTES_STAT, CLUSTER_WRITE_BYTES_STAT, CLUSTER_OP_DELAYED_FOR_LOCK_STAT, CLUSTER_CONNECTIONS_READ_LOCKED_STAT, CLUSTER_CONNECTIONS_WRITE_LOCKED_STAT, CLUSTER_CONNECTIONS_BUMPED_STAT, CLUSTER_NODES_STAT, CLUSTER_NET_BACKUP_STAT, CLUSTER_MACHINES_ALLOCATED_STAT, CLUSTER_MACHINES_FREED_STAT, CLUSTER_CONFIGURATION_CHANGES_STAT, CLUSTER_DELAYED_READS_STAT, CLUSTER_BYTE_BANK_USED_STAT, CLUSTER_ALLOC_DATA_NEWS_STAT, CLUSTER_WRITE_BB_MALLOCS_STAT, CLUSTER_PARTIAL_READS_STAT, CLUSTER_PARTIAL_WRITES_STAT, CLUSTER_CACHE_OUTSTANDING_STAT, CLUSTER_REMOTE_OP_TIMEOUTS_STAT, CLUSTER_REMOTE_OP_REPLY_TIMEOUTS_STAT, CLUSTER_CHAN_INUSE_STAT, CLUSTER_OPEN_DELAYS_STAT, CLUSTER_OPEN_DELAY_TIME_STAT, CLUSTER_CACHE_CALLBACKS_STAT, CLUSTER_CACHE_CALLBACK_TIME_STAT, CLUSTER_THREAD_STEAL_EXPIRES_STAT, CLUSTER_RDMSG_ASSEMBLE_TIME_STAT, CLUSTER_PING_TIME_STAT, cluster_setdata_no_CLUSTERVC_STAT, CLUSTER_SETDATA_NO_TUNNEL_STAT, CLUSTER_SETDATA_NO_CACHEVC_STAT, cluster_setdata_no_CLUSTER_STAT, CLUSTER_VC_WRITE_STALL_STAT, CLUSTER_NO_REMOTE_SPACE_STAT, CLUSTER_LEVEL1_BANK_STAT, CLUSTER_MULTILEVEL_BANK_STAT, CLUSTER_VC_CACHE_INSERT_LOCK_MISSES_STAT, CLUSTER_VC_CACHE_INSERTS_STAT, CLUSTER_VC_CACHE_LOOKUP_LOCK_MISSES_STAT, CLUSTER_VC_CACHE_LOOKUP_HITS_STAT, CLUSTER_VC_CACHE_LOOKUP_MISSES_STAT, CLUSTER_VC_CACHE_SCANS_STAT, CLUSTER_VC_CACHE_SCAN_LOCK_MISSES_STAT, CLUSTER_VC_CACHE_PURGES_STAT, CLUSTER_WRITE_LOCK_MISSES_STAT, CLUSTER_CACHE_RMT_CALLBACK_TIME_STAT, CLUSTER_CACHE_LKRMT_CALLBACK_TIME_STAT, CLUSTER_LOCAL_CONNECTION_TIME_STAT, CLUSTER_REMOTE_CONNECTION_TIME_STAT, CLUSTER_SETDATA_NO_CLUSTERVC_STAT, CLUSTER_SETDATA_NO_CLUSTER_STAT, CLUSTER_VC_READ_LIST_LEN_STAT, CLUSTER_VC_WRITE_LIST_LEN_STAT, cluster_stat_count }
Functions
int	init_clusterprocessor (void)
Variables
RecRawStatBlock *	cluster_rsb

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_Cluster.h.

Define Documentation

#define CLUSTER_CLEAR_DYN_STAT ( x )

Value:

do { \
        RecSetRawStatSum(cluster_rsb, x, 0); \
        RecSetRawStatCount(cluster_rsb, x, 0); \
} while (0);

Definition at line 135 of file P_Cluster.h.

Referenced by ClusterProcessor::init().

#define CLUSTER_DECREMENT_DYN_STAT ( x ) RecIncrRawStat(cluster_rsb, mutex->thread_holding, (int) x, -1);

Definition at line 129 of file P_Cluster.h.

Referenced by ClusterHandler::close_ClusterVConnection(), ClusterHandler::machine_down(), CacheContinuation::replyLookupEvent(), and CacheContinuation::replyOpEvent().

#define CLUSTER_INCREMENT_DYN_STAT ( x ) RecIncrRawStat(cluster_rsb, mutex->thread_holding, (int) x, 1);

Definition at line 127 of file P_Cluster.h.

Referenced by ClusterHandler::add_to_byte_bank(), ClusterHandler::build_initial_vector(), ClusterHandler::build_write_descriptors(), cache_lookup_ClusterFunction(), cache_op_ClusterFunction(), cache_op_result_ClusterFunction(), ChannelToCacheWriteVC(), ClusterMachine::ClusterMachine(), configuration_add_machine(), configuration_remove_machine(), ClusterProcessor::connect_local(), ClusterVConnectionCacheEvent::eventHandler(), free_ClusterMachine(), CacheContinuation::handleReplyEvent(), ClusterVConnectionCache::insert(), ClusterProcessor::internal_invoke_remote(), CacheContinuation::localVCsetupEvent(), ClusterVConnectionCache::lookup(), ClusterHandler::mainClusterEvent(), ClusterProcessor::open_local(), post_setchan_pin_ClusterFunction(), post_setchan_priority_ClusterFunction(), post_setchan_send_ClusterFunction(), ClusterHandler::process_read(), ClusterHandler::process_write(), ClusterControl::real_alloc_data(), CacheContinuation::remoteOpEvent(), set_channel_data_ClusterFunction(), ClusterHandler::startClusterEvent(), ClusterHandler::valid_for_data_write(), and ClusterHandler::valid_for_freespace_write().

#define CLUSTER_SUM_DYN_STAT	(	x,
		y
	)		RecIncrRawStat(cluster_rsb, mutex->thread_holding, (int) x, y);

Definition at line 131 of file P_Cluster.h.

Referenced by ClusterHandler::add_small_controlmsg_descriptors(), ClusterHandler::build_freespace_descriptors(), ClusterHandler::build_write_descriptors(), ClusterHandler::close_ClusterVConnection(), CacheContinuation::localVCsetupEvent(), ClusterHandler::process_incoming_callouts(), ClusterHandler::process_read(), ClusterHandler::process_write(), CacheContinuation::remoteOpEvent(), CacheContinuation::replyLookupEvent(), CacheContinuation::replyOpEvent(), and ClusterHandler::update_channels_written().

#define CLUSTER_SUM_GLOBAL_DYN_STAT	(	x,
		y
	)		RecIncrGlobalRawStatSum(cluster_rsb,x,y)

Definition at line 133 of file P_Cluster.h.

Referenced by ClusterProcessor::init().

#define ECLUSTER_CHANNEL_INUSE (CLUSTER_ERRNO+5)

Definition at line 55 of file P_Cluster.h.

Referenced by cache_op_ClusterFunction().

#define ECLUSTER_NO_MACHINE (CLUSTER_ERRNO+1)

Definition at line 51 of file P_Cluster.h.

Referenced by ClusterVConnection::start().

#define ECLUSTER_NO_VC (CLUSTER_ERRNO+0)

Definition at line 50 of file P_Cluster.h.

#define ECLUSTER_NOMORE_CHANNELS (CLUSTER_ERRNO+6)

Definition at line 56 of file P_Cluster.h.

Referenced by ClusterVConnection::start().

#define ECLUSTER_OP_TIMEOUT (CLUSTER_ERRNO+2)

Definition at line 52 of file P_Cluster.h.

Referenced by CacheContinuation::remoteOpEvent().

#define ECLUSTER_ORB_DATA_READ (CLUSTER_ERRNO+3)

Definition at line 53 of file P_Cluster.h.

Referenced by CacheContinuation::VCdataRead().

#define ECLUSTER_ORB_EIO (CLUSTER_ERRNO+4)

Definition at line 54 of file P_Cluster.h.

Enumeration Type Documentation

anonymous enum

Enumerator:

CLUSTER_CONNECTIONS_OPEN_STAT
CLUSTER_CONNECTIONS_OPENNED_STAT
CLUSTER_CON_TOTAL_TIME_STAT
CLUSTER_CTRL_MSGS_SENT_STAT
CLUSTER_SLOW_CTRL_MSGS_SENT_STAT
CLUSTER_CTRL_MSGS_RECVD_STAT
CLUSTER_SLOW_CTRL_MSGS_RECVD_STAT
CLUSTER_CTRL_MSGS_SEND_TIME_STAT
CLUSTER_CTRL_MSGS_RECV_TIME_STAT
CLUSTER_READ_BYTES_STAT
CLUSTER_WRITE_BYTES_STAT
CLUSTER_OP_DELAYED_FOR_LOCK_STAT
CLUSTER_CONNECTIONS_READ_LOCKED_STAT
CLUSTER_CONNECTIONS_WRITE_LOCKED_STAT
CLUSTER_CONNECTIONS_BUMPED_STAT
CLUSTER_NODES_STAT
CLUSTER_NET_BACKUP_STAT
CLUSTER_MACHINES_ALLOCATED_STAT
CLUSTER_MACHINES_FREED_STAT
CLUSTER_CONFIGURATION_CHANGES_STAT
CLUSTER_DELAYED_READS_STAT
CLUSTER_BYTE_BANK_USED_STAT
CLUSTER_ALLOC_DATA_NEWS_STAT
CLUSTER_WRITE_BB_MALLOCS_STAT
CLUSTER_PARTIAL_READS_STAT
CLUSTER_PARTIAL_WRITES_STAT
CLUSTER_CACHE_OUTSTANDING_STAT
CLUSTER_REMOTE_OP_TIMEOUTS_STAT
CLUSTER_REMOTE_OP_REPLY_TIMEOUTS_STAT
CLUSTER_CHAN_INUSE_STAT
CLUSTER_OPEN_DELAYS_STAT
CLUSTER_OPEN_DELAY_TIME_STAT
CLUSTER_CACHE_CALLBACKS_STAT
CLUSTER_CACHE_CALLBACK_TIME_STAT
CLUSTER_THREAD_STEAL_EXPIRES_STAT
CLUSTER_RDMSG_ASSEMBLE_TIME_STAT
CLUSTER_PING_TIME_STAT
cluster_setdata_no_CLUSTERVC_STAT
CLUSTER_SETDATA_NO_TUNNEL_STAT
CLUSTER_SETDATA_NO_CACHEVC_STAT
cluster_setdata_no_CLUSTER_STAT
CLUSTER_VC_WRITE_STALL_STAT
CLUSTER_NO_REMOTE_SPACE_STAT
CLUSTER_LEVEL1_BANK_STAT
CLUSTER_MULTILEVEL_BANK_STAT
CLUSTER_VC_CACHE_INSERT_LOCK_MISSES_STAT
CLUSTER_VC_CACHE_INSERTS_STAT
CLUSTER_VC_CACHE_LOOKUP_LOCK_MISSES_STAT
CLUSTER_VC_CACHE_LOOKUP_HITS_STAT
CLUSTER_VC_CACHE_LOOKUP_MISSES_STAT
CLUSTER_VC_CACHE_SCANS_STAT
CLUSTER_VC_CACHE_SCAN_LOCK_MISSES_STAT
CLUSTER_VC_CACHE_PURGES_STAT
CLUSTER_WRITE_LOCK_MISSES_STAT
CLUSTER_CACHE_RMT_CALLBACK_TIME_STAT
CLUSTER_CACHE_LKRMT_CALLBACK_TIME_STAT
CLUSTER_LOCAL_CONNECTION_TIME_STAT
CLUSTER_REMOTE_CONNECTION_TIME_STAT
CLUSTER_SETDATA_NO_CLUSTERVC_STAT
CLUSTER_SETDATA_NO_CLUSTER_STAT
CLUSTER_VC_READ_LIST_LEN_STAT
CLUSTER_VC_WRITE_LIST_LEN_STAT
cluster_stat_count