Skip to content

Commit

Permalink
Debugging "best" RTMPS connections from FlashPlayer
Browse files Browse the repository at this point in the history
  • Loading branch information
mondain committed Jun 20, 2016
1 parent e68d406 commit c4e2c38
Showing 1 changed file with 5 additions and 7 deletions.
12 changes: 5 additions & 7 deletions src/main/java/org/red5/server/net/rtmp/RTMPConnection.java
Original file line number Diff line number Diff line change
Expand Up @@ -488,10 +488,8 @@ public boolean connect(IScope newScope, Object[] params) {
stopWaitForHandshake();
// once the handshake has completed, start needed jobs start the ping / pong keep-alive
startRoundTripMeasurement();
} else {
if (log.isDebugEnabled()) {
log.debug("Connect failed");
}
} else if (log.isDebugEnabled()) {
log.debug("Connect failed");
}
return success;
} catch (ClientRejectedException e) {
Expand All @@ -513,7 +511,7 @@ public void startWaitForHandshake() {
try {
waitForHandshakeTask = scheduler.schedule(new WaitForHandshakeTask(), new Date(System.currentTimeMillis() + maxHandshakeTimeout));
} catch (TaskRejectedException e) {
log.error("WaitForHandshake task was rejected for " + sessionId, e);
log.error("WaitForHandshake task was rejected for {}", sessionId, e);
}
}

Expand Down Expand Up @@ -542,10 +540,10 @@ private void startRoundTripMeasurement() {
try {
keepAliveTask = scheduler.scheduleAtFixedRate(new KeepAliveTask(), pingInterval);
if (log.isDebugEnabled()) {
log.debug("Keep alive scheduled for: {}", sessionId);
log.debug("Keep alive scheduled for {}", sessionId);
}
} catch (Exception e) {
log.error("Error creating keep alive job for: " + sessionId, e);
log.error("Error creating keep alive job for {}", sessionId, e);
}
}
} else {
Expand Down

0 comments on commit c4e2c38

Please sign in to comment.