abstract class HttpRequestInfo
{
+ public abstract long ContentLength64 { get; }
public abstract NameValueCollection QueryString { get; }
public abstract NameValueCollection Headers { get; }
public abstract Uri Url { get; }
HttpListenerRequest req;
+ public override long ContentLength64 {
+ get { return req.ContentLength64; }
+ }
public override NameValueCollection QueryString {
get { return req.QueryString; }
}
HttpRequest req;
+ public override long ContentLength64 {
+ get { return req.ContentLength; }
+ }
public override NameValueCollection QueryString {
get { return req.QueryString; }
}
// FIXME: supply maxSizeOfHeaders.
int maxSizeOfHeaders = 0x10000;
+#if false // FIXME: enable it, once duplex callback test gets passed.
+ Stream stream = ctxi.Request.InputStream;
+ if (source.Source.TransferMode == TransferMode.Buffered) {
+ if (ctxi.Request.ContentLength64 <= 0)
+ throw new ArgumentException ("This HTTP channel is configured to use buffered mode, and thus expects Content-Length sent to the listener");
+ long size = 0;
+ var ms = new MemoryStream ();
+ var buf = new byte [0x1000];
+ while (size < ctxi.Request.ContentLength64) {
+ if ((size += stream.Read (buf, 0, 0x1000)) > source.Source.MaxBufferSize)
+ throw new QuotaExceededException ("Message quota exceeded");
+ ms.Write (buf, 0, (int) (size - ms.Length));
+ }
+ ms.Position = 0;
+ stream = ms;
+ }
+
+ var msg = Encoder.ReadMessage (
+ stream, maxSizeOfHeaders, ctxi.Request.ContentType);
+#else
var msg = Encoder.ReadMessage (
ctxi.Request.InputStream, maxSizeOfHeaders, ctxi.Request.ContentType);
+#endif
if (MessageVersion.Envelope.Equals (EnvelopeVersion.Soap11) ||
MessageVersion.Addressing.Equals (AddressingVersion.None)) {