Code:
/ WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / WCF / ServiceModel / System / ServiceModel / PeerResolvers / PeerDefaultCustomResolverClient.cs / 1 / PeerDefaultCustomResolverClient.cs
//------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------- namespace System.ServiceModel.PeerResolvers { using System.ServiceModel.Channels; using System.ServiceModel; using System.ServiceModel.Description; using System.Collections.Generic; using System.Collections.ObjectModel; using System.Threading; using System.Diagnostics; using System.IO; using System.Net; internal class PeerDefaultCustomResolverClient : PeerResolver { EndpointAddress address; Binding binding; TimeSpan defaultLifeTime; ClientCredentials credentials; Guid clientId; Guid registrationId; IOThreadTimer timer; bool opened = false; string meshId; PeerNodeAddress nodeAddress; ChannelFactorychannelFactory; PeerReferralPolicy referralPolicy; string bindingName, bindingConfigurationName; bool? shareReferrals; int updateSuccessful = 1; internal PeerDefaultCustomResolverClient() { this.address = null; this.binding = null; this.defaultLifeTime = TimeSpan.FromHours(1); clientId = Guid.NewGuid(); timer = new IOThreadTimer(new WaitCallback(RegistrationExpired), this, false); } public override bool CanShareReferrals { get { if(this.shareReferrals.HasValue) return shareReferrals.Value; if(this.referralPolicy == PeerReferralPolicy.Service && opened) { IPeerResolverClient proxy = GetProxy(); try { ServiceSettingsResponseInfo settings = proxy.GetServiceSettings(); shareReferrals = !settings.ControlMeshShape; proxy.Close(); } finally { proxy.Abort(); } } else { shareReferrals = (PeerReferralPolicy.Share == this.referralPolicy); } return shareReferrals.Value; } } public override void Initialize(EndpointAddress address, Binding binding, ClientCredentials credentials, PeerReferralPolicy referralPolicy) { this.address = address; this.binding = binding; this.credentials = credentials; Validate(); channelFactory = new ChannelFactory (binding, address); channelFactory.Endpoint.Behaviors.Remove (); if(credentials != null) channelFactory.Endpoint.Behaviors.Add(credentials); channelFactory.Open(); this.referralPolicy = referralPolicy; opened = true; } IPeerResolverClient GetProxy() { return (IPeerResolverClient)channelFactory.CreateChannel(); } void Validate() { if(address == null || binding == null ) PeerExceptionHelper.ThrowArgument_InsufficientResolverSettings(); } // Register address for a node participating in a mesh identified by meshId with the resolver service public override object Register(string meshId, PeerNodeAddress nodeAddress, TimeSpan timeout) { if (opened) { long scopeId = -1; bool multipleScopes = false; if (nodeAddress.IPAddresses.Count == 0) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new ArgumentException(SR.GetString(SR.MustRegisterMoreThanZeroAddresses))); } foreach (IPAddress address in nodeAddress.IPAddresses) { if (address.IsIPv6LinkLocal) { if (scopeId == -1) { scopeId = address.ScopeId; } else if (scopeId != address.ScopeId) { multipleScopes = true; break; } } } List addresslist = new List (); foreach (IPAddress address in nodeAddress.IPAddresses) { if (!multipleScopes || (!address.IsIPv6LinkLocal && !address.IsIPv6SiteLocal)) addresslist.Add(address); } if (addresslist.Count == 0) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new CommunicationException(SR.GetString(SR.AmbiguousConnectivitySpec))); } ReadOnlyCollection addresses = new ReadOnlyCollection (addresslist); this.meshId = meshId; this.nodeAddress = new PeerNodeAddress(nodeAddress.EndpointAddress, addresses); RegisterInfo info = new RegisterInfo(clientId, meshId, this.nodeAddress); IPeerResolverClient proxy = GetProxy(); try { proxy.OperationTimeout = timeout; RegisterResponseInfo response = proxy.Register(info); this.registrationId = response.RegistrationId; timer.Set(response.RegistrationLifetime); this.defaultLifeTime = response.RegistrationLifetime; proxy.Close(); } finally { proxy.Abort(); } } return registrationId; } void RegistrationExpired(object state) { if(!opened) return; try { IPeerResolverClient proxy = GetProxy(); RefreshResponseInfo response ; try { int oldValue = Interlocked.Exchange(ref this.updateSuccessful, 1); if(oldValue == 0) { SendUpdate(new UpdateInfo(this.registrationId, this.clientId, this.meshId, this.nodeAddress), ServiceDefaults.SendTimeout); return; } RefreshInfo info = new RefreshInfo(this.meshId, this.registrationId); response = proxy.Refresh(info); if (response.Result == RefreshResult.RegistrationNotFound) { RegisterInfo registerInfo = new RegisterInfo(clientId, meshId, nodeAddress); RegisterResponseInfo registerResponse = proxy.Register(registerInfo); registrationId = registerResponse.RegistrationId; this.defaultLifeTime = registerResponse.RegistrationLifetime; } else { DiagnosticUtility.DebugAssert(response.Result == RefreshResult.Success, "Unrecognized value!!"); } proxy.Close(); } finally { proxy.Abort(); timer.Set(this.defaultLifeTime); } } catch(CommunicationException e) { DiagnosticUtility.ExceptionUtility.TraceHandledException(e, TraceEventType.Information); } catch(Exception e) { if(DiagnosticUtility.IsFatal(e)) throw; DiagnosticUtility.ExceptionUtility.TraceHandledException(e, TraceEventType.Information); } } // Unregister address for a node from the resolver service public override void Unregister(object registrationId, TimeSpan timeout) { if(opened) { UnregisterInfo info = new UnregisterInfo(this.meshId, this.registrationId); try { IPeerResolverClient proxy = GetProxy(); try { proxy.OperationTimeout = timeout; proxy.Unregister(info); proxy.Close(); } finally { proxy.Abort(); } } catch(CommunicationException e) { DiagnosticUtility.ExceptionUtility.TraceHandledException(e, TraceEventType.Information); } finally { opened = false; timer.Cancel(); } } } // Updates a node's registration with the resolver service. public override void Update(object registrationId, PeerNodeAddress updatedNodeAddress, TimeSpan timeout) { if(opened) { UpdateInfo info = new UpdateInfo(this.registrationId, clientId,meshId, updatedNodeAddress); this.nodeAddress = updatedNodeAddress; SendUpdate(info, timeout); } } void SendUpdate(UpdateInfo updateInfo, TimeSpan timeout) { try { RegisterResponseInfo response; IPeerResolverClient proxy = GetProxy(); try { proxy.OperationTimeout = timeout; response = proxy.Update(updateInfo); proxy.Close(); this.registrationId = response.RegistrationId; this.defaultLifeTime = response.RegistrationLifetime; Interlocked.Exchange(ref this.updateSuccessful, 1); timer.Set(this.defaultLifeTime); } finally { proxy.Abort(); } } catch(CommunicationException e) { DiagnosticUtility.ExceptionUtility.TraceHandledException(e, TraceEventType.Information); Interlocked.Exchange(ref this.updateSuccessful, 0); } catch(Exception e) { if(DiagnosticUtility.IsFatal(e)) throw; Interlocked.Exchange(ref this.updateSuccessful, 0); throw; } } // Query the resolver service for addresses associated with a mesh ID public override ReadOnlyCollection Resolve(string meshId, int maxAddresses, TimeSpan timeout) { ResolveResponseInfo result= null; IList addresses = null; List output_addresses = new List (); if(opened) { ResolveInfo info = new ResolveInfo(clientId, meshId, maxAddresses); try { IPeerResolverClient proxy = GetProxy(); try { proxy.OperationTimeout = timeout; result = proxy.Resolve(info); proxy.Close(); } finally { proxy.Abort(); } // If addresses couldn't be obtained, return empty collection if (result != null && result.Addresses != null) addresses = result.Addresses; } catch(CommunicationException e) { DiagnosticUtility.ExceptionUtility.TraceHandledException(e, TraceEventType.Information); } catch(Exception e) { if(DiagnosticUtility.IsFatal(e)) throw; opened = false; throw; } } if (addresses != null) { foreach (PeerNodeAddress nodeaddr in addresses) { bool valid = true; long scopeId = -1; if (nodeaddr == null) continue; foreach (IPAddress addr in nodeaddr.IPAddresses) { if (addr.IsIPv6LinkLocal) { if (scopeId == -1) { scopeId = addr.ScopeId; } else if (scopeId != addr.ScopeId) { valid = false; break; } } } if (valid) { output_addresses.Add(nodeaddr); } } } return new ReadOnlyCollection (output_addresses); } internal string BindingName { get { return bindingName; } set { this.bindingName = value; } } internal string BindingConfigurationName { get { return bindingName; } set { this.bindingConfigurationName = value; } } public override bool Equals(object other) { PeerDefaultCustomResolverClient that = other as PeerDefaultCustomResolverClient; if((that == null) || (this.referralPolicy != that.referralPolicy) || !this.address.Equals(that.address)) return false; if(this.BindingName != null || this.BindingConfigurationName != null) return ((this.BindingName == that.BindingName) && (this.BindingConfigurationName == that.BindingConfigurationName)); else return this.binding.Equals(that.binding); } public override int GetHashCode() { return base.GetHashCode(); } } } // 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
- AmbiguousMatchException.cs
- TextTreeObjectNode.cs
- Rotation3DAnimationUsingKeyFrames.cs
- MatrixUtil.cs
- ReverseInheritProperty.cs
- SqlDataSourceConnectionPanel.cs
- CompositeControl.cs
- SizeAnimationBase.cs
- RemoteArgument.cs
- Transform3DCollection.cs
- InputReferenceExpression.cs
- TrimSurroundingWhitespaceAttribute.cs
- IgnoreFileBuildProvider.cs
- ElementAction.cs
- SchemaTableColumn.cs
- ConcatQueryOperator.cs
- UntypedNullExpression.cs
- StickyNoteAnnotations.cs
- ResourceExpressionBuilder.cs
- UserControl.cs
- SelectionChangedEventArgs.cs
- cache.cs
- SqlProcedureAttribute.cs
- MsmqOutputChannel.cs
- UrlPath.cs
- EndSelectCardRequest.cs
- SessionStateItemCollection.cs
- DbParameterCollectionHelper.cs
- ReadOnlyHierarchicalDataSource.cs
- ILGenerator.cs
- HttpListenerRequest.cs
- AccessViolationException.cs
- Membership.cs
- FileDialogPermission.cs
- FieldMetadata.cs
- ContractAdapter.cs
- SqlUDTStorage.cs
- InternalConfigEventArgs.cs
- ImageListStreamer.cs
- SessionStateUtil.cs
- _HeaderInfo.cs
- Panel.cs
- SiteMapNodeCollection.cs
- NumericUpDown.cs
- ConversionContext.cs
- CompilationUtil.cs
- TemplatedAdorner.cs
- IPCCacheManager.cs
- NumericExpr.cs
- BaseParagraph.cs
- TreeViewHitTestInfo.cs
- GatewayIPAddressInformationCollection.cs
- x509utils.cs
- CodeSubDirectoriesCollection.cs
- TextRange.cs
- InternalConfigHost.cs
- EpmHelper.cs
- WebPartConnectionsCancelVerb.cs
- SendMessageContent.cs
- PolyBezierSegment.cs
- login.cs
- BamlReader.cs
- SystemIcmpV4Statistics.cs
- ArgumentOutOfRangeException.cs
- StandardCommands.cs
- TextMarkerSource.cs
- DispatchChannelSink.cs
- CallSiteHelpers.cs
- SR.cs
- EntitySetDataBindingList.cs
- ListControl.cs
- ProfileService.cs
- DataControlFieldTypeEditor.cs
- FormViewUpdatedEventArgs.cs
- ManagementExtension.cs
- FixedSOMLineCollection.cs
- BidPrivateBase.cs
- LineUtil.cs
- GeneratedContractType.cs
- HttpWebRequestElement.cs
- OnOperation.cs
- XmlAtomicValue.cs
- TextServicesCompartment.cs
- WindowsEditBoxRange.cs
- NameValueCollection.cs
- XamlFilter.cs
- UIElementIsland.cs
- InputQueue.cs
- TransactionProxy.cs
- RealProxy.cs
- PanelContainerDesigner.cs
- SoundPlayer.cs
- TypeExtensionConverter.cs
- ValueProviderWrapper.cs
- IndexedGlyphRun.cs
- RepeaterDesigner.cs
- ColorTranslator.cs
- PathParser.cs
- TypeGeneratedEventArgs.cs
- DataServiceSaveChangesEventArgs.cs