Skip to content

Commit

Permalink
Revert startRender/startPrerender to startWork
Browse files Browse the repository at this point in the history
This split isn't going to work after all. Need to be at the create layer.
  • Loading branch information
sebmarkbage committed Sep 7, 2023
1 parent ee7f9c9 commit ccb8c47
Show file tree
Hide file tree
Showing 18 changed files with 37 additions and 37 deletions.
6 changes: 3 additions & 3 deletions packages/react-dom/src/server/ReactDOMFizzServerBrowser.js
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@ import ReactVersion from 'shared/ReactVersion';

import {
createRequest,
startRender,
startWork,
startFlowing,
abort,
} from 'react-server/src/ReactFizzServer';
Expand Down Expand Up @@ -129,7 +129,7 @@ function renderToReadableStream(
signal.addEventListener('abort', listener);
}
}
startRender(request);
startWork(request);
});
}

Expand Down Expand Up @@ -200,7 +200,7 @@ function resume(
signal.addEventListener('abort', listener);
}
}
startRender(request);
startWork(request);
});
}

Expand Down
4 changes: 2 additions & 2 deletions packages/react-dom/src/server/ReactDOMFizzServerBun.js
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@ import ReactVersion from 'shared/ReactVersion';

import {
createRequest,
startRender,
startWork,
startFlowing,
abort,
} from 'react-server/src/ReactFizzServer';
Expand Down Expand Up @@ -121,7 +121,7 @@ function renderToReadableStream(
signal.addEventListener('abort', listener);
}
}
startRender(request);
startWork(request);
});
}

Expand Down
6 changes: 3 additions & 3 deletions packages/react-dom/src/server/ReactDOMFizzServerEdge.js
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@ import ReactVersion from 'shared/ReactVersion';

import {
createRequest,
startRender,
startWork,
startFlowing,
abort,
} from 'react-server/src/ReactFizzServer';
Expand Down Expand Up @@ -129,7 +129,7 @@ function renderToReadableStream(
signal.addEventListener('abort', listener);
}
}
startRender(request);
startWork(request);
});
}

Expand Down Expand Up @@ -200,7 +200,7 @@ function resume(
signal.addEventListener('abort', listener);
}
}
startRender(request);
startWork(request);
});
}

Expand Down
6 changes: 3 additions & 3 deletions packages/react-dom/src/server/ReactDOMFizzServerNode.js
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,7 @@ import ReactVersion from 'shared/ReactVersion';

import {
createRequest,
startRender,
startWork,
startFlowing,
abort,
} from 'react-server/src/ReactFizzServer';
Expand Down Expand Up @@ -105,7 +105,7 @@ function renderToPipeableStream(
): PipeableStream {
const request = createRequestImpl(children, options);
let hasStartedFlowing = false;
startRender(request);
startWork(request);
return {
pipe<T: Writable>(destination: T): T {
if (hasStartedFlowing) {
Expand Down Expand Up @@ -166,7 +166,7 @@ function resumeToPipeableStream(
): PipeableStream {
const request = resumeRequestImpl(children, postponedState, options);
let hasStartedFlowing = false;
startRender(request);
startWork(request);
return {
pipe<T: Writable>(destination: T): T {
if (hasStartedFlowing) {
Expand Down
4 changes: 2 additions & 2 deletions packages/react-dom/src/server/ReactDOMFizzStaticBrowser.js
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@ import ReactVersion from 'shared/ReactVersion';

import {
createRequest,
startPrerender,
startWork,
startFlowing,
abort,
getPostponedState,
Expand Down Expand Up @@ -109,7 +109,7 @@ function prerender(
signal.addEventListener('abort', listener);
}
}
startPrerender(request);
startWork(request);
});
}

Expand Down
4 changes: 2 additions & 2 deletions packages/react-dom/src/server/ReactDOMFizzStaticEdge.js
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@ import ReactVersion from 'shared/ReactVersion';

import {
createRequest,
startPrerender,
startWork,
startFlowing,
abort,
getPostponedState,
Expand Down Expand Up @@ -109,7 +109,7 @@ function prerender(
signal.addEventListener('abort', listener);
}
}
startPrerender(request);
startWork(request);
});
}

Expand Down
4 changes: 2 additions & 2 deletions packages/react-dom/src/server/ReactDOMFizzStaticNode.js
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,7 @@ import ReactVersion from 'shared/ReactVersion';

import {
createRequest,
startPrerender,
startWork,
startFlowing,
abort,
getPostponedState,
Expand Down Expand Up @@ -123,7 +123,7 @@ function prerenderToNodeStream(
signal.addEventListener('abort', listener);
}
}
startPrerender(request);
startWork(request);
});
}

Expand Down
4 changes: 2 additions & 2 deletions packages/react-dom/src/server/ReactDOMLegacyServerImpl.js
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@ import type {ReactNodeList} from 'shared/ReactTypes';

import {
createRequest,
startRender,
startWork,
startFlowing,
abort,
} from 'react-server/src/ReactFizzServer';
Expand Down Expand Up @@ -81,7 +81,7 @@ function renderToStringImpl(
undefined,
undefined,
);
startRender(request);
startWork(request);
// If anything suspended and is still pending, we'll abort it before writing.
// That way we write only client-rendered boundaries from the start.
abort(request, abortReason);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@ import type {Request} from 'react-server/src/ReactFizzServer';

