hazelcast-all-3.2.5.jar
登录
|
com.hazelcast:hazelcast-all:3.2.5
META-INF
com
hazelcast
queue
nio
SocketClientDataWriter.java
SocketWritable.java
SocketAcceptor.java
SocketPacketWriter.java
ClientPacket.java
DefaultSocketChannelWrapper.java
ObjectDataInput.java
DynamicByteBuffer.java
InSelectorImpl.java
SocketInterceptor.java
IOSelector.java
SocketReader.java
AbstractSelectionHandler.java
NodeIOService.java
Connection.java
ConnectionListener.java
WriteHandler.java
SocketConnector.java
UnsafeHelper.java
ConnectionMonitor.java
BufferObjectDataOutput.java
SocketWriter.java
MemberSocketInterceptor.java
Packet.java
ReadHandler.java
AbstractIOSelector.java
NIOThread.java
IOService.java
OutSelectorImpl.java
ssl
SocketChannelWrapper.java
Protocols.java
IOUtil.java
BufferObjectDataInput.java
ObjectDataOutput.java
SocketReadable.java
ConnectionManager.java
Address.java
SelectionHandler.java
SocketPacketReader.java
ClassLoaderUtil.java
ascii
TcpIpConnection.java
TcpIpConnectionManager.java
SocketClientDataReader.java
UTFEncoderDecoder.java
serialization
ConnectionType.java
CipherHelper.java
core
spring
query
config
partition
mapreduce
aws
security
web
monitor
examples
transaction
wan
util
map
storage
osgi
spi
topic
multimap
cluster
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
ConnectionMonitor.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.nio; import com.hazelcast.logging.
ILogger
; import com.hazelcast.util.
Clock
; import java.util.logging.
Level
; public class
ConnectionMonitor
{ final
ILogger
logger
; final
TcpIpConnectionManager
connectionManager
; final
IOService
ioService
; final
Address
endPoint
; final long
minInterval
; final int
maxFaults
; int
faults
= 0; long
lastFaultTime
= 0L; public
ConnectionMonitor
(
TcpIpConnectionManager
connectionManager
,
Address
endPoint
) { super(); this.
connectionManager
=
connectionManager
; this.
endPoint
=
endPoint
; this.
ioService
=
connectionManager
.
getIOHandler
(); this.
minInterval
=
ioService
.
getConnectionMonitorInterval
(); this.
maxFaults
=
ioService
.
getConnectionMonitorMaxFaults
(); this.
logger
=
ioService
.
getLogger
(
getClass
().
getName
()); } public
Address
getEndPoint
() { return
endPoint
; } public synchronized void
onError
(
Throwable
t
) {
String
errorMessage
= "An error occurred on connection to " +
endPoint
+
getCauseDescription
(
t
);
logger
.
finest
(
errorMessage
);
ioService
.
getSystemLogService
().
logConnection
(
errorMessage
); final long
now
=
Clock
.
currentTimeMillis
(); final long
last
=
lastFaultTime
; if (
now
-
last
>
minInterval
) { if (
faults
++ >=
maxFaults
) {
String
removeEndpointMessage
= "Removing connection to endpoint " +
endPoint
+
getCauseDescription
(
t
);
logger
.
warning
(
removeEndpointMessage
);
ioService
.
getSystemLogService
().
logConnection
(
removeEndpointMessage
);
ioService
.
removeEndpoint
(
endPoint
); }
lastFaultTime
=
now
; } } public synchronized void
reset
() {
String
resetMessage
= "Resetting connection monitor for endpoint " +
endPoint
;
logger
.
finest
(
resetMessage
);
ioService
.
getSystemLogService
().
logConnection
(
resetMessage
);
faults
= 0;
lastFaultTime
= 0L; } private /*synchronized*/
String
getCauseDescription
(
Throwable
t
) {
StringBuilder
s
= new
StringBuilder
(" Cause => "); if (
t
!= null) {
s
.
append
(
t
.
getClass
().
getName
()).
append
(" {").
append
(
t
.
getMessage
()).
append
("}"); } else {
s
.
append
("Unknown"); } return
s
.
append
(", Error-Count: ").
append
(
faults
+ 1).
toString
(); } }
查找资源
Jre/Lib
输入类名或文件名
类结构窗口