ClusterRPC.cc File Reference

A brief file description. More...

#include "P_Cluster.h"

Include dependency graph for ClusterRPC.cc:

Go to the source code of this file.

Functions
void	ping_ClusterFunction (ClusterHandler *ch, void *data, int len)
void	ping_reply_ClusterFunction (ClusterHandler *ch, void *data, int len)
void	machine_list_ClusterFunction (ClusterHandler *from, void *data, int len)
void	close_channel_ClusterFunction (ClusterHandler *ch, void *data, int len)
void	test_ClusterFunction (ClusterHandler *ch, void *data, int len)
CacheVC *	ChannelToCacheWriteVC (ClusterHandler *ch, int channel, uint32_t channel_seqno, ClusterVConnection **cluster_vc)
void	set_channel_data_ClusterFunction (ClusterHandler *ch, void *tdata, int tlen)
void	post_setchan_send_ClusterFunction (ClusterHandler *ch, void *data, int)
void	set_channel_pin_ClusterFunction (ClusterHandler *ch, void *data, int)
void	post_setchan_pin_ClusterFunction (ClusterHandler *ch, void *data, int)
void	set_channel_priority_ClusterFunction (ClusterHandler *ch, void *data, int)
void	post_setchan_priority_ClusterFunction (ClusterHandler *ch, void *data, int)

---

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 ClusterRPC.cc.

---

Function Documentation

CacheVC* ChannelToCacheWriteVC	(	ClusterHandler *	ch,
		int	channel,
		uint32_t	channel_seqno,
		ClusterVConnection **	cluster_vc
	)

Definition at line 134 of file ClusterRPC.cc.

References VIO::_cont, ClusterHandler::channels, CLUSTER_INCREMENT_DYN_STAT, CLUSTER_SETDATA_NO_CACHEVC_STAT, cluster_setdata_no_CLUSTERVC_STAT, CLUSTER_SETDATA_NO_TUNNEL_STAT, Thread::mutex, VIO::op, VIO::READ, ClusterVConnectionBase::read, ClusterVCToken::sequence_number, this_ethread(), ClusterVConnection::token, VALID_CHANNEL, VIO::vc_server, ClusterVConnState::vio, and OneWayTunnel::vioTarget.

Referenced by set_channel_data_ClusterFunction(), set_channel_pin_ClusterFunction(), and set_channel_priority_ClusterFunction().

void close_channel_ClusterFunction	(	ClusterHandler *	ch,
		void *	data,
		int	len
	)

Definition at line 96 of file ClusterRPC.cc.

References CloseMessage::channel, ClusterHandler::channels, close_channel_ClusterFunction, ClusterMessageHeader::GetMsgVersion(), ink_assert, ink_release_assert, CloseMessage::lerrno, ClusterMessageHeader::NeedByteSwap(), ClusterVConnection::remote_closed, ClusterVConnection::remote_lerrno, CloseMessage::sequence_number, ClusterVCToken::sequence_number, CloseMessage::status, CloseMessage::SwapBytes(), ClusterVConnection::token, ClusterVConnection::type, VALID_CHANNEL, and ClusterHandler::vcs_push().

void machine_list_ClusterFunction	(	ClusterHandler *	from,
		void *	data,
		int	len
	)

Definition at line 56 of file ClusterRPC.cc.

References clusterProcessor, ClusterProcessor::connect(), Cluster::current_configuration(), ClusterMessageHeader::GetMsgVersion(), ink_assert, ink_release_assert, MachineListMessage::ip, ClusterMachine::ip, machine_list_ClusterFunction, ClusterConfiguration::machines, MachineListMessage::n_ip, ClusterConfiguration::n_machines, ClusterMessageHeader::NeedByteSwap(), ClusterMachine::num_connections, MachineListMessage::sizeof_fixedlen_msg(), MachineListMessage::SwapBytes(), this_cluster(), and this_cluster_machine().

void ping_ClusterFunction	(	ClusterHandler *	ch,
		void *	data,
		int	len
	)

Definition at line 37 of file ClusterRPC.cc.

References clusterProcessor, ClusterProcessor::invoke_remote(), ping_ClusterFunction, and PING_REPLY_CLUSTER_FUNCTION.

void ping_reply_ClusterFunction	(	ClusterHandler *	ch,
		void *	data,
		int	len
	)

Definition at line 46 of file ClusterRPC.cc.

