Changes between Version 9 and Version 10 of Old/NodeHandler/Broadcast

Timestamp:

Apr 10, 2006, 10:10:26 PM (18 years ago)

Author:

sswami

Comment:

—

Old/NodeHandler/Broadcast

@@ -132 +132 @@
        Setup ACK list
        WHILE (ACK_LIST_INCOMPLETE)
+         IF (TIMEOUT)
+           send(pipe) "TIMEOUT" to NodeHandler
+           break
+         END IF
          sendto(BROADCAST_ADDR, message)  /* send/resend the message */
          sleep(50ms)
@@ -137 +141 @@
     END FUNCTION
   
-2. ''Receiving Thread''
-   ===================
+2. Receiving Thread
+   ================
    create a new TCP connection
    bind 
@@ -162 +166 @@
 '''NodeAgent Communication Server'''
 
+Following is the pseudo-code for this process functionality:
 {{{
+1. MAIN THREAD
+   ===========
+   create the new Broadcast Client socket  
+   create the receiving thread            /* this thread will send TCP message */
+    WHILE (true)
+       message = recvfrom(socket)         /* receive message from NodeHandler*/
+       IF (message for this NodeAgent)
+          construct ACK message
+          send(pipe) ACK message to receiving thread
+          send(pipe) message to the NodeAgent
+       END IF
+    END WHILE
 
+2. RECEIVING THREAD
+   ================
+   create a TCP connection
+   WHILE (true)
+       recv(pipe) message from the NodeAgent / Main Thread
+       Send message to the NodeHandler COmmunication Server
+   END WHILE
+   
 }}}