X-Git-Url: http://git.indexdata.com/?a=blobdiff_plain;f=kernel%2Fmain.c;fp=kernel%2Fmain.c;h=daa054a71730d2d0e79f24afb0cc3e211ff2eefe;hb=272f54128f5b48a61b2aa6dbb7859eca1c1296ae;hp=8a5971c559c769ccb5605aaf7036b689bae12112;hpb=fe54a68aa1e684599c052bee6eca94c7a071d128;p=egate.git

diff --git a/kernel/main.c b/kernel/main.c
index 8a5971c..daa054a 100644
--- a/kernel/main.c
+++ b/kernel/main.c
@@ -2,7 +2,10 @@
  * Europagate, 1995
  *
  * $Log: main.c,v $
- * Revision 1.22  1995/05/03 07:37:39  adam
+ * Revision 1.23  1995/05/03 16:34:18  adam
+ * CCL def command, i.e. user definitions - saved as resource files.
+ *
+ * Revision 1.22  1995/05/03  07:37:39  adam
  * CCL commands stop/continue implemented. New functions gw_res_{int,bool}
  * are used when possible.
  *
@@ -96,7 +99,7 @@ FILE *reply_fd = stdout;
 
 struct gw_kernel_info info;
 
-static void kernel_events (struct str_queue *queue, int userid)
+static void kernel_events (struct str_queue *queue)
 {
     char fifo_client_name[1024];
     char fifo_server_name[1024];
@@ -114,8 +117,8 @@ static void kernel_events (struct str_queue *queue, int userid)
     timeout = gw_res_int (info.kernel_res, "gw.timeout", 600);
     gw_log (GW_LOG_DEBUG, KERNEL_LOG, "event loop");
 
-    sprintf (fifo_client_name, "fifo.c.%d", userid);
-    sprintf (fifo_server_name, "fifo.s.%d", userid);
+    sprintf (fifo_client_name, "fifo.c.%d", info.userid);
+    sprintf (fifo_server_name, "fifo.s.%d", info.userid);
 
     gip = gips_initialize (fifo_server_name);
     gips_open (gip, fifo_client_name);
@@ -141,7 +144,7 @@ static void kernel_events (struct str_queue *queue, int userid)
 	    gw_log (GW_LOG_STAT, KERNEL_LOG, "Timeout after %d seconds", 
 	    	    timeout);
 	    if (info.zass && persist_flag)
-	        save_p_state (userid);
+	        save_p_state (info.userid);
 	    break;
 	}
 	if (FD_ISSET (gip_fd, &set_r))
@@ -163,10 +166,10 @@ static void kernel_events (struct str_queue *queue, int userid)
                     str_queue_enq (queue, line_buf);
 		urp_start (continuation, queue);
                 if (persist_flag && !continuation)
-		    load_p_state (userid);	
+		    load_p_state (info.userid);	
 		r = urp_command (queue);
 		if (persist_flag && r == 1)
-		    del_p_state (userid);
+		    del_p_state (info.userid);
 		urp_end ();
                 while (str_queue_deq (queue, 0, 0))
                     ;
@@ -186,13 +189,13 @@ static void kernel_events (struct str_queue *queue, int userid)
     close (extra_fd);
     gips_close (gip);
     gips_destroy (gip);
