Changeset 682 for trunk/user/init/init.c

Timestamp:

Jan 3, 2021, 11:32:52 PM (3 years ago)

Author:

alain

Message:

Introduce three new applications:

• windows : to test the FBF windows kernel manager
• udp_chat : chat application based on UDP sockets.
• tcp_chat : chat application based on TCP sockets (including packet loss recovery).

File:

• trunk/user/init/init.c (modified) (7 diffs)

trunk/user/init/init.c

@@ -7 +7 @@
 // It uses the fork/exec syscalls to create N KSH child processes 
 // (one child process per user TXT terminal).
-// Then calls the wait() function to block, and recreate any child KSH process
+// Then it calls the wait() function to block, and recreate any child KSH process
 // that has been deleted, using a new fork/exec.
 ///////////////////////////////////////////////////////////////////////////////////////
@@ -31 +31 @@
     int           status;        // used by the wait syscall
     char          string[64];    // log messages on kernel TXT0
+    unsigned int  cxy;           // target cluster identifier
 
 #if DEBUG_PROCESS_INIT
@@ -36 +37 @@
 #endif
 
-    // get number of TXT channels from hard configuration
+    // get number of TXT channels and number of clusters
     hard_config_t config;      
 
@@ -42 +43 @@
 
     unsigned int  txt_channels = config.txt_channels;
+    unsigned int  x_size       = config.x_size;
+    unsigned int  y_size       = config.y_size;
+    unsigned int  n_clusters    = x_size * y_size;
 
     // check number of TXT channels
@@ -52 +56 @@
     }
 
+    cxy = 0;
+
     // create the KSH processes (one per user terminal)
     for( i = 1 ; i <  txt_channels ; i++ )
     {
+        // compute target cluster
+        cxy = (cxy + 1) % n_clusters;
+
+        // select target cluster
+        if( place_fork( cxy ) )
+        {
+            // INIT display error message  
+            snprintf( string , 64 , 
+            "\n[init ERROR] cannot place fork for child[%d] => suicide" , i );
+            display_string( string );
+
+            // INIT suicide
+            exit( EXIT_FAILURE );
+        }
+
+
         // INIT process fork process CHILD[i]
         ret_fork = fork();
@@ -94 +116 @@
             // INIT display CHILD[i] process PID
             snprintf( string , 64 ,
-            "\n[init] (pid 0x1) create ksh[%d] (pid %x)", i , ret_fork ); 
-            display_string( string );
-
-            // wait signal from KSH[i] before creating KSH[i+1]
-            pause();
+            "[init] (pid 0x1) create ksh[%d] (pid %x)", i , ret_fork ); 
+            display_string( string );
         }
     } 
@@ -104 +123 @@
 #if DEBUG_PROCESS_INIT
 {
+    // keep blocked for 2 seconds
+    // to allow all KSH[i] process 
+    // to be launched before display 
+
+    sleep( 2 );
+
     unsigned int  x;             // cluster x coordinate
     unsigned int  y;             // cluster y coordinate