select: Allow registering cleanup method for the callback

This commit adds the registerCleanupFunc method for the callback
passed to the stream implementation. It allows the stream
implementation to optionally register a cleanup function that will be
invoked when select is no longer interested in the stream events. This
enables the stream implementation to perform additional cleanups such
as discarding the reference to the event callback.

Signed-off-by: Kohei Tokunaga <ktokunaga.mail@gmail.com>

Author: ktock

src/lib/libsyscall.js

@@ -665,6 +665,7 @@ var SyscallsLibrary = {
     const pthread_ptr = PThread.currentProxiedOperationCallerThread;
     deactivateSelectCallbacks(pthread_ptr); // deactivate all old callbacks
     var makeNotifyCallback = (fd) => null;
+    var cleanupFuncs = [];
     if (timeoutInMillis != 0) {
       var info = getActiveSelectCallbacks(pthread_ptr);
       {{{ makeSetValue('waitPtr', 0, 'info.buf', '*') }}};
@@ -675,10 +676,14 @@ var SyscallsLibrary = {
             return; // This callback is no longer active.
           }
           deactivateSelectCallbacks(pthread_ptr); // Only the first event is notified.
+          cleanupFuncs.forEach(cb => cb());
           Atomics.store(HEAP32, info.buf >> 2 + 1, flags);
           Atomics.store(HEAP32, info.buf >> 2, fd);
           Atomics.notify(HEAP32, info.buf >> 2);
         }
+        cb.registerCleanupFunc = (f) => {
+          if (f != null) cleanupFuncs.push(f);
+        }
         activateSelectCallback(pthread_ptr, cb);
         return cb;
       }
@@ -716,6 +721,7 @@ var SyscallsLibrary = {
       fdSet.commit(fd, flags);
       // No wait will happen in the caller. Deactivate all callbacks.
       deactivateSelectCallbacks(pthread_ptr);
+      cleanupFuncs.forEach(f => f());
     }
 #else
     fdSet.commit(fd, flags);