Code:
/ WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / WCF / ServiceModel / System / ServiceModel / Dispatcher / QueryResultOp.cs / 1 / QueryResultOp.cs
//------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------- namespace System.ServiceModel.Dispatcher { using System; using System.ServiceModel.Channels; using System.Xml; using System.Xml.XPath; using System.Diagnostics; using System.Collections.Generic; ////// Base class for opcodes that produce the query's final result /// internal abstract class QueryResultOpcode : Opcode { internal QueryResultOpcode(OpcodeID id) : base(id) { this.flags |= OpcodeFlags.Result; } } internal class MatchQueryResultOpcode : QueryResultOpcode { internal MatchQueryResultOpcode() : this(OpcodeID.MatchQueryResult) { } protected MatchQueryResultOpcode(OpcodeID id) : base(id) { this.flags |= OpcodeFlags.Result; } internal override Opcode Eval(ProcessingContext context) { context.Processor.Result = this.IsSuccess(context); context.PopFrame(); return this.next; } protected bool IsSuccess(ProcessingContext context) { StackFrame topFrame = context.TopArg; #if FILTER_SELECT if (context.Processor.IsMatch) { #endif if (1 == topFrame.Count) { return context.Values[topFrame.basePtr].ToBoolean(); } else { context.Processor.Result = false; for (int i = topFrame.basePtr; i <= topFrame.endPtr; ++i) { if (context.Values[i].ToBoolean()) { return true; } } } #if FILTER_SELECT } else if (context.Processor.IsSelect) { string results = string.Empty; if (topFrame.Count > 0) { DiagnosticUtility.DebugAssert(topFrame.Count == 1, ""); results = context.Values[topFrame.basePtr].ToString(); } context.Processor.SelectResults = results; } #endif return false; } } #if NO internal class MatchFilterResultOpcode : MatchQueryResultOpcode { MessageFilter resultFilter; internal MatchFilterResultOpcode(MessageFilter resultFilter) : base(OpcodeID.MatchFilterResult) { DiagnosticUtility.DebugAssert(null != resultFilter, ""); this.resultFilter = resultFilter; } internal MessageFilter Result { get { return this.resultFilter; } } internal override void Add(Opcode op) { MatchFilterResultOpcode filterResult = op as MatchFilterResultOpcode; if (null == filterResult) { base.Add(op); return; } MatchMultipleFilterResultOpcode multipleResults = new MatchMultipleFilterResultOpcode(); DiagnosticUtility.DebugAssert(null != this.prev, ""); this.prev.Replace(this, multipleResults); if (null != this.next) { this.next.Prev = multipleResults; this.next = null; } multipleResults.Add(filterResult); multipleResults.Add(this); } // One MatchFilterResultOpcode result code is always treated equivalent to another internal override bool Equals(Opcode op) { if (base.Equals(op)) { MatchFilterResultOpcode resultOp = op as MatchFilterResultOpcode; return object.ReferenceEquals(resultOp.resultFilter, this.resultFilter); } return false; } internal override Opcode Eval(ProcessingContext context) { if (this.IsSuccess(context)) { context.Processor.ResultSet.Add(this.resultFilter); } return null; } internal override void Remove() { if (null == this.resultFilter) { base.Remove(); } } internal void Remove(MessageFilter resultFilter) { if (resultFilter == this.resultFilter) { this.resultFilter = null; DiagnosticUtility.DebugAssert(null != this.next, ""); base.Remove(); } } } #endif internal class MatchMultipleFilterResultOpcode : MatchQueryResultOpcode { internal QueryBufferresults; internal MatchMultipleFilterResultOpcode(XPathMessageFilter filter) : this() { this.results = new QueryBuffer (1); this.results.Add(filter); } internal MatchMultipleFilterResultOpcode() : base(OpcodeID.MatchMultipleFilterResult) { this.results = new QueryBuffer (0); } internal override void Add(Opcode op) { #if NO MatchFilterResultOpcode resultOp = op as MatchFilterResultOpcode; if (null != resultOp) { this.results.Add(resultOp.Result); return; } #endif MatchMultipleFilterResultOpcode results = op as MatchMultipleFilterResultOpcode; if (null != results) { this.results.Add(ref results.results); this.results.TrimToCount(); return; } base.Add(op); } internal override void CollectXPathFilters(ICollection filters) { for(int i = 0; i < this.results.Count; ++i) { filters.Add(this.results[i]); } } internal override bool Equals(Opcode op) { if (base.Equals (op)) { return object.ReferenceEquals(this, op); } return false; } internal override Opcode Eval(ProcessingContext context) { if (this.IsSuccess(context)) { ICollection matches = context.Processor.ResultSet; for (int i = 0, count = this.results.Count; i < count; ++i) { matches.Add(this.results[i]); } } context.PopFrame(); return this.next; } internal override void Remove() { if (0 == this.results.Count) { base.Remove(); } } internal void Remove(XPathMessageFilter resultFilter) { DiagnosticUtility.DebugAssert(null != resultFilter, ""); this.results.Remove(resultFilter); this.Remove(); } internal override void Trim() { this.results.TrimToCount(); } } } // 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
- Attributes.cs
- CodeObjectCreateExpression.cs
- FontWeights.cs
- RowParagraph.cs
- DependencyObject.cs
- ConstNode.cs
- DefaultWorkflowLoaderService.cs
- DataGridCaption.cs
- DropDownHolder.cs
- PropertyDescriptorComparer.cs
- CopyAttributesAction.cs
- SHA256Managed.cs
- VisualTreeUtils.cs
- ScriptResourceAttribute.cs
- BasicHttpBinding.cs
- TraceUtility.cs
- ListBindingHelper.cs
- EntityViewGenerator.cs
- ExtensionQuery.cs
- DataServiceQueryException.cs
- HttpConfigurationSystem.cs
- ManipulationDelta.cs
- IssuanceTokenProviderBase.cs
- ContractCodeDomInfo.cs
- Style.cs
- DatagridviewDisplayedBandsData.cs
- ClientReliableChannelBinder.cs
- TextEditorCharacters.cs
- Nullable.cs
- ItemPager.cs
- XmlArrayItemAttributes.cs
- StrongNameKeyPair.cs
- TextFragmentEngine.cs
- PasswordDeriveBytes.cs
- ActivityInterfaces.cs
- ResXResourceSet.cs
- IndentTextWriter.cs
- LineBreakRecord.cs
- ImageKeyConverter.cs
- WindowsSpinner.cs
- ProcessManager.cs
- EditorBrowsableAttribute.cs
- GridItem.cs
- SecuritySessionClientSettings.cs
- AbstractSvcMapFileLoader.cs
- TreeView.cs
- SqlClientWrapperSmiStreamChars.cs
- Keyboard.cs
- KeyToListMap.cs
- WmlObjectListAdapter.cs
- DataGridViewColumnStateChangedEventArgs.cs
- CodeParameterDeclarationExpression.cs
- FixedFindEngine.cs
- GrammarBuilderPhrase.cs
- SqlClientWrapperSmiStreamChars.cs
- ConsumerConnectionPointCollection.cs
- IMembershipProvider.cs
- RtfToken.cs
- DatePicker.cs
- ReversePositionQuery.cs
- EncryptedType.cs
- XPathMultyIterator.cs
- ActivityMetadata.cs
- XamlDesignerSerializationManager.cs
- KernelTypeValidation.cs
- WaitingCursor.cs
- QueryAccessibilityHelpEvent.cs
- HostedTransportConfigurationManager.cs
- LoginName.cs
- DataTableTypeConverter.cs
- TraceLevelStore.cs
- hwndwrapper.cs
- WebControlAdapter.cs
- RelationshipManager.cs
- DataGridViewCellStyleConverter.cs
- OrthographicCamera.cs
- HttpAsyncResult.cs
- UnsafeNativeMethods.cs
- dbenumerator.cs
- SqlConnectionString.cs
- FontResourceCache.cs
- ColorConvertedBitmap.cs
- JsonSerializer.cs
- ProcessRequestArgs.cs
- BamlReader.cs
- PathSegmentCollection.cs
- ConfigurationHelpers.cs
- DesignerOptionService.cs
- QilTargetType.cs
- EventBuilder.cs
- KeyNotFoundException.cs
- MessageContractMemberAttribute.cs
- TreeNodeCollection.cs
- CodeIterationStatement.cs
- TrustLevelCollection.cs
- MissingSatelliteAssemblyException.cs
- MasterPage.cs
- Choices.cs
- Rotation3DKeyFrameCollection.cs
- documentsequencetextcontainer.cs