aboutsummaryrefslogtreecommitdiff
path: root/SocketHttpListener/Net/HttpResponseStream.Managed.cs
diff options
context:
space:
mode:
authorLuke Pulverenti <luke.pulverenti@gmail.com>2017-05-25 00:25:51 -0400
committerLuke Pulverenti <luke.pulverenti@gmail.com>2017-05-25 00:25:51 -0400
commitb9be73789b59553731c8d054cd73aa08165fdbca (patch)
tree6f04ceb9c1c0bf5c1f7aa124bc5238c01114baf2 /SocketHttpListener/Net/HttpResponseStream.Managed.cs
parent7470dfe61ba0615529a934e3caf94c4a8335401b (diff)
fix plugin loading
Diffstat (limited to 'SocketHttpListener/Net/HttpResponseStream.Managed.cs')
-rw-r--r--SocketHttpListener/Net/HttpResponseStream.Managed.cs20
1 files changed, 15 insertions, 5 deletions
diff --git a/SocketHttpListener/Net/HttpResponseStream.Managed.cs b/SocketHttpListener/Net/HttpResponseStream.Managed.cs
index 0a9efccb2..73c296580 100644
--- a/SocketHttpListener/Net/HttpResponseStream.Managed.cs
+++ b/SocketHttpListener/Net/HttpResponseStream.Managed.cs
@@ -3,11 +3,13 @@ using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Net;
+using System.Net.Sockets;
using System.Runtime.ExceptionServices;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using MediaBrowser.Model.IO;
+using MediaBrowser.Model.Logging;
using MediaBrowser.Model.Net;
using MediaBrowser.Model.System;
@@ -54,7 +56,9 @@ namespace SocketHttpListener.Net
private readonly bool _supportsDirectSocketAccess;
private readonly IEnvironmentInfo _environment;
private readonly IFileSystem _fileSystem;
- internal HttpResponseStream(Stream stream, HttpListenerResponse response, bool ignore_errors, IMemoryStreamFactory memoryStreamFactory, IAcceptSocket socket, bool supportsDirectSocketAccess, IEnvironmentInfo environment, IFileSystem fileSystem)
+ private readonly ILogger _logger;
+
+ internal HttpResponseStream(Stream stream, HttpListenerResponse response, bool ignore_errors, IMemoryStreamFactory memoryStreamFactory, IAcceptSocket socket, bool supportsDirectSocketAccess, IEnvironmentInfo environment, IFileSystem fileSystem, ILogger logger)
{
_response = response;
_ignore_errors = ignore_errors;
@@ -63,6 +67,7 @@ namespace SocketHttpListener.Net
_supportsDirectSocketAccess = supportsDirectSocketAccess;
_environment = environment;
_fileSystem = fileSystem;
+ _logger = logger;
_stream = stream;
}
@@ -173,7 +178,7 @@ namespace SocketHttpListener.Net
{
_stream.Write(buffer, offset, count);
}
- catch (IOException ex)
+ catch (Exception ex)
{
throw new HttpListenerException(ex.HResult, ex.Message);
}
@@ -265,7 +270,7 @@ namespace SocketHttpListener.Net
{
return _stream.BeginWrite(buffer, offset, size, cback, state);
}
- catch (IOException ex)
+ catch (Exception ex)
{
if (_ignore_errors)
{
@@ -305,12 +310,12 @@ namespace SocketHttpListener.Net
if (_response.SendChunked)
_stream.Write(s_crlf, 0, 2);
}
- catch (IOException ex)
+ catch (Exception ex)
{
// NetworkStream wraps exceptions in IOExceptions; if the underlying socket operation
// failed because of invalid arguments or usage, propagate that error. Otherwise
// wrap the whole thing in an HttpListenerException. This is all to match Windows behavior.
- if (ex.InnerException is ArgumentException || ex.InnerException is InvalidOperationException)
+ if (ex.InnerException is ArgumentException || ex.InnerException is InvalidOperationException || ex.InnerException is SocketException)
{
throw ex.InnerException;
}
@@ -365,6 +370,11 @@ namespace SocketHttpListener.Net
{
var allowAsync = _environment.OperatingSystem != MediaBrowser.Model.System.OperatingSystem.Windows;
+ //if (count <= 0)
+ //{
+ // allowAsync = true;
+ //}
+
var fileOpenOptions = offset > 0
? FileOpenOptions.RandomAccess
: FileOpenOptions.SequentialScan;