Skip to content

Commit 319734e

Browse files
committed
Fixed logging (one more time)
1 parent 542beb2 commit 319734e

File tree

4 files changed

+12
-12
lines changed

4 files changed

+12
-12
lines changed

cluster/src/main/java/io/scalecube/cluster/fdetector/FailureDetectorImpl.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -151,7 +151,7 @@ private void doPing() {
151151
publishPingResult(period, pingMember, computeMemberStatus(message, period));
152152
},
153153
ex -> {
154-
LOGGER.warn(
154+
LOGGER.debug(
155155
"[{}][{}] Failed to get PingAck from {} within {} ms",
156156
localMember,
157157
period,
@@ -198,7 +198,7 @@ private void doPingReq(
198198
publishPingResult(period, pingMember, computeMemberStatus(message, period));
199199
},
200200
throwable -> {
201-
LOGGER.warn(
201+
LOGGER.debug(
202202
"[{}][{}] Timeout getting transit PingAck from {} to {} within {} ms",
203203
localMember,
204204
period,
@@ -250,7 +250,7 @@ private void onPing(Message message) {
250250
.subscribe(
251251
null,
252252
ex ->
253-
LOGGER.warn(
253+
LOGGER.debug(
254254
"[{}][{}] Failed to send PingAck to {}, cause: {}",
255255
localMember,
256256
period,
@@ -276,7 +276,7 @@ private void onPingReq(Message message) {
276276
.subscribe(
277277
null,
278278
ex ->
279-
LOGGER.warn(
279+
LOGGER.debug(
280280
"[{}][{}] Failed to send transit Ping to {}, cause: {}",
281281
localMember,
282282
period,
@@ -306,7 +306,7 @@ private void onTransitPingAck(Message message) {
306306
.subscribe(
307307
null,
308308
ex ->
309-
LOGGER.warn(
309+
LOGGER.debug(
310310
"[{}][{}] Failed to resend transit PingAck to {}, cause: {}",
311311
localMember,
312312
period,

cluster/src/main/java/io/scalecube/cluster/gossip/GossipProtocolImpl.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -299,7 +299,7 @@ private void spreadGossipsTo(long period, Member member) {
299299
.subscribe(
300300
null,
301301
ex ->
302-
LOGGER.warn(
302+
LOGGER.debug(
303303
"[{}][{}] Failed to send GossipReq({}) to {}, cause: {}",
304304
localMember,
305305
period,

cluster/src/main/java/io/scalecube/cluster/membership/MembershipProtocolImpl.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -289,7 +289,7 @@ private void start0(MonoSink<Object> sink) {
289289
.subscribe(
290290
null,
291291
ex ->
292-
LOGGER.warn(
292+
LOGGER.debug(
293293
"[{}] Exception on initial SyncAck, cause: {}", localMember, ex.toString()));
294294
}
295295

@@ -352,7 +352,7 @@ private void doSync() {
352352
.subscribe(
353353
null,
354354
ex ->
355-
LOGGER.warn(
355+
LOGGER.debug(
356356
"[{}][doSync] Failed to send Sync to {}, cause: {}",
357357
localMember,
358358
address,
@@ -403,7 +403,7 @@ private Mono<Void> onSync(Message syncMsg) {
403403
.subscribe(
404404
null,
405405
ex ->
406-
LOGGER.warn(
406+
LOGGER.debug(
407407
"[{}] Failed to send SyncAck to {}, cause: {}",
408408
localMember,
409409
sender,
@@ -433,7 +433,7 @@ private void onFailureDetectorEvent(FailureDetectorEvent fdEvent) {
433433
.subscribe(
434434
null,
435435
ex ->
436-
LOGGER.warn(
436+
LOGGER.debug(
437437
"[{}][onFailureDetectorEvent] Failed to send Sync to {}, cause: {}",
438438
localMember,
439439
address,
@@ -794,7 +794,7 @@ private Mono<Void> spreadMembershipGossip(MembershipRecord r) {
794794
.spread(msg)
795795
.doOnError(
796796
ex ->
797-
LOGGER.warn(
797+
LOGGER.debug(
798798
"[{}] Failed to send membership with gossip, cause: {}",
799799
localMember,
800800
ex.toString()))

transport-parent/transport-netty/src/main/java/io/scalecube/transport/netty/TransportImpl.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -304,7 +304,7 @@ private Mono<? extends Connection> connect0(Address address) {
304304
.connect()
305305
.doOnError(
306306
th -> {
307-
LOGGER.warn(
307+
LOGGER.debug(
308308
"[{}][connect0][{}] Exception occurred: {}",
309309
this.address,
310310
address,

0 commit comments

Comments
 (0)