Code:
/ WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / WCF / ServiceModel / System / ServiceModel / Channels / MsmqInputMessage.cs / 1 / MsmqInputMessage.cs
//------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------- namespace System.ServiceModel.Channels { class MsmqInputMessage : NativeMsmqMessage { BufferProperty senderId; IntProperty senderIdLength; LongProperty lookupId; IntProperty abortCount; IntProperty moveCount; BufferProperty senderCertificate; IntProperty senderCertificateLength; IntProperty lastMovedTime; BufferProperty body; IntProperty bodyLength; BufferProperty messageId; ShortProperty cls; int maxBufferSize; const int maxSize = 4 * 1024 * 1024; const int initialBodySize = 4096; const int initialSenderIdSize = 256; const int initialCertificateSize = 4096; public MsmqInputMessage() : this(0, maxSize) { } public MsmqInputMessage(int maxBufferSize) : this(0, maxBufferSize) { } protected MsmqInputMessage(int additionalPropertyCount, int maxBufferSize) : this(additionalPropertyCount, new SizeQuota(maxBufferSize)) { } protected MsmqInputMessage(int additionalPropertyCount, SizeQuota bufferSizeQuota) : base(12 + additionalPropertyCount) { this.maxBufferSize = bufferSizeQuota.MaxSize; this.body = new BufferProperty(this, UnsafeNativeMethods.PROPID_M_BODY, bufferSizeQuota.AllocIfAvailable(initialBodySize)); this.bodyLength = new IntProperty(this, UnsafeNativeMethods.PROPID_M_BODY_SIZE); this.messageId = new BufferProperty(this, UnsafeNativeMethods.PROPID_M_MSGID, UnsafeNativeMethods.PROPID_M_MSGID_SIZE); this.lookupId = new LongProperty(this, UnsafeNativeMethods.PROPID_M_LOOKUPID); this.cls = new ShortProperty(this, UnsafeNativeMethods.PROPID_M_CLASS); this.senderId = new BufferProperty(this, UnsafeNativeMethods.PROPID_M_SENDERID, initialSenderIdSize); this.senderIdLength = new IntProperty(this, UnsafeNativeMethods.PROPID_M_SENDERID_LEN); this.senderCertificate = new BufferProperty(this, UnsafeNativeMethods.PROPID_M_SENDER_CERT, bufferSizeQuota.AllocIfAvailable(initialCertificateSize)); this.senderCertificateLength = new IntProperty(this, UnsafeNativeMethods.PROPID_M_SENDER_CERT_LEN); if (Msmq.IsAdvancedPoisonHandlingSupported) { this.lastMovedTime = new IntProperty(this, UnsafeNativeMethods.PROPID_M_LAST_MOVE_TIME); this.abortCount = new IntProperty(this, UnsafeNativeMethods.PROPID_M_ABORT_COUNT); this.moveCount = new IntProperty(this, UnsafeNativeMethods.PROPID_M_MOVE_COUNT); } } public override void GrowBuffers() { OnGrowBuffers(new SizeQuota(this.maxBufferSize)); } protected virtual void OnGrowBuffers(SizeQuota bufferSizeQuota) { bufferSizeQuota.Alloc(this.senderIdLength.Value); this.senderId.EnsureBufferLength(this.senderIdLength.Value); bufferSizeQuota.Alloc(this.senderCertificateLength.Value); this.senderCertificate.EnsureBufferLength(this.senderCertificateLength.Value); bufferSizeQuota.Alloc(this.bodyLength.Value); this.body.EnsureBufferLength(this.bodyLength.Value); } public BufferProperty SenderId { get { return this.senderId; } } public IntProperty SenderIdLength { get { return this.senderIdLength; } } public LongProperty LookupId { get { return this.lookupId; } } public IntProperty AbortCount { get { return this.abortCount; } } public IntProperty MoveCount { get { return this.moveCount; } } public BufferProperty SenderCertificate { get { return this.senderCertificate; } } public IntProperty SenderCertificateLength { get { return this.senderCertificateLength; } } public IntProperty LastMovedTime { get { return this.lastMovedTime; } } public BufferProperty Body { get { return this.body; } } public IntProperty BodyLength { get { return this.bodyLength; } } public BufferProperty MessageId { get { return this.messageId; } } public ShortProperty Class { get { return this.cls; } } protected class SizeQuota { int remainingSize; int maxSize; public SizeQuota(int maxSize) { this.maxSize = maxSize; this.remainingSize = maxSize; } public int MaxSize { get { return this.maxSize; } } public void Alloc(int requiredSize) { if (requiredSize > this.remainingSize) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(MaxMessageSizeStream.CreateMaxReceivedMessageSizeExceededException(this.maxSize)); } this.remainingSize -= requiredSize; } public int AllocIfAvailable(int desiredSize) { int availableSize = Math.Min(desiredSize, this.remainingSize); this.remainingSize -= availableSize; return availableSize; } } } } // 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
- XmlBindingWorker.cs
- FontSourceCollection.cs
- ContainerControl.cs
- SemaphoreSecurity.cs
- CancelEventArgs.cs
- LowerCaseStringConverter.cs
- SendKeys.cs
- PriorityQueue.cs
- CustomWebEventKey.cs
- SerializationAttributes.cs
- HttpStreams.cs
- EpmHelper.cs
- RegexParser.cs
- UnsafeNativeMethods.cs
- HttpPostedFileWrapper.cs
- AstTree.cs
- SqlCommand.cs
- CachedFontFace.cs
- SolidColorBrush.cs
- XmlTypeAttribute.cs
- WebColorConverter.cs
- OutOfProcStateClientManager.cs
- SendMailErrorEventArgs.cs
- HtmlLink.cs
- EntityTransaction.cs
- SqlAggregateChecker.cs
- GradientStopCollection.cs
- PointAnimationBase.cs
- AttachedPropertyInfo.cs
- TagPrefixInfo.cs
- CompositeActivityTypeDescriptor.cs
- Environment.cs
- AnnotationService.cs
- PointF.cs
- MatrixAnimationBase.cs
- WinFormsComponentEditor.cs
- RtfToXamlReader.cs
- SessionState.cs
- ContextActivityUtils.cs
- GenericRootAutomationPeer.cs
- InstanceLockException.cs
- ImageList.cs
- ConnectionInterfaceCollection.cs
- TraceFilter.cs
- CfgParser.cs
- LinqDataSourceContextEventArgs.cs
- TrustSection.cs
- RSAOAEPKeyExchangeFormatter.cs
- JpegBitmapDecoder.cs
- DesignerVerb.cs
- ObjectDataSourceChooseTypePanel.cs
- XmlAggregates.cs
- ReachFixedPageSerializerAsync.cs
- LabelLiteral.cs
- CodePageUtils.cs
- TextTreeFixupNode.cs
- HttpBufferlessInputStream.cs
- KeyNotFoundException.cs
- ObjectDataSourceSelectingEventArgs.cs
- ClientSideQueueItem.cs
- TimeZone.cs
- Int32Storage.cs
- SecurityManager.cs
- DeviceContexts.cs
- ValueHandle.cs
- TemplateBindingExpression.cs
- MachineKeyConverter.cs
- TraceUtils.cs
- TypographyProperties.cs
- ItemsPresenter.cs
- Line.cs
- DynamicMetaObjectBinder.cs
- TimeIntervalCollection.cs
- StartUpEventArgs.cs
- StringDictionary.cs
- HttpCookie.cs
- ControlCollection.cs
- TextCompositionManager.cs
- UrlMappingsSection.cs
- DefinitionUpdate.cs
- ItemAutomationPeer.cs
- SecondaryViewProvider.cs
- HyperLinkStyle.cs
- ApplicationHost.cs
- OutputCacheSettingsSection.cs
- Metafile.cs
- DataGridColumnHeader.cs
- Hyperlink.cs
- XmlSchemaFacet.cs
- MergeLocalizationDirectives.cs
- StateWorkerRequest.cs
- Membership.cs
- EmptyStringExpandableObjectConverter.cs
- NavigationProgressEventArgs.cs
- xsdvalidator.cs
- DataGrid.cs
- Geometry3D.cs
- LayoutEngine.cs
- PermissionToken.cs
- DynamicScriptObject.cs