}
}
+ internal HttpChannelListener<IReplyChannel> Source {
+ get { return source; }
+ }
+
public MessageEncoder Encoder {
get { return source.MessageEncoder; }
}
AbortConnections (timeout);
// FIXME: this wait is sort of hack (because it should not be required), but without it some tests are blocked.
// This hack even had better be moved to base.CancelAsync().
- if (CurrentAsyncResult != null)
- CurrentAsyncResult.AsyncWaitHandle.WaitOne (TimeSpan.FromMilliseconds (300));
+// if (CurrentAsyncResult != null)
+// CurrentAsyncResult.AsyncWaitHandle.WaitOne (TimeSpan.FromMilliseconds (300));
return base.CancelAsync (timeout);
}
}
bool close_started;
+ object close_lock = new object ();
protected override void OnClose (TimeSpan timeout)
{
- if (close_started)
- return;
- close_started = true;
+ lock (close_lock) {
+ if (close_started)
+ return;
+ close_started = true;
+ }
DateTime start = DateTime.Now;
// FIXME: consider timeout
Message msg = null;
- if (ctxi.Request.HttpMethod == "POST") {
+ if (ctxi.Request.HttpMethod == "POST")
msg = CreatePostMessage (ctxi);
- if (msg == null)
- return false;
- } else if (ctxi.Request.HttpMethod == "GET")
+ else if (ctxi.Request.HttpMethod == "GET")
msg = Message.CreateMessage (MessageVersion.None, null); // HTTP GET-based request
+ if (msg == null)
+ return false;
+
if (msg.Headers.To == null)
msg.Headers.To = ctxi.Request.Url;
msg.Properties.Add ("Via", LocalAddress.Uri);
msg.Properties.Add (HttpRequestMessageProperty.Name, CreateRequestProperty (ctxi));
+ Logger.LogMessage (MessageLogSourceKind.TransportReceive, ref msg, source.Source.MaxReceivedMessageSize);
+
context = new HttpRequestContext (this, ctxi, msg);
reqctx = context;
return true;
msg.Headers.Action = action;
}
}
+ msg.Properties.Add (RemoteEndpointMessageProperty.Name, new RemoteEndpointMessageProperty (ctxi.Request.ClientIPAddress, ctxi.Request.ClientPort));
return msg;
}