You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dubbo.apache.org by il...@apache.org on 2018/04/08 02:21:46 UTC
[incubator-dubbo] branch master updated: typo fix (#1562)
This is an automated email from the ASF dual-hosted git repository.
iluo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-dubbo.git
The following commit(s) were added to refs/heads/master by this push:
new 697724c typo fix (#1562)
697724c is described below
commit 697724cf002fa46ffcbad92b0aebc5f134404355
Author: Junjian Peng <mz...@gmail.com>
AuthorDate: Sun Apr 8 10:21:43 2018 +0800
typo fix (#1562)
---
.../exchange/support/header/HeaderExchangeServer.java | 16 ++++++++--------
1 file changed, 8 insertions(+), 8 deletions(-)
diff --git a/dubbo-remoting/dubbo-remoting-api/src/main/java/com/alibaba/dubbo/remoting/exchange/support/header/HeaderExchangeServer.java b/dubbo-remoting/dubbo-remoting-api/src/main/java/com/alibaba/dubbo/remoting/exchange/support/header/HeaderExchangeServer.java
index 6d77a18..67b9ff2 100644
--- a/dubbo-remoting/dubbo-remoting-api/src/main/java/com/alibaba/dubbo/remoting/exchange/support/header/HeaderExchangeServer.java
+++ b/dubbo-remoting/dubbo-remoting-api/src/main/java/com/alibaba/dubbo/remoting/exchange/support/header/HeaderExchangeServer.java
@@ -54,7 +54,7 @@ public class HeaderExchangeServer implements ExchangeServer {
true));
private final Server server;
// heartbeat timer
- private ScheduledFuture<?> heatbeatTimer;
+ private ScheduledFuture<?> heartbeatTimer;
// heartbeat timeout (ms), default value is 0 , won't execute a heartbeat.
private int heartbeat;
private int heartbeatTimeout;
@@ -70,7 +70,7 @@ public class HeaderExchangeServer implements ExchangeServer {
if (heartbeatTimeout < heartbeat * 2) {
throw new IllegalStateException("heartbeatTimeout < heartbeatInterval * 2");
}
- startHeatbeatTimer();
+ startHeartbeatTimer();
}
public Server getServer() {
@@ -134,7 +134,7 @@ public class HeaderExchangeServer implements ExchangeServer {
if (channel.isConnected())
channel.send(request, getUrl().getParameter(Constants.CHANNEL_READONLYEVENT_SENT_KEY, true));
} catch (RemotingException e) {
- logger.warn("send connot write messge error.", e);
+ logger.warn("send cannot write message error.", e);
}
}
}
@@ -205,7 +205,7 @@ public class HeaderExchangeServer implements ExchangeServer {
if (h != heartbeat || t != heartbeatTimeout) {
heartbeat = h;
heartbeatTimeout = t;
- startHeatbeatTimer();
+ startHeartbeatTimer();
}
}
} catch (Throwable t) {
@@ -232,10 +232,10 @@ public class HeaderExchangeServer implements ExchangeServer {
server.send(message, sent);
}
- private void startHeatbeatTimer() {
+ private void startHeartbeatTimer() {
stopHeartbeatTimer();
if (heartbeat > 0) {
- heatbeatTimer = scheduled.scheduleWithFixedDelay(
+ heartbeatTimer = scheduled.scheduleWithFixedDelay(
new HeartBeatTask(new HeartBeatTask.ChannelProvider() {
public Collection<Channel> getChannels() {
return Collections.unmodifiableCollection(
@@ -248,14 +248,14 @@ public class HeaderExchangeServer implements ExchangeServer {
private void stopHeartbeatTimer() {
try {
- ScheduledFuture<?> timer = heatbeatTimer;
+ ScheduledFuture<?> timer = heartbeatTimer;
if (timer != null && !timer.isCancelled()) {
timer.cancel(true);
}
} catch (Throwable t) {
logger.warn(t.getMessage(), t);
} finally {
- heatbeatTimer = null;
+ heartbeatTimer = null;
}
}
--
To stop receiving notification emails like this one, please contact
iluo@apache.org.