Make sure we dispose of WebResponse, StreamReader and Stream in various places where we were not already.

0.7.4-extended
Justin Clark-Casey (justincc) 2013-02-27 00:21:02 +00:00
parent c80009e86c
commit ce2bf496a4
14 changed files with 244 additions and 211 deletions

View File

@ -44,7 +44,6 @@ namespace OpenSim.ConsoleClient
ReplyDelegate action) ReplyDelegate action)
{ {
WebRequest request = WebRequest.Create(requestUrl); WebRequest request = WebRequest.Create(requestUrl);
WebResponse response = null;
request.Method = "POST"; request.Method = "POST";
@ -64,17 +63,19 @@ namespace OpenSim.ConsoleClient
{ {
string reply = String.Empty; string reply = String.Empty;
response = request.EndGetResponse(ar); using (WebResponse response = request.EndGetResponse(ar))
{
try try
{ {
StreamReader r = new StreamReader(response.GetResponseStream()); using (Stream s = response.GetResponseStream())
using (StreamReader r = new StreamReader(s))
reply = r.ReadToEnd(); reply = r.ReadToEnd();
} }
catch (System.InvalidOperationException) catch (System.InvalidOperationException)
{ {
} }
}
action(requestUrl, data, reply); action(requestUrl, data, reply);
}, null); }, null);

View File

