A brief file description. More...

#include "P_ClusterMachine.h"

Include dependency graph for P_ClusterCache.h:

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

Data Structures
struct	ClusterConfiguration
struct	Cluster
struct	ClusterVCToken
struct	ClusterVConnState
struct	ClusterVConnectionBase
class	ByteBankDescriptor
struct	ClusterVConnection
struct	ClusterRemoteDataHeader
struct	ClusterProcessor
struct	ClusterFunctionDescriptor
struct	ClusterHelloMessage
struct	ClusterMessageHeader
struct	PingMessage
Defines
#define	CLUSTER_MAJOR_VERSION 3
#define	CLUSTER_MINOR_VERSION 2
#define	MIN_CLUSTER_MAJOR_VERSION CLUSTER_MAJOR_VERSION
#define	MIN_CLUSTER_MINOR_VERSION CLUSTER_MINOR_VERSION
#define	DEFAULT_CLUSTER_PORT_NUMBER 0
#define	DEFAULT_NUMBER_OF_CLUSTER_THREADS 1
#define	DEFAULT_CLUSTER_HOST ""
#define	MAX_CLUSTER_SEND_LENGTH INT_MAX
#define	CLUSTER_MAX_MACHINES 256
#define	CLUSTER_HASH_TABLE_SIZE 32707
#define	CLUSTER_CONFIGURATION_TIMEOUT HRTIME_DAY
#define	CLUSTER_CONFIGURATION_ZOMBIE (HRTIME_DAY*2)
#define	CONFIGURATION_HISTORY_PROBE_DEPTH 1
#define	CLUSTER_EVENT_CHANGE (CLUSTER_EVENT_EVENTS_START)
#define	CLUSTER_EVENT_CONFIGURATION (CLUSTER_EVENT_EVENTS_START+1)
#define	CLUSTER_EVENT_OPEN (CLUSTER_EVENT_EVENTS_START+2)
#define	CLUSTER_EVENT_OPEN_EXISTS (CLUSTER_EVENT_EVENTS_START+3)
#define	CLUSTER_EVENT_OPEN_FAILED (CLUSTER_EVENT_EVENTS_START+4)
#define	CLUSTER_EVENT_STEAL_THREAD (CLUSTER_EVENT_EVENTS_START+50)
#define	CLUSTER_IOV_NOT_OPEN -2
#define	CLUSTER_IOV_NONE -1
#define	CLUSTER_OPT_STEAL 0x0001
#define	CLUSTER_OPT_IMMEDIATE 0x0002
#define	CLUSTER_OPT_ALLOW_IMMEDIATE 0x0004
#define	CLUSTER_OPT_DELAY 0x0008
#define	CLUSTER_OPT_CONN_READ 0x0010
#define	CLUSTER_OPT_CONN_WRITE 0x0020
#define	CLUSTER_OPT_DATA_IS_OCONTROL 0x0040
#define	CLUSTER_FUNCTION_MALLOCED -1
#define	CLUSTER_DELAYED_OPEN ((ClusterVConnection*)-1)
#define	CLUSTER_NODE_DOWN ((ClusterVConnection*)-2)
#define	CLUSTER_CMSG_QUEUES 2
#define	CMSG_MAX_PRI 0
#define	CMSG_LOW_PRI (CLUSTER_CMSG_QUEUES-1)
#define	TEST_CLUSTER_FUNCTION 0
#define	PING_CLUSTER_FUNCTION 1
#define	PING_REPLY_CLUSTER_FUNCTION 2
#define	MACHINE_LIST_CLUSTER_FUNCTION 3
#define	CLOSE_CHANNEL_CLUSTER_FUNCTION 4
#define	GET_HOSTINFO_CLUSTER_FUNCTION 5
#define	PUT_HOSTINFO_CLUSTER_FUNCTION 6
#define	CACHE_LOOKUP_CLUSTER_FUNCTION 7
#define	CACHE_OP_MALLOCED_CLUSTER_FUNCTION 8
#define	CACHE_OP_CLUSTER_FUNCTION 9
#define	CACHE_OP_RESULT_CLUSTER_FUNCTION 10
#define	SET_CHANNEL_DATA_CLUSTER_FUNCTION 14
#define	SET_CHANNEL_PIN_CLUSTER_FUNCTION 15
#define	SET_CHANNEL_PRIORITY_CLUSTER_FUNCTION 16
#define	INTERNAL_RESERVED1_CLUSTER_FUNCTION 17
#define	INTERNAL_RESERVED2_CLUSTER_FUNCTION 18
#define	INTERNAL_RESERVED3_CLUSTER_FUNCTION 19
#define	INTERNAL_RESERVED4_CLUSTER_FUNCTION 20
#define	INTERNAL_RESERVED5_CLUSTER_FUNCTION 21
#define	INTERNAL_RESERVED6_CLUSTER_FUNCTION 22
#define	INTERNAL_RESERVED7_CLUSTER_FUNCTION 23
#define	INTERNAL_RESERVED8_CLUSTER_FUNCTION 24
#define	INTERNAL_RESERVED9_CLUSTER_FUNCTION 25
#define	INTERNAL_RESERVED10_CLUSTER_FUNCTION 26
#define	INTERNAL_RESERVED11_CLUSTER_FUNCTION 27
#define	INTERNAL_RESERVED12_CLUSTER_FUNCTION 28
#define	INTERNAL_RESERVED13_CLUSTER_FUNCTION 29
#define	INTERNAL_RESERVED14_CLUSTER_FUNCTION 30
#define	INTERNAL_RESERVED15_CLUSTER_FUNCTION 31
#define	INTERNAL_RESERVED16_CLUSTER_FUNCTION 32
#define	INTERNAL_RESERVED17_CLUSTER_FUNCTION 33
#define	INTERNAL_RESERVED18_CLUSTER_FUNCTION 34
#define	INTERNAL_RESERVED19_CLUSTER_FUNCTION 35
#define	INTERNAL_RESERVED20_CLUSTER_FUNCTION 36
#define	INTERNAL_RESERVED21_CLUSTER_FUNCTION 37
#define	INTERNAL_RESERVED22_CLUSTER_FUNCTION 38
#define	INTERNAL_RESERVED23_CLUSTER_FUNCTION 39
#define	INTERNAL_RESERVED24_CLUSTER_FUNCTION 40
#define	INTERNAL_RESERVED25_CLUSTER_FUNCTION 41
#define	INTERNAL_RESERVED26_CLUSTER_FUNCTION 42
#define	INTERNAL_RESERVED27_CLUSTER_FUNCTION 43
#define	INTERNAL_RESERVED28_CLUSTER_FUNCTION 44
#define	INTERNAL_RESERVED29_CLUSTER_FUNCTION 45
#define	INTERNAL_RESERVED30_CLUSTER_FUNCTION 46
#define	INTERNAL_RESERVED31_CLUSTER_FUNCTION 47
#define	INTERNAL_RESERVED32_CLUSTER_FUNCTION 48
#define	INTERNAL_RESERVED33_CLUSTER_FUNCTION 49
#define	INTERNAL_RESERVED34_CLUSTER_FUNCTION 50
#define	API_F01_CLUSTER_FUNCTION 51
#define	API_F02_CLUSTER_FUNCTION 52
#define	API_F03_CLUSTER_FUNCTION 53
#define	API_F04_CLUSTER_FUNCTION 54
#define	API_F05_CLUSTER_FUNCTION 55
#define	API_F06_CLUSTER_FUNCTION 56
#define	API_F07_CLUSTER_FUNCTION 57
#define	API_F08_CLUSTER_FUNCTION 58
#define	API_F09_CLUSTER_FUNCTION 59
#define	API_F10_CLUSTER_FUNCTION 60
#define	API_F11_CLUSTER_FUNCTION 61
#define	API_F12_CLUSTER_FUNCTION 62
#define	API_F13_CLUSTER_FUNCTION 63
#define	API_F14_CLUSTER_FUNCTION 64
#define	API_F15_CLUSTER_FUNCTION 65
#define	API_F16_CLUSTER_FUNCTION 66
#define	API_F17_CLUSTER_FUNCTION 67
#define	API_F18_CLUSTER_FUNCTION 68
#define	API_F19_CLUSTER_FUNCTION 69
#define	API_F20_CLUSTER_FUNCTION 70
#define	API_F21_CLUSTER_FUNCTION 71
#define	API_F22_CLUSTER_FUNCTION 72
#define	API_F23_CLUSTER_FUNCTION 73
#define	API_F24_CLUSTER_FUNCTION 74
#define	API_F25_CLUSTER_FUNCTION 75
#define	API_F26_CLUSTER_FUNCTION 76
#define	API_F27_CLUSTER_FUNCTION 77
#define	API_F28_CLUSTER_FUNCTION 78
#define	API_F29_CLUSTER_FUNCTION 79
#define	API_F30_CLUSTER_FUNCTION 80
#define	API_STARECT_CLUSTER_FUNCTION API_F01_CLUSTER_FUNCTION
#define	API_END_CLUSTER_FUNCTION API_F30_CLUSTER_FUNCTION
#define	UNDEFINED_CLUSTER_FUNCTION 0xFDEFFDEF
Typedefs
typedef void	ClusterFunction (ClusterHandler ch, void data, int len)
typedef ClusterFunction *	ClusterFunctionPtr
typedef void(*	PingReturnFunction )(ClusterHandler , void data, int len)
Enumerations
enum	TypeVConnection { VC_NULL, VC_CLUSTER, VC_CLUSTER_READ, VC_CLUSTER_WRITE, VC_CLUSTER_CLOSED }
Functions
void	ats_swap16 (uint16_t *d)
uint16_t	ats_swap16 (uint16_t d)
void	ats_swap32 (uint32_t *d)
uint32_t	ats_swap32 (uint32_t d)
void	ats_swap64 (uint64_t *d)
uint64_t	ats_swap64 (uint64_t d)
bool	machine_in_vector (ClusterMachine m, ClusterMachine *mm, int len)
inkcoreapi ClusterMachine *	cluster_machine_at_depth (unsigned int hash, int probe_depth=NULL, ClusterMachine *past_probes=NULL)
Cluster *	this_cluster ()
void	initialize_thread_for_cluster (EThread *thread)
int	ClusterFuncToQpri (int cluster_func)
void	cluster_ping (ClusterHandler ch, PingReturnFunction fn, void data, int len)
ClusterConfiguration *	configuration_add_machine (ClusterConfiguration c, ClusterMachine m)
ClusterConfiguration *	configuration_remove_machine (ClusterConfiguration c, ClusterMachine m)
void	build_cluster_hash_table (ClusterConfiguration *)
void	ClusterVC_enqueue_read (Queue< ClusterVConnectionBase, ClusterVConnectionBase::Link_read_link > &q, ClusterVConnectionBase *vc)
void	ClusterVC_enqueue_write (Queue< ClusterVConnectionBase, ClusterVConnectionBase::Link_write_link > &q, ClusterVConnectionBase *vc)
void	ClusterVC_remove_read (ClusterVConnectionBase *vc)
void	ClusterVC_remove_write (ClusterVConnectionBase *vc)
Variables
inkcoreapi ClusterProcessor	clusterProcessor
ClusterFunction *	ptest_ClusterFunction
ClusterFunction	test_ClusterFunction
ClusterFunction	ping_ClusterFunction
ClusterFunction	ping_reply_ClusterFunction
ClusterFunction	machine_list_ClusterFunction
ClusterFunction	close_channel_ClusterFunction
ClusterFunction	get_hostinfo_ClusterFunction
ClusterFunction	put_hostinfo_ClusterFunction
ClusterFunction	cache_lookup_ClusterFunction
ClusterFunction	cache_op_ClusterFunction
ClusterFunction	cache_op_malloc_ClusterFunction
ClusterFunction	cache_op_result_ClusterFunction
ClusterFunction	set_channel_data_ClusterFunction
ClusterFunction	post_setchan_send_ClusterFunction
ClusterFunction	set_channel_pin_ClusterFunction
ClusterFunction	post_setchan_pin_ClusterFunction
ClusterFunction	set_channel_priority_ClusterFunction
ClusterFunction	post_setchan_priority_ClusterFunction
ClusterFunction	default_api_ClusterFunction
ClusterFunctionDescriptor	clusterFunction []
unsigned	SIZE_clusterFunction
char	channel_dummy_output [DEFAULT_MAX_BUFFER_SIZE]
bool	machineClusterHash
bool	boundClusterHash
bool	randClusterHash

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

