Code:
/ WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / WCF / ServiceModel / System / ServiceModel / Channels / ConnectionAcceptor.cs / 1 / ConnectionAcceptor.cs
//------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------- namespace System.ServiceModel.Channels { using System.Diagnostics; using System.ServiceModel; using System.ServiceModel.Diagnostics; using System.ServiceModel.Dispatcher; using System.Threading; delegate void ConnectionAvailableCallback(IConnection connection, ItemDequeuedCallback connectionDequeuedCallback); delegate void ErrorCallback(Exception exception); class ConnectionAcceptor : IDisposable { int maxAccepts; int maxPendingConnections; int connections; int pendingAccepts; IConnectionListener listener; AsyncCallback acceptCompletedCallback; WaitCallback scheduleAcceptCallback; ItemDequeuedCallback onConnectionDequeued; bool isDisposed; ConnectionAvailableCallback callback; ErrorCallback errorCallback; public ConnectionAcceptor(IConnectionListener listener, int maxAccepts, int maxPendingConnections, ConnectionAvailableCallback callback) : this(listener, maxAccepts, maxPendingConnections, callback, null) { // empty } public ConnectionAcceptor(IConnectionListener listener, int maxAccepts, int maxPendingConnections, ConnectionAvailableCallback callback, ErrorCallback errorCallback) { if (maxAccepts <= 0) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new ArgumentOutOfRangeException("maxAccepts", maxAccepts, SR.GetString(SR.ValueMustBePositive))); } DiagnosticUtility.DebugAssert(maxPendingConnections > 0, "maxPendingConnections must be positive"); this.listener = listener; this.maxAccepts = maxAccepts; this.maxPendingConnections = maxPendingConnections; this.callback = callback; this.errorCallback = errorCallback; this.onConnectionDequeued = new ItemDequeuedCallback(OnConnectionDequeued); this.acceptCompletedCallback = DiagnosticUtility.ThunkAsyncCallback(new AsyncCallback(AcceptCompletedCallback)); this.scheduleAcceptCallback = new WaitCallback(ScheduleAcceptCallback); } bool IsAcceptNecessary { get { return (pendingAccepts < maxAccepts) && ((connections + pendingAccepts) < maxPendingConnections) && !isDisposed; } } public int ConnectionCount { get { return connections; } } object ThisLock { get { return this; } } void AcceptIfNecessary(bool startAccepting) { if (IsAcceptNecessary) { lock (ThisLock) { while (IsAcceptNecessary) { IAsyncResult result = null; Exception unexpectedException = null; try { result = listener.BeginAccept(acceptCompletedCallback, null); } catch (CommunicationException exception) { if (DiagnosticUtility.ShouldTraceInformation) { DiagnosticUtility.ExceptionUtility.TraceHandledException(exception, TraceEventType.Information); } } catch (Exception exception) { if (DiagnosticUtility.IsFatal(exception)) { throw; } if (startAccepting) { // Since we're under a call to StartAccepting(), just throw the exception up the stack. throw; } if ((errorCallback == null) && !ExceptionHandler.HandleTransportExceptionHelper(exception)) { throw; } unexpectedException = exception; } if ((unexpectedException != null) && (errorCallback != null)) { errorCallback(unexpectedException); } if (result != null) { // don't block our accept processing loop if (result.CompletedSynchronously) { IOThreadScheduler.ScheduleCallback(scheduleAcceptCallback, result); } pendingAccepts++; } } } } } void AcceptCompletedCallback(IAsyncResult result) { if (result.CompletedSynchronously) { return; } HandleCompletedAccept(result); } public void Dispose() { lock (ThisLock) { if (!isDisposed) { isDisposed = true; listener.Dispose(); } } } void HandleCompletedAccept(IAsyncResult result) { IConnection connection = null; lock (ThisLock) { bool success = false; Exception unexpectedException = null; try { if (!isDisposed) { connection = listener.EndAccept(result); if (connection != null) { if (DiagnosticUtility.ShouldTraceWarning) { if (connections + 1 >= maxPendingConnections) { TraceUtility.TraceEvent(TraceEventType.Warning, TraceCode.MaxPendingConnectionsReached, new StringTraceRecord("MaxPendingConnections", maxPendingConnections.ToString(System.Globalization.CultureInfo.InvariantCulture)), this, null); } } // This is incremented after the Trace just in case the Trace throws. connections++; } } success = true; } catch (CommunicationException exception) { if (DiagnosticUtility.ShouldTraceInformation) { DiagnosticUtility.ExceptionUtility.TraceHandledException(exception, TraceEventType.Information); } } catch (Exception exception) { if (DiagnosticUtility.IsFatal(exception)) { throw; } if ((errorCallback == null) && !ExceptionHandler.HandleTransportExceptionHelper(exception)) { throw; } unexpectedException = exception; } finally { if (!success) { connection = null; } pendingAccepts--; } if ((unexpectedException != null) && (errorCallback != null)) { errorCallback(unexpectedException); } } AcceptIfNecessary(false); if (connection != null) { callback(connection, onConnectionDequeued); } } void OnConnectionDequeued() { lock (ThisLock) { connections--; } AcceptIfNecessary(false); } void ScheduleAcceptCallback(object state) { HandleCompletedAccept((IAsyncResult)state); } public void StartAccepting() { listener.Listen(); AcceptIfNecessary(true); } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007. // Copyright (c) Microsoft Corporation. All rights reserved.
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- DataGridViewDataConnection.cs
- HtmlControlPersistable.cs
- DataGridViewCell.cs
- AsmxEndpointPickerExtension.cs
- Mapping.cs
- HwndSubclass.cs
- CodeTypeReferenceExpression.cs
- _CacheStreams.cs
- ObjectItemCollection.cs
- infer.cs
- PowerModeChangedEventArgs.cs
- AutoCompleteStringCollection.cs
- SecurityChannelListener.cs
- ChameleonKey.cs
- BuildProviderAppliesToAttribute.cs
- ServicePoint.cs
- FilterQuery.cs
- WebPartTransformerAttribute.cs
- DbConnectionPoolCounters.cs
- DefaultSection.cs
- ArrayElementGridEntry.cs
- BinarySecretKeyIdentifierClause.cs
- util.cs
- Repeater.cs
- ThemeableAttribute.cs
- Int16KeyFrameCollection.cs
- MouseEvent.cs
- SpotLight.cs
- ControlCollection.cs
- TemplateBuilder.cs
- DisplayMemberTemplateSelector.cs
- ColorTransformHelper.cs
- PtsContext.cs
- WebPartTransformerAttribute.cs
- AnimatedTypeHelpers.cs
- TraceSection.cs
- HttpConfigurationSystem.cs
- LicenseException.cs
- TakeOrSkipQueryOperator.cs
- Geometry3D.cs
- NaturalLanguageHyphenator.cs
- control.ime.cs
- _NestedMultipleAsyncResult.cs
- SHA1CryptoServiceProvider.cs
- ApplicationDirectory.cs
- DataBinder.cs
- MemberHolder.cs
- ISAPIApplicationHost.cs
- ComPlusServiceHost.cs
- DataGridTable.cs
- DesignerTransactionCloseEvent.cs
- ScrollChrome.cs
- CorrelationManager.cs
- SqlStream.cs
- ListControlBuilder.cs
- SqlFunctions.cs
- FacetValues.cs
- CLRBindingWorker.cs
- AdornerDecorator.cs
- ListSourceHelper.cs
- DeferrableContentConverter.cs
- KnownColorTable.cs
- TextProperties.cs
- ProfileManager.cs
- TemplatedMailWebEventProvider.cs
- HttpAsyncResult.cs
- ParameterBuilder.cs
- StatusBar.cs
- RecordConverter.cs
- ValidatorCompatibilityHelper.cs
- _KerberosClient.cs
- JsonQueryStringConverter.cs
- SourceFileInfo.cs
- RenderData.cs
- DataObjectFieldAttribute.cs
- MonitorWrapper.cs
- StatusBarDrawItemEvent.cs
- SspiNegotiationTokenAuthenticator.cs
- HtmlToClrEventProxy.cs
- WebServiceHost.cs
- CodeTypeDeclaration.cs
- DynamicQueryableWrapper.cs
- SplashScreen.cs
- NameTable.cs
- HyperLinkColumn.cs
- StructuredTypeEmitter.cs
- SmiEventStream.cs
- SqlMethodAttribute.cs
- VideoDrawing.cs
- AddInSegmentDirectoryNotFoundException.cs
- DefaultCommandConverter.cs
- ItemContainerProviderWrapper.cs
- InkCanvasSelectionAdorner.cs
- ScriptControlManager.cs
- GeneralTransform3DGroup.cs
- TemplateDefinition.cs
- AssemblyHash.cs
- PenContexts.cs
- ConnectionString.cs
- UrlMapping.cs