| /dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/test/java/org/apache/zookeeper/common/ |
| H A D | ZKConfigTest.java | 39 ZKConfig conf = new ZKConfig(); in testBooleanRetrievalFromPropertyDefault()
53 ZKConfig conf = new ZKConfig(); in testBooleanRetrievalFromProperty()
65 ZKConfig conf = new ZKConfig(); in testBooleanRetrievalFromPropertyWithWhitespacesInBeginning()
77 ZKConfig conf = new ZKConfig(); in testBooleanRetrievalFromPropertyWithWhitespacesAtEnd()
89 ZKConfig conf = new ZKConfig(); in testBooleanRetrievalFromPropertyWithWhitespacesAtBeginningAndEnd()
|
| /dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/test/java/org/apache/zookeeper/client/ |
| H A D | ZKClientConfigTest.java | 39 import org.apache.zookeeper.common.ZKConfig;
166 conf.setProperty(ZKConfig.JUTE_MAXBUFFER, "InvlaidIntValue123"); in testIntegerRetrievalFromProperty()
168 result = conf.getInt(ZKConfig.JUTE_MAXBUFFER, defaultValue); in testIntegerRetrievalFromProperty()
177 conf.setProperty(ZKConfig.JUTE_MAXBUFFER, Integer.toString(value)); in testIntegerRetrievalFromProperty()
178 result = conf.getInt(ZKConfig.JUTE_MAXBUFFER, defaultValue); in testIntegerRetrievalFromProperty()
183 conf.setProperty(ZKConfig.JUTE_MAXBUFFER, " " + value + " "); in testIntegerRetrievalFromProperty()
184 result = conf.getInt(ZKConfig.JUTE_MAXBUFFER, defaultValue); in testIntegerRetrievalFromProperty()
196 zkClientConfig.setProperty(ZKConfig.JUTE_MAXBUFFER, in testIntegerRetrievalFromHexadecimalProperty()
200 zkClientConfig.setProperty(ZKConfig.JUTE_MAXBUFFER, in testIntegerRetrievalFromHexadecimalProperty()
208 zkClientConfig.setProperty(ZKConfig.JUTE_MAXBUFFER, in testIntegerRetrievalFromHexadecimalProperty()
[all …]
|
| /dports/databases/hbase/hbase-1.2.1/hbase-common/src/test/java/org/apache/hadoop/hbase/zookeeper/ |
| H A D | TestZKConfig.java | 44 Properties props = ZKConfig.makeZKProps(conf); in testZKConfigLoading()
56 String clusterKey = ZKConfig.getZooKeeperClusterKey(conf, "test"); in testGetZooKeeperClusterKey()
66 ZKConfig.validateClusterKey("2181:hbase"); in testClusterKey()
100 ZKConfig.ZKClusterKey zkClusterKey = ZKConfig.transformClusterKey(key); in testKey()
102 ensemble2 = ZKConfig.standardizeZKQuorumServerString(ensemble, in testKey()
117 String reconstructedKey = ZKConfig.getZooKeeperClusterKey(conf); in testKey()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/zookeeper/ |
| H A D | TestHQuorumPeer.java | 70 Properties properties = ZKConfig.makeZKProps(conf); in testMakeZKProps()
79 properties = ZKConfig.makeZKProps(conf); in testMakeZKProps()
103 Properties properties = ZKConfig.parseZooCfg(conf, is); in testConfigInjection()
125 properties = ZKConfig.parseZooCfg(conf, is); in testConfigInjection()
138 Properties p = ZKConfig.makeZKProps(config); in testShouldAssignDefaultZookeeperClientPort()
149 String s = ZKConfig.getZKQuorumServersString(config); in testGetZKQuorumServersString()
|
| /dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/main/java/org/apache/zookeeper/ |
| H A D | ClientCnxnSocket.java | 33 import org.apache.zookeeper.common.ZKConfig;
237 ZKConfig.JUTE_MAXBUFFER, in initProperties()
239 LOG.info("{} value is {} Bytes", ZKConfig.JUTE_MAXBUFFER, packetLen); in initProperties()
243 clientConfig.getProperty(ZKConfig.JUTE_MAXBUFFER), in initProperties()
244 ZKConfig.JUTE_MAXBUFFER); in initProperties()
|
| H A D | Login.java | 41 import org.apache.zookeeper.common.ZKConfig;
79 private final ZKConfig zkConfig;
97 …public Login(final String loginContextName, CallbackHandler callbackHandler, final ZKConfig zkConf… in Login()
213 … String cmd = zkConfig.getProperty(ZKConfig.KINIT_COMMAND, KINIT_COMMAND_DEFAULT); in Login()
|
| /dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/main/java/org/apache/zookeeper/common/ |
| H A D | SSLContextAndOptions.java | 64 …SSLContextAndOptions(final X509Util x509Util, final ZKConfig config, final SSLContext sslContext) { in SSLContextAndOptions()
170 private String[] getEnabledProtocols(final ZKConfig config, final SSLContext sslContext) { in getEnabledProtocols()
178 private String[] getCipherSuites(final ZKConfig config) { in getCipherSuites()
187 private X509Util.ClientAuth getClientAuth(final ZKConfig config) { in getClientAuth()
191 private int getHandshakeDetectionTimeoutMillis(final ZKConfig config) { in getHandshakeDetectionTimeoutMillis()
|
| H A D | ZKConfig.java | 41 public class ZKConfig { class
43 private static final Logger LOG = LoggerFactory.getLogger(ZKConfig.class);
60 public ZKConfig() { in ZKConfig() method in ZKConfig
71 public ZKConfig(String configPath) throws ConfigException { in ZKConfig() method in ZKConfig
82 public ZKConfig(File configFile) throws ConfigException { in ZKConfig() method in ZKConfig
|
| H A D | X509Util.java | 162 private ZKConfig zkConfig;
172 public X509Util(ZKConfig zkConfig) { in X509Util()
255 public SSLContext createSSLContext(ZKConfig config) throws SSLContextException { in createSSLContext()
282 return createSSLContextAndOptions(zkConfig == null ? new ZKConfig() : zkConfig); in createSSLContextAndOptions()
306 …public SSLContextAndOptions createSSLContextAndOptions(ZKConfig config) throws SSLContextException… in createSSLContextAndOptions()
332 …public SSLContextAndOptions createSSLContextAndOptionsFromConfig(ZKConfig config) throws SSLContex… in createSSLContextAndOptionsFromConfig()
573 ZKConfig config = zkConfig == null ? new ZKConfig() : zkConfig; in enableCertFileReloading()
|
| /dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/test/java/org/apache/zookeeper/ |
| H A D | ClientCnxnSocketTest.java | 25 import org.apache.zookeeper.common.ZKConfig;
48 clientConfig.setProperty(ZKConfig.JUTE_MAXBUFFER, value); in testWhenInvalidJuteMaxBufferIsConfiguredIOExceptionIsThrown()
|
| /dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/main/java/org/apache/zookeeper/server/auth/ |
| H A D | X509AuthenticationProvider.java | 32 import org.apache.zookeeper.common.ZKConfig;
67 ZKConfig config = new ZKConfig(); in X509AuthenticationProvider()
|
| /dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/main/java/org/apache/zookeeper/client/ |
| H A D | ZKClientConfig.java | 24 import org.apache.zookeeper.common.ZKConfig;
32 public class ZKClientConfig extends ZKConfig {
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/ |
| H A D | TestReplicationStateZKImpl.java | 40 import org.apache.hadoop.hbase.zookeeper.ZKConfig;
83 return ZKConfig.getZooKeeperClusterKey(testConf); in initPeerClusterState()
98 OUR_KEY = ZKConfig.getZooKeeperClusterKey(conf); in setUp()
|
| H A D | TestReplicationEndpoint.java | 45 import org.apache.hadoop.hbase.zookeeper.ZKConfig;
117 new ReplicationPeerConfig().setClusterKey(ZKConfig.getZooKeeperClusterKey(conf1)) in testCustomReplicationEndpoint()
159 new ReplicationPeerConfig().setClusterKey(ZKConfig.getZooKeeperClusterKey(conf1)) in testReplicationEndpointReturnsFalseOnReplicate()
211 new ReplicationPeerConfig().setClusterKey(ZKConfig.getZooKeeperClusterKey(conf2)) in testInterClusterReplication()
236 new ReplicationPeerConfig().setClusterKey(ZKConfig.getZooKeeperClusterKey(conf1)) in testWALEntryFilterFromReplicationEndpoint()
|
| H A D | TestReplicationStateBasic.java | 30 import org.apache.hadoop.hbase.zookeeper.ZKConfig;
205 assertEquals(KEY_ONE, ZKConfig.getZooKeeperClusterKey(rp.getPeerConf(ID_ONE).getSecond())); in testReplicationPeers()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-client/src/main/java/org/apache/hadoop/hbase/replication/ |
| H A D | ReplicationStateZKBase.java | 28 import org.apache.hadoop.hbase.zookeeper.ZKConfig;
73 this.ourClusterKey = ZKConfig.getZooKeeperClusterKey(this.conf); in ReplicationStateZKBase()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-common/src/main/java/org/apache/hadoop/hbase/ |
| H A D | HBaseConfiguration.java | 32 import org.apache.hadoop.hbase.zookeeper.ZKConfig;
302 ZKConfig.ZKClusterKey zkClusterKey = ZKConfig.transformClusterKey(key); in applyClusterKeyToConf()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-common/src/main/java/org/apache/hadoop/hbase/zookeeper/ |
| H A D | ZKConfig.java | 44 public final class ZKConfig { class
45 private static final Log LOG = LogFactory.getLog(ZKConfig.class);
52 private ZKConfig() { in ZKConfig() method in ZKConfig
92 ClassLoader cl = ZKConfig.class.getClassLoader(); in makeZKPropsFromZooCfg()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-shell/src/main/ruby/hbase/ |
| H A D | replication_admin.rb | 25 java_import org.apache.hadoop.hbase.zookeeper.ZKConfig
65 cluster_key = ZKConfig.getZooKeeperClusterKey(@configuration)
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/util/ |
| H A D | ServerRegionReplicaUtil.java | 36 import org.apache.hadoop.hbase.zookeeper.ZKConfig;
151 peerConfig.setClusterKey(ZKConfig.getZooKeeperClusterKey(conf)); in setupRegionReplicaReplication()
|
| /dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/auth/ |
| H A D | SaslQuorumAuthServer.java | 35 import org.apache.zookeeper.common.ZKConfig;
60 serverLogin = new Login(loginContext, saslServerCallbackHandler, new ZKConfig()); in SaslQuorumAuthServer()
|
| H A D | SaslQuorumAuthLearner.java | 38 import org.apache.zookeeper.common.ZKConfig;
68 new ZKConfig()); in SaslQuorumAuthLearner()
|
| /dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/main/java/org/apache/zookeeper/server/ |
| H A D | ServerCnxnFactory.java | 34 import org.apache.zookeeper.common.ZKConfig;
273 login = new Login(serverSection, saslServerCallbackHandler, new ZKConfig()); in configureSaslLogin()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/regionserver/ |
| H A D | TestRegionReplicaReplicationEndpoint.java | 56 import org.apache.hadoop.hbase.zookeeper.ZKConfig;
132 assertEquals(peerConfig.getClusterKey(), ZKConfig.getZooKeeperClusterKey( in testRegionReplicaReplicationPeerIsCreated()
166 assertEquals(peerConfig.getClusterKey(), ZKConfig.getZooKeeperClusterKey( in testRegionReplicaReplicationPeerIsCreatedForModifyTable()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/zookeeper/ |
| H A D | ZKServerTool.java | 47 Properties zkProps = ZKConfig.makeZKProps(conf); in readZKNodes()
|