@ -65,10 +65,10 @@ namespace OpenSim.Framework.Configuration.HTTP
byte[] buf = new byte[8192]; byte[] buf = new byte[8192];
HttpWebRequest request = HttpWebRequest request =
(HttpWebRequest) WebRequest.Create(remoteConfigSettings.baseConfigURL + configFileName); (HttpWebRequest) WebRequest.Create(remoteConfigSettings.baseConfigURL + configFileName);
HttpWebResponse response = (HttpWebResponse) request.GetResponse(); using (HttpWebResponse response = (HttpWebResponse)request.GetResponse())
{
Stream resStream = response.GetResponseStream(); using (Stream resStream = response.GetResponseStream())
{
string tempString = null; string tempString = null;
int count = 0; int count = 0;
@ -80,9 +80,13 @@ namespace OpenSim.Framework.Configuration.HTTP
tempString = Util.UTF8.GetString(buf, 0, count); tempString = Util.UTF8.GetString(buf, 0, count);
sb.Append(tempString); sb.Append(tempString);
} }
} while (count > 0); }
while (count > 0);
LoadDataFromString(sb.ToString()); LoadDataFromString(sb.ToString());
} }
}
}
catch (WebException) catch (WebException)
{ {
m_log.Warn("Unable to connect to remote configuration file (" + m_log.Warn("Unable to connect to remote configuration file (" +

View File

@ -74,16 +74,26 @@ namespace OpenSim.Framework.RegionLoader.Web
try try
{ {
HttpWebResponse webResponse = (HttpWebResponse) webRequest.GetResponse();
m_log.Debug("[WEBLOADER]: Downloading region information...");
StreamReader reader = new StreamReader(webResponse.GetResponseStream());
string xmlSource = String.Empty; string xmlSource = String.Empty;
using (HttpWebResponse webResponse = (HttpWebResponse) webRequest.GetResponse())
{
m_log.Debug("[WEBLOADER]: Downloading region information...");
using (Stream s = webResponse.GetResponseStream())
{
using (StreamReader reader = new StreamReader(s))
{
string tempStr = reader.ReadLine(); string tempStr = reader.ReadLine();
while (tempStr != null) while (tempStr != null)
{ {
xmlSource = xmlSource + tempStr; xmlSource = xmlSource + tempStr;
tempStr = reader.ReadLine(); tempStr = reader.ReadLine();
} }
}
}
}
m_log.Debug("[WEBLOADER]: Done downloading region information from server. Total Bytes: " + m_log.Debug("[WEBLOADER]: Done downloading region information from server. Total Bytes: " +
xmlSource.Length); xmlSource.Length);
XmlDocument xmlDoc = new XmlDocument(); XmlDocument xmlDoc = new XmlDocument();
@ -107,17 +117,24 @@ namespace OpenSim.Framework.RegionLoader.Web
} }
catch (WebException ex) catch (WebException ex)
{ {
if (((HttpWebResponse)ex.Response).StatusCode == HttpStatusCode.NotFound) using (HttpWebResponse response = (HttpWebResponse)ex.Response)
{
if (response.StatusCode == HttpStatusCode.NotFound)
{ {
if (!allowRegionless) if (!allowRegionless)
throw ex; throw ex;
} }
else else
{
throw ex; throw ex;
} }
}
}
if (regionCount > 0 | allowRegionless) if (regionCount > 0 | allowRegionless)
{
return regionInfos; return regionInfos;
}
else else
{ {
m_log.Error("[WEBLOADER]: No region configs were available."); m_log.Error("[WEBLOADER]: No region configs were available.");

View File

@ -101,20 +101,11 @@ namespace OpenSim.Framework.Servers.HttpServer
using (WebResponse resp = request.GetResponse()) using (WebResponse resp = request.GetResponse())
{ {
XmlSerializer deserializer = new XmlSerializer(typeof(TResponse)); XmlSerializer deserializer = new XmlSerializer(typeof(TResponse));
Stream respStream = null;
try using (Stream respStream = resp.GetResponseStream())
{
respStream = resp.GetResponseStream();
deserial = (TResponse)deserializer.Deserialize(respStream); deserial = (TResponse)deserializer.Deserialize(respStream);
} }
catch { }
finally
{
if (respStream != null)
respStream.Close();
resp.Close();
}
}
return deserial; return deserial;
} }
} }

View File

@ -228,7 +228,7 @@ namespace OpenSim.Framework
errorMessage = we.Message; errorMessage = we.Message;
if (we.Status == WebExceptionStatus.ProtocolError) if (we.Status == WebExceptionStatus.ProtocolError)
{ {
HttpWebResponse webResponse = (HttpWebResponse)we.Response; using (HttpWebResponse webResponse = (HttpWebResponse)we.Response)
errorMessage = String.Format("[{0}] {1}", webResponse.StatusCode, webResponse.StatusDescription); errorMessage = String.Format("[{0}] {1}", webResponse.StatusCode, webResponse.StatusDescription);
} }
} }
@ -387,7 +387,7 @@ namespace OpenSim.Framework
errorMessage = we.Message; errorMessage = we.Message;
if (we.Status == WebExceptionStatus.ProtocolError) if (we.Status == WebExceptionStatus.ProtocolError)
{ {
HttpWebResponse webResponse = (HttpWebResponse)we.Response; using (HttpWebResponse webResponse = (HttpWebResponse)we.Response)
errorMessage = String.Format("[{0}] {1}",webResponse.StatusCode,webResponse.StatusDescription); errorMessage = String.Format("[{0}] {1}",webResponse.StatusCode,webResponse.StatusDescription);
} }
} }
@ -823,8 +823,8 @@ namespace OpenSim.Framework
{ {
if (e.Response is HttpWebResponse) if (e.Response is HttpWebResponse)
{ {
HttpWebResponse httpResponse = (HttpWebResponse)e.Response; using (HttpWebResponse httpResponse = (HttpWebResponse)e.Response)
{
if (httpResponse.StatusCode != HttpStatusCode.NotFound) if (httpResponse.StatusCode != HttpStatusCode.NotFound)
{ {
// We don't appear to be handling any other status codes, so log these feailures to that // We don't appear to be handling any other status codes, so log these feailures to that
@ -835,6 +835,7 @@ namespace OpenSim.Framework
} }
} }
} }
}
else else
{ {
m_log.ErrorFormat( m_log.ErrorFormat(
@ -972,12 +973,10 @@ namespace OpenSim.Framework
Stream respStream = null; Stream respStream = null;
try try
{ {
respStream = resp.GetResponseStream(); using (respStream = resp.GetResponseStream())
using (StreamReader reader = new StreamReader(respStream)) using (StreamReader reader = new StreamReader(respStream))
{
respstring = reader.ReadToEnd(); respstring = reader.ReadToEnd();
} }
}
catch (Exception e) catch (Exception e)
{ {
m_log.DebugFormat( m_log.DebugFormat(
@ -1102,10 +1101,11 @@ namespace OpenSim.Framework
{ {
if (resp.ContentLength != 0) if (resp.ContentLength != 0)
{ {
Stream respStream = resp.GetResponseStream(); using (Stream respStream = resp.GetResponseStream())
{
XmlSerializer deserializer = new XmlSerializer(typeof(TResponse)); XmlSerializer deserializer = new XmlSerializer(typeof(TResponse));
deserial = (TResponse)deserializer.Deserialize(respStream); deserial = (TResponse)deserializer.Deserialize(respStream);
respStream.Close(); }
} }
else else
{ {
@ -1117,8 +1117,8 @@ namespace OpenSim.Framework
} }
catch (WebException e) catch (WebException e)
{ {
HttpWebResponse hwr = (HttpWebResponse)e.Response; using (HttpWebResponse hwr = (HttpWebResponse)e.Response)
{
if (hwr != null && hwr.StatusCode == HttpStatusCode.NotFound) if (hwr != null && hwr.StatusCode == HttpStatusCode.NotFound)
return deserial; return deserial;
else else
@ -1126,6 +1126,7 @@ namespace OpenSim.Framework
"[SynchronousRestObjectRequester]: WebException for {0} {1} {2}: {3} {4}", "[SynchronousRestObjectRequester]: WebException for {0} {1} {2}: {3} {4}",
verb, requestUrl, typeof(TResponse).ToString(), e.Message, e.StackTrace); verb, requestUrl, typeof(TResponse).ToString(), e.Message, e.StackTrace);
} }
}
catch (System.InvalidOperationException) catch (System.InvalidOperationException)
{ {
// This is what happens when there is invalid XML // This is what happens when there is invalid XML

View File

@ -826,15 +826,19 @@ namespace OpenSim.Region.CoreModules.Scripting.VectorRender
try try
{ {
WebRequest request = HttpWebRequest.Create(url); WebRequest request = HttpWebRequest.Create(url);
//Ckrinke: Comment out for now as 'str' is unused. Bring it back into play later when it is used.
//Ckrinke Stream str = null; using (HttpWebResponse response = (HttpWebResponse)(request).GetResponse())
HttpWebResponse response = (HttpWebResponse)(request).GetResponse(); {
if (response.StatusCode == HttpStatusCode.OK) if (response.StatusCode == HttpStatusCode.OK)
{ {
Bitmap image = new Bitmap(response.GetResponseStream()); using (Stream s = response.GetResponseStream())
{
Bitmap image = new Bitmap(s);
return image; return image;
} }
} }
}
}
catch { } catch { }
return null; return null;

View File

@ -863,14 +863,15 @@ namespace OpenSim.Region.CoreModules.World.WorldMap
} }
string response_mapItems_reply = null; string response_mapItems_reply = null;
{ // get the response {
StreamReader sr = null;
try try
{ {
WebResponse webResponse = mapitemsrequest.GetResponse(); using (WebResponse webResponse = mapitemsrequest.GetResponse())
{
if (webResponse != null) if (webResponse != null)
{ {
sr = new StreamReader(webResponse.GetResponseStream()); using (Stream s = webResponse.GetResponseStream())
using (StreamReader sr = new StreamReader(s))
response_mapItems_reply = sr.ReadToEnd().Trim(); response_mapItems_reply = sr.ReadToEnd().Trim();
} }
else else
@ -878,6 +879,7 @@ namespace OpenSim.Region.CoreModules.World.WorldMap
return new OSDMap(); return new OSDMap();
} }
} }
}
catch (WebException) catch (WebException)
{ {
responseMap["connect"] = OSD.FromBoolean(false); responseMap["connect"] = OSD.FromBoolean(false);
@ -903,11 +905,6 @@ namespace OpenSim.Region.CoreModules.World.WorldMap
return responseMap; return responseMap;
} }
finally
{
if (sr != null)
sr.Close();
}
OSD rezResponse = null; OSD rezResponse = null;
try try
@ -921,6 +918,7 @@ namespace OpenSim.Region.CoreModules.World.WorldMap
{ {
m_log.InfoFormat("[WORLD MAP]: exception on parse of RequestMapItems reply from {0}: {1}", httpserver, ex.Message); m_log.InfoFormat("[WORLD MAP]: exception on parse of RequestMapItems reply from {0}: {1}", httpserver, ex.Message);
responseMap["connect"] = OSD.FromBoolean(false); responseMap["connect"] = OSD.FromBoolean(false);
lock (m_blacklistedregions) lock (m_blacklistedregions)
{ {
if (!m_blacklistedregions.ContainsKey(regionhandle)) if (!m_blacklistedregions.ContainsKey(regionhandle))

View File

@ -551,13 +551,20 @@ namespace OpenSim.Region.OptionalModules.Avatar.Voice.FreeSwitchVoice
reqStream.Close(); reqStream.Close();
} }
HttpWebResponse fwdrsp = (HttpWebResponse)forwardreq.GetResponse(); using (HttpWebResponse fwdrsp = (HttpWebResponse)forwardreq.GetResponse())
{
Encoding encoding = Util.UTF8; Encoding encoding = Util.UTF8;
StreamReader fwdresponsestream = new StreamReader(fwdrsp.GetResponseStream(), encoding);
using (Stream s = fwdrsp.GetResponseStream())
{
using (StreamReader fwdresponsestream = new StreamReader(s))
{
fwdresponsestr = fwdresponsestream.ReadToEnd(); fwdresponsestr = fwdresponsestream.ReadToEnd();
fwdresponsecontenttype = fwdrsp.ContentType; fwdresponsecontenttype = fwdrsp.ContentType;
fwdresponsecode = (int)fwdrsp.StatusCode; fwdresponsecode = (int)fwdrsp.StatusCode;
fwdresponsestream.Close(); }
}
}
response["content_type"] = fwdresponsecontenttype; response["content_type"] = fwdresponsecontenttype;
response["str_response_string"] = fwdresponsestr; response["str_response_string"] = fwdresponsestr;

View File

@ -1115,17 +1115,15 @@ namespace OpenSim.Region.OptionalModules.Avatar.Voice.VivoxVoice
m_log.DebugFormat("[VivoxVoice] Sending request <{0}>", requrl); m_log.DebugFormat("[VivoxVoice] Sending request <{0}>", requrl);
HttpWebRequest req = (HttpWebRequest)WebRequest.Create(requrl); HttpWebRequest req = (HttpWebRequest)WebRequest.Create(requrl);
HttpWebResponse rsp = null;
// We are sending just parameters, no content // We are sending just parameters, no content
req.ContentLength = 0; req.ContentLength = 0;
// Send request and retrieve the response // Send request and retrieve the response
rsp = (HttpWebResponse)req.GetResponse(); using (HttpWebResponse rsp = (HttpWebResponse)req.GetResponse())
using (Stream s = rsp.GetResponseStream())
XmlTextReader rdr = new XmlTextReader(rsp.GetResponseStream()); using (XmlTextReader rdr = new XmlTextReader(s))
doc.Load(rdr); doc.Load(rdr);
rdr.Close();
} }
catch (Exception e) catch (Exception e)
{ {

View File

@ -1151,17 +1151,25 @@ namespace Nwc.XmlRpc
request.AllowWriteStreamBuffering = true; request.AllowWriteStreamBuffering = true;
request.KeepAlive = !_disableKeepAlive; request.KeepAlive = !_disableKeepAlive;
Stream stream = request.GetRequestStream(); using (Stream stream = request.GetRequestStream())
XmlTextWriter xml = new XmlTextWriter(stream, Encoding.ASCII); {
using (XmlTextWriter xml = new XmlTextWriter(stream, Encoding.ASCII))
{
_serializer.Serialize(xml, this); _serializer.Serialize(xml, this);
xml.Flush(); xml.Flush();
xml.Close(); }
}
HttpWebResponse response = (HttpWebResponse)request.GetResponse();
StreamReader input = new StreamReader(response.GetResponseStream());
string inputXml = input.ReadToEnd();
XmlRpcResponse resp; XmlRpcResponse resp;
using (HttpWebResponse response = (HttpWebResponse)request.GetResponse())
{
using (Stream s = response.GetResponseStream())
{
using (StreamReader input = new StreamReader(s))
{
string inputXml = input.ReadToEnd();
try try
{ {
resp = (XmlRpcResponse)_deserializer.Deserialize(inputXml); resp = (XmlRpcResponse)_deserializer.Deserialize(inputXml);
@ -1171,8 +1179,10 @@ namespace Nwc.XmlRpc
RequestResponse = inputXml; RequestResponse = inputXml;
throw e; throw e;
} }
input.Close(); }
response.Close(); }
}
return resp; return resp;
} }
} }

View File

@ -73,7 +73,6 @@ namespace OpenSim.Services.Connectors
} }
} }
public virtual string Helo() public virtual string Helo()
{ {
HttpWebRequest req = (HttpWebRequest)HttpWebRequest.Create(m_ServerURI); HttpWebRequest req = (HttpWebRequest)HttpWebRequest.Create(m_ServerURI);
@ -82,11 +81,13 @@ namespace OpenSim.Services.Connectors
try try
{ {
WebResponse response = req.GetResponse(); using (WebResponse response = req.GetResponse())
{
if (response.Headers.Get("X-Handlers-Provided") == null) // just in case this ever returns a null if (response.Headers.Get("X-Handlers-Provided") == null) // just in case this ever returns a null
return string.Empty; return string.Empty;
return response.Headers.Get("X-Handlers-Provided"); return response.Headers.Get("X-Handlers-Provided");
} }
}
catch (Exception e) catch (Exception e)
{ {
m_log.DebugFormat("[HELO SERVICE]: Unable to perform HELO request to {0}: {1}", m_ServerURI, e.Message); m_log.DebugFormat("[HELO SERVICE]: Unable to perform HELO request to {0}: {1}", m_ServerURI, e.Message);
@ -95,6 +96,5 @@ namespace OpenSim.Services.Connectors
// fail // fail
return string.Empty; return string.Empty;
} }
} }
} }

