NetTcpBindingElement.cs 8.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185
  1. //------------------------------------------------------------------------------
  2. // Copyright (c) Microsoft Corporation. All rights reserved.
  3. //------------------------------------------------------------------------------
  4. namespace System.ServiceModel.Configuration
  5. {
  6. using System.ComponentModel;
  7. using System.Configuration;
  8. using System.ServiceModel;
  9. using System.Globalization;
  10. using System.ServiceModel.Security;
  11. using System.ServiceModel.Channels;
  12. using System.Net.Security;
  13. using System.Net.Sockets;
  14. public partial class NetTcpBindingElement : StandardBindingElement
  15. {
  16. public NetTcpBindingElement(string name)
  17. : base(name)
  18. {
  19. }
  20. public NetTcpBindingElement()
  21. : this(null)
  22. {
  23. }
  24. protected override Type BindingElementType
  25. {
  26. get { return typeof(NetTcpBinding); }
  27. }
  28. [ConfigurationProperty(ConfigurationStrings.TransactionFlow, DefaultValue = TransactionFlowDefaults.Transactions)]
  29. public bool TransactionFlow
  30. {
  31. get { return (bool)base[ConfigurationStrings.TransactionFlow]; }
  32. set { base[ConfigurationStrings.TransactionFlow] = value; }
  33. }
  34. [ConfigurationProperty(ConfigurationStrings.TransferMode, DefaultValue = ConnectionOrientedTransportDefaults.TransferMode)]
  35. [ServiceModelEnumValidator(typeof(TransferModeHelper))]
  36. public TransferMode TransferMode
  37. {
  38. get { return (TransferMode)base[ConfigurationStrings.TransferMode]; }
  39. set { base[ConfigurationStrings.TransferMode] = value; }
  40. }
  41. [ConfigurationProperty(ConfigurationStrings.TransactionProtocol, DefaultValue = TransactionFlowDefaults.TransactionProtocolString)]
  42. [TypeConverter(typeof(TransactionProtocolConverter))]
  43. public TransactionProtocol TransactionProtocol
  44. {
  45. get { return (TransactionProtocol)base[ConfigurationStrings.TransactionProtocol]; }
  46. set { base[ConfigurationStrings.TransactionProtocol] = value; }
  47. }
  48. [ConfigurationProperty(ConfigurationStrings.HostNameComparisonMode, DefaultValue = ConnectionOrientedTransportDefaults.HostNameComparisonMode)]
  49. [ServiceModelEnumValidator(typeof(HostNameComparisonModeHelper))]
  50. public HostNameComparisonMode HostNameComparisonMode
  51. {
  52. get { return (HostNameComparisonMode)base[ConfigurationStrings.HostNameComparisonMode]; }
  53. set { base[ConfigurationStrings.HostNameComparisonMode] = value; }
  54. }
  55. [ConfigurationProperty(ConfigurationStrings.ListenBacklog, DefaultValue = TcpTransportDefaults.ListenBacklogConst)]
  56. [IntegerValidator(MinValue = 0)]
  57. public int ListenBacklog
  58. {
  59. get { return (int)base[ConfigurationStrings.ListenBacklog]; }
  60. set { base[ConfigurationStrings.ListenBacklog] = value; }
  61. }
  62. [ConfigurationProperty(ConfigurationStrings.MaxBufferPoolSize, DefaultValue = TransportDefaults.MaxBufferPoolSize)]
  63. [LongValidator(MinValue = 0)]
  64. public long MaxBufferPoolSize
  65. {
  66. get { return (long)base[ConfigurationStrings.MaxBufferPoolSize]; }
  67. set { base[ConfigurationStrings.MaxBufferPoolSize] = value; }
  68. }
  69. [ConfigurationProperty(ConfigurationStrings.MaxBufferSize, DefaultValue = TransportDefaults.MaxBufferSize)]
  70. [IntegerValidator(MinValue = 1)]
  71. public int MaxBufferSize
  72. {
  73. get { return (int)base[ConfigurationStrings.MaxBufferSize]; }
  74. set { base[ConfigurationStrings.MaxBufferSize] = value; }
  75. }
  76. [ConfigurationProperty(ConfigurationStrings.MaxConnections, DefaultValue = ConnectionOrientedTransportDefaults.MaxPendingConnectionsConst)]
  77. [IntegerValidator(MinValue = 0)]
  78. public int MaxConnections
  79. {
  80. get { return (int)base[ConfigurationStrings.MaxConnections]; }
  81. set { base[ConfigurationStrings.MaxConnections] = value; }
  82. }
  83. [ConfigurationProperty(ConfigurationStrings.MaxReceivedMessageSize, DefaultValue = TransportDefaults.MaxReceivedMessageSize)]
  84. [LongValidator(MinValue = 1)]
  85. public long MaxReceivedMessageSize
  86. {
  87. get { return (long)base[ConfigurationStrings.MaxReceivedMessageSize]; }
  88. set { base[ConfigurationStrings.MaxReceivedMessageSize] = value; }
  89. }
  90. [ConfigurationProperty(ConfigurationStrings.PortSharingEnabled, DefaultValue = TcpTransportDefaults.PortSharingEnabled)]
  91. public bool PortSharingEnabled
  92. {
  93. get { return (bool)base[ConfigurationStrings.PortSharingEnabled]; }
  94. set { base[ConfigurationStrings.PortSharingEnabled] = value; }
  95. }
  96. [ConfigurationProperty(ConfigurationStrings.ReaderQuotas)]
  97. public XmlDictionaryReaderQuotasElement ReaderQuotas
  98. {
  99. get { return (XmlDictionaryReaderQuotasElement)base[ConfigurationStrings.ReaderQuotas]; }
  100. }
  101. [ConfigurationProperty(ConfigurationStrings.ReliableSession)]
  102. public StandardBindingOptionalReliableSessionElement ReliableSession
  103. {
  104. get { return (StandardBindingOptionalReliableSessionElement)base[ConfigurationStrings.ReliableSession]; }
  105. }
  106. [ConfigurationProperty(ConfigurationStrings.Security)]
  107. public NetTcpSecurityElement Security
  108. {
  109. get { return (NetTcpSecurityElement)base[ConfigurationStrings.Security]; }
  110. }
  111. protected internal override void InitializeFrom(Binding binding)
  112. {
  113. base.InitializeFrom(binding);
  114. NetTcpBinding nptBinding = (NetTcpBinding)binding;
  115. SetPropertyValueIfNotDefaultValue(ConfigurationStrings.TransactionFlow, nptBinding.TransactionFlow);
  116. SetPropertyValueIfNotDefaultValue(ConfigurationStrings.TransferMode, nptBinding.TransferMode);
  117. SetPropertyValueIfNotDefaultValue(ConfigurationStrings.TransactionProtocol, nptBinding.TransactionProtocol);
  118. SetPropertyValueIfNotDefaultValue(ConfigurationStrings.HostNameComparisonMode, nptBinding.HostNameComparisonMode);
  119. SetPropertyValueIfNotDefaultValue(ConfigurationStrings.MaxBufferPoolSize, nptBinding.MaxBufferPoolSize);
  120. SetPropertyValueIfNotDefaultValue(ConfigurationStrings.MaxBufferSize, nptBinding.MaxBufferSize);
  121. if (nptBinding.IsMaxConnectionsSet)
  122. {
  123. ConfigurationProperty maxConnectionsProperty = this.Properties[ConfigurationStrings.MaxConnections];
  124. SetPropertyValue(maxConnectionsProperty, nptBinding.MaxConnections, false /*ignore locks*/);
  125. }
  126. SetPropertyValueIfNotDefaultValue(ConfigurationStrings.MaxReceivedMessageSize, nptBinding.MaxReceivedMessageSize);
  127. if (nptBinding.IsListenBacklogSet)
  128. {
  129. ConfigurationProperty listenBacklogProperty = this.Properties[ConfigurationStrings.ListenBacklog];
  130. SetPropertyValue(listenBacklogProperty, nptBinding.ListenBacklog, false /*ignore locks*/);
  131. }
  132. this.ReliableSession.InitializeFrom(nptBinding.ReliableSession);
  133. this.Security.InitializeFrom(nptBinding.Security);
  134. this.ReaderQuotas.InitializeFrom(nptBinding.ReaderQuotas);
  135. }
  136. protected override void OnApplyConfiguration(Binding binding)
  137. {
  138. NetTcpBinding nptBinding = (NetTcpBinding)binding;
  139. PropertyInformationCollection propertyInfo = this.ElementInformation.Properties;
  140. nptBinding.TransactionFlow = this.TransactionFlow;
  141. nptBinding.TransferMode = this.TransferMode;
  142. nptBinding.TransactionProtocol = this.TransactionProtocol;
  143. nptBinding.HostNameComparisonMode = this.HostNameComparisonMode;
  144. if (this.ListenBacklog != TcpTransportDefaults.ListenBacklogConst)
  145. {
  146. nptBinding.ListenBacklog = this.ListenBacklog;
  147. }
  148. nptBinding.MaxBufferPoolSize = this.MaxBufferPoolSize;
  149. if (propertyInfo[ConfigurationStrings.MaxBufferSize].ValueOrigin != PropertyValueOrigin.Default)
  150. {
  151. nptBinding.MaxBufferSize = this.MaxBufferSize;
  152. }
  153. if (this.MaxConnections != 0)
  154. {
  155. nptBinding.MaxConnections = this.MaxConnections;
  156. }
  157. nptBinding.MaxReceivedMessageSize = this.MaxReceivedMessageSize;
  158. nptBinding.PortSharingEnabled = this.PortSharingEnabled;
  159. this.ReliableSession.ApplyConfiguration(nptBinding.ReliableSession);
  160. this.Security.ApplyConfiguration(nptBinding.Security);
  161. this.ReaderQuotas.ApplyConfiguration(nptBinding.ReaderQuotas);
  162. }
  163. }
  164. }