System\ServiceModel\Channels\PeerConnector.cs (12)
73connectInfoMessageConverter = TypedMessageConverter.Create(typeof(ConnectInfo), PeerStrings.ConnectAction);
85disconnectInfoMessageConverter = TypedMessageConverter.Create(typeof(DisconnectInfo), PeerStrings.DisconnectAction);
97refuseInfoMessageConverter = TypedMessageConverter.Create(typeof(RefuseInfo), PeerStrings.RefuseAction);
109welcomeInfoMessageConverter = TypedMessageConverter.Create(typeof(WelcomeInfo), PeerStrings.WelcomeAction);
257SendTerminatingMessage(neighbor, PeerStrings.DisconnectAction, closeReason);
359string action = PeerStrings.RefuseAction;
395SendTerminatingMessage(neighbor, PeerStrings.RefuseAction, closeReason);
487string action = PeerStrings.RefuseAction;
525SendTerminatingMessage(neighbor, PeerStrings.DisconnectAction, closeReason);
592if (action == PeerStrings.DisconnectAction)
691action = PeerStrings.DisconnectAction;
696action = PeerStrings.RefuseAction;
System\ServiceModel\Channels\PeerHelpers.cs (18)
281uriBuilder.Path = PeerStrings.KnownServiceUriPrefix + '/' + guid;
307uriBuilder.Scheme = PeerStrings.Scheme;
419protocolActions.Add(PeerStrings.ConnectAction, PeerOperationNames.Connect);
420protocolActions.Add(PeerStrings.WelcomeAction, PeerOperationNames.Welcome);
421protocolActions.Add(PeerStrings.RefuseAction, PeerOperationNames.Refuse);
422protocolActions.Add(PeerStrings.DisconnectAction, PeerOperationNames.Disconnect);
423protocolActions.Add(PeerStrings.RequestSecurityTokenAction, PeerOperationNames.ProcessRequestSecurityToken);
424protocolActions.Add(PeerStrings.RequestSecurityTokenResponseAction, PeerOperationNames.RequestSecurityTokenResponse);
425protocolActions.Add(PeerStrings.LinkUtilityAction, PeerOperationNames.LinkUtility);
427protocolActions.Add(PeerStrings.PingAction, PeerOperationNames.Ping);
460public const string Namespace = PeerStrings.Namespace + "/resolver";
731throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidOperationException(SR.GetString(SR.PeerConflictingHeader, headerName, PeerStrings.Namespace)));
795string operation = PeerStrings.FindAction(action);
805demux = PeerMessageHelpers.GetHeaderString(message.Headers, PeerOperationNames.Flood, PeerStrings.Namespace);
806via = PeerMessageHelpers.GetHeaderUri(message.Headers, PeerStrings.Via, PeerStrings.Namespace);
807to = PeerMessageHelpers.GetHeaderUri(message.Headers, PeerOperationNames.PeerTo, PeerStrings.Namespace);
826message.Properties.Add(PeerStrings.PeerProperty, peerProperty);
System\ServiceModel\Channels\PeerNodeImplementation.cs (17)
169if (value.Scheme != PeerStrings.Scheme)
172value.Scheme, PeerStrings.Scheme));
348if (-1 != message.Headers.FindHeader(PeerStrings.MessageId, PeerStrings.Namespace))
349PeerExceptionHelper.ThrowInvalidOperation_ConflictingHeader(PeerStrings.MessageId);
350if (-1 != message.Headers.FindHeader(PeerOperationNames.PeerTo, PeerStrings.Namespace))
352if (-1 != message.Headers.FindHeader(PeerOperationNames.PeerVia, PeerStrings.Namespace))
354if (-1 != message.Headers.FindHeader(PeerOperationNames.Flood, PeerStrings.Namespace, PeerOperationNames.Demuxer))
359message.Headers.Add(MessageHeader.CreateHeader(PeerOperationNames.PeerTo, PeerStrings.Namespace, message.Headers.To));
767if (listenUri.Scheme != PeerStrings.Scheme)
770listenUri.Scheme, PeerStrings.Scheme));
775Uri baseUri = new UriBuilder(PeerStrings.Scheme, listenUri.Host).Uri;
792uriBuilder.Scheme = PeerStrings.Scheme;
803if (listenUri.Scheme != PeerStrings.Scheme)
806listenUri.Scheme, PeerStrings.Scheme));
810Uri baseUri = new UriBuilder(PeerStrings.Scheme, listenUri.Host).Uri;
1723this.listenUri = new UriBuilder(PeerStrings.Scheme, listenUri.Host).Uri;
System\ServiceModel\Channels\PeerServiceMessageContracts.cs (24)
16[DataContract(Name = "ConnectInfo", Namespace = PeerStrings.Namespace)]
33[MessageBodyMember(Name = "Connect", Namespace = PeerStrings.Namespace)]
65[DataContract(Name = "DisconnectInfo", Namespace = PeerStrings.Namespace)]
83[MessageBodyMember(Name = "Disconnect", Namespace = PeerStrings.Namespace)]
132[ServiceContract(Name = PeerStrings.ServiceContractName,
133Namespace = PeerStrings.Namespace,
138[OperationContract(IsOneWay = true, Action = PeerStrings.ConnectAction)]
141[OperationContract(IsOneWay = true, Action = PeerStrings.DisconnectAction)]
144[OperationContract(IsOneWay = true, Action = PeerStrings.RefuseAction)]
147[OperationContract(IsOneWay = true, Action = PeerStrings.WelcomeAction)]
150[OperationContract(IsOneWay = true, Action = PeerStrings.FloodAction, AsyncPattern = true)]
154[OperationContract(IsOneWay = true, Action = PeerStrings.LinkUtilityAction)]
162[OperationContract(IsOneWay = true, Action = PeerStrings.PingAction)]
170[ServiceContract(Name = PeerStrings.ServiceContractName,
171Namespace = PeerStrings.Namespace,
178[ServiceContract(Name = PeerStrings.ServiceContractName,
179Namespace = PeerStrings.Namespace,
206[DataContract(Name = "Referral", Namespace = PeerStrings.Namespace)]
237[DataContract(Name = "RefuseInfo", Namespace = PeerStrings.Namespace)]
264[MessageBodyMember(Name = "Refuse", Namespace = PeerStrings.Namespace)]
294[DataContract(Name = "LinkUtilityInfo", Namespace = PeerStrings.Namespace)]
322[MessageBodyMember(Name = "LinkUtility", Namespace = PeerStrings.Namespace)]
344[DataContract(Name = "WelcomeInfo", Namespace = PeerStrings.Namespace)]
370[MessageBodyMember(Name = "Welcome", Namespace = PeerStrings.Namespace)]