Code:
/ 4.0 / 4.0 / untmp / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / clr / src / ManagedLibraries / Remoting / Channels / IPC / IpcChannel.cs / 1305376 / IpcChannel.cs
// ==++== // // Copyright (c) Microsoft Corporation. All rights reserved. // // ==--== //============================================================================ // File: IpcChannel.cs // Author: [....]@Microsoft.Com // Summary: Implements a combined ipc channel // //========================================================================= using System; using System.Collections; using System.Runtime.Remoting; using System.Runtime.Remoting.Messaging; using System.Globalization; using System.Security.AccessControl; using System.Security.Permissions; namespace System.Runtime.Remoting.Channels.Ipc { public class IpcChannel : IChannelReceiver, IChannelSender, ISecurableChannel { private IpcClientChannel _clientChannel = null; // client channel private IpcServerChannel _serverChannel = null; // server channel private int _channelPriority = 20; // channel priority private String _channelName = "ipc"; // channel name public IpcChannel() { _clientChannel = new IpcClientChannel(); // server channel will not be activated. } // IpcChannel public IpcChannel(String portName) : this() { _serverChannel = new IpcServerChannel(portName); } // IpcChannel public IpcChannel(IDictionary properties, IClientChannelSinkProvider clientSinkProvider, IServerChannelSinkProvider serverSinkProvider) : this(properties, clientSinkProvider, serverSinkProvider, null) { } public IpcChannel(IDictionary properties, IClientChannelSinkProvider clientSinkProvider, IServerChannelSinkProvider serverSinkProvider, CommonSecurityDescriptor securityDescriptor) { Hashtable clientData = new Hashtable(); Hashtable serverData = new Hashtable(); bool portFound = false; // divide properties up for respective channels if (properties != null) { foreach (DictionaryEntry entry in properties) { switch ((String)entry.Key) { // general channel properties case "name": _channelName = (String)entry.Value; break; case "priority": _channelPriority = Convert.ToInt32((String)entry.Value, CultureInfo.InvariantCulture); break; case "portName": { serverData["portName"] = entry.Value; portFound = true; break; } default: clientData[entry.Key] = entry.Value; serverData[entry.Key] = entry.Value; break; } } } _clientChannel = new IpcClientChannel(clientData, clientSinkProvider); if (portFound) _serverChannel = new IpcServerChannel(serverData, serverSinkProvider, securityDescriptor); } // IpcChannel // // ISecurableChannel implementation // public bool IsSecured { [SecurityPermission(SecurityAction.LinkDemand, Flags=SecurityPermissionFlag.Infrastructure, Infrastructure=true)] get { if (_clientChannel != null) return _clientChannel.IsSecured; if (_serverChannel != null) return _serverChannel.IsSecured; return false; } [SecurityPermission(SecurityAction.LinkDemand, Flags=SecurityPermissionFlag.Infrastructure, Infrastructure=true)] set { if (((IList)ChannelServices.RegisteredChannels).Contains(this)) throw new InvalidOperationException(CoreChannel.GetResourceString("Remoting_InvalidOperation_IsSecuredCannotBeChangedOnRegisteredChannels")); if (_clientChannel != null) _clientChannel.IsSecured = value; if (_serverChannel != null) _serverChannel.IsSecured = value; } } // // IChannel implementation // public int ChannelPriority { [SecurityPermission(SecurityAction.LinkDemand, Flags=SecurityPermissionFlag.Infrastructure, Infrastructure=true)] get { return _channelPriority; } } // ChannelPriority public String ChannelName { [SecurityPermission(SecurityAction.LinkDemand, Flags=SecurityPermissionFlag.Infrastructure, Infrastructure=true)] get { return _channelName; } } // ChannelName // returns channelURI and places object uri into out parameter [SecurityPermission(SecurityAction.LinkDemand, Flags=SecurityPermissionFlag.Infrastructure, Infrastructure=true)] public String Parse(String url, out String objectURI) { return IpcChannelHelper.ParseURL(url, out objectURI); } // Parse // // end of IChannel implementation // // // IChannelSender implementation // [SecurityPermission(SecurityAction.LinkDemand, Flags=SecurityPermissionFlag.Infrastructure, Infrastructure=true)] public IMessageSink CreateMessageSink(String url, Object remoteChannelData, out String objectURI) { return _clientChannel.CreateMessageSink(url, remoteChannelData, out objectURI); } // CreateMessageSink // // end of IChannelSender implementation // // // IChannelReceiver implementation // public Object ChannelData { [SecurityPermission(SecurityAction.LinkDemand, Flags=SecurityPermissionFlag.Infrastructure, Infrastructure=true)] get { if (_serverChannel != null) return _serverChannel.ChannelData; else return null; } } // ChannelData [SecurityPermission(SecurityAction.LinkDemand, Flags=SecurityPermissionFlag.Infrastructure, Infrastructure=true)] public String[] GetUrlsForUri(String objectURI) { if (_serverChannel != null) return _serverChannel.GetUrlsForUri(objectURI); else return null; } // GetUrlsforURI [SecurityPermission(SecurityAction.LinkDemand, Flags=SecurityPermissionFlag.Infrastructure, Infrastructure=true)] public void StartListening(Object data) { if (_serverChannel != null) _serverChannel.StartListening(data); } // StartListening [SecurityPermission(SecurityAction.LinkDemand, Flags=SecurityPermissionFlag.Infrastructure, Infrastructure=true)] public void StopListening(Object data) { if (_serverChannel != null) _serverChannel.StopListening(data); } // StopListening // // IChannelReceiver implementation // } // class IpcChannel } // namespace System.Runtime.Remoting.Channels.Ipc // 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
- TripleDES.cs
- RegexGroup.cs
- ColorMatrix.cs
- DrawingContextWalker.cs
- FormViewCommandEventArgs.cs
- localization.cs
- EntityDataSourceQueryBuilder.cs
- ExpandSegment.cs
- PropertyIDSet.cs
- EntityCommandExecutionException.cs
- securitycriticaldataformultiplegetandset.cs
- ColumnCollection.cs
- XmlLangPropertyAttribute.cs
- DoubleStorage.cs
- GridViewCellAutomationPeer.cs
- RTTypeWrapper.cs
- EntityDataSourceViewSchema.cs
- SafeFindHandle.cs
- BitmapEffectInput.cs
- PerformanceCounterPermissionEntryCollection.cs
- SmtpReplyReaderFactory.cs
- TreeNodeBindingDepthConverter.cs
- DbProviderFactories.cs
- WrappingXamlSchemaContext.cs
- DocumentEventArgs.cs
- PropertyInformationCollection.cs
- SqlCommandSet.cs
- XmlAnyElementAttributes.cs
- InkSerializer.cs
- IndentedWriter.cs
- TouchEventArgs.cs
- HWStack.cs
- documentsequencetextview.cs
- PreservationFileWriter.cs
- FixedPageProcessor.cs
- SHA384.cs
- FactoryRecord.cs
- ZipIOBlockManager.cs
- TypeLibConverter.cs
- PrivilegeNotHeldException.cs
- OleDbStruct.cs
- AppSettingsExpressionBuilder.cs
- BindingExpression.cs
- SqlDataSourceCache.cs
- ClrProviderManifest.cs
- GeneralTransform2DTo3DTo2D.cs
- WebPartConnection.cs
- _PooledStream.cs
- ViewGenResults.cs
- RenderOptions.cs
- MD5CryptoServiceProvider.cs
- documentation.cs
- RegexCode.cs
- ExtenderProvidedPropertyAttribute.cs
- FunctionNode.cs
- HotSpot.cs
- SignedPkcs7.cs
- NativeObjectSecurity.cs
- ToolTipService.cs
- MissingMethodException.cs
- RewritingSimplifier.cs
- FormatStringEditor.cs
- MembershipPasswordException.cs
- COM2ExtendedTypeConverter.cs
- ExpandSegment.cs
- ArrangedElement.cs
- MediaTimeline.cs
- RoutedPropertyChangedEventArgs.cs
- FileSystemWatcher.cs
- SmtpException.cs
- ReflectionUtil.cs
- PolicyLevel.cs
- DataTablePropertyDescriptor.cs
- DiscoveryService.cs
- ByteStreamGeometryContext.cs
- DbConvert.cs
- TextElementEnumerator.cs
- login.cs
- SqlTriggerAttribute.cs
- DocumentXPathNavigator.cs
- LazyTextWriterCreator.cs
- CalendarDay.cs
- CodeIdentifiers.cs
- ApplicationHost.cs
- SqlAliasesReferenced.cs
- DependencyPropertyKey.cs
- StylusCaptureWithinProperty.cs
- VarRemapper.cs
- JapaneseCalendar.cs
- Directory.cs
- MimeParameterWriter.cs
- EntityDataSourceDesigner.cs
- SEHException.cs
- EntityDataSourceEntitySetNameItem.cs
- ScrollProperties.cs
- NameValueSectionHandler.cs
- ICspAsymmetricAlgorithm.cs
- WebPartAuthorizationEventArgs.cs
- DependencyStoreSurrogate.cs
- LabelLiteral.cs