View File

@ -171,19 +171,20 @@ namespace OpenSim.Services.Connectors.Hypergrid
// Let's wait for the response // Let's wait for the response
//m_log.Info("[USER AGENT CONNECTOR]: Waiting for a reply after DoCreateChildAgentCall"); //m_log.Info("[USER AGENT CONNECTOR]: Waiting for a reply after DoCreateChildAgentCall");
WebResponse webResponse = null;
StreamReader sr = null;
try try
{ {
webResponse = AgentCreateRequest.GetResponse(); using (WebResponse webResponse = AgentCreateRequest.GetResponse())
{
if (webResponse == null) if (webResponse == null)
{ {
m_log.Info("[USER AGENT CONNECTOR]: Null reply on DoCreateChildAgentCall post"); m_log.Info("[USER AGENT CONNECTOR]: Null reply on DoCreateChildAgentCall post");
} }
else else
{ {
using (Stream s = webResponse.GetResponseStream())
sr = new StreamReader(webResponse.GetResponseStream()); {
using (StreamReader sr = new StreamReader(s))
{
string response = sr.ReadToEnd().Trim(); string response = sr.ReadToEnd().Trim();
m_log.InfoFormat("[USER AGENT CONNECTOR]: DoCreateChildAgentCall reply was {0} ", response); m_log.InfoFormat("[USER AGENT CONNECTOR]: DoCreateChildAgentCall reply was {0} ", response);
@ -210,17 +211,15 @@ namespace OpenSim.Services.Connectors.Hypergrid
} }
} }
} }
}
}
}
catch (WebException ex) catch (WebException ex)
{ {
m_log.InfoFormat("[USER AGENT CONNECTOR]: exception on reply of DoCreateChildAgentCall {0}", ex.Message); m_log.InfoFormat("[USER AGENT CONNECTOR]: exception on reply of DoCreateChildAgentCall {0}", ex.Message);
reason = "Destination did not reply"; reason = "Destination did not reply";
return false; return false;
} }
finally
{
if (sr != null)
sr.Close();
}
return true; return true;

