Enable TCP connection sharing to improve raven performance

[andreasohlund]

And avoid:

From time to time "Raven" gives up throwing System.Net.Sockets.SocketException (0x80004005): An operation on a socket could not be performed because the system lacked sufficient buffer space or because a queue was full 127.0.0.1:8080

http://msdn.microsoft.com/en-us/library/system.net.httpwebrequest.unsafeauthenticatedconnectionsharing.aspx

To set it:
documentStore.JsonRequestFactory => req => ((HttpWebRequest)req).UnsafeAuthenticatedConnectionSharing = true;

[johnsimons]

But according to the doco, this is only for when NTLM is used?

[ryanwatson]

I keep unfortunately coming back to this problem and it seems to occur when the server is just extremely busy. However it now seems to be a daily reoccurring theme that takes me ages to have to start stop and sometimes having to restart the server for things to slowly get back and running.

Is this due to a new port being for each request?

[johnsimons]

A different way to configure this is;

store.JsonRequestFactory.ConfigureRequest += (sender, e) =>
                       {
                           var httpWebRequest = ((HttpWebRequest) e.Request);
                           httpWebRequest.UnsafeAuthenticatedConnectionSharing = true;
                           httpWebRequest.PreAuthenticate = true;
                       };

[johnsimons]

Added way to enable it in 6383897

[ryanwatson]

With some modification and finishing off of some code johnsimons sent me, here's a work around in the mean time:

public class ModifyRaven : IWantToRunAtStartup
{
    public void Run() {
        var iDocumentStoreType =
            Type.GetType("Raven.Client.IDocumentStore, NServiceBus.Core, Version=3.3.0.0, Culture=neutral, PublicKeyToken=9fc386479f8a226c");
        var webRequestEventArgsType =
            Type.GetType(
                "Raven.Client.Connection.WebRequestEventArgs, NServiceBus.Core, Version=3.3.0.0, Culture=neutral, PublicKeyToken=9fc386479f8a226c");
        dynamic documentStore = Configure.Instance.Builder.Build(iDocumentStoreType);

        var eventHandlerType = typeof(EventHandler<>);
        var jsonRequestFactory = iDocumentStoreType.GetProperty("JsonRequestFactory")
            .GetValue(documentStore, null);
        var configureRequestEventInfo = iDocumentStoreType.GetProperty("JsonRequestFactory")
            .PropertyType.GetEvent("ConfigureRequest");

        var callbackMethodInfo = typeof(ModifyRaven).GetMethod("JsonRequestFactoryOnConfigureRequest", BindingFlags.Public | BindingFlags.Instance);
        var delegateType = eventHandlerType.MakeGenericType(webRequestEventArgsType);
        var handlera = Delegate.CreateDelegate(delegateType, null, callbackMethodInfo);
        configureRequestEventInfo.AddEventHandler(jsonRequestFactory, handlera);
    }

    public void JsonRequestFactoryOnConfigureRequest(object sender, dynamic webRequestEventArgs) {
        var httpWebRequest = (HttpWebRequest)GetProperty(webRequestEventArgs, "Request");
        httpWebRequest.UnsafeAuthenticatedConnectionSharing = true;
        httpWebRequest.PreAuthenticate = true;
    }

    public static object GetProperty(object target, string name) {
        var site = System.Runtime.CompilerServices.CallSite<Func<System.Runtime.CompilerServices.CallSite, object, object>>.Create(Microsoft.CSharp.RuntimeBinder.Binder.GetMember(0, name, target.GetType(), new[] { Microsoft.CSharp.RuntimeBinder.CSharpArgumentInfo.Create(0, null) }));
        return site.Target(site, target);
    }

    public void Stop() {

    }
}

[johnsimons]

Nice work @ryanwatson