Home
last modified time | relevance | path

Searched refs:servers (Results 1 - 25 of 172) sorted by relevance

1234567

/3.0.3-GA/ns_server/priv/js-unit-tests/t/
H A Dview-helper-test.js5 var servers = [
14 assertEquals("lh:9000", ViewHelpers.maybeStripPort(servers[0].hostname, servers));
15 assertEquals("lh:9001", ViewHelpers.maybeStripPort(servers[1].hostname, servers));
16 assertEquals("dn2:8091", ViewHelpers.maybeStripPort(servers[2].hostname, servers));
19 assertEquals("lh:9000", ViewHelpers.maybeStripPort(servers[0].hostname, servers));
20 assertEquals("lh:9001", ViewHelpers.maybeStripPort(servers[
[all...]
/3.0.3-GA/testrunner/pytests/hostname/
H A Dhostnamemgmt_tests.py15 hostnames = self.rename_nodes(self.servers)
16 self.verify_referenced_by_names(self.servers, hostnames)
20 for server in self.servers[1:self.nodes_in + 1]:
22 self.verify_referenced_by_names(self.servers, hostnames)
25 hostnames = self.rename_nodes(self.servers)
26 self.verify_referenced_by_names(self.servers, hostnames)
28 self.cluster.rebalance(self.servers[:1], self.servers[1:self.nodes_in + 1], [], use_hostnames=True)
29 self.verify_referenced_by_names(self.servers, hostnames)
37 for server in self.servers[
[all...]
H A Dhostnamemgmt_base.py13 self._deinitialize_servers(self.servers)
16 def _deinitialize_servers(self, servers):
17 for server in servers:
22 def rename_nodes(self, servers, names={}):
24 for server in servers:
41 for i in xrange(len(self.servers)):
42 if self.servers[i] in hostnames:
43 if server and server.ip != self.servers[i].ip:
45 self.servers[i].hostname = hostnames[self.servers[
[all...]
H A Dhostnamemgmt_multirenames_tests.py27 if len(self.servers) < 2:
29 hostnames = self.rename_nodes(self.servers[:self.nodes_in + self.nodes_init])
31 self.cluster.rebalance(self.servers[:self.nodes_init],
32 self.servers[self.nodes_init:self.nodes_in + self.nodes_init], [], use_hostnames=True)
33 self.verify_referenced_by_names(self.servers[:self.nodes_init], hostnames)
34 remove_node = self.servers[:self.nodes_in + self.nodes_init][-1]
35 self.cluster.rebalance(self.servers[:self.nodes_in + self.nodes_init],
41 self.cluster.rebalance(self.servers[:self.nodes_in + self.nodes_init - 1],
43 for srv in self.servers:
47 self.verify_referenced_by_names(self.servers[
[all...]
/3.0.3-GA/testrunner/pytests/tuqquery/
H A Dtuq_cluster_ops.py14 self.cluster.rebalance(self.servers[:1], self.servers[1:self.nodes_init], [])
29 ClusterOperationHelper.cleanup_cluster(self.servers)
37 self.assertTrue(len(self.servers) >= self.nodes_in + 1, "Servers are not enough")
40 rebalance = self.cluster.async_rebalance(self.servers[:i],
41 self.servers[i:i+1], [])
47 self.assertTrue(len(self.servers[:self.nodes_init]) > self.nodes_out,
51 rebalance = self.cluster.async_rebalance(self.servers[:self.nodes_init - (i-1)],
53 self.servers[self.nodes_init - i:self.nodes_init - (i-1)])
59 self.assertTrue(len(self.servers) >
[all...]
/3.0.3-GA/testrunner/pytests/rebalance/
H A Drebalanceout.py22 This test begins with all servers clustered together and loads a user defined
43 servs_out = [self.servers[self.num_servers - i - 1] for i in range(self.nodes_out)]
44 self._verify_stats_all_buckets(self.servers[:self.num_servers], timeout=120)
45 self._wait_for_stats_all_buckets(self.servers[:self.num_servers])
46 prev_failover_stats = self.get_failovers_logs(self.servers[:self.num_servers], self.buckets)
47 prev_vbucket_stats = self.get_vbucket_seqnos(self.servers[:self.num_servers], self.buckets)
48 record_data_set = self.get_data_set_all(self.servers[:self.num_servers], self.buckets)
50 rebalance = self.cluster.async_rebalance(self.servers[:1], [], servs_out)
52 self._verify_stats_all_buckets(self.servers[:self.num_servers - self.nodes_out], timeout=120)
53 self._wait_for_stats_all_buckets(self.servers[
[all...]
H A Drebalanceinout.py32 servs_in = self.servers[self.nodes_init:self.nodes_init + 1]
33 servs_out = self.servers[self.nodes_init - 1:self.nodes_init]
34 result_nodes = list(set(self.servers[:self.nodes_init] + servs_in) - set(servs_out))
37 self._verify_stats_all_buckets(self.servers[:self.nodes_init], timeout=120)
38 self._wait_for_stats_all_buckets(self.servers[:self.nodes_init])
40 prev_vbucket_stats = self.get_vbucket_seqnos(self.servers[:self.nodes_init], self.buckets)
41 prev_failover_stats = self.get_failovers_logs(self.servers[:self.nodes_init], self.buckets)
42 disk_replica_dataset, disk_active_dataset = self.get_and_compare_active_replica_data_set_all(self.servers[:self.nodes_init], self.buckets, path=None)
44 self.cluster.rebalance(self.servers[:self.nodes_init - 1], servs_in, servs_out)
55 self.vb_distribution_analysis(servers
[all...]
H A Drebalancein.py35 servs_in = [self.servers[i + self.nodes_init] for i in range(self.nodes_in)]
36 self._verify_stats_all_buckets(self.servers[:self.nodes_init], timeout=120)
37 self._wait_for_stats_all_buckets(self.servers[:self.nodes_init])
39 prev_failover_stats = self.get_failovers_logs(self.servers[:self.nodes_init], self.buckets)
40 prev_vbucket_stats = self.get_vbucket_seqnos(self.servers[:self.nodes_init], self.buckets)
41 disk_replica_dataset, disk_active_dataset = self.get_and_compare_active_replica_data_set_all(self.servers[:self.nodes_init], self.buckets, path=None)
43 rebalance = self.cluster.async_rebalance(self.servers[:self.nodes_init], servs_in, [])
45 self._wait_for_stats_all_buckets(self.servers[:self.nodes_in + self.nodes_init])
46 self._verify_stats_all_buckets(self.servers[:self.nodes_in + self.nodes_init], timeout=120)
47 self.verify_cluster_stats(self.servers[
[all...]
/3.0.3-GA/testrunner/pytests/analysis/
H A Dclusterinfoanalysis.py17 self.cluster.rebalance(self.servers[:self.num_servers], self.servers[1:self.num_servers], [])
48 self._wait_for_stats_all_buckets(self.servers)
61 self._wait_for_stats_all_buckets(self.servers)
73 self._wait_for_stats_all_buckets(self.servers)
86 self._verify_stats_all_buckets(self.servers, timeout=120)
87 self._wait_for_stats_all_buckets(self.servers)
89 self._verify_stats_all_buckets(self.servers, timeout=120)
90 self._wait_for_stats_all_buckets(self.servers)
103 self._wait_for_stats_all_buckets(self.servers)
[all...]
/3.0.3-GA/testrunner/pytests/
H A Dnewupgradetests.py95 self._install(self.servers[:self.nodes_init])
96 self.operations(self.servers[:self.nodes_init])
109 upgrade_nodes = self.servers[self.nodes_init - num_stoped_nodes :self.nodes_init]
142 self.cluster.rebalance(self.servers[:self.nodes_init], [], [])
144 self.cluster.rebalance(self.servers[:self.nodes_init], [], [])
145 rem = [server for server in self.servers[:self.nodes_init]
148 self.verification(list(set(self.servers[:self.nodes_init]) - set(rem)))
151 self.verification(self.servers[:self.nodes_init])
156 self._install(self.servers[:self.nodes_init])
157 self.operations(self.servers[
[all...]
H A Dwarmupcluster.py15 servers = None variable in WarmUpClusterTest
24 self.master = TestInputSingleton.input.servers[0]
26 self.servers = self.input.servers
30 for server in self.servers:
35 for server in self.servers:
39 ClusterOperationHelper.cleanup_cluster(self.servers)
40 BucketOperationHelper.delete_all_buckets_or_assert(self.servers, self)
44 ClusterOperationHelper.begin_rebalance_in(self.master, self.servers)
49 ClusterOperationHelper.cleanup_cluster(self.servers)
[all...]
H A Dautofailovertests.py29 servers = input.servers
30 RemoteUtilHelper.common_basic_setup(servers)
31 BucketOperationHelper.delete_all_buckets_or_assert(servers, testcase)
32 ClusterOperationHelper.cleanup_cluster(servers)
33 ClusterOperationHelper.wait_for_ns_servers_or_assert(servers, testcase)
38 def common_tearDown(servers, testcase):
41 RemoteUtilHelper.common_basic_setup(servers)
45 ClusterOperationHelper.wait_for_ns_servers_or_assert(servers, testcase, \
48 rest = RestConnection(servers[
[all...]
H A Dcreatebuckettests.py13 servers = None variable in CreateMembaseBucketsTests
22 self.servers = self.input.servers
23 BucketOperationHelper.delete_all_buckets_or_assert(servers=self.servers, test_case=self)
27 BucketOperationHelper.delete_all_buckets_or_assert(servers=self.servers, test_case=self)
34 RestConnection(self.servers[0]).log_client_error(msg)
42 RestConnection(self.servers[0]).log_client_error(msg)
49 for serverInfo in self.servers
[all...]
H A Dbasetestcase.py40 self.servers = self.input.servers
43 self.servers = [server for server in self.servers
46 self.master = self.servers[0]
70 self.num_servers = self.input.param("servers", len(self.servers))
128 self.quota = self._initialize_nodes(self.cluster, self.servers, self.disabled_consistent_view,
151 self.cluster.rebalance(self.servers[:self.num_servers], self.servers[
[all...]
H A Ddeletebuckettests.py13 servers = None variable in DeleteMembaseBuckets
21 self.servers = self.input.servers
22 BucketOperationHelper.delete_all_buckets_or_assert(servers=self.servers, test_case=self)
26 BucketOperationHelper.delete_all_buckets_or_assert(servers=self.servers, test_case=self)
32 RestConnection(self.servers[0]).log_client_error(msg)
40 RestConnection(self.servers[0]).log_client_error(msg)
46 for serverInfo in self.servers
[all...]
H A Dbackuptests.py20 servers = None variable in BackupRestoreTests
30 self.servers = self.input.servers
31 self.master = self.servers[0]
47 ClusterOperationHelper.cleanup_cluster(self.servers)
48 BucketOperationHelper.delete_all_buckets_or_assert(self.servers, self)
49 for server in self.servers:
60 for server in self.servers:
66 def add_node_and_rebalance(self, master, servers):
67 ClusterOperationHelper.add_all_nodes_or_assert(master, servers, sel
[all...]
H A DhostnameTests.py26 for server in self.servers:
32 def install_builds(self, builds, servers=None):
38 if None in servers:
39 servers_to_install = self.servers
41 servers_to_install = servers
51 hostnames = self.convert_to_hostname(self, self.servers[0:2])
53 master_rest.add_node(self.servers[1].rest_username, self.servers[1].rest_password, hostnames[1], self.servers[1].port)
55 obj = RestConnection(self.servers[
[all...]
/3.0.3-GA/testrunner/lib/membase/helper/
H A Dcluster_helper.py22 def add_and_rebalance(servers, wait_for_rebalance=True):
24 master = servers[0]
28 if len(servers) > 1:
29 for serverInfo in servers[1:]:
74 def wait_for_ns_servers_or_assert(servers, testcase, wait_time=360, wait_if_warmup=False):
75 for server in servers:
94 def _wait_warmup_completed(self, servers, bucket_name, wait_time=300):
97 for server in servers:
143 def verify_persistence(servers, test, keys_count=400000, timeout_in_seconds=300):
145 master = servers[
[all...]
H A Dfailover_helper.py13 def __init__(self, servers, test):
15 self.servers = servers
19 # failover any node except self.servers[0]
23 rest = RestConnection(self.servers[0])
25 if len(nodes) != len(self.servers):
26 self.test.fail(num_nodes_mismatch.format(len(self.servers), len(nodes)))
58 rest = RestConnection(self.servers[0])
68 for server in self.servers:
83 for server in self.servers
[all...]
/3.0.3-GA/testrunner/pysystests/app/
H A Drest_client_tasks.py306 servers = adminMsg["rebalance_in"]
308 add_nodes(rest, servers, cluster_id, zone_name)
316 servers = adminMsg["rebalance_out"]
317 toBeEjectedNodes = remove_nodes(rest, servers, adminMsg["involve_orchestrator"], cluster_id)
320 servers = adminMsg["failover"]
324 failoverNodes = failover_nodes(rest, servers, only_failover, adminMsg["involve_orchestrator"], cluster_id)
337 servers = adminMsg["soft_restart"]
338 restart(servers, cluster_id=cluster_id)
341 servers = adminMsg["hard_restart"]
342 restart(servers, typ
[all...]
/3.0.3-GA/testrunner/pytests/rackzone/
H A Drackzonetests.py45 serverInfo = self.servers[0]
55 serverInfo = self.servers[0]
66 serverInfo = self.servers[0]
77 serverInfo = self.servers[0]
88 serverInfo = self.servers[0]
99 serverInfo = self.servers[0]
111 serverInfo = self.servers[0]
124 serverInfo = self.servers[0]
150 if len(self.servers) < int(self.num_node):
151 msg = "This test needs minimum {1} servers t
[all...]
/3.0.3-GA/testrunner/
H A DTestInput.py23 self.servers = []
29 #servers , each server can have u,p,port,directory
162 if "num_nodes" not in input.test_params.keys() and input.servers:
163 input.test_params["num_nodes"] = len(input.servers)
169 servers = []
189 if section == 'servers':
216 servers.append(TestInputParser.get_server(cluster_ip, config))
217 servers = TestInputParser.get_server_options(servers, input.membase_settings, global_properties)
224 input.clusters[key] = servers[star
[all...]
/3.0.3-GA/testrunner/pytests/eviction/
H A Deviction_change_policy.py13 self._wait_for_stats_all_buckets(self.servers[:self.nodes_init])
14 self._verify_stats_all_buckets(self.servers[:self.nodes_init])
24 self.servers[:self.nodes_init], self,
28 self._wait_for_stats_all_buckets(self.servers[:self.nodes_init], timeout=self.wait_timeout * 5)
29 self._verify_stats_all_buckets(self.servers[:self.nodes_init])
35 self._wait_for_stats_all_buckets(self.servers[:self.nodes_init])
36 self._verify_stats_all_buckets(self.servers[:self.nodes_init])
42 self.servers[:self.nodes_init], self,
46 self._wait_for_stats_all_buckets(self.servers[:self.nodes_init], timeout=self.wait_timeout * 5)
47 self._verify_stats_all_buckets(self.servers[
[all...]
/3.0.3-GA/testrunner/pytests/performance/
H A Dperf.py48 master = self.input.servers[0]
65 for node in self.input.servers:
71 ClusterOperationHelper.set_erlang_schedulers(self.input.servers,
73 master = self.input.servers[0]
89 master = self.input.servers[0]
130 ClusterOperationHelper.flush_os_caches(self.input.servers)
249 for servers in self.input.clusters.values():
250 RestConnection(servers[0]).set_internalSetting(param, value)
254 for server in self.input.servers:
303 for server in self.input.servers
[all...]
/3.0.3-GA/moxi/src/
H A Dmcs.c102 if (ptr->servers) { in mcs_free()
105 if (ptr->servers[i].usr != NULL) { in mcs_free()
106 free(ptr->servers[i].usr); in mcs_free()
108 if (ptr->servers[i].pwd != NULL) { in mcs_free()
109 free(ptr->servers[i].pwd); in mcs_free()
112 free(ptr->servers); in mcs_free()
133 return &ptr->servers[i]; in mcs_server_index()
172 ptr->servers = calloc(sizeof(mcs_server_st), ptr->nservers); in lvb_create()
173 if (ptr->servers != NULL) { in lvb_create()
176 ptr->servers[ in lvb_create()
[all...]

Completed in 46 milliseconds

1234567