Code:
/ 4.0 / 4.0 / untmp / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / cdf / src / System.Runtime.DurableInstancing / System / Runtime / TimeoutHelper.cs / 1305376 / TimeoutHelper.cs
//------------------------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------------------------- namespace System.Runtime { using System; using System.Threading; struct TimeoutHelper { DateTime deadline; bool deadlineSet; TimeSpan originalTimeout; public static readonly TimeSpan MaxWait = TimeSpan.FromMilliseconds(Int32.MaxValue); public TimeoutHelper(TimeSpan timeout) { Fx.Assert(timeout >= TimeSpan.Zero, "timeout must be non-negative"); this.originalTimeout = timeout; this.deadline = DateTime.MaxValue; this.deadlineSet = (timeout == TimeSpan.MaxValue); } public TimeSpan OriginalTimeout { get { return this.originalTimeout; } } public static bool IsTooLarge(TimeSpan timeout) { return (timeout > TimeoutHelper.MaxWait) && (timeout != TimeSpan.MaxValue); } public static TimeSpan FromMilliseconds(int milliseconds) { if (milliseconds == Timeout.Infinite) { return TimeSpan.MaxValue; } else { return TimeSpan.FromMilliseconds(milliseconds); } } public static int ToMilliseconds(TimeSpan timeout) { if (timeout == TimeSpan.MaxValue) { return Timeout.Infinite; } else { long ticks = Ticks.FromTimeSpan(timeout); if (ticks / TimeSpan.TicksPerMillisecond > int.MaxValue) { return int.MaxValue; } return Ticks.ToMilliseconds(ticks); } } public static TimeSpan Min(TimeSpan val1, TimeSpan val2) { if (val1 > val2) { return val2; } else { return val1; } } public static TimeSpan Add(TimeSpan timeout1, TimeSpan timeout2) { return Ticks.ToTimeSpan(Ticks.Add(Ticks.FromTimeSpan(timeout1), Ticks.FromTimeSpan(timeout2))); } public static DateTime Add(DateTime time, TimeSpan timeout) { if (timeout >= TimeSpan.Zero && DateTime.MaxValue - time <= timeout) { return DateTime.MaxValue; } if (timeout <= TimeSpan.Zero && DateTime.MinValue - time >= timeout) { return DateTime.MinValue; } return time + timeout; } public static DateTime Subtract(DateTime time, TimeSpan timeout) { return Add(time, TimeSpan.Zero - timeout); } public static TimeSpan Divide(TimeSpan timeout, int factor) { if (timeout == TimeSpan.MaxValue) { return TimeSpan.MaxValue; } return Ticks.ToTimeSpan((Ticks.FromTimeSpan(timeout) / factor) + 1); } public TimeSpan RemainingTime() { if (!this.deadlineSet) { this.SetDeadline(); return this.originalTimeout; } else if (this.deadline == DateTime.MaxValue) { return TimeSpan.MaxValue; } else { TimeSpan remaining = this.deadline - DateTime.UtcNow; if (remaining <= TimeSpan.Zero) { return TimeSpan.Zero; } else { return remaining; } } } public TimeSpan ElapsedTime() { return this.originalTimeout - this.RemainingTime(); } void SetDeadline() { Fx.Assert(!deadlineSet, "TimeoutHelper deadline set twice."); this.deadline = DateTime.UtcNow + this.originalTimeout; this.deadlineSet = true; } public static void ThrowIfNegativeArgument(TimeSpan timeout) { ThrowIfNegativeArgument(timeout, "timeout"); } public static void ThrowIfNegativeArgument(TimeSpan timeout, string argumentName) { if (timeout < TimeSpan.Zero) { throw Fx.Exception.ArgumentOutOfRange(argumentName, timeout, SRCore.TimeoutMustBeNonNegative(argumentName, timeout)); } } public static void ThrowIfNonPositiveArgument(TimeSpan timeout) { ThrowIfNonPositiveArgument(timeout, "timeout"); } public static void ThrowIfNonPositiveArgument(TimeSpan timeout, string argumentName) { if (timeout <= TimeSpan.Zero) { throw Fx.Exception.ArgumentOutOfRange(argumentName, timeout, SRCore.TimeoutMustBePositive(argumentName, timeout)); } } [Fx.Tag.Blocking] public static bool WaitOne(WaitHandle waitHandle, TimeSpan timeout) { ThrowIfNegativeArgument(timeout); if (timeout == TimeSpan.MaxValue) { waitHandle.WaitOne(); return true; } else { return waitHandle.WaitOne(timeout, false); } } } } // 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
- XPathDocument.cs
- ManipulationStartingEventArgs.cs
- ComAwareEventInfo.cs
- RuntimeConfigLKG.cs
- SqlRowUpdatingEvent.cs
- WebControl.cs
- DisplayNameAttribute.cs
- Atom10FormatterFactory.cs
- ClientFormsAuthenticationCredentials.cs
- TextEditorContextMenu.cs
- RealizationDrawingContextWalker.cs
- XmlSchemaException.cs
- HyperLinkField.cs
- FileSecurity.cs
- CodeRegionDirective.cs
- SerializerWriterEventHandlers.cs
- RoleExceptions.cs
- Drawing.cs
- DataView.cs
- SelectionRange.cs
- DataTablePropertyDescriptor.cs
- ContentDisposition.cs
- DataBoundControlHelper.cs
- CodeGroup.cs
- Binding.cs
- Vector3DAnimationUsingKeyFrames.cs
- CodeAccessSecurityEngine.cs
- ImmutablePropertyDescriptorGridEntry.cs
- StrokeCollection2.cs
- StorageSetMapping.cs
- TraversalRequest.cs
- ImageIndexConverter.cs
- CompilerTypeWithParams.cs
- SourceLineInfo.cs
- TextClipboardData.cs
- X509SecurityTokenAuthenticator.cs
- SmiGettersStream.cs
- ContextInformation.cs
- Visitor.cs
- DashStyle.cs
- KnowledgeBase.cs
- Activity.cs
- HttpClientProtocol.cs
- SoapElementAttribute.cs
- ScriptReference.cs
- SigningCredentials.cs
- _CommandStream.cs
- BitmapEffect.cs
- unitconverter.cs
- TraceHwndHost.cs
- StaticFileHandler.cs
- XmlWrappingReader.cs
- PnrpPermission.cs
- RecognizedAudio.cs
- SoapAttributes.cs
- DragStartedEventArgs.cs
- StreamUpgradeInitiator.cs
- XmlILCommand.cs
- InvalidCastException.cs
- _ReceiveMessageOverlappedAsyncResult.cs
- TCPListener.cs
- AttributeCollection.cs
- parserscommon.cs
- WindowsTokenRoleProvider.cs
- WindowsListViewItemStartMenu.cs
- PixelShader.cs
- UserPreferenceChangedEventArgs.cs
- DbCommandTree.cs
- AccessedThroughPropertyAttribute.cs
- GlyphRunDrawing.cs
- CheckPair.cs
- HandleCollector.cs
- WebHttpEndpoint.cs
- DataGridViewCellStyleEditor.cs
- SecurityKeyUsage.cs
- WindowsFormsHelpers.cs
- TextStore.cs
- SchemaNames.cs
- SettingsAttributes.cs
- DiscoveryDocumentLinksPattern.cs
- RenameRuleObjectDialog.cs
- RemotingAttributes.cs
- ManagementPath.cs
- XmlIlGenerator.cs
- Mapping.cs
- ReadOnlyDictionary.cs
- Canonicalizers.cs
- XPathCompileException.cs
- ColumnMapVisitor.cs
- DetailsViewInsertedEventArgs.cs
- EndpointAddressAugust2004.cs
- DbConnectionClosed.cs
- DataTableNameHandler.cs
- WebPartConnectVerb.cs
- WaitHandle.cs
- SequentialUshortCollection.cs
- ContainerParagraph.cs
- StatusBarPanel.cs
- CompiledQueryCacheKey.cs
- DesignerTextBoxAdapter.cs