Code:
/ WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / WCF / ServiceModel / System / ServiceModel / Dispatcher / QuerySetOp.cs / 1 / QuerySetOp.cs
//------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------- namespace System.ServiceModel.Dispatcher { using System.Collections; using System.Diagnostics; internal class OrdinalOpcode : Opcode { internal OrdinalOpcode() : base(OpcodeID.Ordinal) { } internal override Opcode Eval(ProcessingContext context) { StackFrame sequences = context.TopSequenceArg; StackFrame ordinals = context.TopArg; Value[] sequenceBuffer = context.Sequences; for (int seqIndex = sequences.basePtr, ordinalIndex = ordinals.basePtr; seqIndex <= sequences.endPtr; ++seqIndex) { NodeSequence sequence = sequenceBuffer[seqIndex].Sequence; for (int item = 0; item < sequence.Count; ++item) { context.Values[ordinalIndex].Boolean = (sequence[item].Position == context.Values[ordinalIndex].Double); ordinalIndex++; } } return this.next; } } internal class LiteralOrdinalOpcode : Opcode { int ordinal; // 1 based internal LiteralOrdinalOpcode(int ordinal) : base(OpcodeID.LiteralOrdinal) { DiagnosticUtility.DebugAssert(ordinal > 0, ""); this.ordinal = ordinal; } #if NO // Never used for inverse query, so don't need this internal override bool Equals(Opcode op) { if (base.Equals (op)) { return (this.ordinal == ((LiteralOrdinalOpcode) op).ordinal); } return false; } #endif internal override Opcode Eval(ProcessingContext context) { StackFrame sequences = context.TopSequenceArg; Value[] sequenceBuffer = context.Sequences; context.PushFrame(); for (int i = sequences.basePtr; i <= sequences.endPtr; ++i) { NodeSequence sequence = sequenceBuffer[i].Sequence; for (int item = 0; item < sequence.Count; ++item) { context.Push(sequence[item].Position == this.ordinal); } } return this.next; } #if DEBUG_FILTER public override string ToString() { return string.Format("{0} {1}", base.ToString(), this.ordinal); } #endif } // Filters context sequences using the results of the last executed predicate // Does pop result values internal class ApplyFilterOpcode : Opcode { internal ApplyFilterOpcode() : base(OpcodeID.Filter) { } internal override Opcode Eval(ProcessingContext context) { StackFrame sequences = context.TopSequenceArg; StackFrame results = context.TopArg; NodeSequenceBuilder sequenceBuilder = new NodeSequenceBuilder(context); Value[] sequenceBuffer = context.Sequences; for (int seqIndex = sequences.basePtr, resultIndex = results.basePtr; seqIndex <= sequences.endPtr; ++seqIndex) { NodeSequence sourceSequence = sequenceBuffer[seqIndex].Sequence; if (sourceSequence.Count > 0) { NodesetIterator nodesetIterator = new NodesetIterator(sourceSequence); while (nodesetIterator.NextNodeset()) { sequenceBuilder.StartNodeset(); while (nodesetIterator.NextItem()) { DiagnosticUtility.DebugAssert(context.Values[resultIndex].IsType(ValueDataType.Boolean), ""); if (context.Values[resultIndex].Boolean) { sequenceBuilder.Add(ref sourceSequence.Items[nodesetIterator.Index]); } ++resultIndex; } sequenceBuilder.EndNodeset(); } context.ReplaceSequenceAt(seqIndex, sequenceBuilder.Sequence); context.ReleaseSequence(sourceSequence); sequenceBuilder.Sequence = null; } } context.PopFrame(); return this.next; } } ////// Union the sequences found in the top two frames of the value stack /// The unionized sequence /// internal class UnionOpcode : Opcode { internal UnionOpcode() : base(OpcodeID.Union) { } internal override Opcode Eval(ProcessingContext context) { StackFrame topArg = context.TopArg; StackFrame secondArg = context.SecondArg; DiagnosticUtility.DebugAssert(topArg.Count == secondArg.Count, ""); for (int x = topArg.basePtr, y = secondArg.basePtr; x <= topArg.endPtr; ++x, ++y) { NodeSequence seqX = context.Values[x].Sequence; NodeSequence seqY = context.Values[y].Sequence; // Replace with a new sequence that is the union of the two context.SetValue(context, y, seqY.Union(context, seqX)); } context.PopFrame(); return this.next; } } internal class MergeOpcode : Opcode { internal MergeOpcode() : base(OpcodeID.Merge) { } internal override Opcode Eval(ProcessingContext context) { Value[] values = context.Values; StackFrame arg = context.TopArg; for (int i = arg.basePtr; i <= arg.endPtr; ++i) { DiagnosticUtility.DebugAssert(ValueDataType.Sequence == values[i].Type, ""); NodeSequence seq = values[i].Sequence; NodeSequence newSeq = context.CreateSequence(); for(int j = 0; j < seq.Count; ++j) { NodeSequenceItem item = seq[j]; newSeq.AddCopy(ref item); } newSeq.Merge(); context.SetValue(context, i, newSeq); } return this.next; } } } // 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
- DefaultPropertiesToSend.cs
- TreeNode.cs
- QueryableDataSourceEditData.cs
- ObjectQuery.cs
- HtmlContainerControl.cs
- HostingPreferredMapPath.cs
- CharacterString.cs
- StringValueSerializer.cs
- CriticalHandle.cs
- QueryReaderSettings.cs
- WorkflowInstance.cs
- SafeThemeHandle.cs
- IgnoreDataMemberAttribute.cs
- DataGridToolTip.cs
- TreeView.cs
- ISO2022Encoding.cs
- ReadOnlyDictionary.cs
- SqlProcedureAttribute.cs
- CredentialCache.cs
- HtmlTitle.cs
- HierarchicalDataBoundControlAdapter.cs
- MouseEventArgs.cs
- future.cs
- SessionState.cs
- RichTextBox.cs
- CustomErrorsSectionWrapper.cs
- FillBehavior.cs
- Soap12ServerProtocol.cs
- PageStatePersister.cs
- FileDialog_Vista_Interop.cs
- TextViewSelectionProcessor.cs
- DocumentXmlWriter.cs
- XPathParser.cs
- TextEncodedRawTextWriter.cs
- XmlNamespaceMappingCollection.cs
- wgx_render.cs
- HtmlInputRadioButton.cs
- LinkDescriptor.cs
- EncodingConverter.cs
- CodeTypeDelegate.cs
- CancelEventArgs.cs
- SchemaSetCompiler.cs
- SafeNativeMethods.cs
- SqlServices.cs
- SupportsPreviewControlAttribute.cs
- SQLSingleStorage.cs
- SspiNegotiationTokenAuthenticator.cs
- ListControlDataBindingHandler.cs
- ResolveCompletedEventArgs.cs
- SqlDataRecord.cs
- CodeRegionDirective.cs
- XmlText.cs
- CollectionViewGroupRoot.cs
- ObjectPersistData.cs
- SqlMethodTransformer.cs
- SecurityPermission.cs
- DataAdapter.cs
- EdmType.cs
- StringPropertyBuilder.cs
- PathFigureCollection.cs
- WebPartActionVerb.cs
- ChannelSinkStacks.cs
- Viewport3DAutomationPeer.cs
- ReadWriteObjectLock.cs
- TextTreeText.cs
- TextRenderingModeValidation.cs
- ListViewTableRow.cs
- Page.cs
- FontWeights.cs
- EntitySqlQueryState.cs
- DataObjectEventArgs.cs
- PointLightBase.cs
- MissingSatelliteAssemblyException.cs
- TdsParserHelperClasses.cs
- ListControlDesigner.cs
- SessionKeyExpiredException.cs
- XmlSchemaSimpleTypeRestriction.cs
- OutputCacheSettings.cs
- DiagnosticTraceSchemas.cs
- DependencyPropertyValueSerializer.cs
- PointCollectionConverter.cs
- CreateUserWizardStep.cs
- Color.cs
- DecoderFallbackWithFailureFlag.cs
- BooleanAnimationBase.cs
- DataServiceProviderMethods.cs
- TreeView.cs
- SplitterDesigner.cs
- ByteStreamBufferedMessageData.cs
- AstTree.cs
- ScaleTransform.cs
- DefaultBinder.cs
- CodeTypeDeclarationCollection.cs
- OuterGlowBitmapEffect.cs
- PolicyStatement.cs
- SqlRemoveConstantOrderBy.cs
- CreateUserWizardStep.cs
- EditorPartChrome.cs
- CompilerError.cs
- ParenthesizePropertyNameAttribute.cs