Define Documentation

#define API_END_CLUSTER_FUNCTION API_F30_CLUSTER_FUNCTION

Definition at line 985 of file P_ClusterCache.h.

Referenced by default_api_ClusterFunction(), TSAddClusterRPCFunction(), and TSDeleteClusterRPCFunction().

#define API_F01_CLUSTER_FUNCTION 51

Definition at line 948 of file P_ClusterCache.h.

#define API_F02_CLUSTER_FUNCTION 52

Definition at line 949 of file P_ClusterCache.h.

#define API_F03_CLUSTER_FUNCTION 53

Definition at line 950 of file P_ClusterCache.h.

#define API_F04_CLUSTER_FUNCTION 54

Definition at line 951 of file P_ClusterCache.h.

#define API_F05_CLUSTER_FUNCTION 55

Definition at line 952 of file P_ClusterCache.h.

#define API_F06_CLUSTER_FUNCTION 56

Definition at line 953 of file P_ClusterCache.h.

#define API_F07_CLUSTER_FUNCTION 57

Definition at line 954 of file P_ClusterCache.h.

#define API_F08_CLUSTER_FUNCTION 58

Definition at line 955 of file P_ClusterCache.h.

#define API_F09_CLUSTER_FUNCTION 59

Definition at line 956 of file P_ClusterCache.h.