View File

@ -168,10 +168,10 @@ namespace OpenSim.Services.Connectors
// Let's wait for the response // Let's wait for the response
//m_log.Info("[REST COMMS]: Waiting for a reply after DoHelloNeighbourCall"); //m_log.Info("[REST COMMS]: Waiting for a reply after DoHelloNeighbourCall");
StreamReader sr = null;
try try
{ {
WebResponse webResponse = helloNeighbourRequest.GetResponse(); using (WebResponse webResponse = helloNeighbourRequest.GetResponse())
{
if (webResponse == null) if (webResponse == null)
{ {
m_log.DebugFormat( m_log.DebugFormat(
@ -179,11 +179,16 @@ namespace OpenSim.Services.Connectors
thisRegion.RegionName, region.RegionName); thisRegion.RegionName, region.RegionName);
} }
sr = new StreamReader(webResponse.GetResponseStream()); using (Stream s = webResponse.GetResponseStream())
{
using (StreamReader sr = new StreamReader(s))
{
//reply = sr.ReadToEnd().Trim(); //reply = sr.ReadToEnd().Trim();
sr.ReadToEnd().Trim(); sr.ReadToEnd().Trim();
//m_log.InfoFormat("[REST COMMS]: DoHelloNeighbourCall reply was {0} ", reply); //m_log.InfoFormat("[REST COMMS]: DoHelloNeighbourCall reply was {0} ", reply);
}
}
}
} }
catch (Exception e) catch (Exception e)
{ {
@ -193,11 +198,6 @@ namespace OpenSim.Services.Connectors
return false; return false;
} }
finally
{
if (sr != null)
sr.Close();
}
return true; return true;
} }

