[Red5devs] [PATCH 14 of 15] connection object erroneously called "client"

[Daniel Rossi]

+1 :)

On 27/08/2008, at 11:13 AM, Thijs Triemstra | Collab wrote:

> +1 !
>
> thanks mabrek
>
> On 27 aug 2008, at 02:11, Steven Gong wrote:
>
>> I really think Mabrek can do all these fixes himself - better to  
>> get him the commit right to SVN...
>>
>> On Wed, Aug 27, 2008 at 2:06 AM, mabrek <mabrek at gmail.com> wrote:
>> 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);
>>        }
>>
>>        /**
>>
>>
>>
>> _______________________________________________
>> Red5devs mailing list
>> Red5devs at osflash.org
>> http://osflash.org/mailman/listinfo/red5devs_osflash.org
>>
>>
>>
>> -- 
>> Best Regards
>> Steven Gong
>>
>> InfraRed5 Red5 Consultant: http://www.infrared5.com, steven at infrared5.com
>>
>> Red5 Developer: http://osflash.org/red5, http://jira.red5.org/confluence/display/ 
>> ~steven/Home
>>
>> Javaflash Project Founder and Maintainer: http://osflash.org/ 
>> javaflash
>>
>> _______________________________________________
>> Red5devs mailing list
>> Red5devs at osflash.org
>> http://osflash.org/mailman/listinfo/red5devs_osflash.org
>
> _______________________________________________
> Red5devs mailing list
> Red5devs at osflash.org
> http://osflash.org/mailman/listinfo/red5devs_osflash.org

-------------- next part --------------
An HTML attachment was scrubbed...
URL: http://osflash.org/pipermail/red5devs_osflash.org/attachments/20080827/19bde40c/attachment-0001.html