#define API_F10_CLUSTER_FUNCTION 60

Definition at line 957 of file P_ClusterCache.h.

#define API_F11_CLUSTER_FUNCTION 61

Definition at line 962 of file P_ClusterCache.h.

#define API_F12_CLUSTER_FUNCTION 62

Definition at line 963 of file P_ClusterCache.h.

#define API_F13_CLUSTER_FUNCTION 63

Definition at line 964 of file P_ClusterCache.h.

#define API_F14_CLUSTER_FUNCTION 64

Definition at line 965 of file P_ClusterCache.h.

#define API_F15_CLUSTER_FUNCTION 65

Definition at line 966 of file P_ClusterCache.h.

#define API_F16_CLUSTER_FUNCTION 66

Definition at line 967 of file P_ClusterCache.h.

#define API_F17_CLUSTER_FUNCTION 67

Definition at line 968 of file P_ClusterCache.h.

#define API_F18_CLUSTER_FUNCTION 68

Definition at line 969 of file P_ClusterCache.h.

#define API_F19_CLUSTER_FUNCTION 69

Definition at line 970 of file P_ClusterCache.h.

#define API_F20_CLUSTER_FUNCTION 70

Definition at line 971 of file P_ClusterCache.h.

#define API_F21_CLUSTER_FUNCTION 71

Definition at line 973 of file P_ClusterCache.h.

#define API_F22_CLUSTER_FUNCTION 72

Definition at line 974 of file P_ClusterCache.h.

#define API_F23_CLUSTER_FUNCTION 73

Definition at line 975 of file P_ClusterCache.h.

#define API_F24_CLUSTER_FUNCTION 74

Definition at line 976 of file P_ClusterCache.h.

#define API_F25_CLUSTER_FUNCTION 75

Definition at line 977 of file P_ClusterCache.h.

#define API_F26_CLUSTER_FUNCTION 76

Definition at line 978 of file P_ClusterCache.h.

#define API_F27_CLUSTER_FUNCTION 77