View File

@ -340,7 +340,8 @@ namespace OpenSim.Services.Connectors.SimianGrid
// By appending it to the URL also, we allow caching proxies (squid) to invalidate asset URLs // By appending it to the URL also, we allow caching proxies (squid) to invalidate asset URLs
HttpWebRequest request = (HttpWebRequest)HttpWebRequest.Create(m_serverUrl + asset.FullID.ToString()); HttpWebRequest request = (HttpWebRequest)HttpWebRequest.Create(m_serverUrl + asset.FullID.ToString());
HttpWebResponse response = MultipartForm.Post(request, postParameters); using (HttpWebResponse response = MultipartForm.Post(request, postParameters))
{
using (Stream responseStream = response.GetResponseStream()) using (Stream responseStream = response.GetResponseStream())
{ {
string responseStr = null; string responseStr = null;
@ -371,6 +372,7 @@ namespace OpenSim.Services.Connectors.SimianGrid
} }
} }
} }
}
catch (WebException ex) catch (WebException ex)
{ {
errorMessage = ex.Message; errorMessage = ex.Message;
@ -378,6 +380,7 @@ namespace OpenSim.Services.Connectors.SimianGrid
m_log.WarnFormat("[SIMIAN ASSET CONNECTOR]: Failed to store asset \"{0}\" ({1}, {2}): {3}", m_log.WarnFormat("[SIMIAN ASSET CONNECTOR]: Failed to store asset \"{0}\" ({1}, {2}): {3}",
asset.Name, asset.ID, asset.Metadata.ContentType, errorMessage); asset.Name, asset.ID, asset.Metadata.ContentType, errorMessage);
return null; return null;
} }