hazelcast-all-3.2.5.jar
登录
|
com.hazelcast:hazelcast-all:3.2.5
META-INF
com
hazelcast
queue
nio
core
spring
query
config
partition
mapreduce
aws
security
web
monitor
examples
transaction
wan
util
map
storage
osgi
spi
topic
multimap
cluster
SetMasterOperation.java
BindOperation.java
JoinRequestOperation.java
JoinOperation.java
ClusterServiceImpl.java
JoinRequest.java
MemberInfo.java
MemberAttributeChangedOperation.java
JoinMessage.java
PostJoinOperation.java
JoinCheckOperation.java
Joiner.java
AuthorizationOperation.java
ClusterProxy.java
NodeMulticastListener.java
ConfigCheck.java
MulticastJoiner.java
ClusterService.java
MasterConfirmationOperation.java
HeartbeatOperation.java
MulticastListener.java
SplitBrainHandler.java
ClusterDataSerializerHook.java
MulticastService.java
client
PrepareMergeOperation.java
TcpIpJoinerOverAWS.java
AbstractJoiner.java
FinalizeJoinOperation.java
MemberAttributeOperationType.java
MergeClustersOperation.java
MemberInfoUpdateOperation.java
TcpIpJoiner.java
MemberRemoveOperation.java
AbstractClusterOperation.java
AuthenticationFailureOperation.java
instance
executor
collection
ascii
client
concurrent
logging
jmx
management
hibernate
server.bat
test.bat
hazelcast-download.properties
hazelcast-client-config-3.1.xsd
hazelcast-client-default.xml
hazelcast-default.xml
hazelcast-client-config-3.2.xsd
hazelcast-spring-3.1.xsd
run.sh
server.sh
hazelcast-common-config-3.1.xsd
hazelcast-fullconfig.xml
hazelcast-config-3.1.xsd
hazelcast-runtime.properties
run.bat
client.sh
hazelcast-spring-3.0.xsd
hazelcast-client-config-3.0.xsd
hazelcast-client-full.xml
hazelcast-common-config-3.0.xsd
test.sh
hazelcast-config-3.0.xsd
hazelcast-spring-3.2.xsd
hazelcast-config-3.2.xsd
PrepareMergeOperation.java
清空
类结构
/* * Copyright (c) 2008-2013, Hazelcast, Inc. All Rights Reserved. * * Licensed 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. */ package com.hazelcast.cluster; import com.hazelcast.instance.
Node
; import com.hazelcast.logging.
ILogger
; import com.hazelcast.nio.
Address
; import com.hazelcast.nio.
ObjectDataInput
; import com.hazelcast.nio.
ObjectDataOutput
; import com.hazelcast.spi.impl.
NodeEngineImpl
; import java.io.
IOException
; import java.util.logging.
Level
; public class
PrepareMergeOperation
extends
AbstractClusterOperation
{ private
Address
newTargetAddress
= null; public
PrepareMergeOperation
() { } public
PrepareMergeOperation
(
Address
newTargetAddress
) { super(); this.
newTargetAddress
=
newTargetAddress
; } @
Override
public void
run
() { final
Address
caller
=
getCallerAddress
(); final
NodeEngineImpl
nodeEngine
= (
NodeEngineImpl
)
getNodeEngine
(); final
Node
node
=
nodeEngine
.
getNode
(); final
Address
masterAddress
=
node
.
getMasterAddress
(); final
ILogger
logger
=
node
.
loggingService
.
getLogger
(this.
getClass
().
getName
()); if (
caller
!= null && !
caller
.
equals
(
masterAddress
)) { // caller null means local invocation.
logger
.
warning
("Prepare-merge instruction sent from non-master endpoint: " +
caller
); return; }
logger
.
warning
("Preparing to merge... Waiting for merge instruction...");
node
.
getClusterService
().
prepareToMerge
(
newTargetAddress
); } @
Override
public boolean
returnsResponse
() { return true; } @
Override
public
Object
getResponse
() { return
Boolean
.
TRUE
; } @
Override
protected void
readInternal
(
ObjectDataInput
in
) throws
IOException
{ super.readInternal(
in
);
newTargetAddress
= new
Address
();
newTargetAddress
.
readData
(
in
); } @
Override
protected void
writeInternal
(
ObjectDataOutput
out
) throws
IOException
{ super.writeInternal(
out
);
newTargetAddress
.
writeData
(
out
); } }
查找资源
Jre/Lib
输入类名或文件名
类结构窗口