+
     unlink (fifo_client_name);
     unlink (fifo_server_name);
 }
 
 int main (int argc, char **argv)
 {
-    int userid = -1;
     struct str_queue *queue;
 
     info.kernel_res = NULL;
@@ -208,6 +211,7 @@ int main (int argc, char **argv)
     info.databases = NULL;
     info.database = NULL;
     info.setno = -1;
+    info.userid = -1;
 #if USE_FML
     info.fml = NULL;
 #endif
@@ -327,11 +331,11 @@ int main (int argc, char **argv)
                 break;
 	    case 'i':
                 if (argv[0][2])
-		    userid = atoi (argv[0]+2);
+		    info.userid = atoi (argv[0]+2);
                 else if (argc > 0)
                 {
                     --argc;
-		    userid = atoi (*++argv);
+		    info.userid = atoi (*++argv);
                 }
                 else
                 {
@@ -352,10 +356,10 @@ int main (int argc, char **argv)
         gw_log (GW_LOG_FATAL|GW_LOG_ERRNO, KERNEL_LOG, "str_queue_mk");
         exit (1);
     }
-    if (userid != -1)
+    if (info.userid != -1)
     {
 	read_kernel_res ();
-        kernel_events (queue, userid);
+        kernel_events (queue);
     }
     else
     {
@@ -459,6 +463,7 @@ void read_kernel_res (void)
         gw_log (GW_LOG_DEBUG, KERNEL_LOG, "reading kernel resource, lang %s",
                 info.lang);
 
+    /* read default resources. These should exist */
     if (gw_res_merge (info.kernel_res, info.default_res))
     {
         gw_log (GW_LOG_WARN, KERNEL_LOG, "Couldn't read resource file %s",
@@ -467,6 +472,7 @@ void read_kernel_res (void)
     }
     strcpy (path_prefix, gw_res_get (info.kernel_res, "gw.path", "."));
     
+    /* fetch target definitions (if defined at all) */
     if (*info.target)
     {
         sprintf (resource_name, "gw.target.%s", info.target);
@@ -477,9 +483,17 @@ void read_kernel_res (void)
             gw_res_merge (info.kernel_res, fname);
         }
     }
-    if (info.lang)
+    /* fetch user definitions (if user-id is specified) */
+    if (info.userid >= 0)
+    {
+        sprintf (fname, "%s/user.%d.r", path_prefix, info.userid);
+        gw_res_merge (info.kernel_res, fname);
+    }
+    /* fetch language definitions (if specified at all) */
+    v = gw_res_get (info.kernel_res, "gw.language", info.lang);
+    if (v)
     {
-        sprintf (resource_name, "gw.lang.%s", info.lang);
+        sprintf (resource_name, "gw.lang.%s", v);
         v = gw_res_get (info.kernel_res, resource_name, NULL);
         if (v)
         {
@@ -487,11 +501,14 @@ void read_kernel_res (void)
             gw_res_merge (info.kernel_res, fname);
         }
     }
+    /* fetch overriding resources from file (if specified) */
     if (info.override_res)
     {
         sprintf (fname, "%s/%s", path_prefix, info.override_res);
         gw_res_merge (info.kernel_res, fname);        
     }
+
+    /* read bibset definition for ccl */
     v = gw_res_get (info.kernel_res, "gw.bibset", NULL);
     if (v)
     {
@@ -508,10 +525,12 @@ void read_kernel_res (void)
             fclose (bib_inf);
         }
     }
+
+    /* determine host name and port no */
     sprintf (resource_name, "gw.target.%s", info.target);
     if (*info.target && ! gw_res_get (info.kernel_res, resource_name, NULL))
     {
-        /* target is there, and there is no sub-resource for it... */
+        /* target is specified, and there is no sub-resource for it... */
         const char *split;
 
         if ((split = strchr (info.target, ':')))
@@ -527,13 +546,15 @@ void read_kernel_res (void)
         }
     }
     else
-    {
+    {   /* resources gw.hostname and gw.portno will be used */
         strncpy (info.hostname, gw_res_get (info.kernel_res,
                                             "gw.hostname", "localhost"),
                  sizeof(info.hostname)-1);
         info.port = gw_res_int (info.kernel_res, "gw.portno", 210);
         strcpy (info.account, gw_res_get (info.kernel_res, "gw.account", ""));
     }
+    /* set info.databases (all available databases for target) */
+    /* set info.database (first database for target) */
     if (info.databases)
         free (info.databases);
     if (info.database)
@@ -560,11 +581,17 @@ void read_kernel_res (void)
         for (cp = info.database; (cp = strchr (cp, ' ')); cp++)
             *cp = ',';
     }
+
+    /* the port no can be explicitly overridden by a command line option */
     if (info.override_portno)
         info.port = atoi (info.override_portno);
+
+    /* the hostname can be explicitly overridden by a command line option */
     if (info.override_hostname)
         strncpy (info.hostname, info.override_hostname,
                  sizeof(info.hostname)-1);
+
+    /* determine if more than one result-set names is supported */
     if (gw_res_bool (info.kernel_res, "gw.result.set", 1))
         info.setno = 0;
     else