Definition at line 979 of file P_ClusterCache.h.

#define API_F28_CLUSTER_FUNCTION 78

Definition at line 980 of file P_ClusterCache.h.

#define API_F29_CLUSTER_FUNCTION 79

Definition at line 981 of file P_ClusterCache.h.

#define API_F30_CLUSTER_FUNCTION 80

Definition at line 982 of file P_ClusterCache.h.

#define API_STARECT_CLUSTER_FUNCTION API_F01_CLUSTER_FUNCTION

Definition at line 984 of file P_ClusterCache.h.

Referenced by default_api_ClusterFunction(), TSAddClusterRPCFunction(), and TSDeleteClusterRPCFunction().

#define CACHE_LOOKUP_CLUSTER_FUNCTION 7

Definition at line 891 of file P_ClusterCache.h.

Referenced by CacheContinuation::do_remote_lookup().

#define CACHE_OP_CLUSTER_FUNCTION 9

Definition at line 893 of file P_ClusterCache.h.

Referenced by CacheContinuation::do_op(), and CacheContinuation::localVCsetupEvent().

#define CACHE_OP_MALLOCED_CLUSTER_FUNCTION 8

Definition at line 892 of file P_ClusterCache.h.

Referenced by CacheContinuation::do_op(), and CacheContinuation::localVCsetupEvent().

#define CACHE_OP_RESULT_CLUSTER_FUNCTION 10

Definition at line 894 of file P_ClusterCache.h.

Referenced by CacheContinuation::replyLookupEvent(), and CacheContinuation::replyOpEvent().

#define CLOSE_CHANNEL_CLUSTER_FUNCTION 4

Definition at line 888 of file P_ClusterCache.h.

Referenced by ClusterHandler::close_ClusterVConnection().

#define CLUSTER_CMSG_QUEUES 2

Definition at line 763 of file P_ClusterCache.h.

Referenced by ClusterHandler::build_controlmsg_descriptors().

#define CLUSTER_CONFIGURATION_TIMEOUT HRTIME_DAY

Definition at line 84 of file P_ClusterCache.h.

Referenced by cluster_machine_at_depth(), and free_configuration().

#define CLUSTER_CONFIGURATION_ZOMBIE (HRTIME_DAY*2)

Definition at line 86 of file P_ClusterCache.h.

Referenced by ConfigurationContinuation::zombieEvent().

#define CLUSTER_DELAYED_OPEN ((ClusterVConnection*)-1)

Definition at line 671 of file P_ClusterCache.h.

Referenced by cache_op_ClusterFunction(), CacheContinuation::lookupOpenWriteVC(), and CacheContinuation::setup_local_vc().

#define CLUSTER_EVENT_CHANGE (CLUSTER_EVENT_EVENTS_START)

Definition at line 97 of file P_ClusterCache.h.

Referenced by event_int_to_string().

#define CLUSTER_EVENT_CONFIGURATION (CLUSTER_EVENT_EVENTS_START+1)

Definition at line 98 of file P_ClusterCache.h.

Referenced by event_int_to_string().

#define CLUSTER_EVENT_OPEN (CLUSTER_EVENT_EVENTS_START+2)

Definition at line 99 of file P_ClusterCache.h.

Referenced by TestProxy::clusterOpenEvent(), event_int_to_string(), CacheContinuation::localVCsetupEvent(), CacheContinuation::lookupOpenWriteVC(), and ClusterVConnection::start().

#define CLUSTER_EVENT_OPEN_EXISTS (CLUSTER_EVENT_EVENTS_START+3)

Definition at line 100 of file P_ClusterCache.h.

Referenced by CacheContinuation::localVCsetupEvent(), and CacheContinuation::lookupOpenWriteVC().

#define CLUSTER_EVENT_OPEN_FAILED (CLUSTER_EVENT_EVENTS_START+4)

Definition at line 101 of file P_ClusterCache.h.

Referenced by TestProxy::clusterOpenEvent(), ClusterHandler::do_open_local_requests(), event_int_to_string(), CacheContinuation::lookupOpenWriteVC(), and ClusterVConnection::start().

#define CLUSTER_EVENT_STEAL_THREAD (CLUSTER_EVENT_EVENTS_START+50)

Definition at line 104 of file P_ClusterCache.h.

Referenced by event_int_to_string(), and ClusterHandler::steal_thread().

#define CLUSTER_FUNCTION_MALLOCED -1

Definition at line 619 of file P_ClusterCache.h.

Referenced by ClusterProcessor::invoke_remote_malloced().

#define CLUSTER_HASH_TABLE_SIZE 32707

Definition at line 81 of file P_ClusterCache.h.

Referenced by ClusterProcessor::init(), and test().

#define CLUSTER_IOV_NONE -1

Definition at line 564 of file P_ClusterCache.h.

Referenced by ClusterHandler::update_channels_partial_read().

#define CLUSTER_IOV_NOT_OPEN -2

Definition at line 563 of file P_ClusterCache.h.

Referenced by ClusterHandler::compute_active_channels().

#define CLUSTER_MAJOR_VERSION 3

Definition at line 65 of file P_ClusterCache.h.

#define CLUSTER_MAX_MACHINES 256

Definition at line 79 of file P_ClusterCache.h.

Referenced by configuration_add_machine().

#define CLUSTER_MINOR_VERSION 2

