buildChunkGraph.js 42 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359
  1. /*
  2. MIT License http://www.opensource.org/licenses/mit-license.php
  3. Author Tobias Koppers @sokra
  4. */
  5. "use strict";
  6. const AsyncDependencyToInitialChunkError = require("./AsyncDependencyToInitialChunkError");
  7. const { connectChunkGroupParentAndChild } = require("./GraphHelpers");
  8. const ModuleGraphConnection = require("./ModuleGraphConnection");
  9. const { getEntryRuntime, mergeRuntime } = require("./util/runtime");
  10. /** @typedef {import("./AsyncDependenciesBlock")} AsyncDependenciesBlock */
  11. /** @typedef {import("./Chunk")} Chunk */
  12. /** @typedef {import("./ChunkGroup")} ChunkGroup */
  13. /** @typedef {import("./Compilation")} Compilation */
  14. /** @typedef {import("./DependenciesBlock")} DependenciesBlock */
  15. /** @typedef {import("./Dependency")} Dependency */
  16. /** @typedef {import("./Dependency").DependencyLocation} DependencyLocation */
  17. /** @typedef {import("./Entrypoint")} Entrypoint */
  18. /** @typedef {import("./Module")} Module */
  19. /** @typedef {import("./ModuleGraph")} ModuleGraph */
  20. /** @typedef {import("./ModuleGraphConnection").ConnectionState} ConnectionState */
  21. /** @typedef {import("./logging/Logger").Logger} Logger */
  22. /** @typedef {import("./util/runtime").RuntimeSpec} RuntimeSpec */
  23. /**
  24. * @typedef {object} QueueItem
  25. * @property {number} action
  26. * @property {DependenciesBlock} block
  27. * @property {Module} module
  28. * @property {Chunk} chunk
  29. * @property {ChunkGroup} chunkGroup
  30. * @property {ChunkGroupInfo} chunkGroupInfo
  31. */
  32. /**
  33. * @typedef {object} ChunkGroupInfo
  34. * @property {ChunkGroup} chunkGroup the chunk group
  35. * @property {RuntimeSpec} runtime the runtimes
  36. * @property {boolean} initialized is this chunk group initialized
  37. * @property {bigint | undefined} minAvailableModules current minimal set of modules available at this point
  38. * @property {bigint[]} availableModulesToBeMerged enqueued updates to the minimal set of available modules
  39. * @property {Set<Module>=} skippedItems modules that were skipped because module is already available in parent chunks (need to reconsider when minAvailableModules is shrinking)
  40. * @property {Set<[Module, ModuleGraphConnection[]]>=} skippedModuleConnections referenced modules that where skipped because they were not active in this runtime
  41. * @property {bigint | undefined} resultingAvailableModules set of modules available including modules from this chunk group
  42. * @property {Set<ChunkGroupInfo> | undefined} children set of children chunk groups, that will be revisited when availableModules shrink
  43. * @property {Set<ChunkGroupInfo> | undefined} availableSources set of chunk groups that are the source for minAvailableModules
  44. * @property {Set<ChunkGroupInfo> | undefined} availableChildren set of chunk groups which depend on the this chunk group as availableSource
  45. * @property {number} preOrderIndex next pre order index
  46. * @property {number} postOrderIndex next post order index
  47. * @property {boolean} chunkLoading has a chunk loading mechanism
  48. * @property {boolean} asyncChunks create async chunks
  49. */
  50. /**
  51. * @typedef {object} BlockChunkGroupConnection
  52. * @property {ChunkGroupInfo} originChunkGroupInfo origin chunk group
  53. * @property {ChunkGroup} chunkGroup referenced chunk group
  54. */
  55. /** @typedef {(Module | ConnectionState | ModuleGraphConnection)[]} BlockModulesInTuples */
  56. /** @typedef {(Module | ConnectionState | ModuleGraphConnection[])[]} BlockModulesInFlattenTuples */
  57. /** @typedef {Map<DependenciesBlock, BlockModulesInFlattenTuples>} BlockModulesMap */
  58. /** @typedef {Map<Chunk, bigint>} MaskByChunk */
  59. /** @typedef {Set<DependenciesBlock>} BlocksWithNestedBlocks */
  60. /** @typedef {Map<AsyncDependenciesBlock, BlockChunkGroupConnection[]>} BlockConnections */
  61. /** @typedef {Map<ChunkGroup, ChunkGroupInfo>} ChunkGroupInfoMap */
  62. /** @typedef {Set<ChunkGroup>} AllCreatedChunkGroups */
  63. /** @typedef {Map<Entrypoint, Module[]>} InputEntrypointsAndModules */
  64. const ZERO_BIGINT = BigInt(0);
  65. const ONE_BIGINT = BigInt(1);
  66. /**
  67. * @param {bigint} mask The mask to test
  68. * @param {number} ordinal The ordinal of the bit to test
  69. * @returns {boolean} If the ordinal-th bit is set in the mask
  70. */
  71. const isOrdinalSetInMask = (mask, ordinal) =>
  72. BigInt.asUintN(1, mask >> BigInt(ordinal)) !== ZERO_BIGINT;
  73. /**
  74. * @param {ModuleGraphConnection[]} connections list of connections
  75. * @param {RuntimeSpec} runtime for which runtime
  76. * @returns {ConnectionState} connection state
  77. */
  78. const getActiveStateOfConnections = (connections, runtime) => {
  79. let merged = connections[0].getActiveState(runtime);
  80. if (merged === true) return true;
  81. for (let i = 1; i < connections.length; i++) {
  82. const c = connections[i];
  83. merged = ModuleGraphConnection.addConnectionStates(
  84. merged,
  85. c.getActiveState(runtime)
  86. );
  87. if (merged === true) return true;
  88. }
  89. return merged;
  90. };
  91. /**
  92. * @param {Module} module module
  93. * @param {ModuleGraph} moduleGraph module graph
  94. * @param {RuntimeSpec} runtime runtime
  95. * @param {BlockModulesMap} blockModulesMap block modules map
  96. */
  97. const extractBlockModules = (module, moduleGraph, runtime, blockModulesMap) => {
  98. /** @type {DependenciesBlock | undefined} */
  99. let blockCache;
  100. /** @type {BlockModulesInTuples | undefined} */
  101. let modules;
  102. /** @type {BlockModulesInTuples[]} */
  103. const arrays = [];
  104. /** @type {DependenciesBlock[]} */
  105. const queue = [module];
  106. while (queue.length > 0) {
  107. const block = /** @type {DependenciesBlock} */ (queue.pop());
  108. /** @type {Module[]} */
  109. const arr = [];
  110. arrays.push(arr);
  111. blockModulesMap.set(block, arr);
  112. for (const b of block.blocks) {
  113. queue.push(b);
  114. }
  115. }
  116. for (const connection of moduleGraph.getOutgoingConnections(module)) {
  117. const d = connection.dependency;
  118. // We skip connections without dependency
  119. if (!d) continue;
  120. const m = connection.module;
  121. // We skip connections without Module pointer
  122. if (!m) continue;
  123. // We skip weak connections
  124. if (connection.weak) continue;
  125. const block = moduleGraph.getParentBlock(d);
  126. let index = moduleGraph.getParentBlockIndex(d);
  127. // deprecated fallback
  128. if (index < 0) {
  129. index = /** @type {DependenciesBlock} */ (block).dependencies.indexOf(d);
  130. }
  131. if (blockCache !== block) {
  132. modules =
  133. /** @type {BlockModulesInTuples} */
  134. (
  135. blockModulesMap.get(
  136. (blockCache = /** @type {DependenciesBlock} */ (block))
  137. )
  138. );
  139. }
  140. const i = index * 3;
  141. /** @type {BlockModulesInTuples} */
  142. (modules)[i] = m;
  143. /** @type {BlockModulesInTuples} */
  144. (modules)[i + 1] = connection.getActiveState(runtime);
  145. /** @type {BlockModulesInTuples} */
  146. (modules)[i + 2] = connection;
  147. }
  148. for (const modules of arrays) {
  149. if (modules.length === 0) continue;
  150. let indexMap;
  151. let length = 0;
  152. outer: for (let j = 0; j < modules.length; j += 3) {
  153. const m = modules[j];
  154. if (m === undefined) continue;
  155. const state = /** @type {ConnectionState} */ (modules[j + 1]);
  156. const connection = /** @type {ModuleGraphConnection} */ (modules[j + 2]);
  157. if (indexMap === undefined) {
  158. let i = 0;
  159. for (; i < length; i += 3) {
  160. if (modules[i] === m) {
  161. const merged = /** @type {ConnectionState} */ (modules[i + 1]);
  162. /** @type {ModuleGraphConnection[]} */
  163. (/** @type {unknown} */ (modules[i + 2])).push(connection);
  164. if (merged === true) continue outer;
  165. modules[i + 1] = ModuleGraphConnection.addConnectionStates(
  166. merged,
  167. state
  168. );
  169. continue outer;
  170. }
  171. }
  172. modules[length] = m;
  173. length++;
  174. modules[length] = state;
  175. length++;
  176. /** @type {ModuleGraphConnection[]} */
  177. (/** @type {unknown} */ (modules[length])) = [connection];
  178. length++;
  179. if (length > 30) {
  180. // To avoid worse case performance, we will use an index map for
  181. // linear cost access, which allows to maintain O(n) complexity
  182. // while keeping allocations down to a minimum
  183. indexMap = new Map();
  184. for (let i = 0; i < length; i += 3) {
  185. indexMap.set(modules[i], i + 1);
  186. }
  187. }
  188. } else {
  189. const idx = indexMap.get(m);
  190. if (idx !== undefined) {
  191. const merged = /** @type {ConnectionState} */ (modules[idx]);
  192. /** @type {ModuleGraphConnection[]} */
  193. (/** @type {unknown} */ (modules[idx + 1])).push(connection);
  194. if (merged === true) continue;
  195. modules[idx] = ModuleGraphConnection.addConnectionStates(
  196. merged,
  197. state
  198. );
  199. } else {
  200. modules[length] = m;
  201. length++;
  202. modules[length] = state;
  203. indexMap.set(m, length);
  204. length++;
  205. /** @type {ModuleGraphConnection[]} */
  206. (
  207. /** @type {unknown} */
  208. (modules[length])
  209. ) = [connection];
  210. length++;
  211. }
  212. }
  213. }
  214. modules.length = length;
  215. }
  216. };
  217. /**
  218. * @param {Logger} logger a logger
  219. * @param {Compilation} compilation the compilation
  220. * @param {InputEntrypointsAndModules} inputEntrypointsAndModules chunk groups which are processed with the modules
  221. * @param {ChunkGroupInfoMap} chunkGroupInfoMap mapping from chunk group to available modules
  222. * @param {BlockConnections} blockConnections connection for blocks
  223. * @param {BlocksWithNestedBlocks} blocksWithNestedBlocks flag for blocks that have nested blocks
  224. * @param {AllCreatedChunkGroups} allCreatedChunkGroups filled with all chunk groups that are created here
  225. * @param {MaskByChunk} maskByChunk module content mask by chunk
  226. */
  227. const visitModules = (
  228. logger,
  229. compilation,
  230. inputEntrypointsAndModules,
  231. chunkGroupInfoMap,
  232. blockConnections,
  233. blocksWithNestedBlocks,
  234. allCreatedChunkGroups,
  235. maskByChunk
  236. ) => {
  237. const { moduleGraph, chunkGraph, moduleMemCaches } = compilation;
  238. /** @type {Map<RuntimeSpec, BlockModulesMap>} */
  239. const blockModulesRuntimeMap = new Map();
  240. /** @type {BlockModulesMap | undefined} */
  241. let blockModulesMap;
  242. /** @type {Map<Module, number>} */
  243. const ordinalByModule = new Map();
  244. /**
  245. * @param {Module} module The module to look up
  246. * @returns {number} The ordinal of the module in masks
  247. */
  248. const getModuleOrdinal = module => {
  249. let ordinal = ordinalByModule.get(module);
  250. if (ordinal === undefined) {
  251. ordinal = ordinalByModule.size;
  252. ordinalByModule.set(module, ordinal);
  253. }
  254. return ordinal;
  255. };
  256. for (const chunk of compilation.chunks) {
  257. let mask = ZERO_BIGINT;
  258. for (const m of chunkGraph.getChunkModulesIterable(chunk)) {
  259. mask |= ONE_BIGINT << BigInt(getModuleOrdinal(m));
  260. }
  261. maskByChunk.set(chunk, mask);
  262. }
  263. /**
  264. * @param {DependenciesBlock} block block
  265. * @param {RuntimeSpec} runtime runtime
  266. * @returns {BlockModulesInFlattenTuples | undefined} block modules in flatten tuples
  267. */
  268. const getBlockModules = (block, runtime) => {
  269. blockModulesMap = blockModulesRuntimeMap.get(runtime);
  270. if (blockModulesMap === undefined) {
  271. /** @type {BlockModulesMap} */
  272. blockModulesMap = new Map();
  273. blockModulesRuntimeMap.set(runtime, blockModulesMap);
  274. }
  275. let blockModules = blockModulesMap.get(block);
  276. if (blockModules !== undefined) return blockModules;
  277. const module = /** @type {Module} */ (block.getRootBlock());
  278. const memCache = moduleMemCaches && moduleMemCaches.get(module);
  279. if (memCache !== undefined) {
  280. /** @type {BlockModulesMap} */
  281. const map = memCache.provide(
  282. "bundleChunkGraph.blockModules",
  283. runtime,
  284. () => {
  285. logger.time("visitModules: prepare");
  286. const map = new Map();
  287. extractBlockModules(module, moduleGraph, runtime, map);
  288. logger.timeAggregate("visitModules: prepare");
  289. return map;
  290. }
  291. );
  292. for (const [block, blockModules] of map)
  293. blockModulesMap.set(block, blockModules);
  294. return map.get(block);
  295. }
  296. logger.time("visitModules: prepare");
  297. extractBlockModules(module, moduleGraph, runtime, blockModulesMap);
  298. blockModules =
  299. /** @type {BlockModulesInFlattenTuples} */
  300. (blockModulesMap.get(block));
  301. logger.timeAggregate("visitModules: prepare");
  302. return blockModules;
  303. };
  304. let statProcessedQueueItems = 0;
  305. let statProcessedBlocks = 0;
  306. let statConnectedChunkGroups = 0;
  307. let statProcessedChunkGroupsForMerging = 0;
  308. let statMergedAvailableModuleSets = 0;
  309. const statForkedAvailableModules = 0;
  310. const statForkedAvailableModulesCount = 0;
  311. const statForkedAvailableModulesCountPlus = 0;
  312. const statForkedMergedModulesCount = 0;
  313. const statForkedMergedModulesCountPlus = 0;
  314. const statForkedResultModulesCount = 0;
  315. let statChunkGroupInfoUpdated = 0;
  316. let statChildChunkGroupsReconnected = 0;
  317. let nextChunkGroupIndex = 0;
  318. let nextFreeModulePreOrderIndex = 0;
  319. let nextFreeModulePostOrderIndex = 0;
  320. /** @type {Map<DependenciesBlock, ChunkGroupInfo>} */
  321. const blockChunkGroups = new Map();
  322. /** @type {Map<ChunkGroupInfo, Set<DependenciesBlock>>} */
  323. const blocksByChunkGroups = new Map();
  324. /** @type {Map<string, ChunkGroupInfo>} */
  325. const namedChunkGroups = new Map();
  326. /** @type {Map<string, ChunkGroupInfo>} */
  327. const namedAsyncEntrypoints = new Map();
  328. /** @type {Set<ChunkGroupInfo>} */
  329. const outdatedOrderIndexChunkGroups = new Set();
  330. const ADD_AND_ENTER_ENTRY_MODULE = 0;
  331. const ADD_AND_ENTER_MODULE = 1;
  332. const ENTER_MODULE = 2;
  333. const PROCESS_BLOCK = 3;
  334. const PROCESS_ENTRY_BLOCK = 4;
  335. const LEAVE_MODULE = 5;
  336. /** @type {QueueItem[]} */
  337. let queue = [];
  338. /** @type {Map<ChunkGroupInfo, Set<[ChunkGroupInfo, QueueItem | null]>>} */
  339. const queueConnect = new Map();
  340. /** @type {Set<ChunkGroupInfo>} */
  341. const chunkGroupsForCombining = new Set();
  342. // Fill queue with entrypoint modules
  343. // Create ChunkGroupInfo for entrypoints
  344. for (const [chunkGroup, modules] of inputEntrypointsAndModules) {
  345. const runtime = getEntryRuntime(
  346. compilation,
  347. /** @type {string} */ (chunkGroup.name),
  348. chunkGroup.options
  349. );
  350. /** @type {ChunkGroupInfo} */
  351. const chunkGroupInfo = {
  352. initialized: false,
  353. chunkGroup,
  354. runtime,
  355. minAvailableModules: undefined,
  356. availableModulesToBeMerged: [],
  357. skippedItems: undefined,
  358. resultingAvailableModules: undefined,
  359. children: undefined,
  360. availableSources: undefined,
  361. availableChildren: undefined,
  362. preOrderIndex: 0,
  363. postOrderIndex: 0,
  364. chunkLoading:
  365. chunkGroup.options.chunkLoading !== undefined
  366. ? chunkGroup.options.chunkLoading !== false
  367. : compilation.outputOptions.chunkLoading !== false,
  368. asyncChunks:
  369. chunkGroup.options.asyncChunks !== undefined
  370. ? chunkGroup.options.asyncChunks
  371. : compilation.outputOptions.asyncChunks !== false
  372. };
  373. chunkGroup.index = nextChunkGroupIndex++;
  374. if (chunkGroup.getNumberOfParents() > 0) {
  375. // minAvailableModules for child entrypoints are unknown yet, set to undefined.
  376. // This means no module is added until other sets are merged into
  377. // this minAvailableModules (by the parent entrypoints)
  378. const skippedItems = new Set(modules);
  379. chunkGroupInfo.skippedItems = skippedItems;
  380. chunkGroupsForCombining.add(chunkGroupInfo);
  381. } else {
  382. // The application may start here: We start with an empty list of available modules
  383. chunkGroupInfo.minAvailableModules = ZERO_BIGINT;
  384. const chunk = chunkGroup.getEntrypointChunk();
  385. for (const module of modules) {
  386. queue.push({
  387. action: ADD_AND_ENTER_MODULE,
  388. block: module,
  389. module,
  390. chunk,
  391. chunkGroup,
  392. chunkGroupInfo
  393. });
  394. }
  395. }
  396. chunkGroupInfoMap.set(chunkGroup, chunkGroupInfo);
  397. if (chunkGroup.name) {
  398. namedChunkGroups.set(chunkGroup.name, chunkGroupInfo);
  399. }
  400. }
  401. // Fill availableSources with parent-child dependencies between entrypoints
  402. for (const chunkGroupInfo of chunkGroupsForCombining) {
  403. const { chunkGroup } = chunkGroupInfo;
  404. chunkGroupInfo.availableSources = new Set();
  405. for (const parent of chunkGroup.parentsIterable) {
  406. const parentChunkGroupInfo =
  407. /** @type {ChunkGroupInfo} */
  408. (chunkGroupInfoMap.get(parent));
  409. chunkGroupInfo.availableSources.add(parentChunkGroupInfo);
  410. if (parentChunkGroupInfo.availableChildren === undefined) {
  411. parentChunkGroupInfo.availableChildren = new Set();
  412. }
  413. parentChunkGroupInfo.availableChildren.add(chunkGroupInfo);
  414. }
  415. }
  416. // pop() is used to read from the queue
  417. // so it need to be reversed to be iterated in
  418. // correct order
  419. queue.reverse();
  420. /** @type {Set<ChunkGroupInfo>} */
  421. const outdatedChunkGroupInfo = new Set();
  422. /** @type {Set<[ChunkGroupInfo, QueueItem | null]>} */
  423. const chunkGroupsForMerging = new Set();
  424. /** @type {QueueItem[]} */
  425. let queueDelayed = [];
  426. /** @type {[Module, ModuleGraphConnection[]][]} */
  427. const skipConnectionBuffer = [];
  428. /** @type {Module[]} */
  429. const skipBuffer = [];
  430. /** @type {QueueItem[]} */
  431. const queueBuffer = [];
  432. /** @type {Module} */
  433. let module;
  434. /** @type {Chunk} */
  435. let chunk;
  436. /** @type {ChunkGroup} */
  437. let chunkGroup;
  438. /** @type {DependenciesBlock} */
  439. let block;
  440. /** @type {ChunkGroupInfo} */
  441. let chunkGroupInfo;
  442. // For each async Block in graph
  443. /**
  444. * @param {AsyncDependenciesBlock} b iterating over each Async DepBlock
  445. * @returns {void}
  446. */
  447. const iteratorBlock = b => {
  448. // 1. We create a chunk group with single chunk in it for this Block
  449. // but only once (blockChunkGroups map)
  450. /** @type {ChunkGroupInfo | undefined} */
  451. let cgi = blockChunkGroups.get(b);
  452. /** @type {ChunkGroup | undefined} */
  453. let c;
  454. /** @type {Entrypoint | undefined} */
  455. let entrypoint;
  456. const entryOptions = b.groupOptions && b.groupOptions.entryOptions;
  457. if (cgi === undefined) {
  458. const chunkName = (b.groupOptions && b.groupOptions.name) || b.chunkName;
  459. if (entryOptions) {
  460. cgi = namedAsyncEntrypoints.get(/** @type {string} */ (chunkName));
  461. if (!cgi) {
  462. entrypoint = compilation.addAsyncEntrypoint(
  463. entryOptions,
  464. module,
  465. /** @type {DependencyLocation} */ (b.loc),
  466. /** @type {string} */ (b.request)
  467. );
  468. maskByChunk.set(entrypoint.chunks[0], ZERO_BIGINT);
  469. entrypoint.index = nextChunkGroupIndex++;
  470. cgi = {
  471. chunkGroup: entrypoint,
  472. initialized: false,
  473. runtime:
  474. entrypoint.options.runtime ||
  475. /** @type {string | undefined} */ (entrypoint.name),
  476. minAvailableModules: ZERO_BIGINT,
  477. availableModulesToBeMerged: [],
  478. skippedItems: undefined,
  479. resultingAvailableModules: undefined,
  480. children: undefined,
  481. availableSources: undefined,
  482. availableChildren: undefined,
  483. preOrderIndex: 0,
  484. postOrderIndex: 0,
  485. chunkLoading:
  486. entryOptions.chunkLoading !== undefined
  487. ? entryOptions.chunkLoading !== false
  488. : chunkGroupInfo.chunkLoading,
  489. asyncChunks:
  490. entryOptions.asyncChunks !== undefined
  491. ? entryOptions.asyncChunks
  492. : chunkGroupInfo.asyncChunks
  493. };
  494. chunkGroupInfoMap.set(
  495. entrypoint,
  496. /** @type {ChunkGroupInfo} */
  497. (cgi)
  498. );
  499. chunkGraph.connectBlockAndChunkGroup(b, entrypoint);
  500. if (chunkName) {
  501. namedAsyncEntrypoints.set(
  502. chunkName,
  503. /** @type {ChunkGroupInfo} */
  504. (cgi)
  505. );
  506. }
  507. } else {
  508. entrypoint = /** @type {Entrypoint} */ (cgi.chunkGroup);
  509. // TODO merge entryOptions
  510. entrypoint.addOrigin(
  511. module,
  512. /** @type {DependencyLocation} */ (b.loc),
  513. /** @type {string} */ (b.request)
  514. );
  515. chunkGraph.connectBlockAndChunkGroup(b, entrypoint);
  516. }
  517. // 2. We enqueue the DependenciesBlock for traversal
  518. queueDelayed.push({
  519. action: PROCESS_ENTRY_BLOCK,
  520. block: b,
  521. module,
  522. chunk: entrypoint.chunks[0],
  523. chunkGroup: entrypoint,
  524. chunkGroupInfo: /** @type {ChunkGroupInfo} */ (cgi)
  525. });
  526. } else if (!chunkGroupInfo.asyncChunks || !chunkGroupInfo.chunkLoading) {
  527. // Just queue the block into the current chunk group
  528. queue.push({
  529. action: PROCESS_BLOCK,
  530. block: b,
  531. module,
  532. chunk,
  533. chunkGroup,
  534. chunkGroupInfo
  535. });
  536. } else {
  537. cgi = chunkName ? namedChunkGroups.get(chunkName) : undefined;
  538. if (!cgi) {
  539. c = compilation.addChunkInGroup(
  540. b.groupOptions || b.chunkName,
  541. module,
  542. /** @type {DependencyLocation} */ (b.loc),
  543. /** @type {string} */ (b.request)
  544. );
  545. maskByChunk.set(c.chunks[0], ZERO_BIGINT);
  546. c.index = nextChunkGroupIndex++;
  547. cgi = {
  548. initialized: false,
  549. chunkGroup: c,
  550. runtime: chunkGroupInfo.runtime,
  551. minAvailableModules: undefined,
  552. availableModulesToBeMerged: [],
  553. skippedItems: undefined,
  554. resultingAvailableModules: undefined,
  555. children: undefined,
  556. availableSources: undefined,
  557. availableChildren: undefined,
  558. preOrderIndex: 0,
  559. postOrderIndex: 0,
  560. chunkLoading: chunkGroupInfo.chunkLoading,
  561. asyncChunks: chunkGroupInfo.asyncChunks
  562. };
  563. allCreatedChunkGroups.add(c);
  564. chunkGroupInfoMap.set(c, cgi);
  565. if (chunkName) {
  566. namedChunkGroups.set(chunkName, cgi);
  567. }
  568. } else {
  569. c = cgi.chunkGroup;
  570. if (c.isInitial()) {
  571. compilation.errors.push(
  572. new AsyncDependencyToInitialChunkError(
  573. /** @type {string} */ (chunkName),
  574. module,
  575. /** @type {DependencyLocation} */ (b.loc)
  576. )
  577. );
  578. c = chunkGroup;
  579. } else {
  580. c.addOptions(b.groupOptions);
  581. }
  582. c.addOrigin(
  583. module,
  584. /** @type {DependencyLocation} */ (b.loc),
  585. /** @type {string} */ (b.request)
  586. );
  587. }
  588. blockConnections.set(b, []);
  589. }
  590. blockChunkGroups.set(b, /** @type {ChunkGroupInfo} */ (cgi));
  591. } else if (entryOptions) {
  592. entrypoint = /** @type {Entrypoint} */ (cgi.chunkGroup);
  593. } else {
  594. c = cgi.chunkGroup;
  595. }
  596. if (c !== undefined) {
  597. // 2. We store the connection for the block
  598. // to connect it later if needed
  599. /** @type {BlockChunkGroupConnection[]} */
  600. (blockConnections.get(b)).push({
  601. originChunkGroupInfo: chunkGroupInfo,
  602. chunkGroup: c
  603. });
  604. // 3. We enqueue the chunk group info creation/updating
  605. let connectList = queueConnect.get(chunkGroupInfo);
  606. if (connectList === undefined) {
  607. connectList = new Set();
  608. queueConnect.set(chunkGroupInfo, connectList);
  609. }
  610. connectList.add([
  611. /** @type {ChunkGroupInfo} */ (cgi),
  612. {
  613. action: PROCESS_BLOCK,
  614. block: b,
  615. module,
  616. chunk: c.chunks[0],
  617. chunkGroup: c,
  618. chunkGroupInfo: /** @type {ChunkGroupInfo} */ (cgi)
  619. }
  620. ]);
  621. } else if (entrypoint !== undefined) {
  622. chunkGroupInfo.chunkGroup.addAsyncEntrypoint(entrypoint);
  623. }
  624. };
  625. /**
  626. * @param {DependenciesBlock} block the block
  627. * @returns {void}
  628. */
  629. const processBlock = block => {
  630. statProcessedBlocks++;
  631. // get prepared block info
  632. const blockModules = getBlockModules(block, chunkGroupInfo.runtime);
  633. if (blockModules !== undefined) {
  634. const minAvailableModules =
  635. /** @type {bigint} */
  636. (chunkGroupInfo.minAvailableModules);
  637. // Buffer items because order need to be reversed to get indices correct
  638. // Traverse all referenced modules
  639. for (let i = 0, len = blockModules.length; i < len; i += 3) {
  640. const refModule = /** @type {Module} */ (blockModules[i]);
  641. // For single comparisons this might be cheaper
  642. const isModuleInChunk = chunkGraph.isModuleInChunk(refModule, chunk);
  643. if (isModuleInChunk) {
  644. // skip early if already connected
  645. continue;
  646. }
  647. const refOrdinal = /** @type {number} */ getModuleOrdinal(refModule);
  648. const activeState = /** @type {ConnectionState} */ (
  649. blockModules[i + 1]
  650. );
  651. if (activeState !== true) {
  652. const connections = /** @type {ModuleGraphConnection[]} */ (
  653. blockModules[i + 2]
  654. );
  655. skipConnectionBuffer.push([refModule, connections]);
  656. // We skip inactive connections
  657. if (activeState === false) continue;
  658. } else if (isOrdinalSetInMask(minAvailableModules, refOrdinal)) {
  659. // already in parent chunks, skip it for now
  660. skipBuffer.push(refModule);
  661. continue;
  662. }
  663. // enqueue, then add and enter to be in the correct order
  664. // this is relevant with circular dependencies
  665. queueBuffer.push({
  666. action: activeState === true ? ADD_AND_ENTER_MODULE : PROCESS_BLOCK,
  667. block: refModule,
  668. module: refModule,
  669. chunk,
  670. chunkGroup,
  671. chunkGroupInfo
  672. });
  673. }
  674. // Add buffered items in reverse order
  675. if (skipConnectionBuffer.length > 0) {
  676. let { skippedModuleConnections } = chunkGroupInfo;
  677. if (skippedModuleConnections === undefined) {
  678. chunkGroupInfo.skippedModuleConnections = skippedModuleConnections =
  679. new Set();
  680. }
  681. for (let i = skipConnectionBuffer.length - 1; i >= 0; i--) {
  682. skippedModuleConnections.add(skipConnectionBuffer[i]);
  683. }
  684. skipConnectionBuffer.length = 0;
  685. }
  686. if (skipBuffer.length > 0) {
  687. let { skippedItems } = chunkGroupInfo;
  688. if (skippedItems === undefined) {
  689. chunkGroupInfo.skippedItems = skippedItems = new Set();
  690. }
  691. for (let i = skipBuffer.length - 1; i >= 0; i--) {
  692. skippedItems.add(skipBuffer[i]);
  693. }
  694. skipBuffer.length = 0;
  695. }
  696. if (queueBuffer.length > 0) {
  697. for (let i = queueBuffer.length - 1; i >= 0; i--) {
  698. queue.push(queueBuffer[i]);
  699. }
  700. queueBuffer.length = 0;
  701. }
  702. }
  703. // Traverse all Blocks
  704. for (const b of block.blocks) {
  705. iteratorBlock(b);
  706. }
  707. if (block.blocks.length > 0 && module !== block) {
  708. blocksWithNestedBlocks.add(block);
  709. }
  710. };
  711. /**
  712. * @param {DependenciesBlock} block the block
  713. * @returns {void}
  714. */
  715. const processEntryBlock = block => {
  716. statProcessedBlocks++;
  717. // get prepared block info
  718. const blockModules = getBlockModules(block, chunkGroupInfo.runtime);
  719. if (blockModules !== undefined) {
  720. // Traverse all referenced modules in reverse order
  721. for (let i = blockModules.length - 3; i >= 0; i -= 3) {
  722. const refModule = /** @type {Module} */ (blockModules[i]);
  723. const activeState = /** @type {ConnectionState} */ (
  724. blockModules[i + 1]
  725. );
  726. // enqueue, then add and enter to be in the correct order
  727. // this is relevant with circular dependencies
  728. queue.push({
  729. action:
  730. activeState === true ? ADD_AND_ENTER_ENTRY_MODULE : PROCESS_BLOCK,
  731. block: refModule,
  732. module: refModule,
  733. chunk,
  734. chunkGroup,
  735. chunkGroupInfo
  736. });
  737. }
  738. }
  739. // Traverse all Blocks
  740. for (const b of block.blocks) {
  741. iteratorBlock(b);
  742. }
  743. if (block.blocks.length > 0 && module !== block) {
  744. blocksWithNestedBlocks.add(block);
  745. }
  746. };
  747. const processQueue = () => {
  748. while (queue.length) {
  749. statProcessedQueueItems++;
  750. const queueItem = /** @type {QueueItem} */ (queue.pop());
  751. module = queueItem.module;
  752. block = queueItem.block;
  753. chunk = queueItem.chunk;
  754. chunkGroup = queueItem.chunkGroup;
  755. chunkGroupInfo = queueItem.chunkGroupInfo;
  756. switch (queueItem.action) {
  757. case ADD_AND_ENTER_ENTRY_MODULE:
  758. chunkGraph.connectChunkAndEntryModule(
  759. chunk,
  760. module,
  761. /** @type {Entrypoint} */ (chunkGroup)
  762. );
  763. // fallthrough
  764. case ADD_AND_ENTER_MODULE: {
  765. const isModuleInChunk = chunkGraph.isModuleInChunk(module, chunk);
  766. if (isModuleInChunk) {
  767. // already connected, skip it
  768. break;
  769. }
  770. // We connect Module and Chunk
  771. chunkGraph.connectChunkAndModule(chunk, module);
  772. const moduleOrdinal = getModuleOrdinal(module);
  773. let chunkMask = /** @type {bigint} */ (maskByChunk.get(chunk));
  774. chunkMask |= ONE_BIGINT << BigInt(moduleOrdinal);
  775. maskByChunk.set(chunk, chunkMask);
  776. }
  777. // fallthrough
  778. case ENTER_MODULE: {
  779. const index = chunkGroup.getModulePreOrderIndex(module);
  780. if (index === undefined) {
  781. chunkGroup.setModulePreOrderIndex(
  782. module,
  783. chunkGroupInfo.preOrderIndex++
  784. );
  785. }
  786. if (
  787. moduleGraph.setPreOrderIndexIfUnset(
  788. module,
  789. nextFreeModulePreOrderIndex
  790. )
  791. ) {
  792. nextFreeModulePreOrderIndex++;
  793. }
  794. // reuse queueItem
  795. queueItem.action = LEAVE_MODULE;
  796. queue.push(queueItem);
  797. }
  798. // fallthrough
  799. case PROCESS_BLOCK: {
  800. processBlock(block);
  801. break;
  802. }
  803. case PROCESS_ENTRY_BLOCK: {
  804. processEntryBlock(block);
  805. break;
  806. }
  807. case LEAVE_MODULE: {
  808. const index = chunkGroup.getModulePostOrderIndex(module);
  809. if (index === undefined) {
  810. chunkGroup.setModulePostOrderIndex(
  811. module,
  812. chunkGroupInfo.postOrderIndex++
  813. );
  814. }
  815. if (
  816. moduleGraph.setPostOrderIndexIfUnset(
  817. module,
  818. nextFreeModulePostOrderIndex
  819. )
  820. ) {
  821. nextFreeModulePostOrderIndex++;
  822. }
  823. break;
  824. }
  825. }
  826. }
  827. };
  828. /**
  829. * @param {ChunkGroupInfo} chunkGroupInfo The info object for the chunk group
  830. * @returns {bigint} The mask of available modules after the chunk group
  831. */
  832. const calculateResultingAvailableModules = chunkGroupInfo => {
  833. if (chunkGroupInfo.resultingAvailableModules !== undefined)
  834. return chunkGroupInfo.resultingAvailableModules;
  835. let resultingAvailableModules = /** @type {bigint} */ (
  836. chunkGroupInfo.minAvailableModules
  837. );
  838. // add the modules from the chunk group to the set
  839. for (const chunk of chunkGroupInfo.chunkGroup.chunks) {
  840. const mask = /** @type {bigint} */ (maskByChunk.get(chunk));
  841. resultingAvailableModules |= mask;
  842. }
  843. return (chunkGroupInfo.resultingAvailableModules =
  844. resultingAvailableModules);
  845. };
  846. const processConnectQueue = () => {
  847. // Figure out new parents for chunk groups
  848. // to get new available modules for these children
  849. for (const [chunkGroupInfo, targets] of queueConnect) {
  850. // 1. Add new targets to the list of children
  851. if (chunkGroupInfo.children === undefined) {
  852. chunkGroupInfo.children = new Set();
  853. }
  854. for (const [target] of targets) {
  855. chunkGroupInfo.children.add(target);
  856. }
  857. // 2. Calculate resulting available modules
  858. const resultingAvailableModules =
  859. calculateResultingAvailableModules(chunkGroupInfo);
  860. const runtime = chunkGroupInfo.runtime;
  861. // 3. Update chunk group info
  862. for (const [target, processBlock] of targets) {
  863. target.availableModulesToBeMerged.push(resultingAvailableModules);
  864. chunkGroupsForMerging.add([target, processBlock]);
  865. const oldRuntime = target.runtime;
  866. const newRuntime = mergeRuntime(oldRuntime, runtime);
  867. if (oldRuntime !== newRuntime) {
  868. target.runtime = newRuntime;
  869. outdatedChunkGroupInfo.add(target);
  870. }
  871. }
  872. statConnectedChunkGroups += targets.size;
  873. }
  874. queueConnect.clear();
  875. };
  876. const processChunkGroupsForMerging = () => {
  877. statProcessedChunkGroupsForMerging += chunkGroupsForMerging.size;
  878. // Execute the merge
  879. for (const [info, processBlock] of chunkGroupsForMerging) {
  880. const availableModulesToBeMerged = info.availableModulesToBeMerged;
  881. const cachedMinAvailableModules = info.minAvailableModules;
  882. let minAvailableModules = cachedMinAvailableModules;
  883. statMergedAvailableModuleSets += availableModulesToBeMerged.length;
  884. for (const availableModules of availableModulesToBeMerged) {
  885. if (minAvailableModules === undefined) {
  886. minAvailableModules = availableModules;
  887. } else {
  888. minAvailableModules &= availableModules;
  889. }
  890. }
  891. const changed = minAvailableModules !== cachedMinAvailableModules;
  892. availableModulesToBeMerged.length = 0;
  893. if (changed) {
  894. info.minAvailableModules = minAvailableModules;
  895. info.resultingAvailableModules = undefined;
  896. outdatedChunkGroupInfo.add(info);
  897. }
  898. if (processBlock) {
  899. let blocks = blocksByChunkGroups.get(info);
  900. if (!blocks) {
  901. blocksByChunkGroups.set(info, (blocks = new Set()));
  902. }
  903. // Whether to walk block depends on minAvailableModules and input block.
  904. // We can treat creating chunk group as a function with 2 input, entry block and minAvailableModules
  905. // If input is the same, we can skip re-walk
  906. let needWalkBlock = !info.initialized || changed;
  907. if (!blocks.has(processBlock.block)) {
  908. needWalkBlock = true;
  909. blocks.add(processBlock.block);
  910. }
  911. if (needWalkBlock) {
  912. info.initialized = true;
  913. queueDelayed.push(processBlock);
  914. }
  915. }
  916. }
  917. chunkGroupsForMerging.clear();
  918. };
  919. const processChunkGroupsForCombining = () => {
  920. for (const info of chunkGroupsForCombining) {
  921. for (const source of /** @type {Set<ChunkGroupInfo>} */ (
  922. info.availableSources
  923. )) {
  924. if (source.minAvailableModules === undefined) {
  925. chunkGroupsForCombining.delete(info);
  926. break;
  927. }
  928. }
  929. }
  930. for (const info of chunkGroupsForCombining) {
  931. let availableModules = ZERO_BIGINT;
  932. // combine minAvailableModules from all resultingAvailableModules
  933. for (const source of /** @type {Set<ChunkGroupInfo>} */ (
  934. info.availableSources
  935. )) {
  936. const resultingAvailableModules =
  937. calculateResultingAvailableModules(source);
  938. availableModules |= resultingAvailableModules;
  939. }
  940. info.minAvailableModules = availableModules;
  941. info.resultingAvailableModules = undefined;
  942. outdatedChunkGroupInfo.add(info);
  943. }
  944. chunkGroupsForCombining.clear();
  945. };
  946. const processOutdatedChunkGroupInfo = () => {
  947. statChunkGroupInfoUpdated += outdatedChunkGroupInfo.size;
  948. // Revisit skipped elements
  949. for (const info of outdatedChunkGroupInfo) {
  950. // 1. Reconsider skipped items
  951. if (info.skippedItems !== undefined) {
  952. const minAvailableModules =
  953. /** @type {bigint} */
  954. (info.minAvailableModules);
  955. for (const module of info.skippedItems) {
  956. const ordinal = getModuleOrdinal(module);
  957. if (!isOrdinalSetInMask(minAvailableModules, ordinal)) {
  958. queue.push({
  959. action: ADD_AND_ENTER_MODULE,
  960. block: module,
  961. module,
  962. chunk: info.chunkGroup.chunks[0],
  963. chunkGroup: info.chunkGroup,
  964. chunkGroupInfo: info
  965. });
  966. info.skippedItems.delete(module);
  967. }
  968. }
  969. }
  970. // 2. Reconsider skipped connections
  971. if (info.skippedModuleConnections !== undefined) {
  972. const minAvailableModules =
  973. /** @type {bigint} */
  974. (info.minAvailableModules);
  975. for (const entry of info.skippedModuleConnections) {
  976. const [module, connections] = entry;
  977. const activeState = getActiveStateOfConnections(
  978. connections,
  979. info.runtime
  980. );
  981. if (activeState === false) continue;
  982. if (activeState === true) {
  983. const ordinal = getModuleOrdinal(module);
  984. info.skippedModuleConnections.delete(entry);
  985. if (isOrdinalSetInMask(minAvailableModules, ordinal)) {
  986. /** @type {NonNullable<ChunkGroupInfo["skippedItems"]>} */
  987. (info.skippedItems).add(module);
  988. continue;
  989. }
  990. }
  991. queue.push({
  992. action: activeState === true ? ADD_AND_ENTER_MODULE : PROCESS_BLOCK,
  993. block: module,
  994. module,
  995. chunk: info.chunkGroup.chunks[0],
  996. chunkGroup: info.chunkGroup,
  997. chunkGroupInfo: info
  998. });
  999. }
  1000. }
  1001. // 2. Reconsider children chunk groups
  1002. if (info.children !== undefined) {
  1003. statChildChunkGroupsReconnected += info.children.size;
  1004. for (const cgi of info.children) {
  1005. let connectList = queueConnect.get(info);
  1006. if (connectList === undefined) {
  1007. connectList = new Set();
  1008. queueConnect.set(info, connectList);
  1009. }
  1010. connectList.add([cgi, null]);
  1011. }
  1012. }
  1013. // 3. Reconsider chunk groups for combining
  1014. if (info.availableChildren !== undefined) {
  1015. for (const cgi of info.availableChildren) {
  1016. chunkGroupsForCombining.add(cgi);
  1017. }
  1018. }
  1019. outdatedOrderIndexChunkGroups.add(info);
  1020. }
  1021. outdatedChunkGroupInfo.clear();
  1022. };
  1023. // Iterative traversal of the Module graph
  1024. // Recursive would be simpler to write but could result in Stack Overflows
  1025. while (queue.length || queueConnect.size) {
  1026. logger.time("visitModules: visiting");
  1027. processQueue();
  1028. logger.timeAggregateEnd("visitModules: prepare");
  1029. logger.timeEnd("visitModules: visiting");
  1030. if (chunkGroupsForCombining.size > 0) {
  1031. logger.time("visitModules: combine available modules");
  1032. processChunkGroupsForCombining();
  1033. logger.timeEnd("visitModules: combine available modules");
  1034. }
  1035. if (queueConnect.size > 0) {
  1036. logger.time("visitModules: calculating available modules");
  1037. processConnectQueue();
  1038. logger.timeEnd("visitModules: calculating available modules");
  1039. if (chunkGroupsForMerging.size > 0) {
  1040. logger.time("visitModules: merging available modules");
  1041. processChunkGroupsForMerging();
  1042. logger.timeEnd("visitModules: merging available modules");
  1043. }
  1044. }
  1045. if (outdatedChunkGroupInfo.size > 0) {
  1046. logger.time("visitModules: check modules for revisit");
  1047. processOutdatedChunkGroupInfo();
  1048. logger.timeEnd("visitModules: check modules for revisit");
  1049. }
  1050. // Run queueDelayed when all items of the queue are processed
  1051. // This is important to get the global indexing correct
  1052. // Async blocks should be processed after all sync blocks are processed
  1053. if (queue.length === 0) {
  1054. const tempQueue = queue;
  1055. queue = queueDelayed.reverse();
  1056. queueDelayed = tempQueue;
  1057. }
  1058. }
  1059. for (const info of outdatedOrderIndexChunkGroups) {
  1060. const { chunkGroup, runtime } = info;
  1061. const blocks = blocksByChunkGroups.get(info);
  1062. if (!blocks) {
  1063. continue;
  1064. }
  1065. for (const block of blocks) {
  1066. let preOrderIndex = 0;
  1067. let postOrderIndex = 0;
  1068. /**
  1069. * @param {DependenciesBlock} current current
  1070. * @param {BlocksWithNestedBlocks} visited visited dependencies blocks
  1071. */
  1072. const process = (current, visited) => {
  1073. const blockModules =
  1074. /** @type {BlockModulesInFlattenTuples} */
  1075. (getBlockModules(current, runtime));
  1076. for (let i = 0, len = blockModules.length; i < len; i += 3) {
  1077. const activeState = /** @type {ConnectionState} */ (
  1078. blockModules[i + 1]
  1079. );
  1080. if (activeState === false) {
  1081. continue;
  1082. }
  1083. const refModule = /** @type {Module} */ (blockModules[i]);
  1084. if (visited.has(refModule)) {
  1085. continue;
  1086. }
  1087. visited.add(refModule);
  1088. if (refModule) {
  1089. chunkGroup.setModulePreOrderIndex(refModule, preOrderIndex++);
  1090. process(refModule, visited);
  1091. chunkGroup.setModulePostOrderIndex(refModule, postOrderIndex++);
  1092. }
  1093. }
  1094. };
  1095. process(block, new Set());
  1096. }
  1097. }
  1098. outdatedOrderIndexChunkGroups.clear();
  1099. ordinalByModule.clear();
  1100. logger.log(
  1101. `${statProcessedQueueItems} queue items processed (${statProcessedBlocks} blocks)`
  1102. );
  1103. logger.log(`${statConnectedChunkGroups} chunk groups connected`);
  1104. logger.log(
  1105. `${statProcessedChunkGroupsForMerging} chunk groups processed for merging (${statMergedAvailableModuleSets} module sets, ${statForkedAvailableModules} forked, ${statForkedAvailableModulesCount} + ${statForkedAvailableModulesCountPlus} modules forked, ${statForkedMergedModulesCount} + ${statForkedMergedModulesCountPlus} modules merged into fork, ${statForkedResultModulesCount} resulting modules)`
  1106. );
  1107. logger.log(
  1108. `${statChunkGroupInfoUpdated} chunk group info updated (${statChildChunkGroupsReconnected} already connected chunk groups reconnected)`
  1109. );
  1110. };
  1111. /**
  1112. * @param {Compilation} compilation the compilation
  1113. * @param {BlocksWithNestedBlocks} blocksWithNestedBlocks flag for blocks that have nested blocks
  1114. * @param {BlockConnections} blockConnections connection for blocks
  1115. * @param {MaskByChunk} maskByChunk mapping from chunk to module mask
  1116. */
  1117. const connectChunkGroups = (
  1118. compilation,
  1119. blocksWithNestedBlocks,
  1120. blockConnections,
  1121. maskByChunk
  1122. ) => {
  1123. const { chunkGraph } = compilation;
  1124. /**
  1125. * Helper function to check if all modules of a chunk are available
  1126. * @param {ChunkGroup} chunkGroup the chunkGroup to scan
  1127. * @param {bigint} availableModules the comparator set
  1128. * @returns {boolean} return true if all modules of a chunk are available
  1129. */
  1130. const areModulesAvailable = (chunkGroup, availableModules) => {
  1131. for (const chunk of chunkGroup.chunks) {
  1132. const chunkMask = /** @type {bigint} */ (maskByChunk.get(chunk));
  1133. if ((chunkMask & availableModules) !== chunkMask) return false;
  1134. }
  1135. return true;
  1136. };
  1137. // For each edge in the basic chunk graph
  1138. for (const [block, connections] of blockConnections) {
  1139. // 1. Check if connection is needed
  1140. // When none of the dependencies need to be connected
  1141. // we can skip all of them
  1142. // It's not possible to filter each item so it doesn't create inconsistent
  1143. // connections and modules can only create one version
  1144. // TODO maybe decide this per runtime
  1145. if (
  1146. // TODO is this needed?
  1147. !blocksWithNestedBlocks.has(block) &&
  1148. connections.every(({ chunkGroup, originChunkGroupInfo }) =>
  1149. areModulesAvailable(
  1150. chunkGroup,
  1151. /** @type {bigint} */ (originChunkGroupInfo.resultingAvailableModules)
  1152. )
  1153. )
  1154. ) {
  1155. continue;
  1156. }
  1157. // 2. Foreach edge
  1158. for (let i = 0; i < connections.length; i++) {
  1159. const { chunkGroup, originChunkGroupInfo } = connections[i];
  1160. // 3. Connect block with chunk
  1161. chunkGraph.connectBlockAndChunkGroup(block, chunkGroup);
  1162. // 4. Connect chunk with parent
  1163. connectChunkGroupParentAndChild(
  1164. originChunkGroupInfo.chunkGroup,
  1165. chunkGroup
  1166. );
  1167. }
  1168. }
  1169. };
  1170. /**
  1171. * Remove all unconnected chunk groups
  1172. * @param {Compilation} compilation the compilation
  1173. * @param {Iterable<ChunkGroup>} allCreatedChunkGroups all chunk groups that where created before
  1174. */
  1175. const cleanupUnconnectedGroups = (compilation, allCreatedChunkGroups) => {
  1176. const { chunkGraph } = compilation;
  1177. for (const chunkGroup of allCreatedChunkGroups) {
  1178. if (chunkGroup.getNumberOfParents() === 0) {
  1179. for (const chunk of chunkGroup.chunks) {
  1180. compilation.chunks.delete(chunk);
  1181. chunkGraph.disconnectChunk(chunk);
  1182. }
  1183. chunkGraph.disconnectChunkGroup(chunkGroup);
  1184. chunkGroup.remove();
  1185. }
  1186. }
  1187. };
  1188. /**
  1189. * This method creates the Chunk graph from the Module graph
  1190. * @param {Compilation} compilation the compilation
  1191. * @param {InputEntrypointsAndModules} inputEntrypointsAndModules chunk groups which are processed with the modules
  1192. * @returns {void}
  1193. */
  1194. const buildChunkGraph = (compilation, inputEntrypointsAndModules) => {
  1195. const logger = compilation.getLogger("webpack.buildChunkGraph");
  1196. // SHARED STATE
  1197. /** @type {BlockConnections} */
  1198. const blockConnections = new Map();
  1199. /** @type {AllCreatedChunkGroups} */
  1200. const allCreatedChunkGroups = new Set();
  1201. /** @type {ChunkGroupInfoMap} */
  1202. const chunkGroupInfoMap = new Map();
  1203. /** @type {BlocksWithNestedBlocks} */
  1204. const blocksWithNestedBlocks = new Set();
  1205. /** @type {MaskByChunk} */
  1206. const maskByChunk = new Map();
  1207. // PART ONE
  1208. logger.time("visitModules");
  1209. visitModules(
  1210. logger,
  1211. compilation,
  1212. inputEntrypointsAndModules,
  1213. chunkGroupInfoMap,
  1214. blockConnections,
  1215. blocksWithNestedBlocks,
  1216. allCreatedChunkGroups,
  1217. maskByChunk
  1218. );
  1219. logger.timeEnd("visitModules");
  1220. // PART TWO
  1221. logger.time("connectChunkGroups");
  1222. connectChunkGroups(
  1223. compilation,
  1224. blocksWithNestedBlocks,
  1225. blockConnections,
  1226. maskByChunk
  1227. );
  1228. logger.timeEnd("connectChunkGroups");
  1229. for (const [chunkGroup, chunkGroupInfo] of chunkGroupInfoMap) {
  1230. for (const chunk of chunkGroup.chunks)
  1231. chunk.runtime = mergeRuntime(chunk.runtime, chunkGroupInfo.runtime);
  1232. }
  1233. // Cleanup work
  1234. logger.time("cleanup");
  1235. cleanupUnconnectedGroups(compilation, allCreatedChunkGroups);
  1236. logger.timeEnd("cleanup");
  1237. };
  1238. module.exports = buildChunkGraph;