Changeset 4338


Ignore:
Timestamp:
08/27/10 13:25:48 (12 years ago)
Author:
cneumuel
Message:

improved stateless WCF-Proxy client with ServicePool

Location:
branches/3.3-HiveMigration/sources/HeuristicLab.Hive
Files:
1 added
1 deleted
10 edited

Legend:

Unmodified
Added
Removed
  • branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Calendar/3.3/Properties/AssemblyInfo.cs

    r4337 r4338  
    5858// [assembly: AssemblyVersion("1.0.*")]
    5959[assembly: AssemblyVersion("3.3.0.0")]
    60 [assembly: AssemblyFileVersion("3.3.0.4333")]
     60[assembly: AssemblyFileVersion("3.3.0.4337")]
  • branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Server.Core/3.3/app.config

    r4337 r4338  
    33  <system.diagnostics>
    44    <sources>
    5       <source name="Warnings" switchValue="Warning, ActivityTracing">
     5      <source name="System.ServiceModel.MessageLogging" switchValue="Verbose,ActivityTracing">
    66        <listeners>
    77          <add type="System.Diagnostics.DefaultTraceListener" name="Default">
     
    9292        <endpoint address="" binding="wsHttpBinding" bindingConfiguration="HiveServerHttpBinding"
    9393          name="SlaveHttpEndpoint" contract="HeuristicLab.Hive.Contracts.Interfaces.ISlaveFacade" />
    94         <endpoint address="mex" binding="mexHttpBinding" name="SlaveMexEndpoint" bindingConfiguration=""
    95           contract="HeuristicLab.Hive.Contracts.Interfaces.ISlaveFacade" />
     94        <endpoint address="mex" binding="mexHttpBinding" bindingConfiguration=""
     95          name="SlaveMexEndpoint" contract="IMetadataExchange" />
    9696        <endpoint binding="netTcpBinding" bindingConfiguration="TcpStreamedBinding"
    9797          name="SlaveTcpStreamedEndpoint" contract="HeuristicLab.Hive.Contracts.Interfaces.ISlaveFacade" />
    98         <endpoint address="mex" binding="mexTcpBinding" bindingConfiguration=""
    99           name="SlaveTcpMexEndpoint" contract="IMetadataExchange" />
    10098        <host>
    10199          <baseAddresses>
     
    109107          name="ServerConsoleHttpEndpoint" contract="HeuristicLab.Hive.Contracts.Interfaces.IServerConsoleFacade" />
    110108        <endpoint address="mex" binding="mexHttpBinding" name="ServerConsoleMexEndpoint"
    111           contract="HeuristicLab.Hive.Contracts.Interfaces.IServerConsoleFacade" />
     109          contract="IMetadataExchange" />
    112110        <host>
    113111          <baseAddresses>
     
    119117        <endpoint address="" binding="netTcpBinding" bindingConfiguration="TcpStreamedBinding"
    120118          name="ClientTcpStreamedEndpoint" contract="HeuristicLab.Hive.Contracts.Interfaces.IClientFacade" />
    121         <endpoint address="mex" binding="mexTcpBinding" bindingConfiguration=""
    122           name="ClientTcpMexEndpoint" contract="IMetadataExchange" />
    123119        <endpoint binding="wsHttpBinding" bindingConfiguration="HiveServerHttpBinding"
    124120          name="ClientHttpEndpoint" contract="HeuristicLab.Hive.Contracts.Interfaces.IClientFacade" />
    125121        <endpoint address="mex" binding="mexHttpBinding" bindingConfiguration=""
    126           name="ClientHttpMexEndpoint" contract="HeuristicLab.Hive.Contracts.Interfaces.IClientFacade" />
     122          name="ClientHttpMexEndpoint" contract="IMetadataExchange" />
    127123        <host>
    128124          <baseAddresses>
  • branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Slave.Communication/3.3/HeuristicLab.Hive.Slave.Communication-3.3.csproj

    r4316 r4338  
    122122      <DependentUpon>Settings.settings</DependentUpon>
    123123    </Compile>
    124     <Compile Include="ServiceLocator.cs" />
     124    <Compile Include="SlaveServicePool.cs" />
    125125    <Compile Include="WcfService.cs" />
    126126  </ItemGroup>
  • branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Slave.Communication/3.3/Service References/SlaveService/SlaveFacade.wsdl

    r4316 r4338  
    12151215      </wsa10:EndpointReference>
    12161216    </wsdl:port>
    1217     <wsdl:port name="SlaveTcpMexEndpoint" binding="i0:SlaveTcpMexEndpoint">
    1218       <soap12:address location="net.tcp://localhost:9001/SlaveServiceStreamed/mex" />
    1219       <wsa10:EndpointReference>
    1220         <wsa10:Address>net.tcp://localhost:9001/SlaveServiceStreamed/mex</wsa10:Address>
    1221       </wsa10:EndpointReference>
    1222     </wsdl:port>
    12231217  </wsdl:service>
    12241218</wsdl:definitions>
  • branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Slave.Communication/3.3/Service References/SlaveService/SlaveService.wsdl

    r4316 r4338  
    44    <wsp:ExactlyOne>
    55      <wsp:All>
    6         <wsaw:UsingAddressing />
    7       </wsp:All>
    8     </wsp:ExactlyOne>
    9   </wsp:Policy>
    10   <wsp:Policy wsu:Id="SlaveTcpMexEndpoint_policy">
    11     <wsp:ExactlyOne>
    12       <wsp:All>
    13         <msb:BinaryEncoding xmlns:msb="http://schemas.microsoft.com/ws/06/2004/mspolicy/netbinary1" />
    146        <wsaw:UsingAddressing />
    157      </wsp:All>
     
    148140    </wsdl:operation>
    149141  </wsdl:binding>
    150   <wsdl:binding name="SlaveTcpMexEndpoint" type="i0:ISlaveFacade">
    151     <wsp:PolicyReference URI="#SlaveTcpMexEndpoint_policy" />
    152     <soap12:binding transport="http://schemas.microsoft.com/soap/tcp" />
    153     <wsdl:operation name="Login">
    154       <soap12:operation soapAction="http://tempuri.org/ISlaveCommunicator/Login" style="document" />
    155       <wsdl:input>
    156         <soap12:body use="literal" />
    157       </wsdl:input>
    158       <wsdl:output>
    159         <soap12:body use="literal" />
    160       </wsdl:output>
    161     </wsdl:operation>
    162     <wsdl:operation name="ProcessHeartBeat">
    163       <soap12:operation soapAction="http://tempuri.org/ISlaveCommunicator/ProcessHeartBeat" style="document" />
    164       <wsdl:input>
    165         <soap12:body use="literal" />
    166       </wsdl:input>
    167       <wsdl:output>
    168         <soap12:body use="literal" />
    169       </wsdl:output>
    170     </wsdl:operation>
    171     <wsdl:operation name="GetJob">
    172       <soap12:operation soapAction="http://tempuri.org/ISlaveCommunicator/GetJob" style="document" />
    173       <wsdl:input>
    174         <soap12:body use="literal" />
    175       </wsdl:input>
    176       <wsdl:output>
    177         <soap12:body use="literal" />
    178       </wsdl:output>
    179     </wsdl:operation>
    180     <wsdl:operation name="StoreFinishedJobResult">
    181       <soap12:operation soapAction="http://tempuri.org/ISlaveCommunicator/StoreFinishedJobResult" style="document" />
    182       <wsdl:input>
    183         <soap12:body use="literal" />
    184       </wsdl:input>
    185       <wsdl:output>
    186         <soap12:body use="literal" />
    187       </wsdl:output>
    188     </wsdl:operation>
    189     <wsdl:operation name="ProcessSnapshot">
    190       <soap12:operation soapAction="http://tempuri.org/ISlaveCommunicator/ProcessSnapshot" style="document" />
    191       <wsdl:input>
    192         <soap12:body use="literal" />
    193       </wsdl:input>
    194       <wsdl:output>
    195         <soap12:body use="literal" />
    196       </wsdl:output>
    197     </wsdl:operation>
    198     <wsdl:operation name="Logout">
    199       <soap12:operation soapAction="http://tempuri.org/ISlaveCommunicator/Logout" style="document" />
    200       <wsdl:input>
    201         <soap12:body use="literal" />
    202       </wsdl:input>
    203       <wsdl:output>
    204         <soap12:body use="literal" />
    205       </wsdl:output>
    206     </wsdl:operation>
    207     <wsdl:operation name="IsJobStillNeeded">
    208       <soap12:operation soapAction="http://tempuri.org/ISlaveCommunicator/IsJobStillNeeded" style="document" />
    209       <wsdl:input>
    210         <soap12:body use="literal" />
    211       </wsdl:input>
    212       <wsdl:output>
    213         <soap12:body use="literal" />
    214       </wsdl:output>
    215     </wsdl:operation>
    216     <wsdl:operation name="GetPlugins">
    217       <soap12:operation soapAction="http://tempuri.org/ISlaveCommunicator/GetPlugins" style="document" />
    218       <wsdl:input>
    219         <soap12:body use="literal" />
    220       </wsdl:input>
    221       <wsdl:output>
    222         <soap12:body use="literal" />
    223       </wsdl:output>
    224     </wsdl:operation>
    225     <wsdl:operation name="GetCalendar">
    226       <soap12:operation soapAction="http://tempuri.org/ISlaveCommunicator/GetCalendar" style="document" />
    227       <wsdl:input>
    228         <soap12:body use="literal" />
    229       </wsdl:input>
    230       <wsdl:output>
    231         <soap12:body use="literal" />
    232       </wsdl:output>
    233     </wsdl:operation>
    234     <wsdl:operation name="SetCalendarStatus">
    235       <soap12:operation soapAction="http://tempuri.org/ISlaveCommunicator/SetCalendarStatus" style="document" />
    236       <wsdl:input>
    237         <soap12:body use="literal" />
    238       </wsdl:input>
    239       <wsdl:output>
    240         <soap12:body use="literal" />
    241       </wsdl:output>
    242     </wsdl:operation>
    243     <wsdl:operation name="GetStreamedJob">
    244       <soap12:operation soapAction="http://tempuri.org/ISlaveFacade/GetStreamedJob" style="document" />
    245       <wsdl:input>
    246         <soap12:body use="literal" />
    247       </wsdl:input>
    248       <wsdl:output>
    249         <soap12:body use="literal" />
    250       </wsdl:output>
    251     </wsdl:operation>
    252     <wsdl:operation name="GetStreamedPlugins">
    253       <soap12:operation soapAction="http://tempuri.org/ISlaveFacade/GetStreamedPlugins" style="document" />
    254       <wsdl:input>
    255         <soap12:body use="literal" />
    256       </wsdl:input>
    257       <wsdl:output>
    258         <soap12:body use="literal" />
    259       </wsdl:output>
    260     </wsdl:operation>
    261     <wsdl:operation name="StoreFinishedJobResultStreamed">
    262       <soap12:operation soapAction="http://tempuri.org/ISlaveFacade/StoreFinishedJobResultStreamed" style="document" />
    263       <wsdl:input>
    264         <soap12:body use="literal" />
    265       </wsdl:input>
    266       <wsdl:output>
    267         <soap12:body use="literal" />
    268       </wsdl:output>
    269     </wsdl:operation>
    270     <wsdl:operation name="ProcessSnapshotStreamed">
    271       <soap12:operation soapAction="http://tempuri.org/ISlaveFacade/ProcessSnapshotStreamed" style="document" />
    272       <wsdl:input>
    273         <soap12:body use="literal" />
    274       </wsdl:input>
    275       <wsdl:output>
    276         <soap12:body use="literal" />
    277       </wsdl:output>
    278     </wsdl:operation>
    279   </wsdl:binding>
    280142</wsdl:definitions>
  • branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Slave.Communication/3.3/Service References/SlaveService/SlaveService9.xsd

    r4305 r4338  
    9292          <xs:element minOccurs="0" name="Slave" nillable="true" type="tns:SlaveDto" />
    9393          <xs:element minOccurs="0" name="State" type="tns:JobState" />
    94           <xs:element minOccurs="0" name="UserId" type="ser:guid" />
     94          <xs:element minOccurs="0" name="UserId" nillable="true" type="xs:string" />
    9595        </xs:sequence>
    9696      </xs:extension>
  • branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Slave.Communication/3.3/Service References/SlaveService/configuration.svcinfo

    r4316 r4338  
    44  <bindings>
    55    <binding digest="System.ServiceModel.Configuration.NetTcpBindingElement, System.ServiceModel, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089:&lt;?xml version=&quot;1.0&quot; encoding=&quot;utf-16&quot;?&gt;&lt;Data hostNameComparisonMode=&quot;StrongWildcard&quot; listenBacklog=&quot;10&quot; maxBufferSize=&quot;65536&quot; maxConnections=&quot;10&quot; name=&quot;SlaveTcpStreamedEndpoint&quot; transactionFlow=&quot;false&quot; transactionProtocol=&quot;OleTransactions&quot; transferMode=&quot;Streamed&quot;&gt;&lt;readerQuotas maxArrayLength=&quot;16384&quot; maxBytesPerRead=&quot;4096&quot; maxDepth=&quot;32&quot; maxNameTableCharCount=&quot;16384&quot; maxStringContentLength=&quot;8192&quot; /&gt;&lt;reliableSession enabled=&quot;false&quot; inactivityTimeout=&quot;00:10:00&quot; ordered=&quot;true&quot; /&gt;&lt;security mode=&quot;TransportWithMessageCredential&quot;&gt;&lt;message algorithmSuite=&quot;Default&quot; clientCredentialType=&quot;UserName&quot; /&gt;&lt;transport clientCredentialType=&quot;Windows&quot; protectionLevel=&quot;EncryptAndSign&quot; /&gt;&lt;/security&gt;&lt;/Data&gt;" bindingType="netTcpBinding" name="SlaveTcpStreamedEndpoint" />
    6     <binding digest="System.ServiceModel.Configuration.NetTcpBindingElement, System.ServiceModel, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089:&lt;?xml version=&quot;1.0&quot; encoding=&quot;utf-16&quot;?&gt;&lt;Data hostNameComparisonMode=&quot;StrongWildcard&quot; listenBacklog=&quot;10&quot; maxBufferSize=&quot;65536&quot; maxConnections=&quot;10&quot; name=&quot;SlaveTcpMexEndpoint&quot; transactionFlow=&quot;false&quot; transactionProtocol=&quot;OleTransactions&quot; transferMode=&quot;Buffered&quot;&gt;&lt;readerQuotas maxArrayLength=&quot;16384&quot; maxBytesPerRead=&quot;4096&quot; maxDepth=&quot;32&quot; maxNameTableCharCount=&quot;16384&quot; maxStringContentLength=&quot;8192&quot; /&gt;&lt;reliableSession enabled=&quot;false&quot; inactivityTimeout=&quot;00:10:00&quot; ordered=&quot;true&quot; /&gt;&lt;security mode=&quot;None&quot;&gt;&lt;message clientCredentialType=&quot;Windows&quot; /&gt;&lt;transport clientCredentialType=&quot;Windows&quot; protectionLevel=&quot;EncryptAndSign&quot; /&gt;&lt;/security&gt;&lt;/Data&gt;" bindingType="netTcpBinding" name="SlaveTcpMexEndpoint" />
    76    <binding digest="System.ServiceModel.Configuration.WSHttpBindingElement, System.ServiceModel, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089:&lt;?xml version=&quot;1.0&quot; encoding=&quot;utf-16&quot;?&gt;&lt;Data hostNameComparisonMode=&quot;StrongWildcard&quot; messageEncoding=&quot;Text&quot; name=&quot;SlaveHttpEndpoint&quot; textEncoding=&quot;utf-8&quot; transactionFlow=&quot;false&quot;&gt;&lt;readerQuotas maxArrayLength=&quot;16384&quot; maxBytesPerRead=&quot;4096&quot; maxDepth=&quot;32&quot; maxNameTableCharCount=&quot;16384&quot; maxStringContentLength=&quot;8192&quot; /&gt;&lt;reliableSession enabled=&quot;false&quot; inactivityTimeout=&quot;00:10:00&quot; ordered=&quot;true&quot; /&gt;&lt;security mode=&quot;Message&quot;&gt;&lt;message algorithmSuite=&quot;Default&quot; clientCredentialType=&quot;UserName&quot; negotiateServiceCredential=&quot;true&quot; /&gt;&lt;transport clientCredentialType=&quot;Windows&quot; proxyCredentialType=&quot;None&quot; realm=&quot;&quot; /&gt;&lt;/security&gt;&lt;/Data&gt;" bindingType="wsHttpBinding" name="SlaveHttpEndpoint" />
    87    <binding digest="System.ServiceModel.Configuration.WSHttpBindingElement, System.ServiceModel, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089:&lt;?xml version=&quot;1.0&quot; encoding=&quot;utf-16&quot;?&gt;&lt;Data hostNameComparisonMode=&quot;StrongWildcard&quot; messageEncoding=&quot;Text&quot; name=&quot;SlaveMexEndpoint&quot; textEncoding=&quot;utf-8&quot; transactionFlow=&quot;false&quot;&gt;&lt;readerQuotas maxArrayLength=&quot;16384&quot; maxBytesPerRead=&quot;4096&quot; maxDepth=&quot;32&quot; maxNameTableCharCount=&quot;16384&quot; maxStringContentLength=&quot;8192&quot; /&gt;&lt;reliableSession enabled=&quot;false&quot; inactivityTimeout=&quot;00:10:00&quot; ordered=&quot;true&quot; /&gt;&lt;security mode=&quot;None&quot;&gt;&lt;message clientCredentialType=&quot;Windows&quot; negotiateServiceCredential=&quot;true&quot; /&gt;&lt;transport clientCredentialType=&quot;Windows&quot; proxyCredentialType=&quot;None&quot; realm=&quot;&quot; /&gt;&lt;/security&gt;&lt;/Data&gt;" bindingType="wsHttpBinding" name="SlaveMexEndpoint" />
     
    1211    <endpoint normalizedDigest="&lt;?xml version=&quot;1.0&quot; encoding=&quot;utf-16&quot;?&gt;&lt;Data address=&quot;http://localhost:9000/SlaveService/mex&quot; binding=&quot;wsHttpBinding&quot; bindingConfiguration=&quot;SlaveMexEndpoint&quot; contract=&quot;SlaveService.ISlaveFacade&quot; name=&quot;SlaveMexEndpoint&quot; /&gt;" digest="&lt;?xml version=&quot;1.0&quot; encoding=&quot;utf-16&quot;?&gt;&lt;Data address=&quot;http://localhost:9000/SlaveService/mex&quot; binding=&quot;wsHttpBinding&quot; bindingConfiguration=&quot;SlaveMexEndpoint&quot; contract=&quot;SlaveService.ISlaveFacade&quot; name=&quot;SlaveMexEndpoint&quot; /&gt;" contractName="SlaveService.ISlaveFacade" name="SlaveMexEndpoint" />
    1312    <endpoint normalizedDigest="&lt;?xml version=&quot;1.0&quot; encoding=&quot;utf-16&quot;?&gt;&lt;Data address=&quot;net.tcp://localhost:9001/SlaveServiceStreamed&quot; binding=&quot;netTcpBinding&quot; bindingConfiguration=&quot;SlaveTcpStreamedEndpoint&quot; contract=&quot;SlaveService.ISlaveFacade&quot; name=&quot;SlaveTcpStreamedEndpoint&quot;&gt;&lt;identity&gt;&lt;dns value=&quot;localhost&quot; /&gt;&lt;/identity&gt;&lt;/Data&gt;" digest="&lt;?xml version=&quot;1.0&quot; encoding=&quot;utf-16&quot;?&gt;&lt;Data address=&quot;net.tcp://localhost:9001/SlaveServiceStreamed&quot; binding=&quot;netTcpBinding&quot; bindingConfiguration=&quot;SlaveTcpStreamedEndpoint&quot; contract=&quot;SlaveService.ISlaveFacade&quot; name=&quot;SlaveTcpStreamedEndpoint&quot;&gt;&lt;identity&gt;&lt;dns value=&quot;localhost&quot; /&gt;&lt;/identity&gt;&lt;/Data&gt;" contractName="SlaveService.ISlaveFacade" name="SlaveTcpStreamedEndpoint" />
    14     <endpoint normalizedDigest="&lt;?xml version=&quot;1.0&quot; encoding=&quot;utf-16&quot;?&gt;&lt;Data address=&quot;net.tcp://localhost:9001/SlaveServiceStreamed/mex&quot; binding=&quot;netTcpBinding&quot; bindingConfiguration=&quot;SlaveTcpMexEndpoint&quot; contract=&quot;SlaveService.ISlaveFacade&quot; name=&quot;SlaveTcpMexEndpoint&quot; /&gt;" digest="&lt;?xml version=&quot;1.0&quot; encoding=&quot;utf-16&quot;?&gt;&lt;Data address=&quot;net.tcp://localhost:9001/SlaveServiceStreamed/mex&quot; binding=&quot;netTcpBinding&quot; bindingConfiguration=&quot;SlaveTcpMexEndpoint&quot; contract=&quot;SlaveService.ISlaveFacade&quot; name=&quot;SlaveTcpMexEndpoint&quot; /&gt;" contractName="SlaveService.ISlaveFacade" name="SlaveTcpMexEndpoint" />
    1513  </endpoints>
    1614</configurationSnapshot>
  • branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Slave.Communication/3.3/Service References/SlaveService/configuration91.svcinfo

    r4316 r4338  
    11<?xml version="1.0" encoding="utf-8"?>
    2 <SavedWcfConfigurationInformation xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsd="http://www.w3.org/2001/XMLSchema" Version="9.1" CheckSum="JGDzzEU6ZhHdCWJVHV2k7+yia3Q=">
     2<SavedWcfConfigurationInformation xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsd="http://www.w3.org/2001/XMLSchema" Version="9.1" CheckSum="IVbHOGoLIiHm7HALbaYOYdLHHj8=">
    33  <bindingConfigurations>
    44    <bindingConfiguration bindingType="netTcpBinding" name="SlaveTcpStreamedEndpoint">
     
    113113        </property>
    114114        <property path="/security/message/algorithmSuite" isComplexType="false" isExplicitlyDefined="true" clrType="System.ServiceModel.Security.SecurityAlgorithmSuite, System.ServiceModel, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    115           <serializedValue>Default</serializedValue>
    116         </property>
    117       </properties>
    118     </bindingConfiguration>
    119     <bindingConfiguration bindingType="netTcpBinding" name="SlaveTcpMexEndpoint">
    120       <properties>
    121         <property path="/name" isComplexType="false" isExplicitlyDefined="true" clrType="System.String, mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    122           <serializedValue>SlaveTcpMexEndpoint</serializedValue>
    123         </property>
    124         <property path="/closeTimeout" isComplexType="false" isExplicitlyDefined="true" clrType="System.TimeSpan, mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    125           <serializedValue>00:01:00</serializedValue>
    126         </property>
    127         <property path="/openTimeout" isComplexType="false" isExplicitlyDefined="true" clrType="System.TimeSpan, mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    128           <serializedValue>00:01:00</serializedValue>
    129         </property>
    130         <property path="/receiveTimeout" isComplexType="false" isExplicitlyDefined="true" clrType="System.TimeSpan, mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    131           <serializedValue>00:10:00</serializedValue>
    132         </property>
    133         <property path="/sendTimeout" isComplexType="false" isExplicitlyDefined="true" clrType="System.TimeSpan, mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    134           <serializedValue>00:01:00</serializedValue>
    135         </property>
    136         <property path="/transactionFlow" isComplexType="false" isExplicitlyDefined="true" clrType="System.Boolean, mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    137           <serializedValue>False</serializedValue>
    138         </property>
    139         <property path="/transferMode" isComplexType="false" isExplicitlyDefined="true" clrType="System.ServiceModel.TransferMode, System.ServiceModel, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    140           <serializedValue>Buffered</serializedValue>
    141         </property>
    142         <property path="/transactionProtocol" isComplexType="false" isExplicitlyDefined="true" clrType="System.ServiceModel.TransactionProtocol, System.ServiceModel, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    143           <serializedValue>OleTransactions</serializedValue>
    144         </property>
    145         <property path="/hostNameComparisonMode" isComplexType="false" isExplicitlyDefined="true" clrType="System.ServiceModel.HostNameComparisonMode, System.ServiceModel, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    146           <serializedValue>StrongWildcard</serializedValue>
    147         </property>
    148         <property path="/listenBacklog" isComplexType="false" isExplicitlyDefined="true" clrType="System.Int32, mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    149           <serializedValue>10</serializedValue>
    150         </property>
    151         <property path="/maxBufferPoolSize" isComplexType="false" isExplicitlyDefined="true" clrType="System.Int64, mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    152           <serializedValue>524288</serializedValue>
    153         </property>
    154         <property path="/maxBufferSize" isComplexType="false" isExplicitlyDefined="true" clrType="System.Int32, mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    155           <serializedValue>65536</serializedValue>
    156         </property>
    157         <property path="/maxConnections" isComplexType="false" isExplicitlyDefined="true" clrType="System.Int32, mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    158           <serializedValue>10</serializedValue>
    159         </property>
    160         <property path="/maxReceivedMessageSize" isComplexType="false" isExplicitlyDefined="true" clrType="System.Int64, mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    161           <serializedValue>65536</serializedValue>
    162         </property>
    163         <property path="/portSharingEnabled" isComplexType="false" isExplicitlyDefined="false" clrType="System.Boolean, mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    164           <serializedValue>False</serializedValue>
    165         </property>
    166         <property path="/readerQuotas" isComplexType="true" isExplicitlyDefined="false" clrType="System.ServiceModel.Configuration.XmlDictionaryReaderQuotasElement, System.ServiceModel, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    167           <serializedValue>System.ServiceModel.Configuration.XmlDictionaryReaderQuotasElement</serializedValue>
    168         </property>
    169         <property path="/readerQuotas/maxDepth" isComplexType="false" isExplicitlyDefined="true" clrType="System.Int32, mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    170           <serializedValue>32</serializedValue>
    171         </property>
    172         <property path="/readerQuotas/maxStringContentLength" isComplexType="false" isExplicitlyDefined="true" clrType="System.Int32, mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    173           <serializedValue>8192</serializedValue>
    174         </property>
    175         <property path="/readerQuotas/maxArrayLength" isComplexType="false" isExplicitlyDefined="true" clrType="System.Int32, mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    176           <serializedValue>16384</serializedValue>
    177         </property>
    178         <property path="/readerQuotas/maxBytesPerRead" isComplexType="false" isExplicitlyDefined="true" clrType="System.Int32, mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    179           <serializedValue>4096</serializedValue>
    180         </property>
    181         <property path="/readerQuotas/maxNameTableCharCount" isComplexType="false" isExplicitlyDefined="true" clrType="System.Int32, mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    182           <serializedValue>16384</serializedValue>
    183         </property>
    184         <property path="/reliableSession" isComplexType="true" isExplicitlyDefined="false" clrType="System.ServiceModel.Configuration.StandardBindingOptionalReliableSessionElement, System.ServiceModel, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    185           <serializedValue>System.ServiceModel.Configuration.StandardBindingOptionalReliableSessionElement</serializedValue>
    186         </property>
    187         <property path="/reliableSession/ordered" isComplexType="false" isExplicitlyDefined="true" clrType="System.Boolean, mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    188           <serializedValue>True</serializedValue>
    189         </property>
    190         <property path="/reliableSession/inactivityTimeout" isComplexType="false" isExplicitlyDefined="true" clrType="System.TimeSpan, mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    191           <serializedValue>00:10:00</serializedValue>
    192         </property>
    193         <property path="/reliableSession/enabled" isComplexType="false" isExplicitlyDefined="true" clrType="System.Boolean, mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    194           <serializedValue>False</serializedValue>
    195         </property>
    196         <property path="/security" isComplexType="true" isExplicitlyDefined="false" clrType="System.ServiceModel.Configuration.NetTcpSecurityElement, System.ServiceModel, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    197           <serializedValue>System.ServiceModel.Configuration.NetTcpSecurityElement</serializedValue>
    198         </property>
    199         <property path="/security/mode" isComplexType="false" isExplicitlyDefined="true" clrType="System.ServiceModel.SecurityMode, System.ServiceModel, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    200           <serializedValue>None</serializedValue>
    201         </property>
    202         <property path="/security/transport" isComplexType="true" isExplicitlyDefined="false" clrType="System.ServiceModel.Configuration.TcpTransportSecurityElement, System.ServiceModel, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    203           <serializedValue>System.ServiceModel.Configuration.TcpTransportSecurityElement</serializedValue>
    204         </property>
    205         <property path="/security/transport/clientCredentialType" isComplexType="false" isExplicitlyDefined="true" clrType="System.ServiceModel.TcpClientCredentialType, System.ServiceModel, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    206           <serializedValue>Windows</serializedValue>
    207         </property>
    208         <property path="/security/transport/protectionLevel" isComplexType="false" isExplicitlyDefined="true" clrType="System.Net.Security.ProtectionLevel, System, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    209           <serializedValue>EncryptAndSign</serializedValue>
    210         </property>
    211         <property path="/security/transport/extendedProtectionPolicy" isComplexType="true" isExplicitlyDefined="false" clrType="System.Security.Authentication.ExtendedProtection.Configuration.ExtendedProtectionPolicyElement, System, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    212           <serializedValue>System.Security.Authentication.ExtendedProtection.Configuration.ExtendedProtectionPolicyElement</serializedValue>
    213         </property>
    214         <property path="/security/transport/extendedProtectionPolicy/policyEnforcement" isComplexType="false" isExplicitlyDefined="false" clrType="System.Security.Authentication.ExtendedProtection.PolicyEnforcement, System, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    215           <serializedValue>Never</serializedValue>
    216         </property>
    217         <property path="/security/transport/extendedProtectionPolicy/protectionScenario" isComplexType="false" isExplicitlyDefined="false" clrType="System.Security.Authentication.ExtendedProtection.ProtectionScenario, System, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    218           <serializedValue>TransportSelected</serializedValue>
    219         </property>
    220         <property path="/security/transport/extendedProtectionPolicy/customServiceNames" isComplexType="true" isExplicitlyDefined="false" clrType="System.Security.Authentication.ExtendedProtection.Configuration.ServiceNameElementCollection, System, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    221           <serializedValue>(Collection)</serializedValue>
    222         </property>
    223         <property path="/security/message" isComplexType="true" isExplicitlyDefined="false" clrType="System.ServiceModel.Configuration.MessageSecurityOverTcpElement, System.ServiceModel, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    224           <serializedValue>System.ServiceModel.Configuration.MessageSecurityOverTcpElement</serializedValue>
    225         </property>
    226         <property path="/security/message/clientCredentialType" isComplexType="false" isExplicitlyDefined="true" clrType="System.ServiceModel.MessageCredentialType, System.ServiceModel, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    227           <serializedValue>Windows</serializedValue>
    228         </property>
    229         <property path="/security/message/algorithmSuite" isComplexType="false" isExplicitlyDefined="false" clrType="System.ServiceModel.Security.SecurityAlgorithmSuite, System.ServiceModel, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    230115          <serializedValue>Default</serializedValue>
    231116        </property>
     
    737622      </properties>
    738623    </endpoint>
    739     <endpoint name="SlaveTcpMexEndpoint" contract="SlaveService.ISlaveFacade" bindingType="netTcpBinding" address="net.tcp://localhost:9001/SlaveServiceStreamed/mex" bindingConfiguration="SlaveTcpMexEndpoint">
    740       <properties>
    741         <property path="/address" isComplexType="false" isExplicitlyDefined="true" clrType="System.Uri, System, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    742           <serializedValue>net.tcp://localhost:9001/SlaveServiceStreamed/mex</serializedValue>
    743         </property>
    744         <property path="/behaviorConfiguration" isComplexType="false" isExplicitlyDefined="false" clrType="System.String, mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    745           <serializedValue />
    746         </property>
    747         <property path="/binding" isComplexType="false" isExplicitlyDefined="true" clrType="System.String, mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    748           <serializedValue>netTcpBinding</serializedValue>
    749         </property>
    750         <property path="/bindingConfiguration" isComplexType="false" isExplicitlyDefined="true" clrType="System.String, mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    751           <serializedValue>SlaveTcpMexEndpoint</serializedValue>
    752         </property>
    753         <property path="/contract" isComplexType="false" isExplicitlyDefined="true" clrType="System.String, mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    754           <serializedValue>SlaveService.ISlaveFacade</serializedValue>
    755         </property>
    756         <property path="/headers" isComplexType="true" isExplicitlyDefined="false" clrType="System.ServiceModel.Configuration.AddressHeaderCollectionElement, System.ServiceModel, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    757           <serializedValue>System.ServiceModel.Configuration.AddressHeaderCollectionElement</serializedValue>
    758         </property>
    759         <property path="/headers/headers" isComplexType="false" isExplicitlyDefined="true" clrType="System.ServiceModel.Channels.AddressHeaderCollection, System.ServiceModel, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    760           <serializedValue>&lt;Header /&gt;</serializedValue>
    761         </property>
    762         <property path="/identity" isComplexType="true" isExplicitlyDefined="false" clrType="System.ServiceModel.Configuration.IdentityElement, System.ServiceModel, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    763           <serializedValue>System.ServiceModel.Configuration.IdentityElement</serializedValue>
    764         </property>
    765         <property path="/identity/userPrincipalName" isComplexType="true" isExplicitlyDefined="false" clrType="System.ServiceModel.Configuration.UserPrincipalNameElement, System.ServiceModel, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    766           <serializedValue>System.ServiceModel.Configuration.UserPrincipalNameElement</serializedValue>
    767         </property>
    768         <property path="/identity/userPrincipalName/value" isComplexType="false" isExplicitlyDefined="false" clrType="System.String, mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    769           <serializedValue />
    770         </property>
    771         <property path="/identity/servicePrincipalName" isComplexType="true" isExplicitlyDefined="false" clrType="System.ServiceModel.Configuration.ServicePrincipalNameElement, System.ServiceModel, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    772           <serializedValue>System.ServiceModel.Configuration.ServicePrincipalNameElement</serializedValue>
    773         </property>
    774         <property path="/identity/servicePrincipalName/value" isComplexType="false" isExplicitlyDefined="false" clrType="System.String, mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    775           <serializedValue />
    776         </property>
    777         <property path="/identity/dns" isComplexType="true" isExplicitlyDefined="false" clrType="System.ServiceModel.Configuration.DnsElement, System.ServiceModel, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    778           <serializedValue>System.ServiceModel.Configuration.DnsElement</serializedValue>
    779         </property>
    780         <property path="/identity/dns/value" isComplexType="false" isExplicitlyDefined="false" clrType="System.String, mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    781           <serializedValue />
    782         </property>
    783         <property path="/identity/rsa" isComplexType="true" isExplicitlyDefined="false" clrType="System.ServiceModel.Configuration.RsaElement, System.ServiceModel, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    784           <serializedValue>System.ServiceModel.Configuration.RsaElement</serializedValue>
    785         </property>
    786         <property path="/identity/rsa/value" isComplexType="false" isExplicitlyDefined="false" clrType="System.String, mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    787           <serializedValue />
    788         </property>
    789         <property path="/identity/certificate" isComplexType="true" isExplicitlyDefined="false" clrType="System.ServiceModel.Configuration.CertificateElement, System.ServiceModel, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    790           <serializedValue>System.ServiceModel.Configuration.CertificateElement</serializedValue>
    791         </property>
    792         <property path="/identity/certificate/encodedValue" isComplexType="false" isExplicitlyDefined="false" clrType="System.String, mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    793           <serializedValue />
    794         </property>
    795         <property path="/identity/certificateReference" isComplexType="true" isExplicitlyDefined="false" clrType="System.ServiceModel.Configuration.CertificateReferenceElement, System.ServiceModel, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    796           <serializedValue>System.ServiceModel.Configuration.CertificateReferenceElement</serializedValue>
    797         </property>
    798         <property path="/identity/certificateReference/storeName" isComplexType="false" isExplicitlyDefined="false" clrType="System.Security.Cryptography.X509Certificates.StoreName, System, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    799           <serializedValue>My</serializedValue>
    800         </property>
    801         <property path="/identity/certificateReference/storeLocation" isComplexType="false" isExplicitlyDefined="false" clrType="System.Security.Cryptography.X509Certificates.StoreLocation, System, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    802           <serializedValue>LocalMachine</serializedValue>
    803         </property>
    804         <property path="/identity/certificateReference/x509FindType" isComplexType="false" isExplicitlyDefined="false" clrType="System.Security.Cryptography.X509Certificates.X509FindType, System, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    805           <serializedValue>FindBySubjectDistinguishedName</serializedValue>
    806         </property>
    807         <property path="/identity/certificateReference/findValue" isComplexType="false" isExplicitlyDefined="false" clrType="System.String, mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    808           <serializedValue />
    809         </property>
    810         <property path="/identity/certificateReference/isChainIncluded" isComplexType="false" isExplicitlyDefined="false" clrType="System.Boolean, mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    811           <serializedValue>False</serializedValue>
    812         </property>
    813         <property path="/name" isComplexType="false" isExplicitlyDefined="true" clrType="System.String, mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    814           <serializedValue>SlaveTcpMexEndpoint</serializedValue>
    815         </property>
    816         <property path="/kind" isComplexType="false" isExplicitlyDefined="false" clrType="System.String, mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    817           <serializedValue />
    818         </property>
    819         <property path="/endpointConfiguration" isComplexType="false" isExplicitlyDefined="false" clrType="System.String, mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    820           <serializedValue />
    821         </property>
    822       </properties>
    823     </endpoint>
    824624  </endpoints>
    825625</SavedWcfConfigurationInformation>
  • branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Slave.Communication/3.3/WcfService.cs

    r4337 r4338  
    7878    public event EventHandler Connected;
    7979
     80    SlaveFacadeServicePool servicePool;
     81
    8082    /// <summary>
    8183    /// Constructor
     
    9799          return;
    98100        }
     101        servicePool = new SlaveFacadeServicePool(ServerIp);
    99102
    100103        Logger.Debug("Creating the new connection proxy");
    101         client = ServiceLocator.CreateStreamedSlaveFacade(ServerIp);
     104        client = servicePool.CreateStreamedSlaveFacade();
    102105        Logger.Debug("Created the new connection proxy");
    103106
     
    116119      }
    117120      finally {
    118         ServiceLocator.DisposeSlaveClient(client);
     121        servicePool.DisposeSlaveClient(client);
    119122      }
    120123    }
     
    146149        if (ConnState == NetworkEnum.WcfConnState.Connected) {
    147150          Logger.Debug("STARTED: Login Sync");
    148           client = ServiceLocator.CreateSlaveFacade(ServerIp);
     151          client = servicePool.CreateSlaveFacade();
    149152          Response res = client.Login(slaveInfo);
    150153          if (res.StatusMessage != ResponseStatus.Ok) {
     
    161164      }
    162165      finally {
    163         ServiceLocator.DisposeSlaveClient(client);
     166        servicePool.DisposeSlaveClient(client);
    164167      }
    165168    }
     
    173176      if (LoggedIn) {
    174177        Logger.Debug("STARTED: Fetching of Jobs from Server for Slave");
    175         SlaveService.ISlaveFacade client = ServiceLocator.CreateStreamedSlaveFacade(ServerIp);
     178        SlaveService.ISlaveFacade client = servicePool.CreateStreamedSlaveFacade();
    176179        //client.GetStreamedJobAsync(guid);
    177180        client.BeginGetStreamedJob(guid, (ar => {
     
    214217            HandleNetworkError(new FaultException("GetJobAsync did not complete"));
    215218
    216           ServiceLocator.DisposeSlaveClient(client);
     219          servicePool.DisposeSlaveClient(client);
    217220        }), null);
    218221      }
     
    234237        Logger.Debug("Making the call");
    235238        //proxy.StoreFinishedJobResultStreamedAsync(stream, stream);
    236         SlaveService.ISlaveFacade client = ServiceLocator.CreateStreamedSlaveFacade(ServerIp);
     239        SlaveService.ISlaveFacade client = servicePool.CreateStreamedSlaveFacade();
    237240        client.BeginStoreFinishedJobResultStreamed(stream, (ar => {
    238241          Logger.Debug("Finished storing the job");
     
    249252            HandleNetworkError(new FaultException("GetFinishedJobResultAsync did not complete"));
    250253          }
    251           ServiceLocator.DisposeSlaveClient(client);
     254          servicePool.DisposeSlaveClient(client);
    252255        }), null);
    253256      }
     
    262265        Stream stream = GetStreamedJobResult(clientId, jobId, result, percentage, exception);
    263266        //proxy.ProcessSnapshotStreamedAsync(stream, stream);
    264         SlaveService.ISlaveFacade client = ServiceLocator.CreateStreamedSlaveFacade(ServerIp);
     267        SlaveService.ISlaveFacade client = servicePool.CreateStreamedSlaveFacade();
    265268        client.BeginProcessSnapshotStreamed(stream, (ar => {
    266269          if (stream != null)
     
    274277            HandleNetworkError(new FaultException("ProcessSnapshotAsync did not complete"));
    275278          }
    276           ServiceLocator.DisposeSlaveClient(client);
     279          servicePool.DisposeSlaveClient(client);
    277280        }), null);
    278281      }
     
    291294        Logger.Debug("STARTING: sending heartbeat");
    292295        //proxy.ProcessHeartBeatAsync(hbd);
    293         SlaveService.ISlaveFacade client = ServiceLocator.CreateStreamedSlaveFacade(ServerIp);
     296        SlaveService.ISlaveFacade client = servicePool.CreateStreamedSlaveFacade();
    294297        client.BeginProcessHeartBeat(hbd, (ar => {
    295298          if (ar.IsCompleted) {
     
    304307            HandleNetworkError(new FaultException("ProcessHeartBeatAsync did not complete"));
    305308          }
    306           ServiceLocator.DisposeSlaveClient(client);
     309          servicePool.DisposeSlaveClient(client);
    307310        }), null);
    308311      }
     
    334337
    335338    public ResponseResultReceived StoreFinishedJobResultsSync(Guid clientId, Guid jobId, byte[] result, double percentage, Exception exception, bool finished) {
    336       SlaveService.ISlaveFacade client = ServiceLocator.CreateStreamedSlaveFacade(ServerIp);
     339      SlaveService.ISlaveFacade client = servicePool.CreateStreamedSlaveFacade();
    337340      ResponseResultReceived res = client.StoreFinishedJobResultStreamed(GetStreamedJobResult(clientId, jobId, result, percentage, exception));
    338       ServiceLocator.DisposeSlaveClient(client);
     341      servicePool.DisposeSlaveClient(client);
    339342      return res;
    340343    }
     
    343346      try {
    344347        Logger.Debug("STARTING: Sync call: IsJobStillNeeded");
    345         SlaveService.ISlaveFacade client = ServiceLocator.CreateStreamedSlaveFacade(ServerIp);
     348        SlaveService.ISlaveFacade client = servicePool.CreateStreamedSlaveFacade();
    346349        Response res = client.IsJobStillNeeded(jobId);
    347         ServiceLocator.DisposeSlaveClient(client);
     350        servicePool.DisposeSlaveClient(client);
    348351        Logger.Debug("ENDED: Sync call: IsJobStillNeeded");
    349352        return res;
     
    357360    public ResponseResultReceived ProcessSnapshotSync(Guid clientId, Guid jobId, byte[] result, double percentage, Exception exception) {
    358361      try {
    359         SlaveService.ISlaveFacade client = ServiceLocator.CreateStreamedSlaveFacade(ServerIp);
     362        SlaveService.ISlaveFacade client = servicePool.CreateStreamedSlaveFacade();
    360363        var res = client.ProcessSnapshotStreamed(GetStreamedJobResult(clientId, jobId, result, percentage, exception));
    361         ServiceLocator.DisposeSlaveClient(client);
     364        servicePool.DisposeSlaveClient(client);
    362365        return res;
    363366      }
     
    372375        Logger.Debug("STARTED: Requesting Plugins for Job");
    373376        Logger.Debug("STARTED: Getting the stream");
    374         SlaveService.ISlaveFacade client = ServiceLocator.CreateStreamedSlaveFacade(ServerIp);
     377        SlaveService.ISlaveFacade client = servicePool.CreateStreamedSlaveFacade();
    375378        Stream stream = client.GetStreamedPlugins(requestedPlugins.ToArray());
    376         ServiceLocator.DisposeSlaveClient(client);
     379        servicePool.DisposeSlaveClient(client);
    377380        Logger.Debug("ENDED: Getting the stream");
    378381        BinaryFormatter formatter = new BinaryFormatter();
     
    393396      try {
    394397        Logger.Debug("STARTED: Logout");
    395         SlaveService.ISlaveFacade client = ServiceLocator.CreateStreamedSlaveFacade(ServerIp);
     398        SlaveService.ISlaveFacade client = servicePool.CreateStreamedSlaveFacade();
    396399        client.Logout(guid);
    397         ServiceLocator.DisposeSlaveClient(client);
     400        servicePool.DisposeSlaveClient(client);
    398401        Logger.Debug("ENDED: Logout");
    399402      }
     
    406409      try {
    407410        Logger.Debug("STARTED: Syncing Calendars");
    408         SlaveService.ISlaveFacade client = ServiceLocator.CreateStreamedSlaveFacade(ServerIp);
     411        SlaveService.ISlaveFacade client = servicePool.CreateStreamedSlaveFacade();
    409412        ResponseCalendar cal = client.GetCalendar(clientId);
    410         ServiceLocator.DisposeSlaveClient(client);
     413        servicePool.DisposeSlaveClient(client);
    411414        Logger.Debug("ENDED: Syncing Calendars");
    412415        return cal;
     
    421424      try {
    422425        Logger.Debug("STARTED: Setting Calendar status to: " + state);
    423         SlaveService.ISlaveFacade client = ServiceLocator.CreateStreamedSlaveFacade(ServerIp);
     426        SlaveService.ISlaveFacade client = servicePool.CreateStreamedSlaveFacade();
    424427        Response resp = client.SetCalendarStatus(clientId, state);
    425         ServiceLocator.DisposeSlaveClient(client);
     428        servicePool.DisposeSlaveClient(client);
    426429        Logger.Debug("ENDED: Setting Calendar status to: " + state);
    427430        return resp;
  • branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Slave.Communication/3.3/app.config

    r4337 r4338  
    2525          hostNameComparisonMode="StrongWildcard" maxBufferPoolSize="104857600"
    2626          maxBufferSize="104857600" maxReceivedMessageSize="104857600">
    27           <readerQuotas maxDepth="32" maxStringContentLength="104857600" maxArrayLength="104857600"
    28             maxBytesPerRead="4096" maxNameTableCharCount="16384" />
     27          <readerQuotas maxDepth="32" maxStringContentLength="104857600"
     28            maxArrayLength="104857600" maxBytesPerRead="4096" maxNameTableCharCount="16384" />
    2929          <reliableSession ordered="true" inactivityTimeout="00:10:00"
    3030            enabled="false" />
     
    3232            <transport clientCredentialType="Windows" protectionLevel="EncryptAndSign" />
    3333            <message clientCredentialType="UserName" algorithmSuite="Default" />
    34           </security>
    35         </binding>
    36         <binding name="SlaveTcpMexEndpoint" closeTimeout="00:01:00" openTimeout="00:01:00"
    37           receiveTimeout="00:10:00" sendTimeout="00:01:00" transactionFlow="false"
    38           transferMode="Buffered" transactionProtocol="OleTransactions"
    39           hostNameComparisonMode="StrongWildcard" maxBufferPoolSize="524288"
    40           maxBufferSize="65536" maxReceivedMessageSize="65536">
    41           <readerQuotas maxDepth="32" maxStringContentLength="8192" maxArrayLength="16384"
    42             maxBytesPerRead="4096" maxNameTableCharCount="16384" />
    43           <reliableSession ordered="true" inactivityTimeout="00:10:00"
    44             enabled="false" />
    45           <security mode="None">
    46             <transport clientCredentialType="Windows" protectionLevel="EncryptAndSign" />
    47             <message clientCredentialType="Windows" />
    4834          </security>
    4935        </binding>
     
    9278        </identity>
    9379      </endpoint>
    94       <endpoint address="http://localhost:9000/SlaveService/mex" binding="wsHttpBinding"
     80      <endpoint address="http://localhost:9000/SlaveService/mex" binding="wsHttpBinding" behaviorConfiguration="SlaveMexEndpoint"
    9581        bindingConfiguration="SlaveMexEndpoint" contract="SlaveService.ISlaveFacade"
    9682        name="SlaveMexEndpoint" />
     
    10288        </identity>
    10389      </endpoint>
    104       <endpoint address="net.tcp://localhost:9001/SlaveServiceStreamed/mex"
    105         binding="netTcpBinding" bindingConfiguration="SlaveTcpMexEndpoint"
    106         contract="SlaveService.ISlaveFacade" name="SlaveTcpMexEndpoint" />
    10790    </client>
    10891  </system.serviceModel>
Note: See TracChangeset for help on using the changeset viewer.