[Red5devs] [PATCH 14 of 15] connection object erroneously called "client"
mabrek
mabrek at gmail.com
Tue Aug 26 11:06:07 PDT 2008
diff -r 5a36e8d099f4 -r 3e241327cb9a src/org/red5/server/net/rtmpt/RTMPTServlet.java
--- a/src/org/red5/server/net/rtmpt/RTMPTServlet.java Tue Aug 05 16:24:47 2008 +0400
+++ b/src/org/red5/server/net/rtmpt/RTMPTServlet.java Mon Jul 21 11:37:55 2008 +0400
@@ -221,7 +221,7 @@
* Servlet request
* @return RTMP client connection
*/
- protected RTMPTConnection getClient(HttpServletRequest req) {
+ protected RTMPTConnection getClientConnection(HttpServletRequest req) {
final Integer id = getClientId(req);
return getConnection(id);
}
@@ -318,18 +318,18 @@
// Skip sent data
skipData(req);
- RTMPTConnection client = getClient(req);
- if (client == null) {
+ RTMPTConnection connection = getClientConnection(req);
+ if (connection == null) {
handleBadRequest("Unknown client.", resp);
return;
}
- removeConnection(client.getId());
+ removeConnection(connection.getId());
- client.setServletRequest(req);
- handler.connectionClosed(client, client.getState());
+ connection.setServletRequest(req);
+ handler.connectionClosed(connection, connection.getState());
returnMessage((byte) 0, resp);
- client.realClose();
+ connection.realClose();
}
/**
@@ -347,17 +347,17 @@
protected void handleSend(HttpServletRequest req, HttpServletResponse resp)
throws ServletException, IOException {
- RTMPTConnection client = getClient(req);
- if (client == null) {
+ RTMPTConnection connection = getClientConnection(req);
+ if (connection == null) {
handleBadRequest("Unknown client.", resp);
return;
- } else if (client.getState().getState() == RTMP.STATE_DISCONNECTED) {
- removeConnection(client.getId());
+ } else if (connection.getState().getState() == RTMP.STATE_DISCONNECTED) {
+ removeConnection(connection.getId());
handleBadRequest("Connection already closed.", resp);
return;
}
- client.setServletRequest(req);
+ connection.setServletRequest(req);
// Put the received data in a ByteBuffer
int length = req.getContentLength();
@@ -366,25 +366,25 @@
data.flip();
// Decode the objects in the data
- List messages = client.decode(data);
+ List messages = connection.decode(data);
data.release();
data = null;
if (messages == null || messages.isEmpty()) {
- returnMessage(client.getPollingDelay(), resp);
+ returnMessage(connection.getPollingDelay(), resp);
return;
}
// Execute the received RTMP messages
for (Object message : messages) {
try {
- handler.messageReceived(client, client.getState(), message);
+ handler.messageReceived(connection, connection.getState(), message);
} catch (Exception e) {
log.error("Could not process message.", e);
}
}
// Send results to client
- returnPendingMessages(client, resp);
+ returnPendingMessages(connection, resp);
}
/**
@@ -405,23 +405,23 @@
// Skip sent data
skipData(req);
- RTMPTConnection client = getClient(req);
- if (client == null) {
+ RTMPTConnection connection = getClientConnection(req);
+ if (connection == null) {
handleBadRequest("Unknown client.", resp);
return;
- } else if (client.isClosing()) {
+ } else if (connection.isClosing()) {
// Tell client to close the connection
returnMessage((byte) 0, resp);
- client.realClose();
+ connection.realClose();
return;
- } else if (client.getState().getState() == RTMP.STATE_DISCONNECTED) {
- removeConnection(client.getId());
+ } else if (connection.getState().getState() == RTMP.STATE_DISCONNECTED) {
+ removeConnection(connection.getId());
handleBadRequest("Connection already closed.", resp);
return;
}
- client.setServletRequest(req);
- returnPendingMessages(client, resp);
+ connection.setServletRequest(req);
+ returnPendingMessages(connection, resp);
}
/**
More information about the Red5devs
mailing list