Definition at line 66 of file P_ClusterCache.h.

#define CLUSTER_NODE_DOWN ((ClusterVConnection*)-2)

Definition at line 672 of file P_ClusterCache.h.

#define CLUSTER_OPT_ALLOW_IMMEDIATE 0x0004

Definition at line 614 of file P_ClusterCache.h.

Referenced by CacheContinuation::lookupOpenWriteVC(), and CacheContinuation::setup_local_vc().

#define CLUSTER_OPT_CONN_READ 0x0010

Definition at line 616 of file P_ClusterCache.h.

Referenced by cache_op_ClusterFunction(), ClusterProcessor::connect_local(), ClusterProcessor::open_local(), and CacheContinuation::setup_local_vc().

#define CLUSTER_OPT_CONN_WRITE 0x0020

Definition at line 617 of file P_ClusterCache.h.

Referenced by cache_op_ClusterFunction(), CacheContinuation::lookupOpenWriteVC(), CacheContinuation::remoteOpEvent(), CacheContinuation::setup_local_vc(), and CacheContinuation::setupReadWriteVC().

#define CLUSTER_OPT_DATA_IS_OCONTROL 0x0040

Definition at line 618 of file P_ClusterCache.h.

Referenced by ClusterProcessor::internal_invoke_remote().

#define CLUSTER_OPT_DELAY 0x0008

Definition at line 615 of file P_ClusterCache.h.

Referenced by ClusterProcessor::internal_invoke_remote().

#define CLUSTER_OPT_IMMEDIATE 0x0002

Definition at line 613 of file P_ClusterCache.h.

Referenced by cache_op_ClusterFunction().

#define CLUSTER_OPT_STEAL 0x0001

Definition at line 612 of file P_ClusterCache.h.

Referenced by ClusterProcessor::internal_invoke_remote(), CacheContinuation::replyOpEvent(), and TSSendClusterRPC().

#define CMSG_LOW_PRI (CLUSTER_CMSG_QUEUES-1)

Definition at line 765 of file P_ClusterCache.h.

#define CMSG_MAX_PRI 0

Definition at line 764 of file P_ClusterCache.h.

#define CONFIGURATION_HISTORY_PROBE_DEPTH 1

Definition at line 93 of file P_ClusterCache.h.

Referenced by cluster_machine_at_depth().

#define DEFAULT_CLUSTER_HOST ""

Definition at line 75 of file P_ClusterCache.h.

#define DEFAULT_CLUSTER_PORT_NUMBER 0

Definition at line 73 of file P_ClusterCache.h.

Referenced by ClusterProcessor::init().

#define DEFAULT_NUMBER_OF_CLUSTER_THREADS 1

Definition at line 74 of file P_ClusterCache.h.

Referenced by ClusterProcessor::init().

#define GET_HOSTINFO_CLUSTER_FUNCTION 5

Definition at line 889 of file P_ClusterCache.h.

#define INTERNAL_RESERVED10_CLUSTER_FUNCTION 26

Definition at line 911 of file P_ClusterCache.h.

#define INTERNAL_RESERVED11_CLUSTER_FUNCTION 27

Definition at line 912 of file P_ClusterCache.h.

#define INTERNAL_RESERVED12_CLUSTER_FUNCTION 28

Definition at line 913 of file P_ClusterCache.h.

#define INTERNAL_RESERVED13_CLUSTER_FUNCTION 29

Definition at line 914 of file P_ClusterCache.h.

#define INTERNAL_RESERVED14_CLUSTER_FUNCTION 30

Definition at line 915 of file P_ClusterCache.h.

#define INTERNAL_RESERVED15_CLUSTER_FUNCTION 31

Definition at line 916 of file P_ClusterCache.h.

#define INTERNAL_RESERVED16_CLUSTER_FUNCTION 32

Definition at line 917 of file P_ClusterCache.h.

#define INTERNAL_RESERVED17_CLUSTER_FUNCTION 33

Definition at line 918 of file P_ClusterCache.h.

#define INTERNAL_RESERVED18_CLUSTER_FUNCTION 34

Definition at line 919 of file P_ClusterCache.h.

#define INTERNAL_RESERVED19_CLUSTER_FUNCTION 35

Definition at line 920 of file P_ClusterCache.h.

#define INTERNAL_RESERVED1_CLUSTER_FUNCTION 17

Definition at line 902 of file P_ClusterCache.h.

#define INTERNAL_RESERVED20_CLUSTER_FUNCTION 36

Definition at line 921 of file P_ClusterCache.h.

#define INTERNAL_RESERVED21_CLUSTER_FUNCTION 37

Definition at line 922 of file P_ClusterCache.h.

#define INTERNAL_RESERVED22_CLUSTER_FUNCTION 38

Definition at line 923 of file P_ClusterCache.h.

#define INTERNAL_RESERVED23_CLUSTER_FUNCTION 39

Definition at line 924 of file P_ClusterCache.h.

#define INTERNAL_RESERVED24_CLUSTER_FUNCTION 40

Definition at line 925 of file P_ClusterCache.h.

#define INTERNAL_RESERVED25_CLUSTER_FUNCTION 41

Definition at line 926 of file P_ClusterCache.h.

#define INTERNAL_RESERVED26_CLUSTER_FUNCTION 42

Definition at line 927 of file P_ClusterCache.h.