import {
createRequest,
startRender,
startWork,
startFlowing,
abort,
} from 'react-server/src/ReactFizzServer';
Expand Down Expand Up @@ -92,7 +92,7 @@ function renderToNodeStreamImpl(
undefined,
);
destination.request = request;
startRender(request);
startWork(request);
return destination;
}

Expand Down
2 changes: 1 addition & 1 deletion packages/react-noop-renderer/src/ReactNoopFlightServer.js
Original file line number Diff line number Diff line change
Expand Up @@ -84,7 +84,7 @@ function render(model: ReactClientValue, options?: Options): Destination {
options ? options.context : undefined,
options ? options.identifierPrefix : undefined,
);
ReactNoopFlightServer.startRender(request);
ReactNoopFlightServer.startWork(request);
ReactNoopFlightServer.startFlowing(request, destination);
return destination;
}
Expand Down
2 changes: 1 addition & 1 deletion packages/react-noop-renderer/src/ReactNoopServer.js
Original file line number Diff line number Diff line change
Expand Up @@ -304,7 +304,7 @@ function render(children: React$Element<any>, options?: Options): Destination {
options ? options.onAllReady : undefined,
options ? options.onShellReady : undefined,
);
ReactNoopServer.startRender(request);
ReactNoopServer.startWork(request);
ReactNoopServer.startFlowing(request, destination);
return destination;
}
Expand Down
4 changes: 2 additions & 2 deletions packages/react-server-dom-esm/src/ReactFlightDOMServerNode.js
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@ import type {ServerContextJSONValue, Thenable} from 'shared/ReactTypes';

import {
createRequest,
startRender,
startWork,
startFlowing,
abort,
} from 'react-server/src/ReactFlightServer';
Expand Down Expand Up @@ -73,7 +73,7 @@ function renderToPipeableStream(
options ? options.onPostpone : undefined,
);
let hasStartedFlowing = false;
startRender(request);
startWork(request);
return {
pipe<T: Writable>(destination: T): T {
if (hasStartedFlowing) {
Expand Down
4 changes: 2 additions & 2 deletions packages/react-server-dom-fb/src/ReactDOMServerFB.js
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@ import type {BootstrapScriptDescriptor} from 'react-dom-bindings/src/server/Reac

import {
createRequest,
startRender,
startWork,
performWork,
startFlowing,
abort,
Expand Down Expand Up @@ -68,7 +68,7 @@ function renderToStream(children: ReactNodeList, options: Options): Stream {
undefined,
undefined,
);
startRender(request);
startWork(request);
if (destination.fatal) {
throw destination.error;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@ import type {ServerManifest} from 'react-client/src/ReactFlightClientConfig';

import {
createRequest,
startRender,
startWork,
startFlowing,
abort,
} from 'react-server/src/ReactFlightServer';
Expand Down Expand Up @@ -70,7 +70,7 @@ function renderToReadableStream(
{
type: 'bytes',
start: (controller): ?Promise<void> => {
startRender(request);
startWork(request);
},
pull: (controller): ?Promise<void> => {
startFlowing(request, controller);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@ import type {ServerManifest} from 'react-client/src/ReactFlightClientConfig';

import {
createRequest,
startRender,
startWork,
startFlowing,
abort,
} from 'react-server/src/ReactFlightServer';
Expand Down Expand Up @@ -70,7 +70,7 @@ function renderToReadableStream(
{
type: 'bytes',
start: (controller): ?Promise<void> => {
startRender(request);
startWork(request);
},
pull: (controller): ?Promise<void> => {
startFlowing(request, controller);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@ import type {ServerContextJSONValue, Thenable} from 'shared/ReactTypes';

import {
createRequest,
startRender,
startWork,
startFlowing,
abort,
} from 'react-server/src/ReactFlightServer';
Expand Down Expand Up @@ -74,7 +74,7 @@ function renderToPipeableStream(
options ? options.onPostpone : undefined,
);
let hasStartedFlowing = false;
startRender(request);
startWork(request);
return {
pipe<T: Writable>(destination: T): T {
if (hasStartedFlowing) {
Expand Down
6 changes: 3 additions & 3 deletions packages/react-server/src/ReactFizzServer.js
Original file line number Diff line number Diff line change
Expand Up @@ -2751,7 +2751,7 @@ function flushCompletedQueues(
}
}

export function startRender(request: Request): void {
export function startWork(request: Request): void {
request.flushScheduled = request.destination !== null;
if (supportsRequestStorage) {
scheduleWork(() => requestStorage.run(request, performWork, request));
Expand All @@ -2760,10 +2760,10 @@ export function startRender(request: Request): void {
}
}

export function startPrerender(request: Request): void {
export function startPrerenderWork(request: Request): void {
// Start tracking postponed holes during this render.
request.trackedPostpones = {workingMap: new Map(), root: []};
startRender(request);
startWork(request);
}

function enqueueFlush(request: Request): void {
Expand Down
2 changes: 1 addition & 1 deletion packages/react-server/src/ReactFlightServer.js
Original file line number Diff line number Diff line change
Expand Up @@ -1519,7 +1519,7 @@ function flushCompletedChunks(
}
}

export function startRender(request: Request): void {
export function startWork(request: Request): void {
request.flushScheduled = request.destination !== null;
if (supportsRequestStorage) {
scheduleWork(() => requestStorage.run(request, performWork, request));
Expand Down

0 comments on commit ccb8c47

Please sign in to comment.