You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@helix.apache.org by ki...@apache.org on 2013/05/21 02:45:05 UTC
svn commit: r1484629 [21/23] - in /incubator/helix/site-content: ./
apidocs/reference/org/apache/helix/agent/
apidocs/reference/org/apache/helix/manager/zk/
apidocs/reference/org/apache/helix/recipes/rabbitmq/ helix-admin-webapp/
helix-agent/ helix-cor...
Added: incubator/helix/site-content/tutorial_state.html
URL: http://svn.apache.org/viewvc/incubator/helix/site-content/tutorial_state.html?rev=1484629&view=auto
==============================================================================
--- incubator/helix/site-content/tutorial_state.html (added)
+++ incubator/helix/site-content/tutorial_state.html Tue May 21 00:45:01 2013
@@ -0,0 +1,240 @@
+<!DOCTYPE html>
+<!--
+ | Generated by Apache Maven Doxia at May 20, 2013
+ | Rendered using Apache Maven Fluido Skin 1.3.0
+-->
+<html xmlns="http://www.w3.org/1999/xhtml" xml:lang="en" lang="en">
+ <head>
+ <meta charset="UTF-8" />
+ <meta name="viewport" content="width=device-width, initial-scale=1.0" />
+ <meta name="Date-Revision-yyyymmdd" content="20130520" />
+ <meta http-equiv="Content-Language" content="en" />
+ <title>Apache Helix - </title>
+ <link rel="stylesheet" href="./css/apache-maven-fluido-1.3.0.min.css" />
+ <link rel="stylesheet" href="./css/site.css" />
+ <link rel="stylesheet" href="./css/print.css" media="print" />
+
+
+ <script type="text/javascript" src="./js/apache-maven-fluido-1.3.0.min.js"></script>
+
+
+
+<script type="text/javascript">var _gaq = _gaq || [];
+ _gaq.push(['_setAccount', 'UA-3211522-12']);
+ _gaq.push(['_trackPageview']);
+
+ (function() {
+ var ga = document.createElement('script'); ga.type = 'text/javascript'; ga.async = true;
+ ga.src = ('https:' == document.location.protocol ? 'https://ssl' : 'http://www') + '.google-analytics.com/ga.js';
+ var s = document.getElementsByTagName('script')[0]; s.parentNode.insertBefore(ga, s);
+ })();</script>
+
+ </head>
+ <body class="topBarEnabled">
+
+
+
+
+
+ <div id="topbar" class="navbar navbar-fixed-top ">
+ <div class="navbar-inner">
+ <div class="container"><div class="nav-collapse">
+
+
+ <ul class="nav">
+ <li class="dropdown">
+ <a href="#" class="dropdown-toggle" data-toggle="dropdown">Helix <b class="caret"></b></a>
+ <ul class="dropdown-menu">
+
+ <li> <a href="index.html" title="Introduction">Introduction</a>
+</li>
+
+ <li> <a href="Concepts.html" title="Core concepts">Core concepts</a>
+</li>
+
+ <li> <a href="Architecture.html" title="Architecture">Architecture</a>
+</li>
+
+ <li> <a href="Quickstart.html" title="Quick Start">Quick Start</a>
+</li>
+
+ <li> <a href="Tutorial.html" title="Tutorial">Tutorial</a>
+</li>
+
+ <li> <a href="releasenotes/release-0.6.1-incubating.html" title="release 0.6.1-incubating">release 0.6.1-incubating</a>
+</li>
+
+ <li> <a href="download.html" title="Download">Download</a>
+</li>
+ </ul>
+ </li>
+ <li class="dropdown">
+ <a href="#" class="dropdown-toggle" data-toggle="dropdown">Recipes <b class="caret"></b></a>
+ <ul class="dropdown-menu">
+
+ <li> <a href="recipes/lock_manager.html" title="Distributed lock manager">Distributed lock manager</a>
+</li>
+
+ <li> <a href="recipes/rabbitmq_consumer_group.html" title="Rabbit MQ consumer group">Rabbit MQ consumer group</a>
+</li>
+
+ <li> <a href="recipes/rsync_replicated_file_store.html" title="Rsync replicated file store">Rsync replicated file store</a>
+</li>
+
+ <li> <a href="recipes/service_discovery.html" title="Service Discovery">Service Discovery</a>
+</li>
+
+ <li> <a href="recipes/task_dag_execution.html" title="Distributed task DAG Execution">Distributed task DAG Execution</a>
+</li>
+ </ul>
+ </li>
+ <li class="dropdown">
+ <a href="#" class="dropdown-toggle" data-toggle="dropdown">Get Involved <b class="caret"></b></a>
+ <ul class="dropdown-menu">
+
+ <li> <a href="mail-lists.html" title="Mailing Lists">Mailing Lists</a>
+</li>
+
+ <li> <a href="issue-tracking.html" title="Issues">Issues</a>
+</li>
+
+ <li> <a href="team-list.html" title="Team">Team</a>
+</li>
+
+ <li> <a href="source-repository.html" title="Sources">Sources</a>
+</li>
+
+ <li> <a href="integration.html" title="Continuous Integration">Continuous Integration</a>
+</li>
+
+ <li> <a href="involved/building.html" title="Building Guide">Building Guide</a>
+</li>
+
+ <li> <a href="releasing.html" title="Release Guide">Release Guide</a>
+</li>
+ </ul>
+ </li>
+ </ul>
+
+ <form id="search-form" action="http://www.google.com/search" method="get" class="navbar-search pull-right" >
+
+ <input value="helix.incubator.apache.org" name="sitesearch" type="hidden"/>
+ <input class="search-query" name="q" id="query" type="text" />
+</form>
+<script type="text/javascript" src="http://www.google.com/coop/cse/brand?form=search-form"></script>
+
+
+
+
+ <ul class="nav pull-right"><li>
+
+ <a href="https://twitter.com/ApacheHelix" class="twitter-follow-button" data-show-count="false" data-align="right" data-size="large" data-show-screen-name="true" data-lang="en">Follow ApacheHelix</a>
+ <script type="text/javascript">!function(d,s,id){var js,fjs=d.getElementsByTagName(s)[0];if(!d.getElementById(id)){js=d.createElement(s);js.id=id;js.src="//platform.twitter.com/widgets.js";fjs.parentNode.insertBefore(js,fjs);}}(document,"script","twitter-wjs");</script>
+
+ </li></ul>
+
+
+ </div>
+
+ </div>
+ </div>
+ </div>
+
+ <div class="container">
+ <div id="banner">
+ <div class="pull-left">
+ <a href="./" id="bannerLeft">
+ <img src="images/helix-logo.jpg" />
+ </a>
+ </div>
+ <div class="pull-right"> <a href="http://incubator.apache.org/" id="bannerRight">
+ <img src="http://incubator.apache.org/images/egg-logo.png" />
+ </a>
+ </div>
+ <div class="clear"><hr/></div>
+ </div>
+
+ <div id="breadcrumbs">
+ <ul class="breadcrumb">
+
+
+ <li id="projectVersion">Version: 0.6.2-incubating-SNAPSHOT</li>
+ | <li class="">
+ <a href="./" title="Apache Helix">
+ Apache Helix</a>
+ </li>
+ <li class="divider ">/</li>
+ <li class=""></li>
+
+
+
+ <li id="publishDate" class="pull-right">Last Published: 2013-05-20</li>
+
+ </ul>
+ </div>
+
+
+
+ <div id="bodyColumn" >
+
+ <!-- -
+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. --><h1>Helix Tutorial: State Machine Configuration</h1><p>In this chapter, we'll learn about the state models provided by Helix, and how to create your own custom state model.</p><div class="section"><h2>State Models<a name="State_Models"></a></h2><p>Helix comes with 3 default state models that are commonly used. It is possible to have multiple state models in a cluster. Every resource that is added should be configured to use a state model that govern its <i>ideal state</i>.</p><div class="section"><h3>MASTER-SLAVE<a name="MASTER-SLAVE"></a></h3>
+<ul>
+ <li>Has 3 states: OFFLINE, SLAVE, MASTER</li>
+ <li>Maximum # of masters: 1</li>
+ <li>Slaves are based on the replication factor. Replication factor can be specified while adding the resource</li>
+</ul></div><div class="section"><h3>ONLINE-OFFLINE<a name="ONLINE-OFFLINE"></a></h3>
+<ul>
+ <li>Has 2 states: OFFLINE and ONLINE. This simple state model is a good starting point for most applications.</li>
+</ul></div><div class="section"><h3>LEADER-STANDBY<a name="LEADER-STANDBY"></a></h3>
+<ul>
+ <li>1 Leader and multiple stand-bys. The idea is that exactly one leader accomplishes a designated task, the stand-bys are ready to take over if the leader fails.</li>
+</ul></div></div><div class="section"><h2>Constraints<a name="Constraints"></a></h2><p>In addition to the state machine configuration, one can specify the constraints of states and transitions.</p><p>For example, one can say: * MASTER:1 Maximum number of replicas in MASTER state at any time is 1</p>
+<ul>
+ <li>OFFLINE-SLAVE:5 Maximum number of OFFLINE-SLAVE transitions that can happen concurrently in the system is 5 in this example.</li>
+</ul><div class="section"><h3>State Priority<a name="State_Priority"></a></h3><p>Helix uses a greedy approach to satisfy the state constraints. For example, if the state machine configuration says it needs 1 MASTER and 2 SLAVES, but only 1 node is active, Helix must promote it to MASTER. This behavior is achieved by providing the state priority list as MASTER,SLAVE.</p></div><div class="section"><h3>State Transition Priority<a name="State_Transition_Priority"></a></h3><p>Helix tries to fire as many transitions as possible in parallel to reach the stable state without violating constraints. By default, Helix simply sorts the transitions alphabetically and fires as many as it can without violating the constraints. You can control this by overriding the priority order.</p></div></div>
+ </div>
+ </div>
+
+ <hr/>
+
+ <footer>
+ <div class="container">
+ <div class="row span12">Copyright © 2013
+ <a href="http://www.apache.org/">The Apache Software Foundation</a>.
+ All Rights Reserved.
+
+ </div>
+
+ <?xml version="1.0" encoding="UTF-8"?>
+<div class="row span16">
+ <div>Apache Helix, Apache, the Apache feather logo, and the Apache Helix project logos are trademarks of The Apache Software Foundation.
+ All other marks mentioned may be trademarks or registered trademarks of their respective owners.</div>
+ <a href="http://helix.incubator.apache.org/privacy-policy.html">Privacy Policy</a>
+</div>
+
+ <p id="poweredBy" class="pull-right">
+ <a href="http://maven.apache.org/" title="Built by Maven" class="poweredBy">
+ <img class="builtBy" alt="Built by Maven" src="./images/logos/maven-feather.png" />
+ </a>
+ </p>
+
+ </div>
+ </footer>
+ </body>
+</html>
\ No newline at end of file
Added: incubator/helix/site-content/tutorial_throttling.html
URL: http://svn.apache.org/viewvc/incubator/helix/site-content/tutorial_throttling.html?rev=1484629&view=auto
==============================================================================
--- incubator/helix/site-content/tutorial_throttling.html (added)
+++ incubator/helix/site-content/tutorial_throttling.html Tue May 21 00:45:01 2013
@@ -0,0 +1,232 @@
+<!DOCTYPE html>
+<!--
+ | Generated by Apache Maven Doxia at May 20, 2013
+ | Rendered using Apache Maven Fluido Skin 1.3.0
+-->
+<html xmlns="http://www.w3.org/1999/xhtml" xml:lang="en" lang="en">
+ <head>
+ <meta charset="UTF-8" />
+ <meta name="viewport" content="width=device-width, initial-scale=1.0" />
+ <meta name="Date-Revision-yyyymmdd" content="20130520" />
+ <meta http-equiv="Content-Language" content="en" />
+ <title>Apache Helix - </title>
+ <link rel="stylesheet" href="./css/apache-maven-fluido-1.3.0.min.css" />
+ <link rel="stylesheet" href="./css/site.css" />
+ <link rel="stylesheet" href="./css/print.css" media="print" />
+
+
+ <script type="text/javascript" src="./js/apache-maven-fluido-1.3.0.min.js"></script>
+
+
+
+<script type="text/javascript">var _gaq = _gaq || [];
+ _gaq.push(['_setAccount', 'UA-3211522-12']);
+ _gaq.push(['_trackPageview']);
+
+ (function() {
+ var ga = document.createElement('script'); ga.type = 'text/javascript'; ga.async = true;
+ ga.src = ('https:' == document.location.protocol ? 'https://ssl' : 'http://www') + '.google-analytics.com/ga.js';
+ var s = document.getElementsByTagName('script')[0]; s.parentNode.insertBefore(ga, s);
+ })();</script>
+
+ </head>
+ <body class="topBarEnabled">
+
+
+
+
+
+ <div id="topbar" class="navbar navbar-fixed-top ">
+ <div class="navbar-inner">
+ <div class="container"><div class="nav-collapse">
+
+
+ <ul class="nav">
+ <li class="dropdown">
+ <a href="#" class="dropdown-toggle" data-toggle="dropdown">Helix <b class="caret"></b></a>
+ <ul class="dropdown-menu">
+
+ <li> <a href="index.html" title="Introduction">Introduction</a>
+</li>
+
+ <li> <a href="Concepts.html" title="Core concepts">Core concepts</a>
+</li>
+
+ <li> <a href="Architecture.html" title="Architecture">Architecture</a>
+</li>
+
+ <li> <a href="Quickstart.html" title="Quick Start">Quick Start</a>
+</li>
+
+ <li> <a href="Tutorial.html" title="Tutorial">Tutorial</a>
+</li>
+
+ <li> <a href="releasenotes/release-0.6.1-incubating.html" title="release 0.6.1-incubating">release 0.6.1-incubating</a>
+</li>
+
+ <li> <a href="download.html" title="Download">Download</a>
+</li>
+ </ul>
+ </li>
+ <li class="dropdown">
+ <a href="#" class="dropdown-toggle" data-toggle="dropdown">Recipes <b class="caret"></b></a>
+ <ul class="dropdown-menu">
+
+ <li> <a href="recipes/lock_manager.html" title="Distributed lock manager">Distributed lock manager</a>
+</li>
+
+ <li> <a href="recipes/rabbitmq_consumer_group.html" title="Rabbit MQ consumer group">Rabbit MQ consumer group</a>
+</li>
+
+ <li> <a href="recipes/rsync_replicated_file_store.html" title="Rsync replicated file store">Rsync replicated file store</a>
+</li>
+
+ <li> <a href="recipes/service_discovery.html" title="Service Discovery">Service Discovery</a>
+</li>
+
+ <li> <a href="recipes/task_dag_execution.html" title="Distributed task DAG Execution">Distributed task DAG Execution</a>
+</li>
+ </ul>
+ </li>
+ <li class="dropdown">
+ <a href="#" class="dropdown-toggle" data-toggle="dropdown">Get Involved <b class="caret"></b></a>
+ <ul class="dropdown-menu">
+
+ <li> <a href="mail-lists.html" title="Mailing Lists">Mailing Lists</a>
+</li>
+
+ <li> <a href="issue-tracking.html" title="Issues">Issues</a>
+</li>
+
+ <li> <a href="team-list.html" title="Team">Team</a>
+</li>
+
+ <li> <a href="source-repository.html" title="Sources">Sources</a>
+</li>
+
+ <li> <a href="integration.html" title="Continuous Integration">Continuous Integration</a>
+</li>
+
+ <li> <a href="involved/building.html" title="Building Guide">Building Guide</a>
+</li>
+
+ <li> <a href="releasing.html" title="Release Guide">Release Guide</a>
+</li>
+ </ul>
+ </li>
+ </ul>
+
+ <form id="search-form" action="http://www.google.com/search" method="get" class="navbar-search pull-right" >
+
+ <input value="helix.incubator.apache.org" name="sitesearch" type="hidden"/>
+ <input class="search-query" name="q" id="query" type="text" />
+</form>
+<script type="text/javascript" src="http://www.google.com/coop/cse/brand?form=search-form"></script>
+
+
+
+
+ <ul class="nav pull-right"><li>
+
+ <a href="https://twitter.com/ApacheHelix" class="twitter-follow-button" data-show-count="false" data-align="right" data-size="large" data-show-screen-name="true" data-lang="en">Follow ApacheHelix</a>
+ <script type="text/javascript">!function(d,s,id){var js,fjs=d.getElementsByTagName(s)[0];if(!d.getElementById(id)){js=d.createElement(s);js.id=id;js.src="//platform.twitter.com/widgets.js";fjs.parentNode.insertBefore(js,fjs);}}(document,"script","twitter-wjs");</script>
+
+ </li></ul>
+
+
+ </div>
+
+ </div>
+ </div>
+ </div>
+
+ <div class="container">
+ <div id="banner">
+ <div class="pull-left">
+ <a href="./" id="bannerLeft">
+ <img src="images/helix-logo.jpg" />
+ </a>
+ </div>
+ <div class="pull-right"> <a href="http://incubator.apache.org/" id="bannerRight">
+ <img src="http://incubator.apache.org/images/egg-logo.png" />
+ </a>
+ </div>
+ <div class="clear"><hr/></div>
+ </div>
+
+ <div id="breadcrumbs">
+ <ul class="breadcrumb">
+
+
+ <li id="projectVersion">Version: 0.6.2-incubating-SNAPSHOT</li>
+ | <li class="">
+ <a href="./" title="Apache Helix">
+ Apache Helix</a>
+ </li>
+ <li class="divider ">/</li>
+ <li class=""></li>
+
+
+
+ <li id="publishDate" class="pull-right">Last Published: 2013-05-20</li>
+
+ </ul>
+ </div>
+
+
+
+ <div id="bodyColumn" >
+
+ <!-- -
+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. --><h1>Helix Tutorial: Throttling</h1><p>In this chapter, we'll learn how to control the parallel execution of cluster tasks. Only a centralized cluster manager with global knowledge is capable of coordinating this decision.</p><div class="section"><div class="section"><h3>Throttling<a name="Throttling"></a></h3><p>Since all state changes in the system are triggered through transitions, Helix can control the number of transitions that can happen in parallel. Some of the transitions may be light weight, but some might involve moving data, which is quite expensive from a network and iops perspective.</p><p>Helix allows applications to set a threshold on transitions. The threshold can be set at multiple scopes:</p>
+<ul>
+ <li>MessageType e.g STATE_TRANSITION</li>
+ <li>TransitionType e.g SLAVE-MASTER</li>
+ <li>Resource e.g database</li>
+ <li>Node i.e per-node maximum transitions in parallel</li>
+</ul><p><i>I can't find this code.</i> See HelixManager.getHelixAdmin.addMessageConstraint() </p></div></div>
+ </div>
+ </div>
+
+ <hr/>
+
+ <footer>
+ <div class="container">
+ <div class="row span12">Copyright © 2013
+ <a href="http://www.apache.org/">The Apache Software Foundation</a>.
+ All Rights Reserved.
+
+ </div>
+
+ <?xml version="1.0" encoding="UTF-8"?>
+<div class="row span16">
+ <div>Apache Helix, Apache, the Apache feather logo, and the Apache Helix project logos are trademarks of The Apache Software Foundation.
+ All other marks mentioned may be trademarks or registered trademarks of their respective owners.</div>
+ <a href="http://helix.incubator.apache.org/privacy-policy.html">Privacy Policy</a>
+</div>
+
+ <p id="poweredBy" class="pull-right">
+ <a href="http://maven.apache.org/" title="Built by Maven" class="poweredBy">
+ <img class="builtBy" alt="Built by Maven" src="./images/logos/maven-feather.png" />
+ </a>
+ </p>
+
+ </div>
+ </footer>
+ </body>
+</html>
\ No newline at end of file
Modified: incubator/helix/site-content/xref-test/allclasses-frame.html
URL: http://svn.apache.org/viewvc/incubator/helix/site-content/xref-test/allclasses-frame.html?rev=1484629&r1=1484628&r2=1484629&view=diff
==============================================================================
--- incubator/helix/site-content/xref-test/allclasses-frame.html (original)
+++ incubator/helix/site-content/xref-test/allclasses-frame.html Tue May 21 00:45:01 2013
@@ -87,7 +87,7 @@
<a href="org/apache/helix/healthcheck/TestExpandAlert.html" target="classFrame">ExpandAlertTransition</a>
</li>
<li>
- <a href="org/apache/helix/integration/TestAutoRebalancePartitionLimit.html" target="classFrame">ExternalViewBalancedVerifier</a>
+ <a href="org/apache/helix/integration/TestCustomizedIdealStateRebalancer.html" target="classFrame">ExternalViewBalancedVerifier</a>
</li>
<li>
<a href="org/apache/helix/integration/IntegrationTest.html" target="classFrame">IntegrationTest</a>
@@ -99,7 +99,7 @@
<a href="org/apache/helix/Mocks.html" target="classFrame">MockAccessor</a>
</li>
<li>
- <a href="org/apache/helix/integration/TestSchedulerMessage.html" target="classFrame">MockAsyncCallback</a>
+ <a href="org/apache/helix/integration/TestMessagingService.html" target="classFrame">MockAsyncCallback</a>
</li>
<li>
<a href="org/apache/helix/Mocks.html" target="classFrame">MockBaseDataAccessor</a>
@@ -129,7 +129,7 @@
<a href="org/apache/helix/mock/controller/MockControllerProcess.html" target="classFrame">MockControllerProcess</a>
</li>
<li>
- <a href="org/apache/helix/monitoring/mbeans/TestClusterStatusMonitor.html" target="classFrame">MockDataAccessor</a>
+ <a href="org/apache/helix/monitoring/mbeans/TestResourceMonitor.html" target="classFrame">MockDataAccessor</a>
</li>
<li>
<a href="org/apache/helix/mock/participant/MockEspressoHealthReportProvider.html" target="classFrame">MockEspressoHealthReportProvider</a>
@@ -147,7 +147,7 @@
<a href="org/apache/helix/Mocks.html" target="classFrame">MockHealthReportProvider</a>
</li>
<li>
- <a href="org/apache/helix/monitoring/mbeans/TestClusterStatusMonitor.html" target="classFrame">MockHelixManager</a>
+ <a href="org/apache/helix/monitoring/mbeans/TestResourceMonitor.html" target="classFrame">MockHelixManager</a>
</li>
<li>
<a href="org/apache/helix/Mocks.html" target="classFrame">MockHelixTaskExecutor</a>
@@ -222,7 +222,7 @@
<a href="org/apache/helix/integration/TestSessionExpiryInTransition.html" target="classFrame">SessionExpiryTransition</a>
</li>
<li>
- <a href="org/apache/helix/healthcheck/TestSimpleWildcardAlert.html" target="classFrame">SimpleAlertTransition</a>
+ <a href="org/apache/helix/healthcheck/TestSimpleAlert.html" target="classFrame">SimpleAlertTransition</a>
</li>
<li>
<a href="org/apache/helix/integration/TestZkReconnect.html" target="classFrame">SimpleStateModel</a>
@@ -279,7 +279,7 @@
<a href="org/apache/helix/alerts/TestArrivingParticipantStats.html" target="classFrame">TestArrivingParticipantStats</a>
</li>
<li>
- <a href="org/apache/helix/messaging/TestAsyncCallbackSvc.html" target="classFrame">TestAsyncCallback</a>
+ <a href="org/apache/helix/messaging/TestAsyncCallback.html" target="classFrame">TestAsyncCallback</a>
</li>
<li>
<a href="org/apache/helix/messaging/TestAsyncCallbackSvc.html" target="classFrame">TestAsyncCallbackSvc</a>
@@ -537,10 +537,10 @@
<a href="org/apache/helix/controller/stages/TestMessageThrottleStage.html" target="classFrame">TestMessageThrottleStage</a>
</li>
<li>
- <a href="org/apache/helix/integration/TestSchedulerMessage.html" target="classFrame">TestMessagingHandler</a>
+ <a href="org/apache/helix/integration/TestMessagingService.html" target="classFrame">TestMessagingHandler</a>
</li>
<li>
- <a href="org/apache/helix/integration/TestSchedulerMessage.html" target="classFrame">TestMessagingHandlerFactory</a>
+ <a href="org/apache/helix/integration/TestMessagingService.html" target="classFrame">TestMessagingHandlerFactory</a>
</li>
<li>
<a href="org/apache/helix/messaging/handling/TestConfigThreadpoolSize.html" target="classFrame">TestMessagingHandlerFactory2</a>
@@ -753,6 +753,9 @@
<a href="org/apache/helix/integration/TestBatchMessage.html" target="classFrame">TestZkChildListener</a>
</li>
<li>
+ <a href="org/apache/helix/manager/zk/TestZkClient.html" target="classFrame">TestZkClient</a>
+ </li>
+ <li>
<a href="org/apache/helix/TestZkClientWrapper.html" target="classFrame">TestZkClientWrapper</a>
</li>
<li>
Modified: incubator/helix/site-content/xref-test/org/apache/helix/healthcheck/TestSimpleAlert.html
URL: http://svn.apache.org/viewvc/incubator/helix/site-content/xref-test/org/apache/helix/healthcheck/TestSimpleAlert.html?rev=1484629&r1=1484628&r2=1484629&view=diff
==============================================================================
--- incubator/helix/site-content/xref-test/org/apache/helix/healthcheck/TestSimpleAlert.html (original)
+++ incubator/helix/site-content/xref-test/org/apache/helix/healthcheck/TestSimpleAlert.html Tue May 21 00:45:01 2013
@@ -84,10 +84,10 @@
<a class="jxr_linenumber" name="74" href="#74">74</a> _zkClient.close();
<a class="jxr_linenumber" name="75" href="#75">75</a> }
<a class="jxr_linenumber" name="76" href="#76">76</a>
-<a class="jxr_linenumber" name="77" href="#77">77</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">class</strong> <a href="../../../../org/apache/helix/healthcheck/TestSimpleWildcardAlert.html">SimpleAlertTransition</a> <strong class="jxr_keyword">extends</strong> <a href="../../../../org/apache/helix/mock/participant/MockTransition.html">MockTransition</a>
+<a class="jxr_linenumber" name="77" href="#77">77</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">class</strong> <a href="../../../../org/apache/helix/healthcheck/TestSimpleAlert.html">SimpleAlertTransition</a> <strong class="jxr_keyword">extends</strong> <a href="../../../../org/apache/helix/mock/participant/MockTransition.html">MockTransition</a>
<a class="jxr_linenumber" name="78" href="#78">78</a> {
<a class="jxr_linenumber" name="79" href="#79">79</a> <strong class="jxr_keyword">int</strong> _alertValue;
-<a class="jxr_linenumber" name="80" href="#80">80</a> <strong class="jxr_keyword">public</strong> <a href="../../../../org/apache/helix/healthcheck/TestSimpleWildcardAlert.html">SimpleAlertTransition</a>(<strong class="jxr_keyword">int</strong> value)
+<a class="jxr_linenumber" name="80" href="#80">80</a> <strong class="jxr_keyword">public</strong> <a href="../../../../org/apache/helix/healthcheck/TestSimpleAlert.html">SimpleAlertTransition</a>(<strong class="jxr_keyword">int</strong> value)
<a class="jxr_linenumber" name="81" href="#81">81</a> {
<a class="jxr_linenumber" name="82" href="#82">82</a> _alertValue = value;
<a class="jxr_linenumber" name="83" href="#83">83</a> }
@@ -176,7 +176,7 @@
<a class="jxr_linenumber" name="166" href="#166">166</a> participants[i] = <strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/mock/participant/MockParticipant.html">MockParticipant</a>(clusterName,
<a class="jxr_linenumber" name="167" href="#167">167</a> instanceName,
<a class="jxr_linenumber" name="168" href="#168">168</a> ZK_ADDR,
-<a class="jxr_linenumber" name="169" href="#169">169</a> <strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/healthcheck/TestSimpleWildcardAlert.html">SimpleAlertTransition</a>(15));
+<a class="jxr_linenumber" name="169" href="#169">169</a> <strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/healthcheck/TestSimpleAlert.html">SimpleAlertTransition</a>(15));
<a class="jxr_linenumber" name="170" href="#170">170</a> participants[i].syncStart();
<a class="jxr_linenumber" name="171" href="#171">171</a> <em class="jxr_comment">// new Thread(participants[i]).start();</em>
<a class="jxr_linenumber" name="172" href="#172">172</a> }
Modified: incubator/helix/site-content/xref-test/org/apache/helix/healthcheck/TestSimpleWildcardAlert.html
URL: http://svn.apache.org/viewvc/incubator/helix/site-content/xref-test/org/apache/helix/healthcheck/TestSimpleWildcardAlert.html?rev=1484629&r1=1484628&r2=1484629&view=diff
==============================================================================
--- incubator/helix/site-content/xref-test/org/apache/helix/healthcheck/TestSimpleWildcardAlert.html (original)
+++ incubator/helix/site-content/xref-test/org/apache/helix/healthcheck/TestSimpleWildcardAlert.html Tue May 21 00:45:01 2013
@@ -83,10 +83,10 @@
<a class="jxr_linenumber" name="73" href="#73">73</a> _zkClient.close();
<a class="jxr_linenumber" name="74" href="#74">74</a> }
<a class="jxr_linenumber" name="75" href="#75">75</a>
-<a class="jxr_linenumber" name="76" href="#76">76</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">class</strong> <a href="../../../../org/apache/helix/healthcheck/TestSimpleWildcardAlert.html">SimpleAlertTransition</a> <strong class="jxr_keyword">extends</strong> <a href="../../../../org/apache/helix/mock/participant/MockTransition.html">MockTransition</a>
+<a class="jxr_linenumber" name="76" href="#76">76</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">class</strong> <a href="../../../../org/apache/helix/healthcheck/TestSimpleAlert.html">SimpleAlertTransition</a> <strong class="jxr_keyword">extends</strong> <a href="../../../../org/apache/helix/mock/participant/MockTransition.html">MockTransition</a>
<a class="jxr_linenumber" name="77" href="#77">77</a> {
<a class="jxr_linenumber" name="78" href="#78">78</a> <strong class="jxr_keyword">int</strong> _alertValue;
-<a class="jxr_linenumber" name="79" href="#79">79</a> <strong class="jxr_keyword">public</strong> <a href="../../../../org/apache/helix/healthcheck/TestSimpleWildcardAlert.html">SimpleAlertTransition</a>(<strong class="jxr_keyword">int</strong> value)
+<a class="jxr_linenumber" name="79" href="#79">79</a> <strong class="jxr_keyword">public</strong> <a href="../../../../org/apache/helix/healthcheck/TestSimpleAlert.html">SimpleAlertTransition</a>(<strong class="jxr_keyword">int</strong> value)
<a class="jxr_linenumber" name="80" href="#80">80</a> {
<a class="jxr_linenumber" name="81" href="#81">81</a> _alertValue = value;
<a class="jxr_linenumber" name="82" href="#82">82</a> }
@@ -177,7 +177,7 @@
<a class="jxr_linenumber" name="167" href="#167">167</a> participants[i] = <strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/mock/participant/MockParticipant.html">MockParticipant</a>(clusterName,
<a class="jxr_linenumber" name="168" href="#168">168</a> instanceName,
<a class="jxr_linenumber" name="169" href="#169">169</a> ZK_ADDR,
-<a class="jxr_linenumber" name="170" href="#170">170</a> <strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/healthcheck/TestSimpleWildcardAlert.html">SimpleAlertTransition</a>(i * 5));
+<a class="jxr_linenumber" name="170" href="#170">170</a> <strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/healthcheck/TestSimpleAlert.html">SimpleAlertTransition</a>(i * 5));
<a class="jxr_linenumber" name="171" href="#171">171</a> participants[i].syncStart();
<a class="jxr_linenumber" name="172" href="#172">172</a> <em class="jxr_comment">// new Thread(participants[i]).start();</em>
<a class="jxr_linenumber" name="173" href="#173">173</a> }
Modified: incubator/helix/site-content/xref-test/org/apache/helix/healthcheck/package-frame.html
URL: http://svn.apache.org/viewvc/incubator/helix/site-content/xref-test/org/apache/helix/healthcheck/package-frame.html?rev=1484629&r1=1484628&r2=1484629&view=diff
==============================================================================
--- incubator/helix/site-content/xref-test/org/apache/helix/healthcheck/package-frame.html (original)
+++ incubator/helix/site-content/xref-test/org/apache/helix/healthcheck/package-frame.html Tue May 21 00:45:01 2013
@@ -25,7 +25,7 @@
<a href="TestExpandAlert.html" target="classFrame">ExpandAlertTransition</a>
</li>
<li>
- <a href="TestSimpleWildcardAlert.html" target="classFrame">SimpleAlertTransition</a>
+ <a href="TestSimpleAlert.html" target="classFrame">SimpleAlertTransition</a>
</li>
<li>
<a href="TestStalenessAlert.html" target="classFrame">StalenessAlertTransition</a>
Modified: incubator/helix/site-content/xref-test/org/apache/helix/healthcheck/package-summary.html
URL: http://svn.apache.org/viewvc/incubator/helix/site-content/xref-test/org/apache/helix/healthcheck/package-summary.html?rev=1484629&r1=1484628&r2=1484629&view=diff
==============================================================================
--- incubator/helix/site-content/xref-test/org/apache/helix/healthcheck/package-summary.html (original)
+++ incubator/helix/site-content/xref-test/org/apache/helix/healthcheck/package-summary.html Tue May 21 00:45:01 2013
@@ -52,7 +52,7 @@
</tr>
<tr>
<td>
- <a href="TestSimpleWildcardAlert.html" target="classFrame">SimpleAlertTransition</a>
+ <a href="TestSimpleAlert.html" target="classFrame">SimpleAlertTransition</a>
</td>
</tr>
<tr>
Modified: incubator/helix/site-content/xref-test/org/apache/helix/integration/TestAutoRebalance.html
URL: http://svn.apache.org/viewvc/incubator/helix/site-content/xref-test/org/apache/helix/integration/TestAutoRebalance.html?rev=1484629&r1=1484628&r2=1484629&view=diff
==============================================================================
--- incubator/helix/site-content/xref-test/org/apache/helix/integration/TestAutoRebalance.html (original)
+++ incubator/helix/site-content/xref-test/org/apache/helix/integration/TestAutoRebalance.html Tue May 21 00:45:01 2013
@@ -129,7 +129,7 @@
<a class="jxr_linenumber" name="119" href="#119">119</a> _startCMResultMap.put(controllerName, startResult);
<a class="jxr_linenumber" name="120" href="#120">120</a>
<a class="jxr_linenumber" name="121" href="#121">121</a> <strong class="jxr_keyword">boolean</strong> result =
-<a class="jxr_linenumber" name="122" href="#122">122</a> ClusterStateVerifier.verifyByZkCallback(<strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestAutoRebalancePartitionLimit.html">ExternalViewBalancedVerifier</a>(_zkClient,
+<a class="jxr_linenumber" name="122" href="#122">122</a> ClusterStateVerifier.verifyByZkCallback(<strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestCustomizedIdealStateRebalancer.html">ExternalViewBalancedVerifier</a>(_zkClient,
<a class="jxr_linenumber" name="123" href="#123">123</a> CLUSTER_NAME, TEST_DB));
<a class="jxr_linenumber" name="124" href="#124">124</a>
<a class="jxr_linenumber" name="125" href="#125">125</a> Assert.assertTrue(result);
@@ -147,7 +147,7 @@
<a class="jxr_linenumber" name="137" href="#137">137</a> _setupTool.rebalanceStorageCluster(CLUSTER_NAME, <span class="jxr_string">"MyDB"</span>, 1);
<a class="jxr_linenumber" name="138" href="#138">138</a>
<a class="jxr_linenumber" name="139" href="#139">139</a> <strong class="jxr_keyword">boolean</strong> result =
-<a class="jxr_linenumber" name="140" href="#140">140</a> ClusterStateVerifier.verifyByZkCallback(<strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestAutoRebalancePartitionLimit.html">ExternalViewBalancedVerifier</a>(_zkClient,
+<a class="jxr_linenumber" name="140" href="#140">140</a> ClusterStateVerifier.verifyByZkCallback(<strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestCustomizedIdealStateRebalancer.html">ExternalViewBalancedVerifier</a>(_zkClient,
<a class="jxr_linenumber" name="141" href="#141">141</a> CLUSTER_NAME, <span class="jxr_string">"MyDB"</span>));
<a class="jxr_linenumber" name="142" href="#142">142</a> Assert.assertTrue(result);
<a class="jxr_linenumber" name="143" href="#143">143</a>
@@ -172,7 +172,7 @@
<a class="jxr_linenumber" name="162" href="#162">162</a> _setupTool.rebalanceStorageCluster(CLUSTER_NAME, <span class="jxr_string">"MyDB2"</span>, 3);
<a class="jxr_linenumber" name="163" href="#163">163</a>
<a class="jxr_linenumber" name="164" href="#164">164</a> result =
-<a class="jxr_linenumber" name="165" href="#165">165</a> ClusterStateVerifier.verifyByZkCallback(<strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestAutoRebalancePartitionLimit.html">ExternalViewBalancedVerifier</a>(_zkClient,
+<a class="jxr_linenumber" name="165" href="#165">165</a> ClusterStateVerifier.verifyByZkCallback(<strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestCustomizedIdealStateRebalancer.html">ExternalViewBalancedVerifier</a>(_zkClient,
<a class="jxr_linenumber" name="166" href="#166">166</a> CLUSTER_NAME, <span class="jxr_string">"MyDB2"</span>));
<a class="jxr_linenumber" name="167" href="#167">167</a> Assert.assertTrue(result);
<a class="jxr_linenumber" name="168" href="#168">168</a>
@@ -207,7 +207,7 @@
<a class="jxr_linenumber" name="197" href="#197">197</a>
<a class="jxr_linenumber" name="198" href="#198">198</a> <em class="jxr_comment">//verifyBalanceExternalView();</em>
<a class="jxr_linenumber" name="199" href="#199">199</a> <strong class="jxr_keyword">boolean</strong> result =
-<a class="jxr_linenumber" name="200" href="#200">200</a> ClusterStateVerifier.verifyByZkCallback(<strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestAutoRebalancePartitionLimit.html">ExternalViewBalancedVerifier</a>(_zkClient,
+<a class="jxr_linenumber" name="200" href="#200">200</a> ClusterStateVerifier.verifyByZkCallback(<strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestCustomizedIdealStateRebalancer.html">ExternalViewBalancedVerifier</a>(_zkClient,
<a class="jxr_linenumber" name="201" href="#201">201</a> CLUSTER_NAME, TEST_DB));
<a class="jxr_linenumber" name="202" href="#202">202</a> Assert.assertTrue(result);
<a class="jxr_linenumber" name="203" href="#203">203</a>
@@ -223,12 +223,12 @@
<a class="jxr_linenumber" name="213" href="#213">213</a> }
<a class="jxr_linenumber" name="214" href="#214">214</a> Thread.sleep(1000);
<a class="jxr_linenumber" name="215" href="#215">215</a> result =
-<a class="jxr_linenumber" name="216" href="#216">216</a> ClusterStateVerifier.verifyByZkCallback(<strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestAutoRebalancePartitionLimit.html">ExternalViewBalancedVerifier</a>(_zkClient,
+<a class="jxr_linenumber" name="216" href="#216">216</a> ClusterStateVerifier.verifyByZkCallback(<strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestCustomizedIdealStateRebalancer.html">ExternalViewBalancedVerifier</a>(_zkClient,
<a class="jxr_linenumber" name="217" href="#217">217</a> CLUSTER_NAME, TEST_DB));
<a class="jxr_linenumber" name="218" href="#218">218</a> Assert.assertTrue(result);
<a class="jxr_linenumber" name="219" href="#219">219</a>
<a class="jxr_linenumber" name="220" href="#220">220</a> result =
-<a class="jxr_linenumber" name="221" href="#221">221</a> ClusterStateVerifier.verifyByZkCallback(<strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestAutoRebalancePartitionLimit.html">ExternalViewBalancedVerifier</a>(_zkClient,
+<a class="jxr_linenumber" name="221" href="#221">221</a> ClusterStateVerifier.verifyByZkCallback(<strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestCustomizedIdealStateRebalancer.html">ExternalViewBalancedVerifier</a>(_zkClient,
<a class="jxr_linenumber" name="222" href="#222">222</a> CLUSTER_NAME, db2));
<a class="jxr_linenumber" name="223" href="#223">223</a> Assert.assertTrue(result);
<a class="jxr_linenumber" name="224" href="#224">224</a> HelixDataAccessor accessor = <strong class="jxr_keyword">new</strong> ZKHelixDataAccessor( CLUSTER_NAME, <strong class="jxr_keyword">new</strong> ZkBaseDataAccessor(_zkClient));
@@ -297,13 +297,13 @@
<a class="jxr_linenumber" name="287" href="#287">287</a>
<a class="jxr_linenumber" name="288" href="#288">288</a> }
<a class="jxr_linenumber" name="289" href="#289">289</a>
-<a class="jxr_linenumber" name="290" href="#290">290</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">static</strong> <strong class="jxr_keyword">class</strong> <a href="../../../../org/apache/helix/integration/TestAutoRebalancePartitionLimit.html">ExternalViewBalancedVerifier</a> <strong class="jxr_keyword">implements</strong> ZkVerifier
+<a class="jxr_linenumber" name="290" href="#290">290</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">static</strong> <strong class="jxr_keyword">class</strong> <a href="../../../../org/apache/helix/integration/TestCustomizedIdealStateRebalancer.html">ExternalViewBalancedVerifier</a> <strong class="jxr_keyword">implements</strong> ZkVerifier
<a class="jxr_linenumber" name="291" href="#291">291</a> {
<a class="jxr_linenumber" name="292" href="#292">292</a> ZkClient _client;
<a class="jxr_linenumber" name="293" href="#293">293</a> String _clusterName;
<a class="jxr_linenumber" name="294" href="#294">294</a> String _resourceName;
<a class="jxr_linenumber" name="295" href="#295">295</a>
-<a class="jxr_linenumber" name="296" href="#296">296</a> <strong class="jxr_keyword">public</strong> <a href="../../../../org/apache/helix/integration/TestAutoRebalancePartitionLimit.html">ExternalViewBalancedVerifier</a>(ZkClient client, String clusterName, String resourceName)
+<a class="jxr_linenumber" name="296" href="#296">296</a> <strong class="jxr_keyword">public</strong> <a href="../../../../org/apache/helix/integration/TestCustomizedIdealStateRebalancer.html">ExternalViewBalancedVerifier</a>(ZkClient client, String clusterName, String resourceName)
<a class="jxr_linenumber" name="297" href="#297">297</a> {
<a class="jxr_linenumber" name="298" href="#298">298</a> _client = client;
<a class="jxr_linenumber" name="299" href="#299">299</a> _clusterName = clusterName;
Modified: incubator/helix/site-content/xref-test/org/apache/helix/integration/TestAutoRebalancePartitionLimit.html
URL: http://svn.apache.org/viewvc/incubator/helix/site-content/xref-test/org/apache/helix/integration/TestAutoRebalancePartitionLimit.html?rev=1484629&r1=1484628&r2=1484629&view=diff
==============================================================================
--- incubator/helix/site-content/xref-test/org/apache/helix/integration/TestAutoRebalancePartitionLimit.html (original)
+++ incubator/helix/site-content/xref-test/org/apache/helix/integration/TestAutoRebalancePartitionLimit.html Tue May 21 00:45:01 2013
@@ -113,7 +113,7 @@
<a class="jxr_linenumber" name="103" href="#103">103</a> _startCMResultMap.put(instanceName, startResult);
<a class="jxr_linenumber" name="104" href="#104">104</a> Thread.sleep(2000);
<a class="jxr_linenumber" name="105" href="#105">105</a> <strong class="jxr_keyword">boolean</strong> result =
-<a class="jxr_linenumber" name="106" href="#106">106</a> ClusterStateVerifier.verifyByZkCallback(<strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestAutoRebalancePartitionLimit.html">ExternalViewBalancedVerifier</a>(_zkClient,
+<a class="jxr_linenumber" name="106" href="#106">106</a> ClusterStateVerifier.verifyByZkCallback(<strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestCustomizedIdealStateRebalancer.html">ExternalViewBalancedVerifier</a>(_zkClient,
<a class="jxr_linenumber" name="107" href="#107">107</a> CLUSTER_NAME, TEST_DB));
<a class="jxr_linenumber" name="108" href="#108">108</a> Assert.assertTrue(result);
<a class="jxr_linenumber" name="109" href="#109">109</a> ExternalView ev = manager.getHelixDataAccessor().getProperty(accessor.keyBuilder().externalView(TEST_DB));
@@ -130,7 +130,7 @@
<a class="jxr_linenumber" name="120" href="#120">120</a> }
<a class="jxr_linenumber" name="121" href="#121">121</a>
<a class="jxr_linenumber" name="122" href="#122">122</a> <strong class="jxr_keyword">boolean</strong> result =
-<a class="jxr_linenumber" name="123" href="#123">123</a> ClusterStateVerifier.verifyByZkCallback(<strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestAutoRebalancePartitionLimit.html">ExternalViewBalancedVerifier</a>(_zkClient,
+<a class="jxr_linenumber" name="123" href="#123">123</a> ClusterStateVerifier.verifyByZkCallback(<strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestCustomizedIdealStateRebalancer.html">ExternalViewBalancedVerifier</a>(_zkClient,
<a class="jxr_linenumber" name="124" href="#124">124</a> CLUSTER_NAME, TEST_DB));
<a class="jxr_linenumber" name="125" href="#125">125</a>
<a class="jxr_linenumber" name="126" href="#126">126</a> Assert.assertTrue(result);
@@ -149,7 +149,7 @@
<a class="jxr_linenumber" name="139" href="#139">139</a>
<a class="jxr_linenumber" name="140" href="#140">140</a> <em class="jxr_comment">//verifyBalanceExternalView();</em>
<a class="jxr_linenumber" name="141" href="#141">141</a> <strong class="jxr_keyword">boolean</strong> result =
-<a class="jxr_linenumber" name="142" href="#142">142</a> ClusterStateVerifier.verifyByZkCallback(<strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestAutoRebalancePartitionLimit.html">ExternalViewBalancedVerifier</a>(_zkClient,
+<a class="jxr_linenumber" name="142" href="#142">142</a> ClusterStateVerifier.verifyByZkCallback(<strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestCustomizedIdealStateRebalancer.html">ExternalViewBalancedVerifier</a>(_zkClient,
<a class="jxr_linenumber" name="143" href="#143">143</a> CLUSTER_NAME, TEST_DB));
<a class="jxr_linenumber" name="144" href="#144">144</a> Assert.assertTrue(result);
<a class="jxr_linenumber" name="145" href="#145">145</a> HelixDataAccessor accessor = manager.getHelixDataAccessor();
@@ -163,7 +163,7 @@
<a class="jxr_linenumber" name="153" href="#153">153</a>
<a class="jxr_linenumber" name="154" href="#154">154</a> <em class="jxr_comment">//verifyBalanceExternalView();</em>
<a class="jxr_linenumber" name="155" href="#155">155</a> result =
-<a class="jxr_linenumber" name="156" href="#156">156</a> ClusterStateVerifier.verifyByZkCallback(<strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestAutoRebalancePartitionLimit.html">ExternalViewBalancedVerifier</a>(_zkClient,
+<a class="jxr_linenumber" name="156" href="#156">156</a> ClusterStateVerifier.verifyByZkCallback(<strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestCustomizedIdealStateRebalancer.html">ExternalViewBalancedVerifier</a>(_zkClient,
<a class="jxr_linenumber" name="157" href="#157">157</a> CLUSTER_NAME, TEST_DB));
<a class="jxr_linenumber" name="158" href="#158">158</a> Assert.assertTrue(result);
<a class="jxr_linenumber" name="159" href="#159">159</a> ev = manager.getHelixDataAccessor().getProperty(accessor.keyBuilder().externalView(TEST_DB));
@@ -181,7 +181,7 @@
<a class="jxr_linenumber" name="171" href="#171">171</a> }
<a class="jxr_linenumber" name="172" href="#172">172</a> Thread.sleep(1000);
<a class="jxr_linenumber" name="173" href="#173">173</a> result =
-<a class="jxr_linenumber" name="174" href="#174">174</a> ClusterStateVerifier.verifyByZkCallback(<strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestAutoRebalancePartitionLimit.html">ExternalViewBalancedVerifier</a>(_zkClient,
+<a class="jxr_linenumber" name="174" href="#174">174</a> ClusterStateVerifier.verifyByZkCallback(<strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestCustomizedIdealStateRebalancer.html">ExternalViewBalancedVerifier</a>(_zkClient,
<a class="jxr_linenumber" name="175" href="#175">175</a> CLUSTER_NAME, TEST_DB));
<a class="jxr_linenumber" name="176" href="#176">176</a> Assert.assertTrue(result);
<a class="jxr_linenumber" name="177" href="#177">177</a> }
@@ -241,13 +241,13 @@
<a class="jxr_linenumber" name="231" href="#231">231</a>
<a class="jxr_linenumber" name="232" href="#232">232</a> }
<a class="jxr_linenumber" name="233" href="#233">233</a>
-<a class="jxr_linenumber" name="234" href="#234">234</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">static</strong> <strong class="jxr_keyword">class</strong> <a href="../../../../org/apache/helix/integration/TestAutoRebalancePartitionLimit.html">ExternalViewBalancedVerifier</a> <strong class="jxr_keyword">implements</strong> ZkVerifier
+<a class="jxr_linenumber" name="234" href="#234">234</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">static</strong> <strong class="jxr_keyword">class</strong> <a href="../../../../org/apache/helix/integration/TestCustomizedIdealStateRebalancer.html">ExternalViewBalancedVerifier</a> <strong class="jxr_keyword">implements</strong> ZkVerifier
<a class="jxr_linenumber" name="235" href="#235">235</a> {
<a class="jxr_linenumber" name="236" href="#236">236</a> ZkClient _client;
<a class="jxr_linenumber" name="237" href="#237">237</a> String _clusterName;
<a class="jxr_linenumber" name="238" href="#238">238</a> String _resourceName;
<a class="jxr_linenumber" name="239" href="#239">239</a>
-<a class="jxr_linenumber" name="240" href="#240">240</a> <strong class="jxr_keyword">public</strong> <a href="../../../../org/apache/helix/integration/TestAutoRebalancePartitionLimit.html">ExternalViewBalancedVerifier</a>(ZkClient client, String clusterName, String resourceName)
+<a class="jxr_linenumber" name="240" href="#240">240</a> <strong class="jxr_keyword">public</strong> <a href="../../../../org/apache/helix/integration/TestCustomizedIdealStateRebalancer.html">ExternalViewBalancedVerifier</a>(ZkClient client, String clusterName, String resourceName)
<a class="jxr_linenumber" name="241" href="#241">241</a> {
<a class="jxr_linenumber" name="242" href="#242">242</a> _client = client;
<a class="jxr_linenumber" name="243" href="#243">243</a> _clusterName = clusterName;
Modified: incubator/helix/site-content/xref-test/org/apache/helix/integration/TestCustomizedIdealStateRebalancer.html
URL: http://svn.apache.org/viewvc/incubator/helix/site-content/xref-test/org/apache/helix/integration/TestCustomizedIdealStateRebalancer.html?rev=1484629&r1=1484628&r2=1484629&view=diff
==============================================================================
--- incubator/helix/site-content/xref-test/org/apache/helix/integration/TestCustomizedIdealStateRebalancer.html (original)
+++ incubator/helix/site-content/xref-test/org/apache/helix/integration/TestCustomizedIdealStateRebalancer.html Tue May 21 00:45:01 2013
@@ -92,7 +92,7 @@
<a class="jxr_linenumber" name="82" href="#82">82</a> _setupTool.rebalanceStorageCluster(CLUSTER_NAME, db2, 3);
<a class="jxr_linenumber" name="83" href="#83">83</a>
<a class="jxr_linenumber" name="84" href="#84">84</a> <strong class="jxr_keyword">boolean</strong> result =
-<a class="jxr_linenumber" name="85" href="#85">85</a> ClusterStateVerifier.verifyByZkCallback(<strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestAutoRebalancePartitionLimit.html">ExternalViewBalancedVerifier</a>(_zkClient,
+<a class="jxr_linenumber" name="85" href="#85">85</a> ClusterStateVerifier.verifyByZkCallback(<strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestCustomizedIdealStateRebalancer.html">ExternalViewBalancedVerifier</a>(_zkClient,
<a class="jxr_linenumber" name="86" href="#86">86</a> CLUSTER_NAME, db2));
<a class="jxr_linenumber" name="87" href="#87">87</a> Assert.assertTrue(result);
<a class="jxr_linenumber" name="88" href="#88">88</a> Thread.sleep(1000);
@@ -113,13 +113,13 @@
<a class="jxr_linenumber" name="103" href="#103">103</a> Assert.assertTrue(testRebalancerCreated);
<a class="jxr_linenumber" name="104" href="#104">104</a> }
<a class="jxr_linenumber" name="105" href="#105">105</a>
-<a class="jxr_linenumber" name="106" href="#106">106</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">static</strong> <strong class="jxr_keyword">class</strong> <a href="../../../../org/apache/helix/integration/TestAutoRebalancePartitionLimit.html">ExternalViewBalancedVerifier</a> <strong class="jxr_keyword">implements</strong> ZkVerifier
+<a class="jxr_linenumber" name="106" href="#106">106</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">static</strong> <strong class="jxr_keyword">class</strong> <a href="../../../../org/apache/helix/integration/TestCustomizedIdealStateRebalancer.html">ExternalViewBalancedVerifier</a> <strong class="jxr_keyword">implements</strong> ZkVerifier
<a class="jxr_linenumber" name="107" href="#107">107</a> {
<a class="jxr_linenumber" name="108" href="#108">108</a> ZkClient _client;
<a class="jxr_linenumber" name="109" href="#109">109</a> String _clusterName;
<a class="jxr_linenumber" name="110" href="#110">110</a> String _resourceName;
<a class="jxr_linenumber" name="111" href="#111">111</a>
-<a class="jxr_linenumber" name="112" href="#112">112</a> <strong class="jxr_keyword">public</strong> <a href="../../../../org/apache/helix/integration/TestAutoRebalancePartitionLimit.html">ExternalViewBalancedVerifier</a>(ZkClient client, String clusterName, String resourceName)
+<a class="jxr_linenumber" name="112" href="#112">112</a> <strong class="jxr_keyword">public</strong> <a href="../../../../org/apache/helix/integration/TestCustomizedIdealStateRebalancer.html">ExternalViewBalancedVerifier</a>(ZkClient client, String clusterName, String resourceName)
<a class="jxr_linenumber" name="113" href="#113">113</a> {
<a class="jxr_linenumber" name="114" href="#114">114</a> _client = client;
<a class="jxr_linenumber" name="115" href="#115">115</a> _clusterName = clusterName;
Modified: incubator/helix/site-content/xref-test/org/apache/helix/integration/TestMessagingService.html
URL: http://svn.apache.org/viewvc/incubator/helix/site-content/xref-test/org/apache/helix/integration/TestMessagingService.html?rev=1484629&r1=1484628&r2=1484629&view=diff
==============================================================================
--- incubator/helix/site-content/xref-test/org/apache/helix/integration/TestMessagingService.html (original)
+++ incubator/helix/site-content/xref-test/org/apache/helix/integration/TestMessagingService.html Tue May 21 00:45:01 2013
@@ -58,7 +58,7 @@
<a class="jxr_linenumber" name="48" href="#48">48</a> <strong class="jxr_keyword">public</strong> MessageHandler createHandler(Message message,
<a class="jxr_linenumber" name="49" href="#49">49</a> NotificationContext context)
<a class="jxr_linenumber" name="50" href="#50">50</a> {
-<a class="jxr_linenumber" name="51" href="#51">51</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestSchedulerMessage.html">TestMessagingHandler</a>(message, context);
+<a class="jxr_linenumber" name="51" href="#51">51</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestMessagingService.html">TestMessagingHandler</a>(message, context);
<a class="jxr_linenumber" name="52" href="#52">52</a> }
<a class="jxr_linenumber" name="53" href="#53">53</a>
<a class="jxr_linenumber" name="54" href="#54">54</a> @Override
@@ -74,9 +74,9 @@
<a class="jxr_linenumber" name="64" href="#64">64</a>
<a class="jxr_linenumber" name="65" href="#65">65</a> }
<a class="jxr_linenumber" name="66" href="#66">66</a>
-<a class="jxr_linenumber" name="67" href="#67">67</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">static</strong> <strong class="jxr_keyword">class</strong> <a href="../../../../org/apache/helix/integration/TestSchedulerMessage.html">TestMessagingHandler</a> <strong class="jxr_keyword">extends</strong> MessageHandler
+<a class="jxr_linenumber" name="67" href="#67">67</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">static</strong> <strong class="jxr_keyword">class</strong> <a href="../../../../org/apache/helix/integration/TestMessagingService.html">TestMessagingHandler</a> <strong class="jxr_keyword">extends</strong> MessageHandler
<a class="jxr_linenumber" name="68" href="#68">68</a> {
-<a class="jxr_linenumber" name="69" href="#69">69</a> <strong class="jxr_keyword">public</strong> <a href="../../../../org/apache/helix/integration/TestSchedulerMessage.html">TestMessagingHandler</a>(Message message, NotificationContext context)
+<a class="jxr_linenumber" name="69" href="#69">69</a> <strong class="jxr_keyword">public</strong> <a href="../../../../org/apache/helix/integration/TestMessagingService.html">TestMessagingHandler</a>(Message message, NotificationContext context)
<a class="jxr_linenumber" name="70" href="#70">70</a> {
<a class="jxr_linenumber" name="71" href="#71">71</a> <strong class="jxr_keyword">super</strong>(message, context);
<a class="jxr_linenumber" name="72" href="#72">72</a> <em class="jxr_comment">// TODO Auto-generated constructor stub</em>
@@ -151,10 +151,10 @@
<a class="jxr_linenumber" name="141" href="#141">141</a>
<a class="jxr_linenumber" name="142" href="#142">142</a> }
<a class="jxr_linenumber" name="143" href="#143">143</a>
-<a class="jxr_linenumber" name="144" href="#144">144</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">static</strong> <strong class="jxr_keyword">class</strong> <a href="../../../../org/apache/helix/integration/TestSchedulerMessage.html">MockAsyncCallback</a> <strong class="jxr_keyword">extends</strong> AsyncCallback
+<a class="jxr_linenumber" name="144" href="#144">144</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">static</strong> <strong class="jxr_keyword">class</strong> <a href="../../../../org/apache/helix/integration/TestMessagingService.html">MockAsyncCallback</a> <strong class="jxr_keyword">extends</strong> AsyncCallback
<a class="jxr_linenumber" name="145" href="#145">145</a> {
<a class="jxr_linenumber" name="146" href="#146">146</a>
-<a class="jxr_linenumber" name="147" href="#147">147</a> <strong class="jxr_keyword">public</strong> <a href="../../../../org/apache/helix/integration/TestSchedulerMessage.html">MockAsyncCallback</a>()
+<a class="jxr_linenumber" name="147" href="#147">147</a> <strong class="jxr_keyword">public</strong> <a href="../../../../org/apache/helix/integration/TestMessagingService.html">MockAsyncCallback</a>()
<a class="jxr_linenumber" name="148" href="#148">148</a> {
<a class="jxr_linenumber" name="149" href="#149">149</a> }
<a class="jxr_linenumber" name="150" href="#150">150</a>
@@ -174,9 +174,9 @@
<a class="jxr_linenumber" name="164" href="#164">164</a>
<a class="jxr_linenumber" name="165" href="#165">165</a> }
<a class="jxr_linenumber" name="166" href="#166">166</a>
-<a class="jxr_linenumber" name="167" href="#167">167</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">static</strong> <strong class="jxr_keyword">class</strong> <a href="../../../../org/apache/helix/messaging/TestAsyncCallbackSvc.html">TestAsyncCallback</a> <strong class="jxr_keyword">extends</strong> AsyncCallback
+<a class="jxr_linenumber" name="167" href="#167">167</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">static</strong> <strong class="jxr_keyword">class</strong> <a href="../../../../org/apache/helix/messaging/TestAsyncCallback.html">TestAsyncCallback</a> <strong class="jxr_keyword">extends</strong> AsyncCallback
<a class="jxr_linenumber" name="168" href="#168">168</a> {
-<a class="jxr_linenumber" name="169" href="#169">169</a> <strong class="jxr_keyword">public</strong> <a href="../../../../org/apache/helix/messaging/TestAsyncCallbackSvc.html">TestAsyncCallback</a>(<strong class="jxr_keyword">long</strong> timeout)
+<a class="jxr_linenumber" name="169" href="#169">169</a> <strong class="jxr_keyword">public</strong> <a href="../../../../org/apache/helix/messaging/TestAsyncCallback.html">TestAsyncCallback</a>(<strong class="jxr_keyword">long</strong> timeout)
<a class="jxr_linenumber" name="170" href="#170">170</a> {
<a class="jxr_linenumber" name="171" href="#171">171</a> <strong class="jxr_keyword">super</strong>(timeout);
<a class="jxr_linenumber" name="172" href="#172">172</a> }
@@ -240,7 +240,7 @@
<a class="jxr_linenumber" name="230" href="#230">230</a> cr.setRecipientInstanceType(InstanceType.PARTICIPANT);
<a class="jxr_linenumber" name="231" href="#231">231</a> cr.setSessionSpecific(false);
<a class="jxr_linenumber" name="232" href="#232">232</a>
-<a class="jxr_linenumber" name="233" href="#233">233</a> <a href="../../../../org/apache/helix/messaging/TestAsyncCallbackSvc.html">TestAsyncCallback</a> callback = <strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/messaging/TestAsyncCallbackSvc.html">TestAsyncCallback</a>(60000);
+<a class="jxr_linenumber" name="233" href="#233">233</a> <a href="../../../../org/apache/helix/messaging/TestAsyncCallback.html">TestAsyncCallback</a> callback = <strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/messaging/TestAsyncCallback.html">TestAsyncCallback</a>(60000);
<a class="jxr_linenumber" name="234" href="#234">234</a>
<a class="jxr_linenumber" name="235" href="#235">235</a> _startCMResultMap.get(hostSrc)._manager.getMessagingService().send(cr, msg, callback, 60000);
<a class="jxr_linenumber" name="236" href="#236">236</a>
@@ -250,7 +250,7 @@
<a class="jxr_linenumber" name="240" href="#240">240</a> .contains(<span class="jxr_string">"TestReplyMessage"</span>));
<a class="jxr_linenumber" name="241" href="#241">241</a> AssertJUnit.assertTrue(callback.getMessageReplied().size() == 1);
<a class="jxr_linenumber" name="242" href="#242">242</a>
-<a class="jxr_linenumber" name="243" href="#243">243</a> <a href="../../../../org/apache/helix/messaging/TestAsyncCallbackSvc.html">TestAsyncCallback</a> callback2 = <strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/messaging/TestAsyncCallbackSvc.html">TestAsyncCallback</a>(500);
+<a class="jxr_linenumber" name="243" href="#243">243</a> <a href="../../../../org/apache/helix/messaging/TestAsyncCallback.html">TestAsyncCallback</a> callback2 = <strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/messaging/TestAsyncCallback.html">TestAsyncCallback</a>(500);
<a class="jxr_linenumber" name="244" href="#244">244</a> _startCMResultMap.get(hostSrc)._manager.getMessagingService().send(cr, msg, callback2, 500);
<a class="jxr_linenumber" name="245" href="#245">245</a>
<a class="jxr_linenumber" name="246" href="#246">246</a> Thread.sleep(3000);
@@ -263,7 +263,7 @@
<a class="jxr_linenumber" name="253" href="#253">253</a> cr.setSessionSpecific(false);
<a class="jxr_linenumber" name="254" href="#254">254</a> cr.setDataSource(DataSource.IDEALSTATES);
<a class="jxr_linenumber" name="255" href="#255">255</a>
-<a class="jxr_linenumber" name="256" href="#256">256</a> callback = <strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/messaging/TestAsyncCallbackSvc.html">TestAsyncCallback</a>(60000);
+<a class="jxr_linenumber" name="256" href="#256">256</a> callback = <strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/messaging/TestAsyncCallback.html">TestAsyncCallback</a>(60000);
<a class="jxr_linenumber" name="257" href="#257">257</a>
<a class="jxr_linenumber" name="258" href="#258">258</a> _startCMResultMap.get(hostSrc)._manager.getMessagingService().send(cr, msg, callback, 60000);
<a class="jxr_linenumber" name="259" href="#259">259</a>
@@ -273,7 +273,7 @@
<a class="jxr_linenumber" name="263" href="#263">263</a> .contains(<span class="jxr_string">"TestReplyMessage"</span>));
<a class="jxr_linenumber" name="264" href="#264">264</a> AssertJUnit.assertTrue(callback.getMessageReplied().size() == 1);
<a class="jxr_linenumber" name="265" href="#265">265</a>
-<a class="jxr_linenumber" name="266" href="#266">266</a> callback2 = <strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/messaging/TestAsyncCallbackSvc.html">TestAsyncCallback</a>(500);
+<a class="jxr_linenumber" name="266" href="#266">266</a> callback2 = <strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/messaging/TestAsyncCallback.html">TestAsyncCallback</a>(500);
<a class="jxr_linenumber" name="267" href="#267">267</a> _startCMResultMap.get(hostSrc)._manager.getMessagingService().send(cr, msg, callback2, 500);
<a class="jxr_linenumber" name="268" href="#268">268</a>
<a class="jxr_linenumber" name="269" href="#269">269</a> Thread.sleep(3000);
@@ -307,7 +307,7 @@
<a class="jxr_linenumber" name="297" href="#297">297</a> cr.setRecipientInstanceType(InstanceType.PARTICIPANT);
<a class="jxr_linenumber" name="298" href="#298">298</a> cr.setSessionSpecific(false);
<a class="jxr_linenumber" name="299" href="#299">299</a>
-<a class="jxr_linenumber" name="300" href="#300">300</a> AsyncCallback asyncCallback = <strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestSchedulerMessage.html">MockAsyncCallback</a>();
+<a class="jxr_linenumber" name="300" href="#300">300</a> AsyncCallback asyncCallback = <strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestMessagingService.html">MockAsyncCallback</a>();
<a class="jxr_linenumber" name="301" href="#301">301</a> <strong class="jxr_keyword">int</strong> messagesSent = _startCMResultMap.get(hostSrc)._manager.getMessagingService()
<a class="jxr_linenumber" name="302" href="#302">302</a> .sendAndWait(cr, msg, asyncCallback, 60000);
<a class="jxr_linenumber" name="303" href="#303">303</a>
@@ -317,7 +317,7 @@
<a class="jxr_linenumber" name="307" href="#307">307</a> AssertJUnit.assertTrue(asyncCallback.getMessageReplied().size() == 1);
<a class="jxr_linenumber" name="308" href="#308">308</a>
<a class="jxr_linenumber" name="309" href="#309">309</a>
-<a class="jxr_linenumber" name="310" href="#310">310</a> AsyncCallback asyncCallback2 = <strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestSchedulerMessage.html">MockAsyncCallback</a>();
+<a class="jxr_linenumber" name="310" href="#310">310</a> AsyncCallback asyncCallback2 = <strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestMessagingService.html">MockAsyncCallback</a>();
<a class="jxr_linenumber" name="311" href="#311">311</a> messagesSent = _startCMResultMap.get(hostSrc)._manager.getMessagingService()
<a class="jxr_linenumber" name="312" href="#312">312</a> .sendAndWait(cr, msg, asyncCallback2, 500);
<a class="jxr_linenumber" name="313" href="#313">313</a> AssertJUnit.assertTrue(asyncCallback2.isTimedOut());
@@ -351,7 +351,7 @@
<a class="jxr_linenumber" name="341" href="#341">341</a> cr.setInstanceName(<span class="jxr_string">"%"</span>);
<a class="jxr_linenumber" name="342" href="#342">342</a> cr.setRecipientInstanceType(InstanceType.PARTICIPANT);
<a class="jxr_linenumber" name="343" href="#343">343</a> cr.setSessionSpecific(false);
-<a class="jxr_linenumber" name="344" href="#344">344</a> AsyncCallback callback1 = <strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestSchedulerMessage.html">MockAsyncCallback</a>();
+<a class="jxr_linenumber" name="344" href="#344">344</a> AsyncCallback callback1 = <strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestMessagingService.html">MockAsyncCallback</a>();
<a class="jxr_linenumber" name="345" href="#345">345</a> <strong class="jxr_keyword">int</strong> messageSent1 = _startCMResultMap.get(hostSrc)._manager.getMessagingService()
<a class="jxr_linenumber" name="346" href="#346">346</a> .sendAndWait(cr, msg, callback1, 10000);
<a class="jxr_linenumber" name="347" href="#347">347</a>
@@ -360,32 +360,32 @@
<a class="jxr_linenumber" name="350" href="#350">350</a> .get(<span class="jxr_string">"ReplyMessage"</span>).equals(<span class="jxr_string">"TestReplyMessage"</span>));
<a class="jxr_linenumber" name="351" href="#351">351</a> AssertJUnit.assertTrue(callback1.getMessageReplied().size() == NODE_NR - 1);
<a class="jxr_linenumber" name="352" href="#352">352</a>
-<a class="jxr_linenumber" name="353" href="#353">353</a> AsyncCallback callback2 = <strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestSchedulerMessage.html">MockAsyncCallback</a>();
+<a class="jxr_linenumber" name="353" href="#353">353</a> AsyncCallback callback2 = <strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestMessagingService.html">MockAsyncCallback</a>();
<a class="jxr_linenumber" name="354" href="#354">354</a> <strong class="jxr_keyword">int</strong> messageSent2 = _startCMResultMap.get(hostSrc)._manager.getMessagingService()
<a class="jxr_linenumber" name="355" href="#355">355</a> .sendAndWait(cr, msg, callback2, 500);
<a class="jxr_linenumber" name="356" href="#356">356</a> AssertJUnit.assertTrue(callback2.isTimedOut());
<a class="jxr_linenumber" name="357" href="#357">357</a>
<a class="jxr_linenumber" name="358" href="#358">358</a> cr.setPartition(<span class="jxr_string">"TestDB_17"</span>);
-<a class="jxr_linenumber" name="359" href="#359">359</a> AsyncCallback callback3 = <strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestSchedulerMessage.html">MockAsyncCallback</a>();
+<a class="jxr_linenumber" name="359" href="#359">359</a> AsyncCallback callback3 = <strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestMessagingService.html">MockAsyncCallback</a>();
<a class="jxr_linenumber" name="360" href="#360">360</a> <strong class="jxr_keyword">int</strong> messageSent3 = _startCMResultMap.get(hostSrc)._manager.getMessagingService()
<a class="jxr_linenumber" name="361" href="#361">361</a> .sendAndWait(cr, msg, callback3, 10000);
<a class="jxr_linenumber" name="362" href="#362">362</a> AssertJUnit.assertTrue(callback3.getMessageReplied().size() == _replica - 1);
<a class="jxr_linenumber" name="363" href="#363">363</a>
<a class="jxr_linenumber" name="364" href="#364">364</a>
<a class="jxr_linenumber" name="365" href="#365">365</a> cr.setPartition(<span class="jxr_string">"TestDB_15"</span>);
-<a class="jxr_linenumber" name="366" href="#366">366</a> AsyncCallback callback4 = <strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestSchedulerMessage.html">MockAsyncCallback</a>();
+<a class="jxr_linenumber" name="366" href="#366">366</a> AsyncCallback callback4 = <strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestMessagingService.html">MockAsyncCallback</a>();
<a class="jxr_linenumber" name="367" href="#367">367</a> <strong class="jxr_keyword">int</strong> messageSent4 = _startCMResultMap.get(hostSrc)._manager.getMessagingService()
<a class="jxr_linenumber" name="368" href="#368">368</a> .sendAndWait(cr, msg, callback4, 10000);
<a class="jxr_linenumber" name="369" href="#369">369</a> AssertJUnit.assertTrue(callback4.getMessageReplied().size() == _replica);
<a class="jxr_linenumber" name="370" href="#370">370</a>
<a class="jxr_linenumber" name="371" href="#371">371</a> cr.setPartitionState(<span class="jxr_string">"SLAVE"</span>);
-<a class="jxr_linenumber" name="372" href="#372">372</a> AsyncCallback callback5 = <strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestSchedulerMessage.html">MockAsyncCallback</a>();
+<a class="jxr_linenumber" name="372" href="#372">372</a> AsyncCallback callback5 = <strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestMessagingService.html">MockAsyncCallback</a>();
<a class="jxr_linenumber" name="373" href="#373">373</a> <strong class="jxr_keyword">int</strong> messageSent5 = _startCMResultMap.get(hostSrc)._manager.getMessagingService()
<a class="jxr_linenumber" name="374" href="#374">374</a> .sendAndWait(cr, msg, callback5, 10000);
<a class="jxr_linenumber" name="375" href="#375">375</a> AssertJUnit.assertTrue(callback5.getMessageReplied().size() == _replica - 1);
<a class="jxr_linenumber" name="376" href="#376">376</a>
<a class="jxr_linenumber" name="377" href="#377">377</a> cr.setDataSource(DataSource.IDEALSTATES);
-<a class="jxr_linenumber" name="378" href="#378">378</a> AsyncCallback callback6 = <strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestSchedulerMessage.html">MockAsyncCallback</a>();
+<a class="jxr_linenumber" name="378" href="#378">378</a> AsyncCallback callback6 = <strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestMessagingService.html">MockAsyncCallback</a>();
<a class="jxr_linenumber" name="379" href="#379">379</a> <strong class="jxr_keyword">int</strong> messageSent6 = _startCMResultMap.get(hostSrc)._manager.getMessagingService()
<a class="jxr_linenumber" name="380" href="#380">380</a> .sendAndWait(cr, msg, callback6, 10000);
<a class="jxr_linenumber" name="381" href="#381">381</a> AssertJUnit.assertTrue(callback6.getMessageReplied().size() == _replica - 1);
@@ -419,7 +419,7 @@
<a class="jxr_linenumber" name="409" href="#409">409</a> cr.setRecipientInstanceType(InstanceType.PARTICIPANT);
<a class="jxr_linenumber" name="410" href="#410">410</a> cr.setSessionSpecific(false);
<a class="jxr_linenumber" name="411" href="#411">411</a> cr.setSelfExcluded(false);
-<a class="jxr_linenumber" name="412" href="#412">412</a> AsyncCallback callback1 = <strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestSchedulerMessage.html">MockAsyncCallback</a>();
+<a class="jxr_linenumber" name="412" href="#412">412</a> AsyncCallback callback1 = <strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestMessagingService.html">MockAsyncCallback</a>();
<a class="jxr_linenumber" name="413" href="#413">413</a> <strong class="jxr_keyword">int</strong> messageSent1 = _startCMResultMap.get(hostSrc)._manager.getMessagingService()
<a class="jxr_linenumber" name="414" href="#414">414</a> .sendAndWait(cr, msg, callback1, 10000);
<a class="jxr_linenumber" name="415" href="#415">415</a>
@@ -456,7 +456,7 @@
<a class="jxr_linenumber" name="446" href="#446">446</a> cr.setRecipientInstanceType(InstanceType.CONTROLLER);
<a class="jxr_linenumber" name="447" href="#447">447</a> cr.setSessionSpecific(false);
<a class="jxr_linenumber" name="448" href="#448">448</a>
-<a class="jxr_linenumber" name="449" href="#449">449</a> AsyncCallback callback1 = <strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestSchedulerMessage.html">MockAsyncCallback</a>();
+<a class="jxr_linenumber" name="449" href="#449">449</a> AsyncCallback callback1 = <strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestMessagingService.html">MockAsyncCallback</a>();
<a class="jxr_linenumber" name="450" href="#450">450</a> <strong class="jxr_keyword">int</strong> messagesSent = _startCMResultMap.get(hostSrc)._manager.getMessagingService()
<a class="jxr_linenumber" name="451" href="#451">451</a> .sendAndWait(cr, msg, callback1, 10000);
<a class="jxr_linenumber" name="452" href="#452">452</a>
@@ -468,7 +468,7 @@
<a class="jxr_linenumber" name="458" href="#458">458</a> msgId = UUID.randomUUID().toString();
<a class="jxr_linenumber" name="459" href="#459">459</a> msg.setMsgId(msgId);
<a class="jxr_linenumber" name="460" href="#460">460</a> cr.setPartition(<span class="jxr_string">"TestDB_17"</span>);
-<a class="jxr_linenumber" name="461" href="#461">461</a> AsyncCallback callback2 = <strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestSchedulerMessage.html">MockAsyncCallback</a>();
+<a class="jxr_linenumber" name="461" href="#461">461</a> AsyncCallback callback2 = <strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestMessagingService.html">MockAsyncCallback</a>();
<a class="jxr_linenumber" name="462" href="#462">462</a> messagesSent = _startCMResultMap.get(hostSrc)._manager.getMessagingService()
<a class="jxr_linenumber" name="463" href="#463">463</a> .sendAndWait(cr, msg, callback2, 10000);
<a class="jxr_linenumber" name="464" href="#464">464</a> AssertJUnit.assertTrue(callback2.getMessageReplied().get(0).getRecord()
@@ -480,7 +480,7 @@
<a class="jxr_linenumber" name="470" href="#470">470</a> msgId = UUID.randomUUID().toString();
<a class="jxr_linenumber" name="471" href="#471">471</a> msg.setMsgId(msgId);
<a class="jxr_linenumber" name="472" href="#472">472</a> cr.setPartitionState(<span class="jxr_string">"SLAVE"</span>);
-<a class="jxr_linenumber" name="473" href="#473">473</a> AsyncCallback callback3 = <strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestSchedulerMessage.html">MockAsyncCallback</a>();
+<a class="jxr_linenumber" name="473" href="#473">473</a> AsyncCallback callback3 = <strong class="jxr_keyword">new</strong> <a href="../../../../org/apache/helix/integration/TestMessagingService.html">MockAsyncCallback</a>();
<a class="jxr_linenumber" name="474" href="#474">474</a> messagesSent = _startCMResultMap.get(hostSrc)._manager.getMessagingService()
<a class="jxr_linenumber" name="475" href="#475">475</a> .sendAndWait(cr, msg, callback3, 10000);
<a class="jxr_linenumber" name="476" href="#476">476</a> AssertJUnit.assertTrue(callback3.getMessageReplied().get(0).getRecord()