events: define abort on prototype

benjamingr · targos · commit 7c95cfc16406 · 2021-04-30T12:00:12.000+02:00
PR-URL: #35931 Backport-PR-URL: #38386 Reviewed-By: Anna Henningsen <anna@addaleax.net> Reviewed-By: Antoine du Hamel <duhamelantoine1995@gmail.com> Reviewed-By: Daijiro Wachi <daijiro.wachi@gmail.com> Reviewed-By: Rich Trott <rtrott@gmail.com>
diff --git a/lib/internal/abort_controller.js b/lib/internal/abort_controller.js
@@ -47,6 +47,8 @@ Object.defineProperties(AbortSignal.prototype, {
 aborted: { enumerable: true }
 });
 
+defineEventHandler(AbortSignal.prototype, 'abort');
+
 function abortSignal(signal) {
 if (signal[kAborted]) return;
 signal[kAborted] = true;
@@ -64,7 +66,6 @@ class AbortController {
 constructor() {
 this[kSignal] = new AbortSignal();
 emitExperimentalWarning('AbortController');
- defineEventHandler(this[kSignal], 'abort');
 }
 
 get signal() { return this[kSignal]; }
diff --git a/lib/internal/event_target.js b/lib/internal/event_target.js
@@ -4,16 +4,15 @@ const {
 ArrayFrom,
 Boolean,
 Error,
- Map,
 NumberIsInteger,
 Object,
 ObjectDefineProperty,
 ObjectGetOwnPropertyDescriptor,
+ SafeMap,
 String,
 Symbol,
 SymbolFor,
 SymbolToStringTag,
- SafeWeakMap,
 SafeWeakSet,
 } = primordials;
 
@@ -35,6 +34,7 @@ const kIsEventTarget = SymbolFor('nodejs.event_target');
 const kEvents = Symbol('kEvents');
 const kStop = Symbol('kStop');
 const kTarget = Symbol('kTarget');
+const kHandlers = Symbol('khandlers');
 
 const kHybridDispatch = Symbol.for('nodejs.internal.kHybridDispatch');
 const kCreateEvent = Symbol('kCreateEvent');
@@ -218,7 +218,7 @@ class Listener {
 }
 
 function initEventTarget(self) {
- self[kEvents] = new Map();
+ self[kEvents] = new SafeMap();
 }
 
 class EventTarget {
@@ -577,27 +577,24 @@ function emitUnhandledRejectionOrErr(that, err, event) {
 process.emit('error', err, event);
 }
 
-// A map of emitter -> map of name -> handler
-const eventHandlerValueMap = new SafeWeakMap();
-
 function defineEventHandler(emitter, name) {
 // 8.1.5.1 Event handlers - basically `on[eventName]` attributes
 ObjectDefineProperty(emitter, `on${name}`, {
 get() {
- return eventHandlerValueMap.get(this)?.get(name);
+ return this[kHandlers]?.get(name);
 },
 set(value) {
- const oldValue = eventHandlerValueMap.get(this)?.get(name);
+ const oldValue = this[kHandlers]?.get(name);
 if (oldValue) {
 this.removeEventListener(name, oldValue);
 }
 if (typeof value === 'function') {
 this.addEventListener(name, value);
 }
- if (!eventHandlerValueMap.has(this)) {
- eventHandlerValueMap.set(this, new Map());
+ if (!this[kHandlers]) {
+ this[kHandlers] = new SafeMap();
 }
- eventHandlerValueMap.get(this).set(name, value);
+ this[kHandlers].set(name, value);
 },
 configurable: true,
 enumerable: true
diff --git a/lib/internal/worker/io.js b/lib/internal/worker/io.js
@@ -99,8 +99,6 @@ ObjectDefineProperty(
 // This is called from inside the `MessagePort` constructor.
 function oninit() {
 initNodeEventTarget(this);
- defineEventHandler(this, 'message');
- defineEventHandler(this, 'messageerror');
 setupPortReferencing(this, this, 'message');
 }
 

-Original file line number
+Diff line change
 aborted: {enumerable: true}
 });
 +defineEventHandler(AbortSignal.prototype,'abort');
++
 functionabortSignal(signal){
 if(signal[kAborted])return;
 signal[kAborted]=true;
 constructor(){
 this[kSignal]=newAbortSignal();
 emitExperimentalWarning('AbortController');
 -defineEventHandler(this[kSignal],'abort');
+}
 getsignal(){returnthis[kSignal];}
-Original file line number
+Diff line change
  ArrayFrom,
  Boolean,
  Error,
 - Map,
  NumberIsInteger,
  Object,
  ObjectDefineProperty,
  ObjectGetOwnPropertyDescriptor,
 + SafeMap,
  String,
  Symbol,
  SymbolFor,
  SymbolToStringTag,
 - SafeWeakMap,
  SafeWeakSet,
 }=primordials;
 constkEvents=Symbol('kEvents');
 constkStop=Symbol('kStop');
 constkTarget=Symbol('kTarget');
 +constkHandlers=Symbol('khandlers');
 constkHybridDispatch=Symbol.for('nodejs.internal.kHybridDispatch');
 constkCreateEvent=Symbol('kCreateEvent');
+}
 functioninitEventTarget(self){
 -self[kEvents]=newMap();
 +self[kEvents]=newSafeMap();
+}
 classEventTarget{
 process.emit('error',err,event);
+}
 -// A map of emitter -> map of name -> handler
 -consteventHandlerValueMap=newSafeWeakMap();
+-
 functiondefineEventHandler(emitter,name){
 // 8.1.5.1 Event handlers - basically `on[eventName]` attributes
 ObjectDefineProperty(emitter,`on${name}`,{
 get(){
 -returneventHandlerValueMap.get(this)?.get(name);
 +returnthis[kHandlers]?.get(name);
 },
 set(value){
 -constoldValue=eventHandlerValueMap.get(this)?.get(name);
 +constoldValue=this[kHandlers]?.get(name);
 if(oldValue){
 this.removeEventListener(name,oldValue);
+}
 if(typeofvalue==='function'){
 this.addEventListener(name,value);
+}
 -if(!eventHandlerValueMap.has(this)){
 -eventHandlerValueMap.set(this,newMap());
 +if(!this[kHandlers]){
 +this[kHandlers]=newSafeMap();
+}
 -eventHandlerValueMap.get(this).set(name,value);
 +this[kHandlers].set(name,value);
 },
 configurable: true,
 enumerable: true
Original file line number	Diff line number	Diff line change
`@@ -99,8 +99,6 @@ ObjectDefineProperty(`
`99`	`99`	// This is called from inside the `MessagePort` constructor.
`100`	`100`	`functiononinit(){`
`101`	`101`	`initNodeEventTarget(this);`
`102`		`-defineEventHandler(this,'message');`
`103`		`-defineEventHandler(this,'messageerror');`
`104`	`102`	`setupPortReferencing(this,this,'message');`
`105`	`103`	`}`
`106`	`104`