Skip to content

watch: Debounce all files updates into a single event. #51988

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
matthieusieben wants to merge 5 commits into from
Closed

watch: Debounce all files updates into a single event. #51988

Changes from 1 commit
Commits
Show all changes
5 commits
Select commit Hold shift + click to select a range
768da12
watch: allow listening for grouped changes
matthieusieben Mar 6, 2024
906f7c8
Update lib/internal/watch_mode/files_watcher.js
matthieusieben Mar 11, 2024
e2ce54a
fix: import clearTimeout
matthieusieben Mar 11, 2024
ada7280
comment on creation of `owners` argument to FilesWatcher's changed event
matthieusieben Mar 11, 2024
f2e2232
Merge branch 'main' into patch-4
matthieusieben Mar 19, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Next Next commit
watch: allow listening for grouped changes
  • Loading branch information
@matthieusieben
matthieusieben committed Mar 6, 2024
commit 768da127acdb023f629a97c1ca653f9f8bc8cf03
17 changes: 10 additions & 7 deletions lib/internal/watch_mode/files_watcher.js
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -24,9 +24,10 @@ const supportsRecursiveWatching = process.platform === 'win32' ||
class FilesWatcher extends EventEmitter {
#watchers = new SafeMap();
#filteredFiles = new SafeSet();
#debouncing = new SafeSet();
#depencencyOwners = new SafeMap();
#ownerDependencies = new SafeMap();
#debounceOwners = new SafeSet();
#debounceTimer;
#debounce;
#mode;
#signal;
Expand Down Expand Up @@ -74,17 +75,19 @@ class FilesWatcher extends EventEmitter {
}

#onChange(trigger) {
if (this.#debouncing.has(trigger)) {
return;
}
if (this.#mode === 'filter' && !this.#filteredFiles.has(trigger)) {
return;
}
this.#debouncing.add(trigger);

const owners = this.#depencencyOwners.get(trigger);
setTimeout(() => {
this.#debouncing.delete(trigger);
if (owners) for (const o of owners) this.#debounceOwners.add(o);
Comment thread
matthieusieben marked this conversation as resolved.
Outdated

clearTimeout(this.#debounceTimer);
this.#debounceTimer = setTimeout(() => {
this.#debounceTimer = null;
const owners = this.#debounceOwners;
this.emit('changed', { owners });
this.#debounceOwners = new SafeSet();
Copy link
Copy Markdown
Member

@anonrig anonrig Mar 11, 2024

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
this.#debounceOwners = new SafeSet();
this.#debounceOwners.clear();

Copy link
Copy Markdown
Contributor Author

@matthieusieben matthieusieben Mar 11, 2024

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

The reason I did that is to allow async processing of the owners by the listeners. I figured it would be more efficient to swap the Set rather than doing:

      const owners = new Set(this.#debounceOwners);
      this.emit('changed', { owners });
      this.#debounceOwners.clear();

What do you think ?

Copy link
Copy Markdown
Contributor Author

@matthieusieben matthieusieben Mar 19, 2024

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

If you think that async processing of the event is not something we should care about here, then I can just implement your change.

}, this.#debounce).unref();
}

Expand Down