fork-context.js 7.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248
  1. /**
  2. * @fileoverview A class to operate forking.
  3. *
  4. * This is state of forking.
  5. * This has a fork list and manages it.
  6. *
  7. * @author Toru Nagashima
  8. */
  9. "use strict";
  10. //------------------------------------------------------------------------------
  11. // Requirements
  12. //------------------------------------------------------------------------------
  13. const assert = require("assert"),
  14. CodePathSegment = require("./code-path-segment");
  15. //------------------------------------------------------------------------------
  16. // Helpers
  17. //------------------------------------------------------------------------------
  18. /**
  19. * Gets whether or not a given segment is reachable.
  20. * @param {CodePathSegment} segment A segment to get.
  21. * @returns {boolean} `true` if the segment is reachable.
  22. */
  23. function isReachable(segment) {
  24. return segment.reachable;
  25. }
  26. /**
  27. * Creates new segments from the specific range of `context.segmentsList`.
  28. *
  29. * When `context.segmentsList` is `[[a, b], [c, d], [e, f]]`, `begin` is `0`, and
  30. * `end` is `-1`, this creates `[g, h]`. This `g` is from `a`, `c`, and `e`.
  31. * This `h` is from `b`, `d`, and `f`.
  32. * @param {ForkContext} context An instance.
  33. * @param {number} begin The first index of the previous segments.
  34. * @param {number} end The last index of the previous segments.
  35. * @param {Function} create A factory function of new segments.
  36. * @returns {CodePathSegment[]} New segments.
  37. */
  38. function makeSegments(context, begin, end, create) {
  39. const list = context.segmentsList;
  40. const normalizedBegin = begin >= 0 ? begin : list.length + begin;
  41. const normalizedEnd = end >= 0 ? end : list.length + end;
  42. const segments = [];
  43. for (let i = 0; i < context.count; ++i) {
  44. const allPrevSegments = [];
  45. for (let j = normalizedBegin; j <= normalizedEnd; ++j) {
  46. allPrevSegments.push(list[j][i]);
  47. }
  48. segments.push(create(context.idGenerator.next(), allPrevSegments));
  49. }
  50. return segments;
  51. }
  52. /**
  53. * `segments` becomes doubly in a `finally` block. Then if a code path exits by a
  54. * control statement (such as `break`, `continue`) from the `finally` block, the
  55. * destination's segments may be half of the source segments. In that case, this
  56. * merges segments.
  57. * @param {ForkContext} context An instance.
  58. * @param {CodePathSegment[]} segments Segments to merge.
  59. * @returns {CodePathSegment[]} The merged segments.
  60. */
  61. function mergeExtraSegments(context, segments) {
  62. let currentSegments = segments;
  63. while (currentSegments.length > context.count) {
  64. const merged = [];
  65. for (let i = 0, length = currentSegments.length / 2 | 0; i < length; ++i) {
  66. merged.push(CodePathSegment.newNext(
  67. context.idGenerator.next(),
  68. [currentSegments[i], currentSegments[i + length]]
  69. ));
  70. }
  71. currentSegments = merged;
  72. }
  73. return currentSegments;
  74. }
  75. //------------------------------------------------------------------------------
  76. // Public Interface
  77. //------------------------------------------------------------------------------
  78. /**
  79. * A class to manage forking.
  80. */
  81. class ForkContext {
  82. /**
  83. * @param {IdGenerator} idGenerator An identifier generator for segments.
  84. * @param {ForkContext|null} upper An upper fork context.
  85. * @param {number} count A number of parallel segments.
  86. */
  87. constructor(idGenerator, upper, count) {
  88. this.idGenerator = idGenerator;
  89. this.upper = upper;
  90. this.count = count;
  91. this.segmentsList = [];
  92. }
  93. /**
  94. * The head segments.
  95. * @type {CodePathSegment[]}
  96. */
  97. get head() {
  98. const list = this.segmentsList;
  99. return list.length === 0 ? [] : list[list.length - 1];
  100. }
  101. /**
  102. * A flag which shows empty.
  103. * @type {boolean}
  104. */
  105. get empty() {
  106. return this.segmentsList.length === 0;
  107. }
  108. /**
  109. * A flag which shows reachable.
  110. * @type {boolean}
  111. */
  112. get reachable() {
  113. const segments = this.head;
  114. return segments.length > 0 && segments.some(isReachable);
  115. }
  116. /**
  117. * Creates new segments from this context.
  118. * @param {number} begin The first index of previous segments.
  119. * @param {number} end The last index of previous segments.
  120. * @returns {CodePathSegment[]} New segments.
  121. */
  122. makeNext(begin, end) {
  123. return makeSegments(this, begin, end, CodePathSegment.newNext);
  124. }
  125. /**
  126. * Creates new segments from this context.
  127. * The new segments is always unreachable.
  128. * @param {number} begin The first index of previous segments.
  129. * @param {number} end The last index of previous segments.
  130. * @returns {CodePathSegment[]} New segments.
  131. */
  132. makeUnreachable(begin, end) {
  133. return makeSegments(this, begin, end, CodePathSegment.newUnreachable);
  134. }
  135. /**
  136. * Creates new segments from this context.
  137. * The new segments don't have connections for previous segments.
  138. * But these inherit the reachable flag from this context.
  139. * @param {number} begin The first index of previous segments.
  140. * @param {number} end The last index of previous segments.
  141. * @returns {CodePathSegment[]} New segments.
  142. */
  143. makeDisconnected(begin, end) {
  144. return makeSegments(this, begin, end, CodePathSegment.newDisconnected);
  145. }
  146. /**
  147. * Adds segments into this context.
  148. * The added segments become the head.
  149. * @param {CodePathSegment[]} segments Segments to add.
  150. * @returns {void}
  151. */
  152. add(segments) {
  153. assert(segments.length >= this.count, `${segments.length} >= ${this.count}`);
  154. this.segmentsList.push(mergeExtraSegments(this, segments));
  155. }
  156. /**
  157. * Replaces the head segments with given segments.
  158. * The current head segments are removed.
  159. * @param {CodePathSegment[]} segments Segments to add.
  160. * @returns {void}
  161. */
  162. replaceHead(segments) {
  163. assert(segments.length >= this.count, `${segments.length} >= ${this.count}`);
  164. this.segmentsList.splice(-1, 1, mergeExtraSegments(this, segments));
  165. }
  166. /**
  167. * Adds all segments of a given fork context into this context.
  168. * @param {ForkContext} context A fork context to add.
  169. * @returns {void}
  170. */
  171. addAll(context) {
  172. assert(context.count === this.count);
  173. const source = context.segmentsList;
  174. for (let i = 0; i < source.length; ++i) {
  175. this.segmentsList.push(source[i]);
  176. }
  177. }
  178. /**
  179. * Clears all segments in this context.
  180. * @returns {void}
  181. */
  182. clear() {
  183. this.segmentsList = [];
  184. }
  185. /**
  186. * Creates the root fork context.
  187. * @param {IdGenerator} idGenerator An identifier generator for segments.
  188. * @returns {ForkContext} New fork context.
  189. */
  190. static newRoot(idGenerator) {
  191. const context = new ForkContext(idGenerator, null, 1);
  192. context.add([CodePathSegment.newRoot(idGenerator.next())]);
  193. return context;
  194. }
  195. /**
  196. * Creates an empty fork context preceded by a given context.
  197. * @param {ForkContext} parentContext The parent fork context.
  198. * @param {boolean} forkLeavingPath A flag which shows inside of `finally` block.
  199. * @returns {ForkContext} New fork context.
  200. */
  201. static newEmpty(parentContext, forkLeavingPath) {
  202. return new ForkContext(
  203. parentContext.idGenerator,
  204. parentContext,
  205. (forkLeavingPath ? 2 : 1) * parentContext.count
  206. );
  207. }
  208. }
  209. module.exports = ForkContext;