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
- RequestCache.cs
- PriorityRange.cs
- BufferAllocator.cs
- DataGridItemCollection.cs
- ListItemsPage.cs
- TextEndOfParagraph.cs
- Boolean.cs
- RequestQueue.cs
- Rectangle.cs
- OletxCommittableTransaction.cs
- XmlNamespaceDeclarationsAttribute.cs
- SchemaNamespaceManager.cs
- relpropertyhelper.cs
- DeferrableContentConverter.cs
- PeerTransportSecuritySettings.cs
- EmbossBitmapEffect.cs
- PageContent.cs
- SuppressMergeCheckAttribute.cs
- XmlAttributeAttribute.cs
- TextContainerHelper.cs
- Line.cs
- SessionSwitchEventArgs.cs
- DbFunctionCommandTree.cs
- CompressionTransform.cs
- DataSourceCacheDurationConverter.cs
- SqlVersion.cs
- LoginCancelEventArgs.cs
- CheckPair.cs
- XmlWrappingReader.cs
- PageRequestManager.cs
- TemplateBaseAction.cs
- HostingEnvironmentException.cs
- CodeFieldReferenceExpression.cs
- MessageTraceRecord.cs
- DetailsViewPageEventArgs.cs
- BidPrivateBase.cs
- SortQuery.cs
- XmlAttributeProperties.cs
- FlowDocument.cs
- Nullable.cs
- UInt16.cs
- AutoScrollExpandMessageFilter.cs
- NamespaceMapping.cs
- GraphicsContainer.cs
- PropertyIdentifier.cs
- HttpProfileBase.cs
- HistoryEventArgs.cs
- TagPrefixAttribute.cs
- PropertyCollection.cs
- ColorDialog.cs
- BufferedConnection.cs
- ZipIORawDataFileBlock.cs
- RequestQueryParser.cs
- SoapHeaderAttribute.cs
- DataTableReaderListener.cs
- OdbcStatementHandle.cs
- XmlSchemaChoice.cs
- GraphicsPath.cs
- ToolStripHighContrastRenderer.cs
- xmlformatgeneratorstatics.cs
- ColumnResult.cs
- ProviderUtil.cs
- SchemaMapping.cs
- Rect3DValueSerializer.cs
- RectConverter.cs
- DocumentViewerBaseAutomationPeer.cs
- XmlNotation.cs
- ScrollContentPresenter.cs
- PointHitTestParameters.cs
- SqlProcedureAttribute.cs
- RSAOAEPKeyExchangeDeformatter.cs
- DataGridColumnEventArgs.cs
- GlyphRunDrawing.cs
- MorphHelpers.cs
- NodeLabelEditEvent.cs
- ComponentConverter.cs
- MenuTracker.cs
- X509ServiceCertificateAuthenticationElement.cs
- EncoderParameter.cs
- KnowledgeBase.cs
- DBPropSet.cs
- BamlVersionHeader.cs
- EpmCustomContentWriterNodeData.cs
- XmlSchemaExporter.cs
- ViewGenerator.cs
- HtmlMeta.cs
- SettingsPropertyValueCollection.cs
- SerializationSectionGroup.cs
- ResourceManager.cs
- NodeLabelEditEvent.cs
- EventLogException.cs
- PathFigureCollection.cs
- X509CertificateCollection.cs
- AnnotationResourceCollection.cs
- PropertyReference.cs
- NumericPagerField.cs
- ExpressionPrefixAttribute.cs
- IdnElement.cs
- ByteStreamGeometryContext.cs
- TraceUtility.cs