References PingMessage::data, PingMessage::fn, ping_reply_ClusterFunction, and PingMessage::sizeof_fixedlen_msg().

void post_setchan_pin_ClusterFunction	(	ClusterHandler *	ch,
		void *	data,
		int
	)

Definition at line 294 of file ClusterRPC.cc.

References SetChanPinMessage::channel, ClusterHandler::channels, CLUSTER_INCREMENT_DYN_STAT, cluster_setdata_no_CLUSTER_STAT, cluster_setdata_no_CLUSTERVC_STAT, Thread::mutex, ClusterVConnection::n_set_data_msgs, post_setchan_pin_ClusterFunction, this_ethread(), and VALID_CHANNEL.

void post_setchan_priority_ClusterFunction	(	ClusterHandler *	ch,
		void *	data,
		int
	)

Definition at line 353 of file ClusterRPC.cc.

References SetChanPriorityMessage::channel, ClusterHandler::channels, CLUSTER_INCREMENT_DYN_STAT, cluster_setdata_no_CLUSTER_STAT, cluster_setdata_no_CLUSTERVC_STAT, Thread::mutex, ClusterVConnection::n_set_data_msgs, post_setchan_priority_ClusterFunction, this_ethread(), and VALID_CHANNEL.

void post_setchan_send_ClusterFunction	(	ClusterHandler *	ch,
		void *	data,
		int
	)

Definition at line 234 of file ClusterRPC.cc.

References SetChanDataMessage::channel, ClusterHandler::channels, CLUSTER_INCREMENT_DYN_STAT, cluster_setdata_no_CLUSTER_STAT, cluster_setdata_no_CLUSTERVC_STAT, Thread::mutex, ClusterVConnection::n_set_data_msgs, post_setchan_send_ClusterFunction, this_ethread(), and VALID_CHANNEL.

void set_channel_data_ClusterFunction	(	ClusterHandler *	ch,
		void *	tdata,
		int	tlen
	)

Definition at line 164 of file ClusterRPC.cc.

References IncomingControl::alloc(), IncomingControl::alloc_data(), CACHE_DATA_HTTP_INFO, SetChanDataMessage::channel, ChannelToCacheWriteVC(), CLUSTER_INCREMENT_DYN_STAT, cluster_setdata_no_CLUSTER_STAT, SetChanDataMessage::data, ClusterControl::data, SetChanDataMessage::data_type, IncomingControl::freeall(), ClusterControl::get_block(), ClusterMessageHeader::GetMsgVersion(), ink_assert, ink_release_assert, ClusterControl::len, memcpy, Thread::mutex, ClusterVConnection::n_recv_set_data_msgs, ClusterMessageHeader::NeedByteSwap(), SetChanDataMessage::sequence_number, set_channel_data_ClusterFunction, SetChanDataMessage::sizeof_fixedlen_msg(), SetChanDataMessage::SwapBytes(), this_ethread(), and HTTPInfo::unmarshal().

void set_channel_pin_ClusterFunction	(	ClusterHandler *	ch,
		void *	data,
		int
	)

Definition at line 260 of file ClusterRPC.cc.

References SetChanPinMessage::channel, ChannelToCacheWriteVC(), ClusterMessageHeader::GetMsgVersion(), ink_release_assert, ClusterVConnection::n_recv_set_data_msgs, ClusterMessageHeader::NeedByteSwap(), SetChanPinMessage::pin_time, SetChanPinMessage::sequence_number, set_channel_pin_ClusterFunction, CacheVC::set_pin_in_cache(), and SetChanPinMessage::SwapBytes().

void set_channel_priority_ClusterFunction	(	ClusterHandler *	ch,
		void *	data,
		int
	)

Definition at line 320 of file ClusterRPC.cc.

References SetChanPriorityMessage::channel, ChannelToCacheWriteVC(), SetChanPriorityMessage::disk_priority, ClusterMessageHeader::GetMsgVersion(), ink_release_assert, ClusterVConnection::n_recv_set_data_msgs, ClusterMessageHeader::NeedByteSwap(), SetChanPriorityMessage::sequence_number, set_channel_priority_ClusterFunction, CacheVC::set_disk_io_priority(), and SetChanPriorityMessage::SwapBytes().

void test_ClusterFunction	(	ClusterHandler *	ch,
		void *	data,
		int	len
	)

Definition at line 124 of file ClusterRPC.cc.

References ptest_ClusterFunction, and test_ClusterFunction.