diff options
author | UbitUmarov | 2014-09-17 15:36:22 +0100 |
---|---|---|
committer | UbitUmarov | 2014-09-17 15:36:22 +0100 |
commit | 9bf3e2a25745000fc9113c4b00f280fa67460601 (patch) | |
tree | e6d35f9c327e6ae16b8d8e443155e90677ee806b /OpenSim/Framework/Communications | |
parent | turn off Nangle on users of ServivePointManager like webrequests (diff) | |
download | opensim-SC-9bf3e2a25745000fc9113c4b00f280fa67460601.zip opensim-SC-9bf3e2a25745000fc9113c4b00f280fa67460601.tar.gz opensim-SC-9bf3e2a25745000fc9113c4b00f280fa67460601.tar.bz2 opensim-SC-9bf3e2a25745000fc9113c4b00f280fa67460601.tar.xz |
dispose some tmp streams
Diffstat (limited to 'OpenSim/Framework/Communications')
-rw-r--r-- | OpenSim/Framework/Communications/RestClient.cs | 32 |
1 files changed, 18 insertions, 14 deletions
diff --git a/OpenSim/Framework/Communications/RestClient.cs b/OpenSim/Framework/Communications/RestClient.cs index 42c0b18..de34250 100644 --- a/OpenSim/Framework/Communications/RestClient.cs +++ b/OpenSim/Framework/Communications/RestClient.cs | |||
@@ -329,15 +329,16 @@ namespace OpenSim.Framework.Communications | |||
329 | return null; | 329 | return null; |
330 | } | 330 | } |
331 | 331 | ||
332 | Stream src = _response.GetResponseStream(); | 332 | using (Stream src = _response.GetResponseStream()) |
333 | int length = src.Read(_readbuf, 0, BufferSize); | ||
334 | while (length > 0) | ||
335 | { | 333 | { |
336 | _resource.Write(_readbuf, 0, length); | 334 | int length = src.Read(_readbuf, 0, BufferSize); |
337 | length = src.Read(_readbuf, 0, BufferSize); | 335 | while (length > 0) |
336 | { | ||
337 | _resource.Write(_readbuf, 0, length); | ||
338 | length = src.Read(_readbuf, 0, BufferSize); | ||
339 | } | ||
338 | } | 340 | } |
339 | 341 | ||
340 | |||
341 | // TODO! Implement timeout, without killing the server | 342 | // TODO! Implement timeout, without killing the server |
342 | // this line implements the timeout, if there is a timeout, the callback fires and the request becomes aborted | 343 | // this line implements the timeout, if there is a timeout, the callback fires and the request becomes aborted |
343 | //ThreadPool.RegisterWaitForSingleObject(responseAsyncResult.AsyncWaitHandle, new WaitOrTimerCallback(TimeoutCallback), _request, DefaultTimeout, true); | 344 | //ThreadPool.RegisterWaitForSingleObject(responseAsyncResult.AsyncWaitHandle, new WaitOrTimerCallback(TimeoutCallback), _request, DefaultTimeout, true); |
@@ -372,16 +373,19 @@ namespace OpenSim.Framework.Communications | |||
372 | m_log.InfoFormat("[REST]: Sending Web Request {0}", buildUri()); | 373 | m_log.InfoFormat("[REST]: Sending Web Request {0}", buildUri()); |
373 | src.Seek(0, SeekOrigin.Begin); | 374 | src.Seek(0, SeekOrigin.Begin); |
374 | m_log.Info("[REST]: Seek is ok"); | 375 | m_log.Info("[REST]: Seek is ok"); |
375 | Stream dst = _request.GetRequestStream(); | ||
376 | m_log.Info("[REST]: GetRequestStream is ok"); | ||
377 | 376 | ||
378 | byte[] buf = new byte[1024]; | 377 | using (Stream dst = _request.GetRequestStream()) |
379 | int length = src.Read(buf, 0, 1024); | ||
380 | m_log.Info("[REST]: First Read is ok"); | ||
381 | while (length > 0) | ||
382 | { | 378 | { |
383 | dst.Write(buf, 0, length); | 379 | m_log.Info("[REST]: GetRequestStream is ok"); |
384 | length = src.Read(buf, 0, 1024); | 380 | |
381 | byte[] buf = new byte[1024]; | ||
382 | int length = src.Read(buf, 0, 1024); | ||
383 | m_log.Info("[REST]: First Read is ok"); | ||
384 | while (length > 0) | ||
385 | { | ||
386 | dst.Write(buf, 0, length); | ||
387 | length = src.Read(buf, 0, 1024); | ||
388 | } | ||
385 | } | 389 | } |
386 | 390 | ||
387 | _response = (HttpWebResponse) _request.GetResponse(); | 391 | _response = (HttpWebResponse) _request.GetResponse(); |