Code:
/ WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / WCF / ServiceModel / System / ServiceModel / ComIntegration / ComPlusInstanceContextInitializer.cs / 1 / ComPlusInstanceContextInitializer.cs
//------------------------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------------------------- namespace System.ServiceModel.ComIntegration { using System; using System.ServiceModel.Channels; using System.ServiceModel.Dispatcher; using System.Diagnostics; using System.EnterpriseServices; using System.Runtime.InteropServices; using System.IdentityModel.Claims; using System.IdentityModel.Policy; using System.Security.Principal; using System.ServiceModel; using System.ServiceModel.Diagnostics; using System.Transactions; using System.Reflection; using System.IO; class ComPlusInstanceContextInitializer : IInstanceContextInitializer { ServiceInfo info; static readonly Guid IID_IServiceActivity = new Guid("67532E0C-9E2F-4450-A354-035633944E17"); static readonly Guid DefaultPartitionId = new Guid("41E90F3E-56C1-4633-81C3-6E8BAC8BDD70"); private static object manifestLock = new object(); private static string manifestFileName = Guid.NewGuid().ToString(); static ComPlusInstanceContextInitializer() { AppDomain currentDomain = AppDomain.CurrentDomain; currentDomain.AssemblyResolve += new ResolveEventHandler(ResolveAssembly); } public ComPlusInstanceContextInitializer(ServiceInfo info) { this.info = info; if (this.info.HasUdts()) { string tempPath = String.Empty; lock (manifestLock) { try { tempPath = Path.GetTempPath(); } catch (Exception e) { if (DiagnosticUtility.IsFatal(e)) throw; throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(System.ServiceModel.ComIntegration.Error.CannotAccessDirectory(tempPath)); } string manifestDirectory = tempPath + this.info.AppID.ToString(); if (Directory.Exists(manifestDirectory)) Directory.Delete(manifestDirectory, true); } } } public void Initialize(InstanceContext instanceContext, Message message) { object serviceConfig = null; serviceConfig = SetupServiceConfig(instanceContext, message); IServiceActivity activity; activity = (IServiceActivity)SafeNativeMethods.CoCreateActivity( serviceConfig, IID_IServiceActivity); ComPlusSynchronizationContext syncContext; bool postSynchronous = (this.info.ThreadingModel == ThreadingModel.MTA); syncContext = new ComPlusSynchronizationContext(activity, postSynchronous); instanceContext.SynchronizationContext = syncContext; instanceContext.Closing += this.OnInstanceContextClosing; Marshal.ReleaseComObject(serviceConfig); } public void OnInstanceContextClosing(object sender, EventArgs args) { InstanceContext instanceContext = (InstanceContext)sender; ComPlusSynchronizationContext syncContext; syncContext = (ComPlusSynchronizationContext)instanceContext.SynchronizationContext; syncContext.Dispose(); } static Assembly ResolveAssembly(object sender, ResolveEventArgs args) { int indexOfComma = args.Name.IndexOf(",", StringComparison.Ordinal); if (indexOfComma == -1) return null; string assemblyGuid = args.Name.Substring(0, indexOfComma).Trim().ToLowerInvariant(); return TypeCacheManager.Provider.ResolveAssembly(new Guid(assemblyGuid)); } object SetupServiceConfig(InstanceContext instanceContext, Message message) { object serviceConfig = new CServiceConfig(); // Threading // IServiceThreadPoolConfig threadPoolConfig; threadPoolConfig = (IServiceThreadPoolConfig)(serviceConfig); switch(this.info.ThreadingModel) { case ThreadingModel.MTA: threadPoolConfig.SelectThreadPool(ThreadPoolOption.MTA); break; case ThreadingModel.STA: threadPoolConfig.SelectThreadPool(ThreadPoolOption.STA); break; default: DiagnosticUtility.DebugAssert("Unexpected threading model"); throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(Error.UnexpectedThreadingModel()); } threadPoolConfig.SetBindingInfo(BindingOption.BindingToPoolThread); // SxS activation context properties // // Manifest for VARIANT UDT types // // this only gets executed if we actually have UDTs if (this.info.HasUdts()) { IServiceSxsConfig sxsConfig = serviceConfig as IServiceSxsConfig; if (sxsConfig == null) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(System.ServiceModel.ComIntegration.Error.QFENotPresent()); } lock (manifestLock) { string tempPath = String.Empty; try { tempPath = Path.GetTempPath(); } catch (Exception e) { if (DiagnosticUtility.IsFatal(e)) throw; throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(System.ServiceModel.ComIntegration.Error.CannotAccessDirectory(tempPath)); } string manifestDirectory = tempPath + this.info.AppID.ToString() + @"\"; if (!Directory.Exists(manifestDirectory)) { try { Directory.CreateDirectory(manifestDirectory); } catch (Exception e) { if (DiagnosticUtility.IsFatal(e)) throw; throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(System.ServiceModel.ComIntegration.Error.CannotAccessDirectory(manifestDirectory)); } Guid[] assemblyGuids = this.info.Assemblies; ComIntegrationManifestGenerator.GenerateManifestCollectionFile(assemblyGuids, manifestDirectory + manifestFileName + @".manifest", manifestFileName); foreach (Guid g in assemblyGuids) { Type[] types = this.info.GetTypes(g); if (types.Length > 0) { String guidStr = g.ToString(); ComIntegrationManifestGenerator.GenerateWin32ManifestFile(types, manifestDirectory + guidStr + @".manifest", guidStr); } } } sxsConfig.SxsConfig(CSC_SxsConfig.CSC_NewSxs); sxsConfig.SxsName(manifestFileName + @".manifest"); sxsConfig.SxsDirectory(manifestDirectory); } } // Partitions // if (this.info.PartitionId != DefaultPartitionId) { IServicePartitionConfig partitionConfig; partitionConfig = (IServicePartitionConfig)(serviceConfig); partitionConfig.PartitionConfig(PartitionOption.New); partitionConfig.PartitionID(this.info.PartitionId); } // Transactions // IServiceTransactionConfig transactionConfig; transactionConfig = (IServiceTransactionConfig)(serviceConfig); transactionConfig.ConfigureTransaction( TransactionConfig.NoTransaction); if ((this.info.TransactionOption == TransactionOption.Required) || (this.info.TransactionOption == TransactionOption.Supported)) { Transaction messageTransaction = null; messageTransaction = MessageUtil.GetMessageTransaction(message); if (messageTransaction != null) { TransactionProxy proxy = new TransactionProxy(info.AppID, info.Clsid); proxy.SetTransaction(messageTransaction); instanceContext.Extensions.Add(proxy); IServiceSysTxnConfig sysTxnconfing = (IServiceSysTxnConfig)transactionConfig ; IntPtr pUnk = TransactionProxyBuilder.CreateTransactionProxyTearOff(proxy); sysTxnconfing.ConfigureBYOTSysTxn(pUnk); Marshal.Release(pUnk); } } return serviceConfig; } } } // 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
- AbstractSvcMapFileLoader.cs
- SimpleType.cs
- XmlCustomFormatter.cs
- HtmlInputFile.cs
- ResourcesBuildProvider.cs
- Content.cs
- CopyOnWriteList.cs
- RotateTransform3D.cs
- SQLInt64Storage.cs
- LongValidator.cs
- TraceFilter.cs
- XPathNodePointer.cs
- ToolStripComboBox.cs
- UInt32Storage.cs
- XmlSchemaSequence.cs
- XmlCodeExporter.cs
- IResourceProvider.cs
- UserControlBuildProvider.cs
- InternalSafeNativeMethods.cs
- log.cs
- ComboBox.cs
- TableProviderWrapper.cs
- SecurityTokenResolver.cs
- ZipIOZip64EndOfCentralDirectoryBlock.cs
- DiscriminatorMap.cs
- HttpFileCollection.cs
- ServiceDebugBehavior.cs
- TimeSpanSecondsConverter.cs
- XPathChildIterator.cs
- JavascriptCallbackBehaviorAttribute.cs
- HtmlImage.cs
- OracleFactory.cs
- Token.cs
- LinqDataSourceView.cs
- InsufficientMemoryException.cs
- SelectedGridItemChangedEvent.cs
- TimeSpanStorage.cs
- DefaultClaimSet.cs
- XPathNodeHelper.cs
- Cloud.cs
- DocumentReferenceCollection.cs
- Process.cs
- PropertyEmitter.cs
- SystemException.cs
- ManipulationStartingEventArgs.cs
- CompositeFontFamily.cs
- DocumentApplicationState.cs
- WindowsListViewGroupHelper.cs
- Triplet.cs
- XPathNodePointer.cs
- ToolStripLabel.cs
- AccessorTable.cs
- RootProfilePropertySettingsCollection.cs
- COAUTHIDENTITY.cs
- Vector.cs
- FormsIdentity.cs
- AccessorTable.cs
- OleDbParameter.cs
- Overlapped.cs
- FrameworkRichTextComposition.cs
- SchemaNotation.cs
- GridViewCellAutomationPeer.cs
- Freezable.cs
- SymbolEqualComparer.cs
- RequestCachingSection.cs
- ChannelBinding.cs
- ReferenceSchema.cs
- BufferBuilder.cs
- ClaimTypeElement.cs
- RowParagraph.cs
- InkSerializer.cs
- InfoCardArgumentException.cs
- XmlWriterDelegator.cs
- BackgroundWorker.cs
- Encoding.cs
- InkCanvas.cs
- _KerberosClient.cs
- WebPartConnectionsEventArgs.cs
- HScrollProperties.cs
- RowToParametersTransformer.cs
- EmptyEnumerator.cs
- PublishLicense.cs
- WebRequestModuleElement.cs
- SolidColorBrush.cs
- ZipIOZip64EndOfCentralDirectoryLocatorBlock.cs
- QueryableDataSource.cs
- XmlTextWriter.cs
- AnonymousIdentificationSection.cs
- DependencyPropertyConverter.cs
- CompositeScriptReferenceEventArgs.cs
- SizeFConverter.cs
- PerspectiveCamera.cs
- EdmComplexTypeAttribute.cs
- LinearKeyFrames.cs
- ProtocolsConfigurationHandler.cs
- CryptoHandle.cs
- SHA1Cng.cs
- GorillaCodec.cs
- TableLayoutPanelCellPosition.cs
- SuppressMessageAttribute.cs