#define INTERNAL_RESERVED27_CLUSTER_FUNCTION 43

Definition at line 928 of file P_ClusterCache.h.

#define INTERNAL_RESERVED28_CLUSTER_FUNCTION 44

Definition at line 929 of file P_ClusterCache.h.

#define INTERNAL_RESERVED29_CLUSTER_FUNCTION 45

Definition at line 930 of file P_ClusterCache.h.

#define INTERNAL_RESERVED2_CLUSTER_FUNCTION 18

Definition at line 903 of file P_ClusterCache.h.

#define INTERNAL_RESERVED30_CLUSTER_FUNCTION 46

Definition at line 931 of file P_ClusterCache.h.

#define INTERNAL_RESERVED31_CLUSTER_FUNCTION 47

Definition at line 932 of file P_ClusterCache.h.

#define INTERNAL_RESERVED32_CLUSTER_FUNCTION 48

Definition at line 933 of file P_ClusterCache.h.

#define INTERNAL_RESERVED33_CLUSTER_FUNCTION 49

Definition at line 934 of file P_ClusterCache.h.

#define INTERNAL_RESERVED34_CLUSTER_FUNCTION 50

Definition at line 935 of file P_ClusterCache.h.

#define INTERNAL_RESERVED3_CLUSTER_FUNCTION 19

Definition at line 904 of file P_ClusterCache.h.

#define INTERNAL_RESERVED4_CLUSTER_FUNCTION 20

Definition at line 905 of file P_ClusterCache.h.

#define INTERNAL_RESERVED5_CLUSTER_FUNCTION 21

Definition at line 906 of file P_ClusterCache.h.

#define INTERNAL_RESERVED6_CLUSTER_FUNCTION 22

Definition at line 907 of file P_ClusterCache.h.

#define INTERNAL_RESERVED7_CLUSTER_FUNCTION 23

Definition at line 908 of file P_ClusterCache.h.

#define INTERNAL_RESERVED8_CLUSTER_FUNCTION 24

Definition at line 909 of file P_ClusterCache.h.

#define INTERNAL_RESERVED9_CLUSTER_FUNCTION 25

Definition at line 910 of file P_ClusterCache.h.

#define MACHINE_LIST_CLUSTER_FUNCTION 3

Definition at line 887 of file P_ClusterCache.h.

#define MAX_CLUSTER_SEND_LENGTH INT_MAX

Definition at line 77 of file P_ClusterCache.h.

Referenced by ClusterHandler::build_write_descriptors().

#define MIN_CLUSTER_MAJOR_VERSION CLUSTER_MAJOR_VERSION

Definition at line 69 of file P_ClusterCache.h.

#define MIN_CLUSTER_MINOR_VERSION CLUSTER_MINOR_VERSION

Definition at line 70 of file P_ClusterCache.h.

#define PING_CLUSTER_FUNCTION 1

Definition at line 885 of file P_ClusterCache.h.

Referenced by cluster_ping().

#define PING_REPLY_CLUSTER_FUNCTION 2

Definition at line 886 of file P_ClusterCache.h.

Referenced by ping_ClusterFunction().

#define PUT_HOSTINFO_CLUSTER_FUNCTION 6

Definition at line 890 of file P_ClusterCache.h.

#define SET_CHANNEL_DATA_CLUSTER_FUNCTION 14

Definition at line 895 of file P_ClusterCache.h.

Referenced by ClusterHandler::process_large_control_msgs(), ClusterHandler::process_set_data_msgs(), ClusterHandler::process_small_control_msgs(), and ClusterVConnection::set_http_info().

#define SET_CHANNEL_PIN_CLUSTER_FUNCTION 15

Definition at line 896 of file P_ClusterCache.h.

Referenced by ClusterVConnection::set_pin_in_cache().

#define SET_CHANNEL_PRIORITY_CLUSTER_FUNCTION 16

Definition at line 897 of file P_ClusterCache.h.

Referenced by ClusterVConnection::set_disk_io_priority().

#define TEST_CLUSTER_FUNCTION 0

Definition at line 884 of file P_ClusterCache.h.

#define UNDEFINED_CLUSTER_FUNCTION 0xFDEFFDEF

Definition at line 987 of file P_ClusterCache.h.

Typedef Documentation

typedef void ClusterFunction(ClusterHandler *ch, void *data, int len)

Definition at line 311 of file P_ClusterCache.h.

typedef ClusterFunction* ClusterFunctionPtr

Definition at line 312 of file P_ClusterCache.h.

typedef void(* PingReturnFunction)(ClusterHandler *, void *data, int len)

Definition at line 1072 of file P_ClusterCache.h.

Enumeration Type Documentation

enum TypeVConnection

Enumerator:

VC_NULL
VC_CLUSTER
VC_CLUSTER_READ
VC_CLUSTER_WRITE
VC_CLUSTER_CLOSED

Definition at line 471 of file P_ClusterCache.h.

Function Documentation

void ats_swap16 ( uint16_t * d ) [inline]

Definition at line 110 of file P_ClusterCache.h.

Referenced by ClusterHelloMessage::AdjustByteOrder(), ats_swap16(), ClusterMessageHeader::GetMsgVersion(), ClusterMsgHeader::SwapBytes(), Descriptor::SwapBytes(), CacheOpMsg_short_2::SwapBytes(), CacheOpMsg_short::SwapBytes(), and CacheOpMsg_long::SwapBytes().

