avoid a data copy

1 files changed, 60 insertions, 52 deletions

diff --git a/OpenSim/Framework/Servers/HttpServer/PollServiceHttpRequest.cs b/OpenSim/Framework/Servers/HttpServer/PollServiceHttpRequest.cs
index cf4f835..66fd2c6 100644
--- a/OpenSim/Framework/Servers/HttpServer/PollServiceHttpRequest.cs
+++ b/OpenSim/Framework/Servers/HttpServer/PollServiceHttpRequest.cs
@@ -81,44 +81,18 @@ namespace OpenSim.Framework.Servers.HttpServer
 
         internal void DoHTTPGruntWork(Hashtable responsedata)
         {
-            OSHttpResponse response
-                = new OSHttpResponse(new HttpResponse(HttpContext, Request), HttpContext);
-
-            byte[] buffer = srvDoHTTPGruntWork(responsedata, response);
-
-            if(Request.Body.CanRead)
+            if (Request.Body.CanRead)
                 Request.Body.Dispose();
 
-            response.SendChunked = false;
-            response.ContentLength64 = buffer.Length;
-
-            try
-            {
-                response.OutputStream.Write(buffer, 0, buffer.Length);
-                response.Send();
-                buffer = null;
-            }
-            catch (Exception ex)
-            {
-                if(ex is System.Net.Sockets.SocketException)
-                {
-                    // only mute connection reset by peer so we are not totally blind for now
-                    if(((System.Net.Sockets.SocketException)ex).SocketErrorCode != System.Net.Sockets.SocketError.ConnectionReset)
-                         m_log.Warn("[POLL SERVICE WORKER THREAD]: Error ", ex);
-                }
-                else
-                    m_log.Warn("[POLL SERVICE WORKER THREAD]: Error ", ex);
-            }
-
-            PollServiceArgs.RequestsHandled++;
-        }
+            OSHttpResponse response
+                = new OSHttpResponse(new HttpResponse(HttpContext, Request), HttpContext);
 
-        internal byte[] srvDoHTTPGruntWork(Hashtable responsedata, OSHttpResponse response)
-        {
-            int responsecode;
+            int responsecode = 200;
             string responseString = String.Empty;
-            byte[] responseBytes = null;
             string contentType;
+            byte[] buffer = null;
+            int rangeStart = 0;
+            int rangeLen = -1;
 
             if (responsedata == null)
             {
@@ -132,12 +106,23 @@ namespace OpenSim.Framework.Servers.HttpServer
                 try
                 {
                     //m_log.Info("[BASE HTTP SERVER]: Doing HTTP Grunt work with response");
-                    responsecode = (int)responsedata["int_response_code"];
+                    if(responsedata["int_response_code"] != null)
+                        responsecode = (int)responsedata["int_response_code"];
 
                     if (responsedata["bin_response_data"] != null)
-                        responseBytes = (byte[])responsedata["bin_response_data"];
+                    {
+                        buffer = (byte[])responsedata["bin_response_data"];
+                        responsedata["bin_response_data"] = null;
+
+                        if (responsedata["bin_start"] != null)
+                            rangeStart = (int)responsedata["bin_start"];
+
+                        if (responsedata["int_bytes"] != null)
+                            rangeLen = (int)responsedata["int_bytes"];
+                    }
                     else
                         responseString = (string)responsedata["str_response_string"];
+
                     contentType = (string)responsedata["content_type"];
                     if (responseString == null)
                         responseString = String.Empty;
@@ -159,7 +144,6 @@ namespace OpenSim.Framework.Servers.HttpServer
             {
                 response.ProtocolVersion = (string)responsedata["http_protocol_version"];
             }
-
             if (responsedata.ContainsKey("keepalive"))
             {
                 bool keepalive = (bool)responsedata["keepalive"];
@@ -170,13 +154,6 @@ namespace OpenSim.Framework.Servers.HttpServer
             if (responsedata.ContainsKey("access_control_allow_origin"))
                 response.AddHeader("Access-Control-Allow-Origin", (string)responsedata["access_control_allow_origin"]);
 
-            if (string.IsNullOrEmpty(contentType))
-            {
-                contentType = "text/html";
-            }
-
-            // The client ignores anything but 200 here for web login, so ensure that this is 200 for that
-
             response.StatusCode = responsecode;
 
             if (responsecode == (int)OSHttpStatusCode.RedirectMovedPermanently)
@@ -184,7 +161,11 @@ namespace OpenSim.Framework.Servers.HttpServer
                 response.RedirectLocation = (string)responsedata["str_redirect_location"];
             }
 
-            response.AddHeader("Content-Type", contentType);
+            if (string.IsNullOrEmpty(contentType))
+                response.AddHeader("Content-Type", "text/html");
+            else
+                response.AddHeader("Content-Type", contentType);
+
             if (responsedata.ContainsKey("headers"))
             {
                 Hashtable headerdata = (Hashtable)responsedata["headers"];
@@ -193,13 +174,7 @@ namespace OpenSim.Framework.Servers.HttpServer
                     response.AddHeader(header, headerdata[header].ToString());
             }
 
-            byte[] buffer;
-
-            if (responseBytes != null)
-            {
-                buffer = responseBytes;
-            }
-            else
+            if(buffer == null)
             {
                 if (!(contentType.Contains("image")
                     || contentType.Contains("x-shockwave-flash")
@@ -217,8 +192,41 @@ namespace OpenSim.Framework.Servers.HttpServer
                 response.ContentEncoding = Encoding.UTF8;
             }
 
-            return buffer;
+            if (rangeStart < 0 || rangeStart > buffer.Length)
+                rangeStart = 0;
+
+            if (rangeLen < 0)
+                rangeLen = buffer.Length;
+            else if (rangeLen + rangeStart > buffer.Length)
+                rangeLen = buffer.Length - rangeStart;
+
+            response.SendChunked = false;
+            response.ContentLength64 = rangeLen;
+
+            try
+            {
+                if(rangeLen > 0)
+                    response.OutputStream.Write(buffer, rangeStart, rangeLen);
+
+                buffer = null;
+
+                response.Send();
+            }
+            catch (Exception ex)
+            {
+                if(ex is System.Net.Sockets.SocketException)
+                {
+                    // only mute connection reset by peer so we are not totally blind for now
+                    if(((System.Net.Sockets.SocketException)ex).SocketErrorCode != System.Net.Sockets.SocketError.ConnectionReset)
+                         m_log.Warn("[POLL SERVICE WORKER THREAD]: Error ", ex);
+                }
+                else
+                    m_log.Warn("[POLL SERVICE WORKER THREAD]: Error ", ex);
+            }
+
+            PollServiceArgs.RequestsHandled++;
         }
+
         internal void DoHTTPstop()
         {
             OSHttpResponse response