Merge pull request #9 from sipcapture/feature_backpressure

Feature backpressure

Author: Dletta

src/connectionManager.js

@@ -66,12 +66,14 @@ const connectionManager = {
                     close(socket, error) {
                         if (error) {
                             console.error('Connection closed with error:', error);
+                            connectionManager.establishConnection(connectionManager.mediator);
                         } else {
                             if (connectionManager.debug) console.log('Connection closed gracefully');
+                            connectionManager.establishConnection(connectionManager.mediator);
                         }
                     },
                     drain(socket) {
-                        if (connectionManager.debug) console.log('Socket buffer drained');
+                        if (connectionManager.debug) console.log('!!! Socket buffer drained');
                     },
                     error(socket, error) {
                         console.error('Socket error:', error);
@@ -82,14 +84,20 @@ const connectionManager = {
                     }, // connection failed
                     end(socket) {
                         if (connectionManager.debug) console.log('Connection ended by server');
+                        connectionManager.establishConnection(connectionManager.mediator);
                     }, // connection closed by server
                     timeout(socket) {
                         if (connectionManager.debug) console.log('Connection timed out');
+                        connectionManager.establishConnection(connectionManager.mediator);
                     }, // connection timed out
                 },
             });
             connectionManager.sendData = (data) => {
-                connectionManager.socket.write(data);
+                let success = connectionManager.socket.write(data);
+                if (connectionManager.debug) console.log(`Data sent over TCP: ${success}`);
+                if (!success) {
+                    console.log('TCP socket buffer full, waiting for drain event');
+                }
             };
             if (connectionManager.debug) console.log(`Ready to send data over TCP.`);
             return true;

src/hepModule.js

@@ -100,7 +100,6 @@ const hepModule = {
 
         return hepJs.encapsulate(inviteRaw.join(''), rcinfo)
     },
-    /* TODO: Add 403, Add RTCP, Check bad calls, reduce CPS to 50, increase duration to 240 */
     /**
      * Generate a 407 Proxy Authentication Required
      * @param {string} seq

src/sessionModule.js

@@ -138,7 +138,7 @@ const sessionModule = {
         sessionModule.sessions.push(session);
     },
     advanceSessions: () => {
-        console.log("Current Sessions in Progress:", sessionModule.sessions.length);
+        if (sessionModule.debug) console.log("Current Sessions in Progress:", sessionModule.sessions.length);
         if (sessionModule.sessions.length === 0) {
             sessionModule.mediator.send({type: "noSessions"});
         } else if (sessionModule.sessions.length > 0) {
@@ -150,7 +150,7 @@ const sessionModule = {
                         session.mediaInfo.rtpstart = Date.now();
                         session.mediaInfo.lastReport = Math.floor(Date.now() / 1000);
                     }
-                    session.duration = session.duration + 200; // increment duration by 20 ms
+                    session.duration = session.duration + 200; // increment duration by 200 ms
                     // console.log("checking: ", session.previous, Date.now(), session.previous - Date.now(), session.duration, session.targetDuration);
                     /* Handle Media */
                     if (session.duration >= session.targetDuration) {