uint16_t ats_swap16 ( uint16_t d ) [inline]

Definition at line 117 of file P_ClusterCache.h.

References ats_swap16().

uint32_t ats_swap32 ( uint32_t d ) [inline]

Definition at line 131 of file P_ClusterCache.h.

References ats_swap32().

void ats_swap32 ( uint32_t * d ) [inline]

void ats_swap64 ( uint64_t * d ) [inline]

Definition at line 138 of file P_ClusterCache.h.

Referenced by ats_swap64().

uint64_t ats_swap64 ( uint64_t d ) [inline]

Definition at line 147 of file P_ClusterCache.h.

References ats_swap64().

void build_cluster_hash_table ( ClusterConfiguration * )

Definition at line 169 of file ClusterHash.cc.

References build_hash_table_bucket(), build_hash_table_machine(), and machineClusterHash.

Referenced by configuration_add_machine(), and configuration_remove_machine().

inkcoreapi ClusterMachine* cluster_machine_at_depth	(	unsigned int	hash,
		int *	probe_depth = `NULL`,
		ClusterMachine **	past_probes = `NULL`
	)

void cluster_ping	(	ClusterHandler *	ch,
		PingReturnFunction	fn,
		void *	data,
		int	len
	)			`[inline]`

Definition at line 1112 of file P_ClusterCache.h.

References clusterProcessor, PingMessage::data, PingMessage::fn, PingMessage::init(), ClusterProcessor::invoke_remote(), memcpy, PING_CLUSTER_FUNCTION, and PingMessage::sizeof_fixedlen_msg().

int ClusterFuncToQpri ( int cluster_func ) [inline]

Definition at line 872 of file P_ClusterCache.h.

References clusterFunction, and ClusterFunctionDescriptor::q_priority.

Referenced by ClusterProcessor::internal_invoke_remote(), and OutgoingControl::startEvent().

void ClusterVC_enqueue_read	(	Queue< ClusterVConnectionBase, ClusterVConnectionBase::Link_read_link > &	q,
		ClusterVConnectionBase *	vc
	)			`[inline]`

Definition at line 1136 of file P_ClusterCache.h.

References Queue< C, L >::enqueue(), ink_assert, ClusterVConnState::queue, and ClusterVConnectionBase::read.

Referenced by cluster_reschedule_offset(), and cluster_schedule().

void ClusterVC_enqueue_write	(	Queue< ClusterVConnectionBase, ClusterVConnectionBase::Link_write_link > &	q,
		ClusterVConnectionBase *	vc
	)			`[inline]`

Definition at line 1145 of file P_ClusterCache.h.

References Queue< C, L >::enqueue(), ink_assert, ClusterVConnState::queue, and ClusterVConnectionBase::write.

Referenced by cluster_reschedule_offset(), and cluster_schedule().

void ClusterVC_remove_read ( ClusterVConnectionBase * vc ) [inline]

Definition at line 1154 of file P_ClusterCache.h.

References ink_assert, ClusterVConnState::queue, and ClusterVConnectionBase::read.

Referenced by ClusterHandler::add_to_byte_bank(), ClusterHandler::close_ClusterVConnection(), cluster_reschedule_offset(), and ClusterHandler::finish_delayed_reads().

void ClusterVC_remove_write ( ClusterVConnectionBase * vc ) [inline]

Definition at line 1163 of file P_ClusterCache.h.

References ink_assert, ClusterVConnState::queue, and ClusterVConnectionBase::write.

Referenced by ClusterHandler::close_ClusterVConnection(), and cluster_reschedule_offset().

ClusterConfiguration* configuration_add_machine	(	ClusterConfiguration *	c,
		ClusterMachine *	m
	)

Definition at line 289 of file ClusterConfig.cc.

References build_cluster_hash_table(), ClusterConfiguration::changed, CLUSTER_CONFIGURATION_CHANGES_STAT, CLUSTER_INCREMENT_DYN_STAT, CLUSTER_MAX_MACHINES, free_configuration(), ink_assert, ink_get_hrtime(), ClusterMachine::ip, ClusterConfiguration::machines, Thread::mutex, ClusterConfiguration::n_machines, and this_ethread().

Referenced by ClusterHandler::startClusterEvent(), and test().

ClusterConfiguration* configuration_remove_machine	(	ClusterConfiguration *	c,
		ClusterMachine *	m
	)

Definition at line 329 of file ClusterConfig.cc.

References build_cluster_hash_table(), ClusterConfiguration::changed, CLUSTER_CONFIGURATION_CHANGES_STAT, CLUSTER_INCREMENT_DYN_STAT, free_configuration(), ink_assert, ink_get_hrtime(), ClusterConfiguration::machines, Thread::mutex, ClusterConfiguration::n_machines, and this_ethread().

Referenced by ClusterHandler::machine_down().

void initialize_thread_for_cluster ( EThread * thread )

Definition at line 450 of file ClusterConfig.cc.

bool machine_in_vector	(	ClusterMachine *	m,
		ClusterMachine **	mm,
		int	len
	)			`[inline]`

Definition at line 182 of file P_ClusterCache.h.

Referenced by cluster_machine_at_depth().

Cluster* this_cluster ( ) [inline]

Definition at line 711 of file P_ClusterCache.h.

