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

Timestamp:

Apr 10, 2006, 10:49:17 PM (18 years ago)

Author:

sswami

Comment:

—

Old/NodeHandler/Broadcast

@@ -108 +108 @@
 messages through a pipe instead of a socket. Also, access to the pipe will be serialized. The 
 Communication Server is a 2-threaded process.
+
+'''Note: '''
+This is a first test implementation. The final implementation will have multiple TCP 
+connections - one for each NodeAgent. Also, all issues relating to message size will be 
+investigated.
 
 '''NodeHandler Communication Server'''
@@ -131 +136 @@
        END IF
        Setup ACK list
-       WHILE (ACK_LIST_INCOMPLETE)
+       set flag = true
+       WHILE (flag)
+         lock(ACK_list)
+         IF (ACK_LIST_COMPLETE)
+            flag = false
+            return
+         END IF
          IF (TIMEOUT)
+           lock(pipe_access)
            send(pipe) "TIMEOUT" to NodeHandler
+           unlock(pipe_access)
            break
          END IF
@@ -140 +153 @@
        END WHILE
     END FUNCTION
-  
+
+      
 2. Receiving Thread
    ================
-   create a new TCP connection
+   create a new TCP socket
    bind 
    listen(400)
@@ -153 +167 @@
         update ACK list
         IF (ACK_LIST_COMPLETE)
+           unlock(ACK_list)
            send "WAKEUP" to main thread
         ELSE IF (ACK_LIST_INCOMPLETE && TIMEOUT)
+           unlock(ACK_list)
            send "TIMEOUT" to main thread
         END IF
-        unlock(ACK_list)
+        
      ELSE IF (message == EVENT)
+        lock(pipe_access)
         send(pipe) message to NodeHandler
+        unlock(pipe_access)
      END IF
+     close(connection)
    END WHILE
 }}}
@@ -170 +189 @@
 1. MAIN THREAD
    ===========
+   create a TCP connection
    create the new Broadcast Client socket  
-   create the receiving thread            /* this thread will send TCP message */
+   create the receiving thread and pass TCP sockfd  /* 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 ACK message to the NodeHandler COmmunication Server
           send(pipe) message to the NodeAgent
        END IF
@@ -183 +203 @@
 2. RECEIVING THREAD
    ================
-   create a TCP connection
+   
    WHILE (true)
-       recv(pipe) message from the NodeAgent / Main Thread
+       recv(pipe) message from the NodeAgent
        Send message to the NodeHandler COmmunication Server
    END WHILE