QueryStack.cs 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764
  1. //------------------------------------------------------------
  2. // Copyright (c) Microsoft Corporation. All rights reserved.
  3. //------------------------------------------------------------
  4. namespace System.ServiceModel.Dispatcher
  5. {
  6. using System;
  7. using System.Runtime;
  8. internal struct StackFrame
  9. {
  10. internal int basePtr;
  11. internal int endPtr;
  12. #if NO
  13. internal StackFrame(int basePtr)
  14. {
  15. Fx.Assert(basePtr >= 0, "");
  16. this.basePtr = basePtr;
  17. this.endPtr = this.basePtr - 1;
  18. }
  19. internal StackFrame(int basePtr, int count)
  20. {
  21. Fx.Assert(basePtr >= 0, "");
  22. this.basePtr = basePtr;
  23. this.endPtr = basePtr + count - 1;
  24. }
  25. #endif
  26. internal int Count
  27. {
  28. get
  29. {
  30. return this.endPtr - this.basePtr + 1;
  31. }
  32. }
  33. internal int EndPtr
  34. {
  35. #if NO
  36. get
  37. {
  38. return this.endPtr;
  39. }
  40. #endif
  41. set
  42. {
  43. Fx.Assert(value >= this.basePtr, "");
  44. this.endPtr = value;
  45. }
  46. }
  47. #if NO
  48. internal void Clear()
  49. {
  50. this.endPtr = this.basePtr - 1;
  51. }
  52. #endif
  53. internal int this[int offset]
  54. {
  55. get
  56. {
  57. Fx.Assert(this.IsValidPtr(this.basePtr + offset), "");
  58. return this.basePtr + offset;
  59. }
  60. }
  61. #if NO
  62. internal void Set(int basePtr)
  63. {
  64. Fx.Assert(basePtr >= 0, "");
  65. this.basePtr = basePtr;
  66. this.endPtr = this.basePtr - 1;
  67. }
  68. #endif
  69. internal bool IsValidPtr(int ptr)
  70. {
  71. return (ptr >= this.basePtr && ptr <= this.endPtr);
  72. }
  73. }
  74. internal struct StackRegion
  75. {
  76. internal QueryRange bounds;
  77. internal int stackPtr;
  78. internal StackRegion(QueryRange bounds)
  79. {
  80. this.bounds = bounds;
  81. this.stackPtr = bounds.start - 1;
  82. }
  83. #if NO
  84. internal StackRegion(QueryRange bounds, int stackPtr)
  85. {
  86. Fx.Assert(bounds.IsInRange(stackPtr), "");
  87. this.bounds = bounds;
  88. this.stackPtr = stackPtr;
  89. }
  90. #endif
  91. internal int Count
  92. {
  93. get
  94. {
  95. return this.stackPtr - this.bounds.start + 1;
  96. }
  97. }
  98. #if NO
  99. internal bool IsReady
  100. {
  101. get
  102. {
  103. return this.bounds.IsNotEmpty;
  104. }
  105. }
  106. #endif
  107. internal bool NeedsGrowth
  108. {
  109. get
  110. {
  111. return (this.stackPtr > this.bounds.end);
  112. }
  113. }
  114. internal void Clear()
  115. {
  116. this.stackPtr = this.bounds.start - 1;
  117. }
  118. internal void Grow(int growBy)
  119. {
  120. this.bounds.end += growBy;
  121. }
  122. internal bool IsValidStackPtr()
  123. {
  124. return this.bounds.IsInRange(this.stackPtr);
  125. }
  126. internal bool IsValidStackPtr(int stackPtr)
  127. {
  128. return this.bounds.IsInRange(stackPtr);
  129. }
  130. #if NO
  131. internal void Set(int start, int end)
  132. {
  133. this.bounds.Set(start, end);
  134. this.stackPtr += start;
  135. }
  136. #endif
  137. internal void Shift(int shiftBy)
  138. {
  139. this.bounds.Shift(shiftBy);
  140. this.stackPtr += shiftBy;
  141. }
  142. }
  143. // The eval stack as well as all its contained data structures are STRUCTs
  144. // fast to allocate
  145. internal struct EvalStack
  146. {
  147. internal QueryBuffer<Value> buffer;
  148. internal StackRegion frames;
  149. internal StackRegion stack;
  150. internal const int DefaultSize = 2;
  151. internal bool contextOnTopOfStack;
  152. internal EvalStack(int frameCapacity, int stackCapacity)
  153. {
  154. Fx.Assert(frameCapacity >= 0 && stackCapacity >= 0, "");
  155. // All structs! Cost of allocation is relatively mild...
  156. this.buffer = new QueryBuffer<Value>(frameCapacity + stackCapacity);
  157. this.stack = new StackRegion(new QueryRange(0, stackCapacity - 1));
  158. this.buffer.Reserve(stackCapacity);
  159. this.frames = new StackRegion(new QueryRange(stackCapacity, stackCapacity + frameCapacity - 1));
  160. this.buffer.Reserve(frameCapacity);
  161. this.contextOnTopOfStack = false;
  162. }
  163. #if NO
  164. internal EvalStack(ref EvalStack stack)
  165. {
  166. this.buffer = new QueryBuffer<Value>(stack.buffer);
  167. this.stackCapacity = stack.stackCapacity;
  168. this.frameCapacity = stack.frameCapacity;
  169. this.stack = stack.stack;
  170. this.frames = stack.frames;
  171. }
  172. #endif
  173. internal Value[] Buffer
  174. {
  175. get
  176. {
  177. return this.buffer.buffer;
  178. }
  179. }
  180. #if NO
  181. internal int FrameCount
  182. {
  183. get
  184. {
  185. return this.frames.Count;
  186. }
  187. }
  188. internal int FramePtr
  189. {
  190. get
  191. {
  192. return this.frames.stackPtr;
  193. }
  194. }
  195. #endif
  196. internal StackFrame this[int frameIndex]
  197. {
  198. get
  199. {
  200. return this.buffer.buffer[this.frames.stackPtr - frameIndex].Frame;
  201. }
  202. }
  203. #if NO
  204. internal bool IsReady
  205. {
  206. get
  207. {
  208. return (this.buffer.count > 0);
  209. }
  210. }
  211. #endif
  212. internal StackFrame SecondArg
  213. {
  214. get
  215. {
  216. return this[1];
  217. }
  218. }
  219. #if NO
  220. internal int StackPtr
  221. {
  222. get
  223. {
  224. return this.stack.stackPtr;
  225. }
  226. }
  227. #endif
  228. internal StackFrame TopArg
  229. {
  230. get
  231. {
  232. return this[0];
  233. }
  234. }
  235. internal void Clear()
  236. {
  237. this.stack.Clear();
  238. this.frames.Clear();
  239. this.contextOnTopOfStack = false;
  240. }
  241. internal void CopyFrom(ref EvalStack stack)
  242. {
  243. this.buffer.CopyFrom(ref stack.buffer);
  244. this.frames = stack.frames;
  245. this.stack = stack.stack;
  246. this.contextOnTopOfStack = stack.contextOnTopOfStack;
  247. }
  248. internal int CalculateNodecount()
  249. {
  250. if (this.stack.stackPtr < 0)
  251. {
  252. return 0;
  253. }
  254. StackFrame topFrame = this.TopArg;
  255. int count = 0;
  256. for (int i = topFrame.basePtr; i <= topFrame.endPtr; ++i)
  257. {
  258. Fx.Assert(this.buffer[i].IsType(ValueDataType.Sequence), "");
  259. count += this.buffer[i].NodeCount;
  260. }
  261. return count;
  262. }
  263. #if NO
  264. internal void Erase()
  265. {
  266. this.buffer.Erase();
  267. }
  268. #endif
  269. void GrowFrames()
  270. {
  271. int growBy = this.frames.Count;
  272. this.buffer.ReserveAt(this.frames.bounds.end + 1, growBy);
  273. this.frames.Grow(growBy);
  274. }
  275. void GrowStack(int growthNeeded)
  276. {
  277. int growBy = this.stack.bounds.Count;
  278. if (growthNeeded > growBy)
  279. {
  280. growBy = growthNeeded;
  281. }
  282. this.buffer.ReserveAt(this.stack.bounds.end + 1, growBy);
  283. this.stack.Grow(growBy);
  284. this.frames.Shift(growBy);
  285. }
  286. #if NO
  287. internal void Init()
  288. {
  289. this.buffer.Reserve(this.stackCapacity);
  290. this.stack.Set(0, stackCapacity - 1);
  291. this.buffer.Reserve(this.frameCapacity);
  292. this.frames.Set(stackCapacity, stackCapacity + frameCapacity - 1);
  293. }
  294. internal void Init(Value[] buffer, int stackCapacity, int frameCapacity)
  295. {
  296. Fx.Assert(null != buffer, "");
  297. this.stackCapacity = stackCapacity;
  298. this.frameCapacity = frameCapacity;
  299. this.buffer = new QueryBuffer<Value>(buffer);
  300. this.stack = new StackRegion(new QueryRange(0, stackCapacity - 1));
  301. this.buffer.Reserve(stackCapacity);
  302. this.frames = new StackRegion(new QueryRange(stackCapacity, stackCapacity + frameCapacity - 1));
  303. this.buffer.Reserve(frameCapacity);
  304. }
  305. #endif
  306. internal bool InUse
  307. {
  308. get
  309. {
  310. if (contextOnTopOfStack)
  311. return (this.frames.Count > 1);
  312. else
  313. return (this.frames.Count > 0);
  314. }
  315. }
  316. internal bool PeekBoolean(int index)
  317. {
  318. Fx.Assert(this.stack.IsValidStackPtr(index), "");
  319. return this.buffer.buffer[index].GetBoolean();
  320. }
  321. internal double PeekDouble(int index)
  322. {
  323. Fx.Assert(this.stack.IsValidStackPtr(index), "");
  324. return this.buffer.buffer[index].GetDouble();
  325. }
  326. #if NO
  327. internal int PeekInteger(int index)
  328. {
  329. Fx.Assert(this.stack.IsValidStackPtr(index), "");
  330. return (int)this.buffer.buffer[index].GetDouble();
  331. }
  332. #endif
  333. internal NodeSequence PeekSequence(int index)
  334. {
  335. Fx.Assert(this.stack.IsValidStackPtr(index), "");
  336. return this.buffer.buffer[index].GetSequence();
  337. }
  338. internal string PeekString(int index)
  339. {
  340. Fx.Assert(this.stack.IsValidStackPtr(index), "");
  341. return this.buffer.buffer[index].GetString();
  342. }
  343. #if NO
  344. internal void Pop()
  345. {
  346. this.stack.stackPtr--;
  347. Fx.Assert(this.stack.IsValidStackPtr(), "");
  348. this.buffer.buffer[this.frames.stackPtr].FrameEndPtr = this.stack.stackPtr;
  349. }
  350. internal void PopFrame()
  351. {
  352. Fx.Assert(this.frames.IsValidStackPtr(), "");
  353. this.stack.stackPtr = this.buffer.buffer[this.frames.stackPtr].StackPtr;
  354. this.frames.stackPtr--;
  355. }
  356. #endif
  357. internal void PopFrame(ProcessingContext context)
  358. {
  359. Fx.Assert(this.frames.IsValidStackPtr(), "");
  360. StackFrame topArg = this.TopArg;
  361. for (int i = topArg.basePtr; i <= topArg.endPtr; ++i)
  362. {
  363. this.buffer.buffer[i].Clear(context);
  364. }
  365. this.stack.stackPtr = topArg.basePtr - 1;
  366. this.frames.stackPtr--;
  367. }
  368. internal void PushFrame()
  369. {
  370. this.frames.stackPtr++;
  371. if (this.frames.NeedsGrowth)
  372. {
  373. this.GrowFrames();
  374. }
  375. //
  376. // The first element in the new frame will be the NEXT item pushed onto the stack
  377. // We save offsets because stacks may get moved and repositioned
  378. //
  379. this.buffer.buffer[this.frames.stackPtr].StartFrame(this.stack.stackPtr);
  380. }
  381. internal void PopSequenceFrameTo(ref EvalStack dest)
  382. {
  383. StackFrame topFrame = this.TopArg;
  384. dest.PushFrame();
  385. int argCount = topFrame.Count;
  386. switch (argCount)
  387. {
  388. default:
  389. dest.Push(this.buffer.buffer, topFrame.basePtr, argCount);
  390. break;
  391. case 0:
  392. break;
  393. case 1:
  394. dest.Push(this.buffer.buffer[topFrame.basePtr].Sequence);
  395. break;
  396. }
  397. // Pop original fame
  398. this.stack.stackPtr = topFrame.basePtr - 1;
  399. this.frames.stackPtr--;
  400. }
  401. #if NO
  402. internal void Push()
  403. {
  404. this.stack.stackPtr++;
  405. if (this.stack.NeedsGrowth)
  406. {
  407. this.GrowStack(1);
  408. }
  409. this.buffer.buffer[this.frames.stackPtr].FrameEndPtr = this.stack.stackPtr;
  410. }
  411. internal void Push(int count)
  412. {
  413. this.stack.stackPtr += count;
  414. if (this.stack.NeedsGrowth)
  415. {
  416. this.GrowStack(count);
  417. }
  418. this.buffer.buffer[this.frames.stackPtr].FrameEndPtr = this.stack.stackPtr;
  419. }
  420. #endif
  421. internal void Push(string val)
  422. {
  423. this.stack.stackPtr++;
  424. if (this.stack.NeedsGrowth)
  425. {
  426. this.GrowStack(1);
  427. }
  428. this.buffer.buffer[this.stack.stackPtr].String = val;
  429. this.buffer.buffer[this.frames.stackPtr].FrameEndPtr = this.stack.stackPtr;
  430. }
  431. internal void Push(string val, int addCount)
  432. {
  433. int stackPtr = this.stack.stackPtr;
  434. this.stack.stackPtr += addCount;
  435. if (this.stack.NeedsGrowth)
  436. {
  437. this.GrowStack(addCount);
  438. }
  439. int stackMax = stackPtr + addCount;
  440. while (stackPtr < stackMax)
  441. {
  442. this.buffer.buffer[++stackPtr].String = val;
  443. }
  444. this.buffer.buffer[this.frames.stackPtr].FrameEndPtr = this.stack.stackPtr;
  445. }
  446. internal void Push(bool val)
  447. {
  448. this.stack.stackPtr++;
  449. if (this.stack.NeedsGrowth)
  450. {
  451. this.GrowStack(1);
  452. }
  453. this.buffer.buffer[this.stack.stackPtr].Boolean = val;
  454. this.buffer.buffer[this.frames.stackPtr].FrameEndPtr = this.stack.stackPtr;
  455. }
  456. internal void Push(bool val, int addCount)
  457. {
  458. int stackPtr = this.stack.stackPtr;
  459. this.stack.stackPtr += addCount;
  460. if (this.stack.NeedsGrowth)
  461. {
  462. this.GrowStack(addCount);
  463. }
  464. int stackMax = stackPtr + addCount;
  465. while (stackPtr < stackMax)
  466. {
  467. this.buffer.buffer[++stackPtr].Boolean = val;
  468. }
  469. this.buffer.buffer[this.frames.stackPtr].FrameEndPtr = this.stack.stackPtr;
  470. }
  471. internal void Push(double val)
  472. {
  473. this.stack.stackPtr++;
  474. if (this.stack.NeedsGrowth)
  475. {
  476. this.GrowStack(1);
  477. }
  478. this.buffer.buffer[this.stack.stackPtr].Double = val;
  479. this.buffer.buffer[this.frames.stackPtr].FrameEndPtr = this.stack.stackPtr;
  480. }
  481. internal void Push(double val, int addCount)
  482. {
  483. int stackPtr = this.stack.stackPtr;
  484. this.stack.stackPtr += addCount;
  485. if (this.stack.NeedsGrowth)
  486. {
  487. this.GrowStack(addCount);
  488. }
  489. int stackMax = stackPtr + addCount;
  490. while (stackPtr < stackMax)
  491. {
  492. this.buffer.buffer[++stackPtr].Double = val;
  493. }
  494. this.buffer.buffer[this.frames.stackPtr].FrameEndPtr = this.stack.stackPtr;
  495. }
  496. internal void Push(NodeSequence val)
  497. {
  498. this.stack.stackPtr++;
  499. if (this.stack.NeedsGrowth)
  500. {
  501. this.GrowStack(1);
  502. }
  503. this.buffer.buffer[this.stack.stackPtr].Sequence = val;
  504. this.buffer.buffer[this.frames.stackPtr].FrameEndPtr = this.stack.stackPtr;
  505. }
  506. internal void Push(NodeSequence val, int addCount)
  507. {
  508. // One of the addCount refs was added by the call to CreateSequence
  509. val.refCount += addCount - 1;
  510. int stackPtr = this.stack.stackPtr;
  511. this.stack.stackPtr += addCount;
  512. if (this.stack.NeedsGrowth)
  513. {
  514. this.GrowStack(addCount);
  515. }
  516. int stackMax = stackPtr + addCount;
  517. while (stackPtr < stackMax)
  518. {
  519. this.buffer.buffer[++stackPtr].Sequence = val;
  520. }
  521. this.buffer.buffer[this.frames.stackPtr].FrameEndPtr = this.stack.stackPtr;
  522. }
  523. internal void Push(Value[] buffer, int startAt, int addCount)
  524. {
  525. if (addCount > 0)
  526. {
  527. int stackPtr = this.stack.stackPtr + 1;
  528. this.stack.stackPtr += addCount;
  529. if (this.stack.NeedsGrowth)
  530. {
  531. this.GrowStack(addCount);
  532. }
  533. if (1 == addCount)
  534. {
  535. this.buffer.buffer[stackPtr] = buffer[startAt];
  536. }
  537. else
  538. {
  539. Array.Copy(buffer, startAt, this.buffer.buffer, stackPtr, addCount);
  540. }
  541. this.buffer.buffer[this.frames.stackPtr].FrameEndPtr = this.stack.stackPtr;
  542. }
  543. }
  544. #if NO
  545. internal void Push(ref EvalStack source)
  546. {
  547. this.Push(source.buffer.buffer, source.stack.bounds.start, source.frames.bounds.end + 1);
  548. }
  549. #endif
  550. internal void ReplaceAt(int index, NodeSequence seq)
  551. {
  552. Fx.Assert(this.stack.IsValidStackPtr(index) && this.buffer.buffer[index].IsType(ValueDataType.Sequence), "");
  553. this.buffer.buffer[index].Sequence = seq;
  554. }
  555. internal void SetValue(ProcessingContext context, int index, bool val)
  556. {
  557. Fx.Assert(this.stack.IsValidStackPtr(index), "");
  558. this.buffer.buffer[index].Update(context, val);
  559. }
  560. internal void SetValue(ProcessingContext context, int index, double val)
  561. {
  562. Fx.Assert(this.stack.IsValidStackPtr(index), "");
  563. this.buffer.buffer[index].Update(context, val);
  564. }
  565. internal void SetValue(ProcessingContext context, int index, string val)
  566. {
  567. Fx.Assert(this.stack.IsValidStackPtr(index), "");
  568. this.buffer.buffer[index].Update(context, val);
  569. }
  570. internal void SetValue(ProcessingContext context, int index, NodeSequence val)
  571. {
  572. Fx.Assert(this.stack.IsValidStackPtr(index), "");
  573. this.buffer.buffer[index].Update(context, val);
  574. }
  575. internal void TransferPositionsTo(ref EvalStack stack)
  576. {
  577. StackFrame arg = this.TopArg;
  578. stack.PushFrame();
  579. for (int i = arg.basePtr; i <= arg.endPtr; ++i)
  580. {
  581. NodeSequence seq = this.buffer.buffer[i].Sequence;
  582. int nodeCount = seq.Count;
  583. if ((this.stack.stackPtr + nodeCount) > this.stack.bounds.end)
  584. {
  585. this.GrowStack(nodeCount);
  586. }
  587. for (int n = 0; n < nodeCount; ++n)
  588. {
  589. stack.Push((double)seq.Items[n].Position);
  590. }
  591. }
  592. }
  593. internal void TransferSequenceSizeTo(ref EvalStack stack)
  594. {
  595. StackFrame arg = this.TopArg;
  596. stack.PushFrame();
  597. for (int i = arg.basePtr; i <= arg.endPtr; ++i)
  598. {
  599. NodeSequence seq = this.buffer.buffer[i].Sequence;
  600. int nodeCount = seq.Count;
  601. if ((this.stack.stackPtr + nodeCount) > this.stack.bounds.end)
  602. {
  603. this.GrowStack(nodeCount);
  604. }
  605. for (int n = 0; n < nodeCount; ++n)
  606. {
  607. stack.Push((double)NodeSequence.GetContextSize(seq, n));
  608. }
  609. }
  610. }
  611. #if NO
  612. internal void Trim()
  613. {
  614. this.buffer.TrimToCount();
  615. }
  616. #endif
  617. }
  618. #if NO
  619. internal struct BoundedStack<T>
  620. {
  621. QueryBuffer<T> buffer;
  622. int maxSize;
  623. internal BoundedStack(int capacity)
  624. {
  625. this.buffer = new QueryBuffer<T>(0);
  626. this.maxSize = capacity;
  627. }
  628. internal bool HasItems
  629. {
  630. get
  631. {
  632. return (this.buffer.count > 0);
  633. }
  634. }
  635. internal bool HasSpace
  636. {
  637. get
  638. {
  639. return (this.buffer.count < this.maxSize);
  640. }
  641. }
  642. internal int MaxSize
  643. {
  644. get
  645. {
  646. return this.maxSize;
  647. }
  648. set
  649. {
  650. Fx.Assert(value >= 0, "");
  651. this.maxSize = value;
  652. if (value < this.buffer.count)
  653. {
  654. this.buffer.count = value;
  655. this.buffer.TrimToCount();
  656. }
  657. }
  658. }
  659. internal T Pop()
  660. {
  661. return this.buffer.Pop();
  662. }
  663. internal void Push(T t)
  664. {
  665. if (this.buffer.count == this.maxSize)
  666. {
  667. return;
  668. }
  669. this.buffer.Push(t);
  670. }
  671. internal void Trim()
  672. {
  673. this.buffer.TrimToCount();
  674. }
  675. }
  676. #endif
  677. }