References clusterProcessor, and ClusterProcessor::this_cluster.

Referenced by cluster_machine_at_depth(), ClusterHandler::machine_down(), machine_list_ClusterFunction(), MachineStatusSM::MachineStatusSMEvent(), ClusterHandler::startClusterEvent(), test(), and TSSendClusterRPC().

Variable Documentation

bool boundClusterHash

Definition at line 46 of file ClusterHash.cc.

Referenced by build_hash_table_bucket(), build_hash_table_machine(), and test().

ClusterFunction cache_lookup_ClusterFunction

Referenced by cache_lookup_ClusterFunction().

ClusterFunction cache_op_ClusterFunction

Referenced by cache_op_ClusterFunction(), and cache_op_malloc_ClusterFunction().

ClusterFunction cache_op_malloc_ClusterFunction

Referenced by cache_op_malloc_ClusterFunction().

ClusterFunction cache_op_result_ClusterFunction

Referenced by cache_op_result_ClusterFunction(), and CacheContinuation::lookupOpenWriteVC().

char channel_dummy_output[DEFAULT_MAX_BUFFER_SIZE]

Definition at line 44 of file ClusterHandler.cc.

Referenced by ClusterHandler::build_initial_vector(), and ClusterProcessor::init().

ClusterFunction close_channel_ClusterFunction

Referenced by close_channel_ClusterFunction().

ClusterFunctionDescriptor clusterFunction[]

Referenced by ClusterHandler::build_controlmsg_descriptors(), ClusterFuncToQpri(), ClusterHandler::process_incoming_callouts(), ClusterHandler::process_large_control_msgs(), ClusterHandler::process_set_data_msgs(), and ClusterHandler::process_small_control_msgs().

inkcoreapi ClusterProcessor clusterProcessor

Definition at line 38 of file ClusterProcessor.cc.

Referenced by cache_op_ClusterFunction(), cache_op_malloc_ClusterFunction(), CacheProcessor::cacheInitialized(), GlobalClusterPeriodicEvent::calloutEvent(), ClusterHandler::close_ClusterVConnection(), Cluster_deref(), Cluster_link(), Cluster_lookup(), cluster_ping(), Cluster_read(), Cluster_remove(), Cluster_write(), default_api_ClusterFunction(), HostDBContinuation::do_get_response(), CacheContinuation::do_op(), HostDBContinuation::do_put_response(), CacheContinuation::do_remote_lookup(), CacheContinuation::localVCsetupEvent(), CacheContinuation::lookupOpenWriteVC(), ClusterHandler::machine_down(), machine_list_ClusterFunction(), main(), make_cluster_connections(), ping_ClusterFunction(), redirect_test(), CacheContinuation::replyLookupEvent(), CacheContinuation::replyOpEvent(), ClusterVConnection::set_disk_io_priority(), ClusterVConnection::set_http_info(), ClusterVConnection::set_pin_in_cache(), CacheContinuation::setup_local_vc(), ClusterHandler::startClusterEvent(), test(), this_cluster(), TSFreeRPCMsg(), and TSSendClusterRPC().

ClusterFunction default_api_ClusterFunction

Referenced by default_api_ClusterFunction().

ClusterFunction get_hostinfo_ClusterFunction

Referenced by get_hostinfo_ClusterFunction().

ClusterFunction machine_list_ClusterFunction

Referenced by machine_list_ClusterFunction().

bool machineClusterHash

Definition at line 45 of file ClusterHash.cc.

Referenced by build_cluster_hash_table(), and test().

ClusterFunction ping_ClusterFunction

Referenced by ping_ClusterFunction().

ClusterFunction ping_reply_ClusterFunction

Referenced by ping_reply_ClusterFunction().

ClusterFunction post_setchan_pin_ClusterFunction

Referenced by post_setchan_pin_ClusterFunction().

ClusterFunction post_setchan_priority_ClusterFunction

Referenced by post_setchan_priority_ClusterFunction().

ClusterFunction post_setchan_send_ClusterFunction

Referenced by post_setchan_send_ClusterFunction().

ClusterFunction* ptest_ClusterFunction

Definition at line 40 of file ClusterHandler.cc.

Referenced by test(), and test_ClusterFunction().

ClusterFunction put_hostinfo_ClusterFunction

Referenced by put_hostinfo_ClusterFunction().

bool randClusterHash

Definition at line 47 of file ClusterHash.cc.

Referenced by build_hash_table_bucket(), build_hash_table_machine(), and test().

ClusterFunction set_channel_data_ClusterFunction

Referenced by set_channel_data_ClusterFunction().

ClusterFunction set_channel_pin_ClusterFunction

Referenced by set_channel_pin_ClusterFunction().

ClusterFunction set_channel_priority_ClusterFunction

Referenced by set_channel_priority_ClusterFunction().

unsigned SIZE_clusterFunction

Definition at line 37 of file ClusterHandler.cc.

Referenced by ClusterProcessor::internal_invoke_remote(), ClusterHandler::process_incoming_callouts(), ClusterHandler::process_large_control_msgs(), ClusterHandler::process_set_data_msgs(), and ClusterHandler::process_small_control_msgs().

ClusterFunction test_ClusterFunction

Referenced by test_ClusterFunction().

P_ClusterCache.h File Reference

Data Structures

Defines

Typedefs

Enumerations

Functions