Changes between Version 4 and Version 5 of Old/NodeHandler/Broadcast

Timestamp:

Apr 10, 2006, 9:35:00 PM (18 years ago)

Author:

sswami

Comment:

—

Old/NodeHandler/Broadcast

@@ -106 +106 @@
 
 The NodeHandler on startup will open the required pipes and then fork the Communication Server
-process. The Communication Server is a 2-threaded process. Following is the algorithm for this 
-process functionality:
+process. The Communication Server is a 2-threaded process. Following is the pseudo-code for 
+this process functionality:
 
 {{{
-1.  
-2. 
+1.  ''Main Thread''
+    create the new receiving thread       /* this thread (2.) will receive TCP message */
+    WHILE (true)
+       message = recv(pipe)               /* receive message from NodeHandler*/
+       IF (messgage != "SHUTDOWN") 
+           SendReliableBroadcast(message)
+       ELSE
+           initiate graceful shutdown
+       END IF
+    END WHILE
 
+    FUNCTION SendReliableBroadcast(message)
+       IF (first invocation)              /* sp that the Socket is created only once */
+          open a new Broadcast Server Socket
+       END IF
+       Setup ACK list
+       WHILE (ACK_LIST_INCOMPLETE)
+         sendto(BROADCAST_ADDR, message)  /* send/resend the message */
+         sleep(50ms)
+       END WHILE
+    END FUNCTION
+  
+2. ''Receiving Thread''
+   create a new TCP connection
+   bind 
+   listen(400)
+   WHILE (true)
+     accept(a connection)
+     read(message)
+     IF (message == ACK)
+        lock(ACK_list)
+        update ACK list
+        IF (ACK_LIST_COMPLETE)
+           send "WAKEUP" to main thread
+        ELSE IF (ACK_LIST_INCOMPLETE && TIMEOUT)
+           send "TIMEOUT" to main thread
+        END IF
+        unlock(ACK_list)
+     ELSE IF (message == EVENT)
+        send(pipe) message to NodeHandler
+     END IF
+   END WHILE
 }}}