Code:
/ 4.0 / 4.0 / untmp / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / cdf / src / NetFx40 / System.ServiceModel.Discovery / System / ServiceModel / Discovery / HelloOperationAsyncResult.cs / 1305376 / HelloOperationAsyncResult.cs
//---------------------------------------------------------------- // Copyright (c) Microsoft Corporation. All rights reserved. //--------------------------------------------------------------- namespace System.ServiceModel.Discovery { using System.Diagnostics.CodeAnalysis; using System.Runtime; using System.Xml; abstract class HelloOperationAsyncResult: AsyncResult where TMessage : class { static AsyncCompletion onOnOnlineAnnoucementCompletedCallback = new AsyncCompletion(OnOnOnlineAnnouncementCompleted); IAnnouncementServiceImplementation announcementServiceImpl; [SuppressMessage("Microsoft.Usage", "CA2214:DoNotCallOverridableMethodsInConstructors")] internal HelloOperationAsyncResult( IAnnouncementServiceImplementation announcementServiceImpl, TMessage message, AsyncCallback callback, object state) : base(callback, state) { this.announcementServiceImpl = announcementServiceImpl; if (this.IsInvalid(message)) { this.Complete(true); return; } IAsyncResult innerAsyncResult = this.announcementServiceImpl.OnBeginOnlineAnnouncement( this.GetMessageSequence(message), this.GetEndpointDiscoveryMetadata(message), this.PrepareAsyncCompletion(onOnOnlineAnnoucementCompletedCallback), this); if (innerAsyncResult.CompletedSynchronously && OnOnOnlineAnnouncementCompleted(innerAsyncResult)) { this.Complete(true); return; } } protected abstract bool ValidateContent(TMessage message); protected abstract DiscoveryMessageSequence GetMessageSequence(TMessage message); protected abstract EndpointDiscoveryMetadata GetEndpointDiscoveryMetadata(TMessage message); static bool OnOnOnlineAnnouncementCompleted(IAsyncResult result) { HelloOperationAsyncResult thisPtr = (HelloOperationAsyncResult )result.AsyncState; thisPtr.announcementServiceImpl.OnEndOnlineAnnouncement(result); return true; } bool IsInvalid(TMessage message) { UniqueId messageId = OperationContext.Current.IncomingMessageHeaders.MessageId; if (messageId == null) { if (TD.DiscoveryMessageWithNullMessageIdIsEnabled()) { TD.DiscoveryMessageWithNullMessageId(ProtocolStrings.TracingStrings.Hello); } return true; } else if (this.announcementServiceImpl.IsDuplicate(messageId)) { if (TD.DuplicateDiscoveryMessageIsEnabled()) { TD.DuplicateDiscoveryMessage(ProtocolStrings.TracingStrings.Hello, messageId.ToString()); } return true; } else if (this.ValidateContent(message)) { return false; } else { if (TD.DiscoveryMessageWithInvalidContentIsEnabled()) { TD.DiscoveryMessageWithInvalidContent(ProtocolStrings.TracingStrings.Hello, messageId.ToString()); } return true; } } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007.
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- TimeIntervalCollection.cs
- TranslateTransform.cs
- SynchronizationLockException.cs
- Dynamic.cs
- AutomationElement.cs
- HtmlForm.cs
- CryptoConfig.cs
- listitem.cs
- ImageMap.cs
- unsafenativemethodsother.cs
- SamlAssertion.cs
- Rect3D.cs
- SolidColorBrush.cs
- ListViewInsertedEventArgs.cs
- GeometryModel3D.cs
- GeometryGroup.cs
- ToolboxItemFilterAttribute.cs
- JsonFormatWriterGenerator.cs
- MailWebEventProvider.cs
- HtmlHistory.cs
- DateRangeEvent.cs
- SwitchLevelAttribute.cs
- CodeEntryPointMethod.cs
- DataBindingsDialog.cs
- EntityContainerEmitter.cs
- RSAProtectedConfigurationProvider.cs
- IndependentAnimationStorage.cs
- CanExecuteRoutedEventArgs.cs
- ReadOnlyTernaryTree.cs
- CodeMemberProperty.cs
- AccessDataSource.cs
- XmlDeclaration.cs
- DataGridViewTopRowAccessibleObject.cs
- OptimisticConcurrencyException.cs
- RepeaterItemEventArgs.cs
- TextSchema.cs
- StatusBar.cs
- DetailsViewInsertEventArgs.cs
- SecurityException.cs
- WebPartEditVerb.cs
- SchemaAttDef.cs
- KeySplineConverter.cs
- HierarchicalDataSourceDesigner.cs
- Debug.cs
- SkewTransform.cs
- ArcSegment.cs
- Panel.cs
- Utils.cs
- UpdateProgress.cs
- FormView.cs
- MappingSource.cs
- MemberInitExpression.cs
- DocumentPage.cs
- BatchServiceHost.cs
- ControlTemplate.cs
- CodeLinePragma.cs
- DeclarativeCatalogPartDesigner.cs
- Point.cs
- WebPartChrome.cs
- OnOperation.cs
- PopupRootAutomationPeer.cs
- AssertUtility.cs
- RestHandler.cs
- ValidationHelper.cs
- ConstructorBuilder.cs
- TraceContextRecord.cs
- HttpModulesSection.cs
- TextDecoration.cs
- ScrollChangedEventArgs.cs
- Timeline.cs
- StateValidator.cs
- DesignerUtils.cs
- ColumnMapVisitor.cs
- PipeSecurity.cs
- UrlMappingsSection.cs
- AspNetHostingPermission.cs
- UnknownBitmapEncoder.cs
- GrammarBuilderBase.cs
- ExtensionQuery.cs
- SignatureResourcePool.cs
- DataSourceView.cs
- StringSorter.cs
- WeakEventManager.cs
- ResourceProviderFactory.cs
- TableCellsCollectionEditor.cs
- XPathEmptyIterator.cs
- CompiledXpathExpr.cs
- SqlBuilder.cs
- MessageContractExporter.cs
- WebPartConnectVerb.cs
- SectionRecord.cs
- Matrix3DValueSerializer.cs
- AuthenticatedStream.cs
- IArgumentProvider.cs
- AsyncCodeActivityContext.cs
- SymbolEqualComparer.cs
- DiscoveryDefaults.cs
- DocumentSequenceHighlightLayer.cs
- ScriptManager.cs
- WinEventQueueItem.cs