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
- FontConverter.cs
- ExternalCalls.cs
- CollectionType.cs
- HttpModulesSection.cs
- ExpressionBindingCollection.cs
- ValidatingPropertiesEventArgs.cs
- SqlNodeTypeOperators.cs
- X509ScopedServiceCertificateElementCollection.cs
- StyleModeStack.cs
- CorruptingExceptionCommon.cs
- FileSystemEventArgs.cs
- TransactionInformation.cs
- UnsafeNativeMethods.cs
- Quad.cs
- QueryStatement.cs
- XhtmlTextWriter.cs
- PersonalizableTypeEntry.cs
- MethodBuilder.cs
- RelationshipEndMember.cs
- XmlSchemaRedefine.cs
- EditorAttribute.cs
- CroppedBitmap.cs
- StorageComplexPropertyMapping.cs
- ArglessEventHandlerProxy.cs
- XmlSchemaSimpleTypeList.cs
- Point.cs
- DataTransferEventArgs.cs
- RotationValidation.cs
- NamedElement.cs
- BindingsCollection.cs
- SafeMILHandle.cs
- PermissionToken.cs
- PolygonHotSpot.cs
- formatter.cs
- HttpListenerTimeoutManager.cs
- oledbmetadatacollectionnames.cs
- TableCell.cs
- CheckBoxPopupAdapter.cs
- DataIdProcessor.cs
- ExceptionUtil.cs
- LoginCancelEventArgs.cs
- SizeAnimationClockResource.cs
- TextTreeNode.cs
- TextClipboardData.cs
- BmpBitmapEncoder.cs
- TypeBuilder.cs
- TextTabProperties.cs
- TypeUtils.cs
- SymbolMethod.cs
- XPathAncestorQuery.cs
- Avt.cs
- PageCatalogPartDesigner.cs
- MemberExpression.cs
- DeploymentSection.cs
- RotateTransform3D.cs
- HttpListenerResponse.cs
- SemanticTag.cs
- ModelTreeEnumerator.cs
- DataSource.cs
- DragSelectionMessageFilter.cs
- CircleHotSpot.cs
- XmlSchemaElement.cs
- DispatcherSynchronizationContext.cs
- unitconverter.cs
- PublishLicense.cs
- Membership.cs
- PropertyAccessVisitor.cs
- RoutedEvent.cs
- Empty.cs
- SamlEvidence.cs
- HierarchicalDataBoundControl.cs
- ZipIOCentralDirectoryFileHeader.cs
- MethodToken.cs
- input.cs
- BaseAppDomainProtocolHandler.cs
- HandlerBase.cs
- InputScopeNameConverter.cs
- StringComparer.cs
- ApplicationId.cs
- Base64Encoding.cs
- MappingSource.cs
- CellQuery.cs
- WebServicesInteroperability.cs
- JpegBitmapDecoder.cs
- SelectionProviderWrapper.cs
- WebPartDisplayModeCancelEventArgs.cs
- SearchForVirtualItemEventArgs.cs
- Rules.cs
- WebControlToolBoxItem.cs
- PropertyChangingEventArgs.cs
- HtmlControlPersistable.cs
- TableAutomationPeer.cs
- TimersDescriptionAttribute.cs
- DocumentXPathNavigator.cs
- WebPartTracker.cs
- NotConverter.cs
- LogExtentCollection.cs
- GridViewUpdatedEventArgs.cs
- TiffBitmapEncoder.cs
- MissingFieldException.cs