Code:
/ WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / WCF / ServiceModel / System / ServiceModel / ComIntegration / DllHostInitializer.cs / 2 / DllHostInitializer.cs
//------------------------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------------------------- namespace System.ServiceModel.ComIntegration { using System; using System.Collections.Generic; using System.EnterpriseServices; using System.Runtime.InteropServices; using System.ServiceModel.Configuration; using System.Diagnostics; using System.Threading; using System.ServiceModel.Diagnostics; class DllHostInitializeWorker { Listhosts = new List (); Guid applicationId; // This thread pings rpcss and the host process so that // it does not assume that we are stuck and kills itself. public static void PingProc(object o) { IProcessInitControl control = o as IProcessInitControl; try { // This will loop for a max of 2000 seconds, which is a sanity check // that should never be hit. The assumption behind that is that // the main thread will not get stuck. It will either make progress // or fail with an exception, which will abort this thread and kill the process. // No COM app should take longer than 30 minutes to initialize since an app that // takes that long would have to be so big that it hits other limits before it hits this. for(int i = 0; i < 200; i++) { Thread.Sleep(10000); // Add 30 more seconds to the timeout control.ResetInitializerTimeout(30); } } catch (ThreadAbortException) { } } public void Startup(IProcessInitControl control) { // Find our application object, and associated components // (classes) collection from the COM+ catalog. // applicationId = ContextUtil.ApplicationId; ComPlusDllHostInitializerTrace.Trace(TraceEventType.Information, TraceCode.ComIntegrationDllHostInitializerStarting, SR.TraceCodeComIntegrationDllHostInitializerStarting, applicationId); Thread pingThread = null; try { pingThread = new Thread(PingProc); pingThread.Start(control); ComCatalogObject application; application = CatalogUtil.FindApplication(applicationId); if (application == null) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(Error.ListenerInitFailed( SR.GetString(SR.ApplicationNotFound, applicationId.ToString("B").ToUpperInvariant()))); } bool processPooled = ((int)application.GetValue("ConcurrentApps")) > 1; if (processPooled) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(Error.ListenerInitFailed( SR.GetString(SR.PooledApplicationNotSupportedForComplusHostedScenarios, applicationId.ToString("B").ToUpperInvariant()))); } bool processRecycled = ((int)application.GetValue("RecycleLifetimeLimit")) > 0 || ((int)application.GetValue("RecycleCallLimit")) > 0 || ((int)application.GetValue("RecycleActivationLimit")) > 0 || ((int)application.GetValue("RecycleMemoryLimit")) > 0; if (processRecycled) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(Error.ListenerInitFailed( SR.GetString(SR.RecycledApplicationNotSupportedForComplusHostedScenarios, applicationId.ToString("B").ToUpperInvariant()))); } ComCatalogCollection classes; classes = application.GetCollection("Components"); // Load up Indigo configuration. // ServicesSection services = ServicesSection.GetSection(); bool foundService = false; foreach (ServiceElement service in services.Services) { Guid clsidToCompare = Guid.Empty; Guid appIdToCompare = Guid.Empty; string[] serviceParams = service.Name.Split(','); if (serviceParams.Length != 2) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidOperationException(SR.GetString(SR.OnlyClsidsAllowedForServiceType, service.Name))); } if ( !DiagnosticUtility.Utility.TryCreateGuid(serviceParams[0], out appIdToCompare)) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidOperationException(SR.GetString(SR.OnlyClsidsAllowedForServiceType, service.Name))); } if ( !DiagnosticUtility.Utility.TryCreateGuid(serviceParams[1], out clsidToCompare)) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidOperationException(SR.GetString(SR.OnlyClsidsAllowedForServiceType, service.Name))); } foundService = false; // CODEWORK: Consider farming this out across multiple threadpool threads. // When it was discovered that startup time could be a problem it was too late // to to do that since it can cause failure conditions that need to be considered // (such as the threadpool running out) so we decided not to touch that part. // But since this can potentially take a very long time on big COM apps // it should be parallelized at some point. foreach (ComCatalogObject classObject in classes) { Guid clsid = new Guid((string)classObject.GetValue("CLSID")); if (clsid == clsidToCompare && applicationId == appIdToCompare) { foundService = true; ComPlusDllHostInitializerTrace.Trace(TraceEventType.Verbose, TraceCode.ComIntegrationDllHostInitializerAddingHost, SR.TraceCodeComIntegrationDllHostInitializerAddingHost, applicationId, clsid, service); this.hosts.Add( new DllHostedComPlusServiceHost(clsid, service, application, classObject)); } } if (!foundService) throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidOperationException(SR.GetString (SR.CannotFindClsidInApplication, clsidToCompare.ToString("B").ToUpperInvariant(), applicationId.ToString("B").ToUpperInvariant()))); } if (foundService == false) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(Error.DllHostInitializerFoundNoServices()); } foreach (ComPlusServiceHost host in this.hosts) { host.Open(); } } catch (Exception e) { DiagnosticUtility.EventLog.LogEvent(TraceEventType.Error, EventLogCategory.ComPlus, EventLogEventId.ComPlusDllHostInitializerStartingError, applicationId.ToString(), e.ToString()); throw; } finally { if (null != pingThread) pingThread.Abort(); // We are done; stop pinging. } ComPlusDllHostInitializerTrace.Trace(TraceEventType.Information, TraceCode.ComIntegrationDllHostInitializerStarted, SR.TraceCodeComIntegrationDllHostInitializerStarted, applicationId); } public void Shutdown() { ComPlusDllHostInitializerTrace.Trace(TraceEventType.Information, TraceCode.ComIntegrationDllHostInitializerStopping, SR.TraceCodeComIntegrationDllHostInitializerStopping, applicationId); foreach(ComPlusServiceHost host in this.hosts) { host.Close(); } ComPlusDllHostInitializerTrace.Trace(TraceEventType.Information, TraceCode.ComIntegrationDllHostInitializerStopped, SR.TraceCodeComIntegrationDllHostInitializerStopped, applicationId); } } [ComVisible (true)] [Guid("7B2801E6-0BC6-4c92-B742-6BE9B01AE874")] public class DllHostInitializer : IProcessInitializer { DllHostInitializeWorker worker = new DllHostInitializeWorker(); public void Startup(object punkProcessControl) { IProcessInitControl control = punkProcessControl as IProcessInitControl; worker.Startup(control); } public void Shutdown() { worker.Shutdown(); } } } // 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
- ExceptionRoutedEventArgs.cs
- Fx.cs
- Int32AnimationUsingKeyFrames.cs
- TargetFrameworkUtil.cs
- UIElement3D.cs
- ProcessStartInfo.cs
- InstanceLockLostException.cs
- WMIGenerator.cs
- EmptyCollection.cs
- ProxyAttribute.cs
- PrintingPermission.cs
- HttpModuleActionCollection.cs
- XPathNodeIterator.cs
- TextWriter.cs
- HwndSourceParameters.cs
- GridViewRow.cs
- LineBreakRecord.cs
- Cursor.cs
- DefaultTraceListener.cs
- DoubleCollectionConverter.cs
- SByteConverter.cs
- ResourceType.cs
- CodePageUtils.cs
- LedgerEntryCollection.cs
- InteropBitmapSource.cs
- _SafeNetHandles.cs
- HandleCollector.cs
- MenuCommands.cs
- StrongTypingException.cs
- UnionCqlBlock.cs
- DefaultDiscoveryServiceExtension.cs
- SemanticResolver.cs
- ToolStripContainerActionList.cs
- TargetParameterCountException.cs
- QilNode.cs
- RewritingValidator.cs
- XmlAnyElementAttributes.cs
- DesignRelation.cs
- SoapCodeExporter.cs
- OdbcError.cs
- ClientCultureInfo.cs
- DynamicActivityXamlReader.cs
- CheckBoxStandardAdapter.cs
- SpecularMaterial.cs
- SerialErrors.cs
- HiddenFieldDesigner.cs
- ApplicationServiceManager.cs
- SafeRightsManagementSessionHandle.cs
- ConsumerConnectionPointCollection.cs
- SessionSwitchEventArgs.cs
- BitmapEncoder.cs
- BindingExpression.cs
- StreamInfo.cs
- HighContrastHelper.cs
- QilTargetType.cs
- XsdDuration.cs
- DbException.cs
- TypefaceMetricsCache.cs
- SelectionWordBreaker.cs
- WorkflowMarkupSerializerMapping.cs
- WsdlInspector.cs
- RawAppCommandInputReport.cs
- XmlSchemaComplexContent.cs
- MultiPageTextView.cs
- TypeSystem.cs
- ApplicationBuildProvider.cs
- GeometryCollection.cs
- TypeContext.cs
- AmbientValueAttribute.cs
- CustomAttributeBuilder.cs
- TileBrush.cs
- ListSortDescription.cs
- FormatConvertedBitmap.cs
- CodeSpit.cs
- TrackingServices.cs
- DataGridRowHeaderAutomationPeer.cs
- GridSplitter.cs
- BitSet.cs
- CanonicalizationDriver.cs
- ObjectIDGenerator.cs
- AxisAngleRotation3D.cs
- VariableElement.cs
- UnlockInstanceAsyncResult.cs
- SerializationIncompleteException.cs
- NotCondition.cs
- SpotLight.cs
- FileEnumerator.cs
- IConvertible.cs
- ParallelTimeline.cs
- ProgressiveCrcCalculatingStream.cs
- FrameworkElement.cs
- TrustSection.cs
- WriterOutput.cs
- HybridCollection.cs
- Metafile.cs
- FormClosedEvent.cs
- Size3D.cs
- AttributeInfo.cs
- InsufficientMemoryException.cs
- CompositeFontInfo.cs