开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 数据库系统 > SQL Server > 查看源码
adm.c
资源名称：gnusql-0.7b5.1.tar.gz　[点击查看]
上传用户：dgyhgb
上传日期：2007-01-07
资源大小：676k
文件大小：34k
源码类别：

SQL Server

开发平台：

Unix_Linux

adm.c：源码内容
  1. /*
  2.  * adm.c - Storage and Transaction Synchrohization Management 
  3.  *         System Administrator of GNU SQL server
  4.  *
  5.  * This file is a part of GNU SQL Server
  6.  *
  7.  * Copyright (c) 1996, 1997, Free Software Foundation, Inc
  8.  * Developed at the Institute of System Programming 
  9.  * This file is written by Vera Ponomarenko
  10.  *
  11.  * This program is free software; you can redistribute it and/or modify it under
  12.  * the terms of the GNU General Public License as published by the Free
  13.  * Software Foundation; either version 2 of the License, or (at your option)
  14.  * any later version.
  15.  *
  16.  * This program is distributed in the hope that it will be useful, but WITHOUT
  17.  * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
  18.  * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License for
  19.  * more details.
  20.  *
  21.  * You should have received a copy of the GNU General Public License along with
  22.  * this program; if not, write to the Free Software Foundation, Inc.,
  23.  * 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
  24.  *
  25.  * Contacts: gss@ispras.ru
  26.  *
  27.  */
  29. /* $Id: adm.c,v 1.248 1997/04/19 17:10:54 kml Exp $ */
  31. #include <setup_os.h>
  33. #ifdef HAVE_UNISTD_H
  34. #include <unistd.h>
  35. #endif
  37. #include <sys/types.h>
  38. #include <sys/times.h>
  40. #ifdef HAVE_SYS_IPC_H
  41. #include <sys/ipc.h>
  42. #endif
  44. #ifdef HAVE_SYS_MSG_H
  45. #include <sys/msg.h>
  46. #endif
  48. #if STDC_HEADERS
  49. #include <string.h>
  50. #endif
  52. /* for uname */
  53. #if HAVE_UNAME
  54. #include <sys/utsname.h>
  55. #endif
  57. #include <signal.h>
  58. #if HAVE_SYS_WAIT_H
  59. #include <sys/wait.h>
  60. #endif
  62. #if TIME_WITH_SYS_TIME
  63. # include <sys/time.h>
  64. # include <time.h>
  65. #else
  66. # if HAVE_SYS_TIME_H
  67. #  include <sys/time.h>
  68. # else
  69. #  include <time.h>
  70. # endif
  71. #endif
  73. #if HAVE_FCNTL_H 
  74. #include <fcntl.h>
  75. #endif
  77. #include "dispatch.h"
  78. #include "global.h"
  79. #include "rnmtp.h"
  80. #include "pupsi.h"
  81. #include "inpop.h"
  82. #include "expop.h"
  83. #include "adfstr.h"
  84. #include "rcvutl/puprcv.h"
  85. #include "totdecl.h"
  87. #define GDBINIT_FILE ".gdb"
  88. #define EXIT  finit(1)
  90. #define PRINT(x, y) /*printf(x,y);*/
  92. /* maximum of time for waiting exiting of all transactions */
  93. #define KILL_WAIT 10 
  95. #define nul     0xffff
  96. #define EOTLJ   0 /* end of transaction */
  98. #include "strml.h"
  100. struct msg_buf  sbuf;
  101. struct msg_buf  rbuf;
  102. struct des_trn *tabtr = NULL;
  105. #define TRN_SEND_NEED
  106. #include "admdef.h"
  107. #undef TRN_SEND_NEED
  109. #include "gspstr.h"
  111. extern i4_t errno, default_num;
  113. debug_pid_t volatile *debuggers_pids = NULL;
  115. i4_t sbuf_sz, rbuf_sz;
  116. pid_t adm_pid;          /* proc id of administrator                       */
  118. char nocrtr_fl = 0;     /* = 1 if dispatcher may not create a transaction */
  119. char finit_fl  = 0;     /* = 1 if after last transaction finish           */
  120.         /*     dispatcher ought to exit                   */
  121. char fix_lj_fl = 0;     /* = 1 if after last transaction finish           */
  122.         /*     dispatcher ought to fix log journal        */
  123. char *fix_path = NULL;  /* path to fix log journal                        */
  125. key_t keyadm, keylj, keymj, keybf, keymcr, keysn, keysr, *keytrn = NULL;
  126. i4_t   fdlj, fdaf, fdto;
  127. volatile pid_t pidlj = 0, pidmj = 0, pidbf = 0, pidsn = 0, pidsr = 0, pidmcr = 0;
  129. volatile i4_t finit_done = 0;
  130. volatile i4_t children   = 0;
  132. i4_t msgida = -1, msgidl = -1, msgidm = -1, msgidb = -1;
  133. i4_t msgidc = -1, msgids = -1, msgidq = -1;
  136. #define  adfsize sizeof(struct ADF)
  138. struct ADF p2;
  139. u2_t *ext_ids = NULL; /* extent numbers            */
  140. u2_t *trn_ids = NULL; /* transaction numbers       */
  141. i4_t    transaction_number;      /* active transaction number */
  142. i4_t    freext;
  143. i4_t    maxtrans, maxusetran, maxext, maxfrext;
  144. i4_t    sizext; /* extent-size in block      */
  145. u2_t  sizesc; /* scale-size in block       */
  146. i4_t   uidconst;
  147. i4_t   unname;
  148. i4_t   nunname;
  149. i4_t    rfile; /* file-size in blocks for temporary object
  150.    file */
  151. i4_t   uidt;
  152. i4_t   idt;
  153. i4_t   minid;
  154. i4_t    numtr;
  155. i4_t    rjzm, rjzl, mpagem, mpagel;
  156. i4_t   vnlj;
  158. extern void  sig_usr_hnd  __P((i4_t sig_num));
  159. extern i4_t   cp_lj_reg  __P((i4_t to_sz, char *to));
  160. extern void  finit  __P((i4_t err));
  161. static i4_t   ini  __P((void));
  162. static u2_t getext  __P((u2_t));
  163. void  kill_all (i4_t err);
  165. static void
  166. adm_exit(void)
  167. {
  168.   finit(0);
  169. }
  171. void
  172. main (i4_t argc,char *argv[])
  173. {
  174.   struct sigaction act;
  175.   sigset_t set;
  177.   printf ("n   GNU SQL server (version %s on %s)",VERSION,HOST);
  178.   printf ("n   Copyright (c) 1996, 1997 Free Software Foundation, Inc.nn");
  179.   
  180.   fix_adm_port(argv[1]); /* argv[1] is adm rpc program identifier */
  181.   
  182.   adm_pid = getpid();
  183.   
  184.   sigemptyset (&set);
  185.   sigaddset (&set, SIGUSR1);
  186.   sigaddset (&set, SIGCHLD);
  187.   
  188. #if HAVE_ATEXIT
  189.   atexit(adm_exit);
  190. #elif HAVE_ON_EXIT
  191.   on_exit(adm_exit);
  192. #endif
  193.   
  194. #if 0 /*SA_SIGINFO*/
  195.   act.sa_handler   = NULL;
  196.   act.sa_mask      = set;
  197.   act.sa_flags     = SA_SIGINFO;
  198.   act.sa_sigaction = sig_usr_hnd;
  199. #else
  200.   act.sa_handler   = sig_usr_hnd;
  201.   act.sa_mask      = set;
  202.   act.sa_flags     = 0;
  203. #endif
  204.   
  205.   if (sigaction (SIGUSR1, &act, NULL) ||
  206.       sigaction (SIGCHLD, &act, NULL) ||
  207.       sigaction (SIGALRM, &act, NULL)   )
  208.     EXIT;
  209.   
  210.   sbuf_sz = rbuf_sz = BD_PAGESIZE;
  211.   
  212.   setbuf (stdout, NULL);
  213.   
  214.   ini ();
  216.   printf ("n<<<<<  Server is ready >>>>>>n");
  217.   ADM_RPC_START; /* rpcgen generated main */
  218.   /* unreachable */
  219. } /* main */
  221. static u2_t 
  222. getext (u2_t num)
  223. {
  224.   register i4_t i, j;
  225.   char found = 0;
  227.   if (freext != 0)
  228.     for (i = 0; i < maxext; i++)
  229.       if (!(trn_ids[i]) && ext_ids[i] != nul)
  230. {
  231.   trn_ids[i] = num;
  232.           freext--;
  233.           PRINTF(("ADM.getext: freext = %d, fpn = %dn", freext, ext_ids[i]));
  234.   return (ext_ids[i]);
  235. }
  236.   
  237.   for (i = 0; i < maxext; i++) /* new extent is needing */
  238.     if (!(trn_ids[i]) && ext_ids[i] == nul)
  239.       {
  240. found++;
  241. break;
  242.       }
  243.   
  244.   if (!found)
  245.     {
  246.       i = maxext;
  247.       maxext *=2;
  248.       ext_ids = (u2_t *) xrealloc (ext_ids, maxext * sizeof(u2_t));
  249.       trn_ids = (u2_t *) xrealloc (trn_ids, maxext * sizeof(u2_t));
  250.       for (j = i; j < maxext; j++)
  251. {
  252.   ext_ids[j] = nul;
  253.   trn_ids[j] = 0;
  254. }
  255.     }
  256.       
  257.   ext_ids[i] = rfile / BD_PAGESIZE;
  258.   rfile += sizext * BD_PAGESIZE;
  259.   trn_ids[i] = num;
  260.   PRINTF(("ADM.getext: freext = %d, fpn = %d, rfile = %dn",
  261.           freext, ext_ids[i], rfile));
  262.   return (ext_ids[i]);
  263. }
  265. static void 
  266. putext (i4_t exnum, u2_t *mfpn)
  267. {
  268.   register i4_t i, j;
  269.   u2_t fpn;
  270.   
  271.   for (i = 0, fpn = *mfpn; i < exnum; i++, fpn = mfpn[i])
  272.     for (j = 0; j < maxext; j++)
  273.       if (fpn == ext_ids[j] && trn_ids[j])
  274. {
  275.           PRINTF(("ADM.putext: exnum=%d, fpn = %dn",exnum, fpn));
  276.   trn_ids[j] = 0;
  277.   freext++;
  278.   break;
  279. }
  280. }
  282. static void 
  283. iamm (u2_t num) /* I'm modifying transaction */
  284. {
  285.   tabtr[num].uidtr = uidt++;
  286.   if (uidt == idt)
  287.     {
  288.       idt += uidconst;
  289.       p2.uid = idt;
  290.       if (lseek (fdaf, 0, SEEK_SET) < 0)
  291. {
  292.   perror ("ADM.lseek: lseek admfile");
  293.   return;
  294. }
  295.       if (write (fdaf, (char *) &p2, adfsize) != adfsize)
  296. {
  297.   perror ("ADMFILE");
  298.   return;
  299. }
  300.     }
  301. }
  303. static void 
  304. uniqnm (u2_t num)
  305. {
  306.   unname++;
  307.   if(unname == nunname)
  308.     {
  309.       nunname += uidconst;
  310.       p2.unname= unname;
  311.       if(lseek(fdaf,0,SEEK_SET) <0 )
  312.         {
  313.           perror("ADM.lseek: lseek admfile");
  314.           exit(1);
  315.         }
  316.       if(write(fdaf,(char *)&p2,adfsize) !=adfsize)
  317.         {
  318.           perror("ADMFILE");
  319.           exit(1);
  320.         }
  321.     }
  322.   PRINTF (("ADM.uniqnm.e: NUM=%d,UNNAME=%dn", num, (i4_t)unname));
  323. }
  325. /* ? ? write to logic log "end of transaction" mark.
  326.  *    "num" - transaction identifier
  327.  */
  328. static void 
  329. wljetr (u2_t num)
  330. {
  331.   register i4_t i, blsz;
  332.   register char *pnt;
  333.   i4_t uid;
  335.   PRINTF (("ADM.wljet.b: numtr=%d, FIR_TRN_NUM = %d, maxusetran = %dn",
  336.           num, FIR_TRN_NUM, maxusetran));
  337.   t2bpack (num + CONSTTR, sbuf.mtext);
  338.   pnt = sbuf.mtext + sizeof(u2_t) + sizeof(u2_t);
  339.   *pnt++ = EOTLJ;
  340.   for (i = FIR_TRN_NUM, blsz = 1; i <= maxusetran; i++)
  341.     {
  342.       uid = tabtr[i].uidtr;
  343.       if ((uid != 0) && (i != num))
  344. {
  345.           t4bpack (uid, pnt);
  346.           pnt +=sizeof(i4_t);
  347.           blsz += sizeof(i4_t);
  348. }
  349.     }
  350.   sbuf.mtype = PUTOUT;
  351.   t2bpack (blsz, sbuf.mtext + sizeof(u2_t));
  352.   if (msgsnd (msgidl, (MSGBUFP)&sbuf, sizeof(u2_t) + sizeof(u2_t) + blsz, 0) < 0)
  353.     {
  354.       perror ("ADM.msgsnd: LOGJ->PUTOUT");
  355.       return;
  356.     }
  357.   PRINTF (("ADM.wljet.e: recsize=%dn", blsz));
  358. } /* wljetr */
  360. #define NUMTR_DEC 
  361. { numtr--; if (maxusetran==numtr) for(;!(tabtr[maxusetran].idprtr);maxusetran--);}
  363. void 
  364. endotr (i2_t num,i4_t exit_code)
  365. {
  366.   register i4_t i, msgid;
  367.   struct msqid_ds msqidds;
  368.   i4_t all_done, work_ext = 0;
  369.   i4_t pr = 0;
  371.   if(exit_code)
  372.     {
  373.       PRINT ("ADM.endotr: some recovery for trn %d must be heren", num);
  374.       kill_all(-1); /* stops everything and restart services with MCR */
  375.     }
  376.   if (tabtr[num].uidtr == minid)
  377.     { /* if fiinished transaction has minID identifier */
  378.       tabtr[num].uidtr = 0;
  379.       for (i = FIR_TRN_NUM; i <= maxusetran; i++) /* search new minID */
  380.         if (tabtr[i].uidtr != 0)
  381.           {
  382.             minid = tabtr[i].uidtr;
  383.             for (; i <= maxusetran; i++) /* search new minID */
  384.               if (tabtr[i].uidtr < minid)
  385.                 minid = tabtr[i].uidtr;
  386.             pr = 1;
  387.             break;
  388.           }
  389.       if (pr == 0)
  390.         minid = uidt;
  391.       
  392.       for (i = FIR_TRN_NUM; i <= maxusetran; i++) /*sending of min identifier*
  393.                 *of transaction to all    *
  394.            *modifying transactions   */
  395. if (tabtr[i].uidtr != 0)
  396.   {
  397.     t4bpack (minid, sbuf.mtext);
  398.     TRN_SEND (GETMIT, sizeof(i4_t));
  399.   }
  400.     }
  401.   
  402.   if ((msgid = tabtr[num].msgidtrn))
  403.     {
  404.       msgctl (msgid, IPC_RMID, &msqidds);
  405.       tabtr[num].msgidtrn = 0;
  406.       keytrn[num] = 0;
  408.     }
  409.   
  410.   PRINTF (("ADM.endotr: TRN N=%d uniq_name = %d is killedn",
  411.           num, (i4_t)tabtr[num].uidtr));
  412.   tabtr[num].idprtr = 0;
  413.   NUMTR_DEC;
  414.   
  415.   /* RPC-Unregistration of transaction server */
  416.   SVC_UNREG(DEFAULT_TRN +num, 1); /* Number of version of interpretator & *
  417.                                    * compiler must = 1                    */
  418.   
  419.   tabtr[num].cretime = 0;
  420.   /* return all extents NUM-transaction */
  421.   for (i = 0; i < maxext; i++)
  422.     if (trn_ids[i])
  423.       if (trn_ids[i] == num)
  424. {
  425.   trn_ids[i] = 0;
  426.   freext++;
  427. }
  428.       else
  429. work_ext++;
  430.   
  431.   if (nocrtr_fl)
  432.     {
  433.       all_done = 1;
  434.       
  435.       for (i = FIR_TRN_NUM; i <= maxusetran; i++)
  436. if (tabtr[i].idprtr)
  437.   if (tabtr[i].cretime)
  438.     {
  439.       all_done = 0;
  440.       break;
  441.     }
  442.       
  443.       if (all_done)
  444. {
  445.           nocrtr_fl = 0;
  446.   if (fix_lj_fl)
  447.     copylj();
  448.   if (finit_fl)
  449.     finit(0);
  450. }
  451.     }
  452.   transaction_number--;
  453.   if (transaction_number == 0)
  454.     {
  455.       freext = 0;
  456.       rfile = 0;
  457.       ftruncate (fdto, 0);
  458.     }
  459.   PRINT ("ADM.endotr.e: NUM=%dn", num);
  460.   PRINT ("ADM.endotr.e: NUMTR=%dn", numtr);
  461.   PRINT ("ADM.endotr.e: %d extents still in usen", work_ext);
  462. }
  465. static void 
  466. errfu (char c, char tperr)
  467. {
  468.   char pr;
  469.   PRINTF (("ADM.ERRFU.b: c=%cn", c));
  470.   switch (c)
  471.     {
  472.     case 'm':
  473.       pr = MJ_PPS;
  474.       break;
  475.     case 'l':
  476.       pr = LJ_PPS;
  477.       break;
  478.     case 'b':
  479.       pr = BF_PPS;
  480.       break;
  481.     case 's':
  482.       pr = SN_PPS;
  483.       break;
  484.     case 'q':
  485.       pr = SR_PPS;
  486.       break;
  487.     default:
  488.       break;
  489.     }
  490.   /* OUT_ERR(tperr,pr,0); */
  491. }
  493. static void 
  494. copy (void)
  495. {
  496.   char file_name[1024];
  497.   char arr[32];
  499.   PRINTF (("ADM.COPY.b:n"));
  501.   sprintf (arr, "%d", (i4_t)vnlj);
  502.   strcpy (file_name, ARCHIVE);
  503.   strcat (file_name, "/ljour.");
  504.   strcat (file_name, arr);
  505.   
  506.   cp_lj_reg (strlen (file_name), file_name);
  508.   PRINTF (("ADM.COPY.e: %sn", file_name));
  509. }
  511. static void 
  512. nobuf (void)
  513. {
  514.   printf ("ADM.NOBUF: BUF doesn't get buffern");
  515. }
  517. void 
  518. realop (i4_t op, u2_t num, char *b)
  519. {
  520.   u2_t fpn;
  521.   sigset_t set;
  522.   
  523.   PRINT ("ADM.realop: op  = %dn", op )
  524.   /* sleep (2);   @ need to delete @ */
  525.   PRINT ("ADM.realop: NUM = %dn", (i4_t)num)
  526.     
  527.   if (!op)
  528.     return;
  529.   
  530.   PRINT ("ADM.realop: op  = %dn", op )
  531.    sigprocmask (0, NULL, &set);
  532.   PRINT ("ADM.realop: presence flag of SIGUSR1: %dn", sigismember(&set, SIGUSR1)) 
  533.   
  534.   switch (op)
  535.     {
  536.     case RES_READY :
  537.       if (tabtr[num].res_ready == 2) /* it was request from client */
  538. tabtr[num].res_ready = 1;
  539.       break;
  540.     case PUTEXT:
  541.       PRINT ("ADM.realop: before putext: msgidtrn = %dn",
  542.      (i4_t)tabtr[num].msgidtrn)
  543.       putext (t2bunpack (b), (u2_t *) (b + sizeof(u2_t)));
  544.       PRINT ("ADM.realop: after putext: msgidtrn = %dn",
  545.      (i4_t)tabtr[num].msgidtrn)
  546.       break;
  547.     case GETEXT:
  548.       fpn = getext ((num == NUM_SRT) ? 
  549.                     /* process SORT */ t2bunpack (b) : num);
  550.       sbuf.mtype = num + CONSTTR;
  551.       t2bpack (fpn, sbuf.mtext);
  552.       
  553.       PRINT ("ADM.realop: getext: msgidtrn = %dn",
  554.      (i4_t)tabtr[num].msgidtrn);
  555.       PRINT ("ADM.realop: getext: sbuf.mtype = %dn",
  556.      (i4_t)(sbuf.mtype));
  557.   
  558.       if (msgsnd (tabtr[num].msgidtrn, (MSGBUFP)&sbuf, sizeof(u2_t), 0) < 0)
  559. {
  560.   perror ("ADM.msgsnd: Answer to GETEXT");
  561.   return;
  562. }
  563.       break;
  564.     case IAMMOD:
  565.       iamm (num);
  566.       sbuf.mtype = num + CONSTTR;
  567.       t4bpack (tabtr[num].uidtr, sbuf.mtext);
  568.       if (msgsnd (tabtr[num].msgidtrn, (MSGBUFP)&sbuf, sizeof(i4_t), 0) < 0)
  569. {
  570.   perror ("ADM.msgsnd: Answer to IAMMOD");
  571.   return;
  572. }
  573.       break;
  574.     case UNIQNM:
  575.       uniqnm (num);
  576.       sbuf.mtype = num + CONSTTR;
  577.       t4bpack (unname, sbuf.mtext);
  578.       if (msgsnd (tabtr[num].msgidtrn, (MSGBUFP)&sbuf, sizeof(i4_t), 0) < 0)
  579. {
  580.   perror ("ADM.msgsnd: Answer to UNIQNM");
  581.   return;
  582. }
  583.       break;
  584.     case WLJET:
  585.       wljetr (num);
  586.       break;
  587.     case ERRFU:
  588.       errfu (*b, *(b + 1));
  589.       break;
  590.     case COPY:
  591.       copy ();
  592.       break;
  593.     case NOBUF:
  594.       nobuf ();
  595.       break;
  596.     case READY:
  597.       break;
  598.     default:
  599.       break;
  600.     }
  601. }
  603. #define TO_TABTR(pid, msgid)  
  604.   { tabtr[numtr].uidtr = 0;     
  605.     tabtr[numtr].idprtr = pid;          
  606.     tabtr[numtr].res_ready = 0;         
  607.     tabtr[numtr].cretime = time(NULL);  
  608.     tabtr[numtr++].msgidtrn = msgid;    
  609.     maxusetran++; 
  610.   }
  612. #define ARG(num, what) sprintf (args[num], "%d", (i4_t)(what))
  614. static int
  615. logj_fix (void)
  616. {
  617.   sbuf.mtype = BEGFIX;
  618.   if (msgsnd (msgidl, (MSGBUFP)&sbuf, 0, 0) < 0)
  619.     {
  620.       perror ("ADM.msgsnd: LOGJ->FIX");
  621.       return -1;
  622.     }
  623.   if (msgrcv (msgidl, (MSGBUFP)&sbuf, 1, ANSLJ, 0) < 0)
  624.     {
  625.       perror ("ADM.msgrcv: BEGFIX LJ");
  626.       return -1;
  627.     }
  628.   return ((i4_t) *sbuf.mtext);
  629. }
  631. static pid_t
  632. fork_service(char **args,i4_t take_care_of_fail)
  633. {
  634.   pid_t chld;
  635.   
  636. #ifndef NOT_DEBUG
  637.   { 
  638.     char **arg;
  639.     fputs ("##>>>",stderr);
  640.     for(arg=args;*arg;arg++)
  641.       fprintf(stderr,"%s ",*arg);
  642.     fputs ("n",stderr);
  643.   }
  644. #endif
  646.   children++;
  647.   
  648.   chld = fork();
  649.   if (chld < 0) /* if fork failed */
  650.     {
  651.       lperror("fork '%s'",*args);
  652.       if (take_care_of_fail)  
  653.         return chld;          /* return error code          */
  654.       EXIT;
  655.     }
  656.   else if (chld==0)     
  657.     { /* child process -- replace by '*args' */
  658.       execvp (*args, args);
  659.       lperror ("ADM.fork_service: '%s' doesn't exec",*args);
  660.       exit(1);
  661.     }
  662.   return chld;
  663. }
  665. #ifndef NOT_DEBUG
  667. static void
  668. run_debugger (pid_t debuggee, char **args,char *to_debugger,char *x_server)
  669. {
  670.   pid_t  debugger;
  671.   char * prog = *args;
  672.   i4_t    i;
  673.   
  674.   { /* prepare debugger script -- written generally for gdb */
  675.     FILE * fl;
  677.     fl = fopen (GDBINIT_FILE, "w");
  678.     fprintf (fl,
  679.              "attach %dn"                  /* attach at MEET_DEBUGGER     */
  680.              "break exitn"
  681.              "break abortn"
  682.              "break lperrorn"
  683.              "%sn"                         /* set local settings          */
  684.              "signal %dn"                  /* clear wait flag             */
  685.              "finishn"                     /* lperror cathes control here */
  686.              "finishn"                     /* go up to 'main'             */
  687.              ,(i4_t)debuggee
  688.              ,(to_debugger?to_debugger:"")
  689.              ,SIGALRM);
  690.     fclose (fl);
  691.   }
  692.   
  693.   if (!x_server)
  694.     x_server = getenv("DISPLAY");
  695.   if (!x_server)
  696.     x_server = ":0.0";
  698.   args[i=1] = "-display";
  699.   args[++i] = x_server;
  700.   args[++i] = "-bg";
  701.   args[++i] = "Gray";
  702. #if defined(HAVE_DDD)
  703.   args[0] = HAVE_DDD;
  704.   args[++i] = prog;
  705.   args[++i] = "-nx";
  706.   args[++i] = "-command=" GDBINIT_FILE;
  707. #elif defined(HAVE_XXGDB)
  708.   args[0] = HAVE_XXGDB;
  709.   args[++i] = "-nx";
  710.   args[++i] = "-command=" GDBINIT_FILE;
  711.   args[++i] = prog;
  712. #elif  defined(HAVE_XTERM)
  713.   args[0] = HAVE_XTERM;
  714.   args[++i] = "-e";
  715. #if defined(HAVE_GDB)
  716.   args[++i] = HAVE_GDB;
  717. #elif defined(HAVE_DBX) 
  718.   args[++i] = HAVE_DBX;
  719. #else
  720. # error configuraton - !NOT_DEBUG && !HAVE_GDB && !HAVE_DBX 
  721. #endif
  722.   args[++i] = prog;
  723.   args[++i] = "-x";
  724.   args[++i] = GDBINIT_FILE;
  725. #else
  726. # error configuraton - !NOT_DEBUG && !HAVE_XTERM && !HAVE_DDD && !HAVE_XXGDB 
  727. #endif
  728.   args[++i] = NULL;
  730.   debugger = fork_service(args,(to_debugger!=NULL));
  731.   if (debugger>0)
  732.     { /* add new entry to debuggers list */
  733.       debug_pid_t *new_d = xmalloc (sizeof(debug_pid_t));
  734.       new_d->debugger = debugger;
  735.       new_d->to_debug = debuggee;
  736.       new_d->next = debuggers_pids;
  737.       if (debuggers_pids)
  738.         debuggers_pids->prev = new_d;
  739.       debuggers_pids = new_d;
  740.     }
  741. }
  743. #endif /* NOT_DEBUG */
  745. static pid_t
  746. run_chld (i4_t run_gdb,char **args,char *to_debugger,char *x_server)
  747. {
  748.   pid_t  chld;
  750. #ifndef NOT_DEBUG
  751.   if (run_gdb<0)
  752.     {
  753.       i4_t c;
  754.       printf ("DO you want to start gdb for '%s'?",*args);
  755.       do 
  756.         c = getchar();
  757.       while ( c == 'n' );
  758.       if (c != 'y')
  759.         run_gdb = 0;
  760.     }
  761.   if (run_gdb)
  762.     { /* add debugger keyword */
  763.       char **p;
  764.       for ( p = args; *p; p++ );
  765.       *p = "DebugIt";
  766.       *(++p) = NULL;
  767.     }  
  768. #endif
  770.   chld = fork_service(args,(to_debugger!=NULL));
  771. #ifndef NOT_DEBUG
  772.   if (run_gdb && chld > 0)
  773.     run_debugger (chld,args,to_debugger,x_server);
  774. #endif
  775.   
  776.   return chld;
  777. }
  779. static key_t
  780. get_msg_key(void)   /* this function has a complete static copy in strgcr.c */
  781. {
  782.   static key_t k = (key_t)-2;
  783.   if (k==(key_t)-2)
  784. #if HAVE_FTOK
  785.     k = ftok(MJ, 'D');
  786. #else
  787.     k = FIRSTMQN;
  788. #endif
  789.   errno = 0;
  790.   for(;;)
  791.     {
  792.       if ( msgget (k, DEFAULT_ACCESS_RIGHTS) < 0 )
  793.         if (errno == ENOENT)
  794.           return k++;
  795.         else if (errno == ENOSPC)
  796.           return -1;
  797.       k++;
  798.     }
  799. }
  801. static i4_t 
  802. ini (void)
  803. {
  804.   register i4_t i;
  805.   char rep, repmj, *args[20];
  806.   i4_t optbufnum, maxnbuf, maxtact;
  807.   key_t fsegnum;
  808.   char mas[sizeof(i4_t)];
  809.   char argarea[20][20];
  810.   
  811. #define INITARG for(i = 0 ; i < 20; i++) args[i] = argarea[i];
  813.   rep = 0;
  814.   
  815.   
  816.   /*------------OPEN,READ AND WRITE ADMFILE------------------*/
  817.   PRINTF (("ADM.ini: Open, read and write ADMFILE %sn", ADMFILE));
  818.   if ((fdaf = open (ADMFILE, O_RDWR, 0644)) < 0)
  819.     {
  820.       perror ("ADMFILE: open error");
  821.       EXIT;
  822.     }
  823.   if (read (fdaf, (char *) &p2, adfsize) != adfsize)
  824.     {
  825.       perror ("ADMFILE: read error");
  826.       EXIT;
  827.     }
  828.   idt       = p2.uid;
  829.   uidconst  = p2.uidconst;
  830.   nunname   = p2.unname;
  831.   sizext    = p2.sizext / BD_PAGESIZE;
  832.   maxext    = p2.maxext;
  833.   maxfrext  = p2.maxfrext;
  834.   maxtrans  = p2.maxtrans;
  835.   rjzm      = p2.mjred;
  836.   rjzl      = p2.ljred;
  837.   mpagem    = p2.mjmpage;
  838.   mpagel    = p2.ljmpage;
  839.   sizesc    = p2.sizesc;
  840.   optbufnum = p2.optbufnum;
  841.   maxnbuf   = p2.maxnbuf;
  842.   maxtact   = p2.maxtact;
  843.   fsegnum   = p2.fshmsegn;
  844.   PRINTF (("ADM.ini: was reading from ADMFILE:n"));
  845.   PRINTF (("  UID=%d, UIDCONST=%d, MAXTRANS=%d, SIZEXT=%d, MAXEXT=%d, "
  846.   "MAXFREXT=%d, UNNAME=%d, RJZm=%d, RJZl=%d, MPAGEm=%d,"
  847.   " MPAGEl=%d, MAXNBUF=%d,  SIZESC=%dn", 
  848.   (i4_t)idt, (i4_t)uidconst, maxtrans, sizext, maxext, 
  849.   maxfrext, (i4_t)nunname, rjzm, rjzl,
  850.   mpagem, mpagel, maxnbuf, sizesc));
  851.   uidt = idt;
  852.   if (uidt == 0)
  853.     uidt++;
  854.   idt += uidconst;
  855.   p2.uid = idt;
  856.   unname = nunname;
  857.   if (unname == 0)
  858.     unname++;
  859.   nunname += uidconst;
  860.   p2.unname = nunname;
  861.   if (lseek (fdaf, 0, SEEK_SET) < 0)
  862.     {
  863.       perror ("ADM.lseek: lseek admfile");
  864.       EXIT;
  865.     }
  866.   if (write (fdaf, (char *) &p2, adfsize) != adfsize)
  867.     {
  868.       perror ("ADMFILE: write error");
  869.       EXIT;
  870.     }
  871.   
  872.   keyadm = get_msg_key();
  873.   keylj  = get_msg_key();
  874.   keymj  = get_msg_key();
  875.   keybf  = get_msg_key();
  876.   keysn  = get_msg_key();
  877.   keysr  = get_msg_key();
  878.   keymcr = get_msg_key();
  879.   
  880.   /* Getting queue for administraror */
  881.   if ((msgida = msgget (keyadm, IPC_CREAT | DEFAULT_ACCESS_RIGHTS)) < 0)
  882.     {
  883.       perror ("ADM: Getting queue for adm");
  884.       EXIT;
  885.     }
  886.     
  887.   freext = 0;
  888.   keytrn = (key_t *) xmalloc (maxtrans * sizeof (key_t));
  889.   
  890.   tabtr = (struct des_trn *) xmalloc (maxtrans * sizeof (struct des_trn));
  891.   ext_ids = (u2_t *) xmalloc (maxext * sizeof(u2_t));
  892.   trn_ids = (u2_t *) xmalloc (maxext * sizeof(u2_t)); /* all trn_ids[i] = 0 */
  893.   for (i = 0; i < maxext; i++)
  894.     ext_ids[i] = nul;
  895.   minid = uidt;
  896.   maxusetran = FIR_TRN_NUM;
  897.   numtr = 1;
  898.   
  899. /*---------------INI MICROJ------------------------------*/
  900.   INITARG;
  901.   args[0] = MJ;
  902.   args[1] = MJFILE;
  903.   sprintf (args[2], "%d", rjzm);
  904.   sprintf (args[3], "%d", mpagem);
  905.   sprintf (args[4], "%d", (i4_t)keymj);
  906.   sprintf (args[5], "%d", (i4_t)keylj);
  907.   args[6] = NULL;
  908.   pidmj = run_chld(-1,args,NULL,NULL);
  909. /*---------------INI MICROJ 2 ----------------------------*/
  911.   PRINTF (("ADM.ini: before MSG_INIT ini MJ keymj = %dn", keymj));
  912.   MSG_INIT (msgidm, keymj, "MJ");
  913.   PRINTF (("ADM.ini: after MSG_INIT ini MJn"));
  914.   if (msgrcv (msgidm, (MSGBUFP)&rbuf, 1, ANSMJ, 0) < 0)
  915.     perror ("ADM.msgrcv: INIT MJ");
  916.   repmj = *rbuf.mtext;
  917.   PRINTF (("ADM.ini: INI repmj = %dn", repmj));
  918.   sbuf.mtype = INIMJ;
  919.   if (msgsnd (msgidm, (MSGBUFP)&sbuf, 0, 0) < 0)
  920.     {
  921.       perror ("ADM.msgsnd: MJ->INIMJ");
  922.       exit (1);
  923.     }
  924.   
  925.   /*----------------INI BUFFER----------------------*/
  926.   PRINTF (("ADM.ini: INI BUFFER>n"));
  927.   if ((fdto = creat (SEG0, DEFAULT_ACCESS_RIGHTS)) < 0)
  928.     {
  929.       perror (SEG0);
  930.       EXIT;
  931.     }
  932.   rfile = 0;
  934.   /*vvvvvvvvvvvvvvv  start BUF   vvvvvvvvvvvvvv*/
  935.   INITARG;
  936.   args[0] = BUF;
  937.   args[1] = SEG0;
  938.   ARG (2, keybf);
  939.   ARG (3, keymj);
  940.   ARG (4, optbufnum);
  941.   ARG (5, maxnbuf);
  942.   ARG (6, maxtact);
  943.   ARG (7, maxtrans);
  944.   /* the first numeric name of the   *
  945.    * shared memory segment for PUPSI */
  946.   ARG (8, fsegnum);
  947.   /* BD segments numbers and names */
  948.   ARG (9, 1);
  949.   args[10] = SEG1;
  950.   ARG (11, adm_pid);
  951.   args[12] = NULL;
  952.   pidbf = run_chld(-1,args,NULL,NULL);
  953.   /*^^^^^^^^^^^^^^^^^^ start BUF ^^^^^^^^^^^^^^^^^^^^^*/
  955.   PRINTF (("ADM.ini: INI BUFn"));  
  956.   MSG_INIT (msgidb, keybf, "BUF");
  957.   
  958.   /*-------------OPEN AND INI LOGJ--------------------------*/
  959.   PRINTF (("ADM.ini: Open and INI LOGJn"));
  960.   if ((fdlj = open (LJFILE, O_RDWR, 0644)) < 0)
  961.     {
  962.       perror ("LJ: open");
  963.       EXIT;
  964.     }
  965.   if (read (fdlj, mas, sizeof(i4_t)) != sizeof(i4_t))
  966.     {
  967.       perror ("LJOUR: read error");
  968.       EXIT;
  969.     }
  970.   vnlj = t4bunpack (mas);
  971.   PRINTF (("ADM.ini: VNLJ=%dn", (i4_t)vnlj));
  973.   /*vvvvvvvvvvvvvvv start LJ  vvvvvvvvvvvvvvvvvvvvv*/
  975.   INITARG;
  976.   args[0] = LJ;
  977.   sprintf (args[1], "%d", fdlj);
  978.   sprintf (args[2], "%d", (i4_t)rjzl);
  979.   sprintf (args[3], "%d", (i4_t)mpagel);
  980.   sprintf (args[4], "%d", (i4_t)keylj);
  981.   sprintf (args[5], "%d", (i4_t)keybf);
  982.   sprintf (args[6], "%d", (i4_t)keyadm);
  983.   sprintf (args[7], "%d", (i4_t)keymj);
  984.   args[8] = NULL;
  985.   pidlj = run_chld(-1,args,NULL,NULL);
  987.   /*^^^^^^^^^^^^^^^ start LJ  ^^^^^^^^^^^^^^^^^^^^^*/
  989.   MSG_INIT (msgidl, keylj, "LJ");
  991.   /* LogJournal is the special (with number NUM_LJ) transaction */
  992.   TO_TABTR (pidlj, msgidl);
  994.   PRINTF (("ADM.ini: INI LOGJ donen"));  
  995.  
  996.   
  997.   if (repmj == MJ_PPS)
  998.     {
  999.       /* Memory crash, invoke Memory Crash Recovery Utility */
  1000.       PRINTF (("ADM.ini: load MCR MCR_name=%s, MJ_name = %sn", MCR, MJ));
  1001.       
  1002.       /*vvvvvvvvvvvvvvv start MCR  vvvvvvvvvvvvvvvvvvvvv*/
  1004.       INITARG;
  1005.       args[0] = MCR;
  1006.       args[1] = MJFILE;
  1007.       args[2] = LJFILE;
  1008.       sprintf (args[3], "%d", (i4_t)keymj);
  1009.       sprintf (args[4], "%d", (i4_t)keylj);
  1010.       sprintf (args[5], "%d", (i4_t)keybf);
  1011.       sprintf (args[6], "%d", (i4_t)keymcr);
  1012.       sprintf (args[7], "%d", sizesc);
  1013.       args[8] = NULL;
  1014.       pidmcr = run_chld(-1,args,NULL,NULL);
  1015.       
  1016.       /*^^^^^^^^^^^^^^^ start MCR ^^^^^^^^^^^^^^^^^^^^^*/
  1018.       MSG_INIT (msgidc, keymcr, "MCR");
  1019.       if (msgrcv (msgidc, (MSGBUFP)&rbuf, 1, ANSADM, 0) < 0)
  1020.         perror ("ADM.msgrcv: Answer from MCR");
  1021.       repmj = *rbuf.mtext;
  1022.     }
  1023.   logj_fix ();
  1025.   /*---------------INI SYNCH-------------------------------*/
  1026.   PRINTF (("ADM.ini: INI SYN>n"));
  1028.   /*vvvvvvvvvvvvvvv start SYN vvvvvvvvvvvvvvvvvvvvv*/
  1030.   INITARG;
  1031.   args[0] = SYN;
  1032.   ARG (1, keysn);
  1033.   ARG (2, keybf);
  1034.   args[3] = NULL;
  1035.   pidsn = run_chld(-1,args,NULL,NULL);
  1037.   /*^^^^^^^^^^^^^^^ start SYN ^^^^^^^^^^^^^^^^^^^^^*/
  1039.   MSG_INIT (msgids, keysn, "SYN");
  1041.   /*---------------INI SORTER------------------------------*/
  1042.   PRINTF (("ADM.ini: INI SORTER>n"));
  1044.   /*vvvvvvvvvvvvvvv start SRT vvvvvvvvvvvvvvvvvvvvv*/
  1046.   INITARG;
  1047.   args[0] = SRT;
  1048.   ARG (1,   keysr);
  1049.   ARG (2,   keybf);
  1050.   ARG (3,   sizext);
  1051.   ARG (4,   adm_pid);
  1052.   ARG (5,   keyadm);
  1053.   args[6] = NULL;
  1054.   pidsr = run_chld(-1,args,NULL,NULL);
  1056.   /*^^^^^^^^^^^^^^^ start SYN ^^^^^^^^^^^^^^^^^^^^^*/
  1058.   MSG_INIT (msgidq, keysr, "SORT");
  1059.   
  1060.   /* SORTER is the special (with number NUM_SRT) transaction */
  1061.   TO_TABTR (pidsr, msgidq);
  1062.   transaction_number = 0;
  1063.   return (0);
  1064. }
  1066. static int
  1067. rpc_check(i4_t tr_num, rpc_svc_t type)
  1068. {
  1069.   static struct timeval tv = { 25, 0 };
  1070.   CLIENT *cl = (CLIENT *) NULL;
  1071.   i4_t    rc = 0,i=0;
  1072.   char   *hostname;
  1073. #if 0
  1074.   struct  utsname unm;
  1075.   uname(&unm);
  1076.   hostname = unm.nodename;
  1077. #else
  1078.   hostname = "localhost";
  1079. #endif
  1080.   
  1081.   while (i++<10)
  1082.     {
  1083.       if (cl == (CLIENT *) NULL)
  1084. cl = clnt_create (hostname, DEFAULT_TRN + tr_num, 1, "tcp");
  1085.       if ( cl == (CLIENT *) NULL )
  1086.         clnt_pcreateerror(hostname);
  1087.       else if ( clnt_call(cl, 1000,
  1088.   (xdrproc_t) xdr_void, (caddr_t) NULL,
  1089.   (xdrproc_t) xdr_long, (caddr_t) &rc,
  1090.   tv)
  1091. == RPC_SUCCESS)
  1092. break;  
  1093.       if (tabtr[tr_num].idprtr == 0)
  1094. break;
  1095.       rc = 0;
  1096.       sleep(1);
  1097.     }
  1098.   if (i>10)
  1099.     clnt_perror(cl,hostname);
  1100.   if (cl)
  1101.     clnt_destroy(cl);
  1102.   if(rc>0)
  1103.     {
  1104.       assert( tabtr[tr_num].idprtr == (pid_t)rc);
  1105.     }
  1106.   return (i<=10);
  1107. }
  1109. /* New transaction with interpretator or compiler creating. *
  1110.  * Returns number of it in TABTR or error (< 0).            */
  1111.      
  1112. i4_t 
  1113. creatr (init_arg *arg)
  1114. {
  1115.   static char *svcs[] = SVC_FILES;
  1116.   register i4_t i, j, trnum;
  1117.   pid_t idpr;
  1118.   char *args[20];
  1119.   char  argarea[20][20];
  1121.   PRINTF (("ADM.creatr.b:n"));
  1122.   for(i=0;i<20;i++)
  1123.     args[i] = argarea[i];
  1124.   
  1125.   /* tabtr cleaning & finding free place in it */
  1126.   for (trnum = 0, j = FIR_TRN_NUM; j <= maxusetran; j++)
  1127.     if (!(tabtr[j].cretime) && (!tabtr[j].idprtr) )
  1128.       {
  1129.         trnum = j;
  1130.         break;
  1131.       }
  1132.   
  1133.   if (!trnum) /* there is no free place in tabtr[1..MAXUSETRAN] */
  1134.     {
  1135.       trnum = ++maxusetran;
  1136.       if (numtr == maxtrans)
  1137. {
  1138.   keytrn = (key_t *) xrealloc (keytrn,
  1139.    2 * maxtrans * sizeof (key_t));
  1140.   for (i = maxtrans; i < 2 * maxtrans; i++)
  1141.     keytrn[i] = 0;
  1142.       
  1143.   maxtrans *= 2;
  1144.   tabtr = (struct des_trn *) xrealloc (tabtr, 
  1145.   maxtrans * sizeof (struct des_trn));
  1146. }
  1147.     }
  1148.   {
  1149.     char *debug = 
  1150.       "break compiler_disconnectn"
  1151.       "set   under_dbg=1n";
  1152.     
  1153.     keytrn[trnum] = get_msg_key();
  1154.     assert(arg->type >=0);
  1155.     assert(arg->type < sizeof(svcs)/sizeof(char*));
  1156.     args[0]  = svcs[arg->type];
  1157.     ARG (1,    keytrn[trnum]);
  1158.     ARG (2,    keysn);
  1159.     ARG (3,    keysr);
  1160.     ARG (4,    keylj);
  1161.     ARG (5,    keymj);
  1162.     ARG (6,    keybf);
  1163.     ARG (7,    trnum);
  1164.     ARG (8,    minid);
  1165.     ARG (9,    sizext);
  1166.     ARG (10,   sizesc);
  1167.     ARG (11,   arg->wait_time);
  1168.     ARG (12,   DEFAULT_TRN + trnum);
  1169.     args[13] = arg->user_name;
  1170.     ARG (14,   adm_pid);
  1171.     ARG (15,   keyadm);
  1172.     args[16] = NULL;
  1173.     
  1174.     idpr = run_chld(arg->need_gdb,args,debug,arg->x_server);
  1175.     if (idpr< 0)
  1176.       return -TRN_INIT;
  1177.   }
  1178.   
  1179.   numtr++;
  1180.   tabtr[trnum].uidtr = 0;
  1181.   tabtr[trnum].idprtr = idpr;
  1182.   tabtr[trnum].res_ready = 0;
  1183.   tabtr[trnum].cretime = time(NULL);
  1184.   MSG_INIT (tabtr[trnum].msgidtrn, keytrn[trnum], "TRN");
  1185.   if (!rpc_check(trnum, arg->type))
  1186.     {
  1187.       if (tabtr[trnum].idprtr == idpr) /* if process still not initialized */
  1188.         {                              /* and still exist - kill it        */
  1189.           tabtr[trnum].idprtr = -idpr;
  1190.           kill(idpr,SIGKILL);          
  1191.           keytrn[trnum] = 0;
  1192.         }
  1193.       printf ("ADM.creatr: TRAN creation failedn");
  1194.       return -TRN_INIT;
  1195.     }
  1196.   PRINTF (("ADM.creatr.e: trn number = %dn", trnum));
  1197.   transaction_number++;
  1198.   return (trnum);
  1199. }
  1201. #undef ARG
  1204. void 
  1205. copylj (void)
  1206. {
  1207.   char file_name[1024];
  1208.   char arr[32];
  1209.   register i4_t n, fd;
  1210.   char buf[1024];
  1211.   
  1212.   /*------------------- suspend LJ --------------------------*/
  1213.   
  1214.   n = logj_fix ();
  1215.   /** printf ("ADM.COPYLJ: after LOGJ.FIX fdlj=%dn", fdlj); */
  1217.   /*---------------copying of Logic Log----------------------*/
  1218.  
  1219.   if (fix_path != NULL)
  1220.     {
  1221.       if (lseek (fdlj, 0, SEEK_SET) < 0)
  1222. {
  1223.   perror ("ADM.lseek: lseek ljfile");
  1224.   return;
  1225. }
  1226.       if ((n = read (fdlj, buf, 1024)) == 0)
  1227.         {
  1228.           perror ("LJOUR: read error");
  1229.           EXIT;
  1230.         }
  1231.       vnlj = t4bunpack (buf);
  1232.       sprintf (arr, "%d", (i4_t)vnlj);
  1233.       strcpy (file_name, ARCHIVE);
  1234.       strcat (file_name, "/ljour.");
  1235.       strcat (file_name, arr);
  1236.       if ((fd = creat (file_name, 0640)) < 0)
  1237. {
  1238.   perror (file_name);
  1239.   return;
  1240. }
  1242.       PRINTF (("ADM.COPYLJ: FIX_PATH=%sn", file_name));
  1243.       write (fd, buf, n);
  1244.       while ((n = read (fdlj, buf, 1024)) != 0)
  1245.         {
  1246.           write (fd, buf, n);
  1247.         }
  1248.       close (fd);
  1249.     }
  1251.   /*----------------refreshment of Logic Log---------------------------*/
  1252.   sbuf.mtype = RENEW;
  1253.   t4bpack ((i4_t)fdlj, sbuf.mtext);
  1254.   t4bpack ((i4_t)rjzl, sbuf.mtext + sizeof(i4_t));
  1255.   if (msgsnd (msgidl, (MSGBUFP)&sbuf, 2 * sizeof (i4_t), 0) < 0)
  1256.     {
  1257.       perror ("ADM.msgsnd: LOGJ->RENEW");
  1258.       return;
  1259.     }
  1260.   if (msgrcv (msgidl, (MSGBUFP)&sbuf, 1, ANSLJ, 0) < 0)
  1261.     {
  1262.       perror ("ADM.msgrcv: Answer LOGJ->RENEW");
  1263.       return;
  1264.     }
  1265.   PRINTF (("ADM.COPYLJ.e: fdlj=%dn", fdlj));
  1266.   fix_lj_fl = 0;
  1267. }
  1269. void 
  1270. kill_all (i4_t err)
  1271. {
  1272.   register i4_t i;
  1273.   i4_t error;
  1274.   struct msqid_ds msqidds;
  1275.   static char entered = 0;
  1276.   static i4_t  err_code = 0;
  1277.   
  1278.   if (entered==0)
  1279.     {
  1280.       entered++;
  1281.       err_code = err;
  1282.       
  1283.       if (tabtr)
  1284.         {
  1285.           for (i = FIR_TRN_NUM; i <= maxusetran; i++)
  1286.             if (tabtr[i].idprtr)
  1287.               {
  1288.                 msgctl (tabtr[i].msgidtrn, IPC_RMID, &msqidds);
  1289.                 kill (tabtr[i].idprtr, SIGKILL);
  1290.                 tabtr[i].idprtr = -tabtr[i].idprtr;
  1291.               }
  1292.         }
  1293.       
  1294. #define RMMSG(id) if (id!=-1){msgctl(id,IPC_RMID,&msqidds);id = -1;}
  1295.       RMMSG(msgidl);   /* lj  queue */
  1296.       RMMSG(msgidm);   /* mj  queue */
  1297.       RMMSG(msgidb);   /* buf queue */
  1298.       RMMSG(msgids);   /* syn queue ?*/
  1299.       RMMSG(msgidq);   /* srt queue ?*/
  1300.       RMMSG(msgida);   /* adm queue */
  1301. #undef RMMSG
  1302.       
  1303. #define KILLP(id) if (id){ error = kill(id, SIGKILL); id = -id; }
  1304.       KILLP(pidlj);
  1305.       KILLP(pidmj);
  1306.       KILLP(pidbf);
  1307.       KILLP(pidsn);
  1308.       KILLP(pidsr);
  1309. #undef KILLP
  1310.     }
  1312.   if (children)
  1313.     return; /* let's wait a bit more */
  1314.   
  1315.   err |= err_code;
  1316. #define CLEAR(ptr)  if(ptr) { xfree(ptr); ptr = NULL; }
  1318.   CLEAR(keytrn);
  1319.   CLEAR(ext_ids);
  1320.   CLEAR(trn_ids);
  1321.   CLEAR(tabtr);
  1322.   
  1323. #undef CLEAR
  1325.   printf ("ADM is stoppedn");
  1326.   if(err!=-1)
  1327.     {
  1328.       /* svc_exit(); */
  1329.       exit (err);
  1330.     }
  1331.   entered = finit_done = err_code = 0;
  1332.   ini();
  1333. } /* kill_all */
  1335. void
  1336. finit (i4_t err)
  1337. {
  1338.   i4_t rep, cd, i;
  1339.   
  1340.   /* This function can't use EXIT */
  1341.   
  1342.   if (finit_done)
  1343.     return;
  1344.   
  1345.   if (err < 0)
  1346.     kill_all(-1);
  1348.   finit_done = 1;
  1350.   
  1351.   if (tabtr)
  1352.     {
  1353.       time_t tm;
  1354.       i4_t all_done;
  1355.       
  1356.       for (i = FIR_TRN_NUM; i <= maxusetran; i++)
  1357. if (tabtr[i].idprtr)
  1358.   {
  1359.     TRN_SEND (FINIT, 0);
  1360.   }      
  1361.       tm = time (NULL);
  1362.       do {
  1363. all_done = 1;
  1364. for (i = FIR_TRN_NUM; i <= maxusetran; i++)
  1365.   if (tabtr[i].idprtr)
  1366.     {
  1367.       all_done--;
  1368.       break;
  1369.     }
  1370. if (all_done)
  1371.   break;
  1372. sleep (1);
  1373.       } while (time (NULL) - tm < KILL_WAIT);
  1374.     }
  1375.   
  1376.   PRINTF (("ADM.finit.b: UNNAME=%d n", (i4_t)unname));
  1377.   p2.unname = unname + 1;
  1378.   if (lseek (fdaf, 0, SEEK_SET) < 0)
  1379.     perror ("ADM.lseek: lseek admfile");
  1380.   if (write (fdaf, (char *) &p2, adfsize) != adfsize)
  1381.     perror ("ADMFILE");
  1382.   rep = close (fdaf);
  1383.   fdaf = 0;
  1384.   
  1385.   if (pidlj)
  1386.     logj_fix ();
  1387.   
  1388.   sbuf.mtype = FINIT;
  1389. #if 0
  1390.   if(msgsnd(msgidl,&sbuf,0,0)<0) 
  1391.     { 
  1392.       perror("ADM.msgsnd: LOGJ->FINIT");
  1393.       exit(1); 
  1394.     } 
  1395.   if(msgrcv(msgidl,&rbuf,1,ANSLJ,0)<0) 
  1396.     { 
  1397.       perror("ADM.msgrcv: FINIT LJ"); 
  1398.       exit(1); 
  1399.     } 
  1400. #endif
  1401.   cd = close (fdlj);
  1402.   fdlj = 0;
  1403.   PRINTF (("ADM.finit: after LJ finishn"));
  1405.   if (pidmj)
  1406.     {
  1407.       if (msgsnd (msgidm, (MSGBUFP)&sbuf, 0, 0) < 0)
  1408. perror ("ADM.msgsnd: MJ->FINIT");
  1409.       if (msgrcv (msgidm, (MSGBUFP)&rbuf, 1, ANSMJ, 0) < 0)
  1410. perror ("ADM.msgrcv: FINIT MJ");
  1411.       PRINTF (("ADM.finit: after MJ finishn"));
  1412.     }
  1414.   if (pidbf)
  1415.     {
  1416.       if (msgsnd (msgidb, (MSGBUFP)&sbuf, 0, 0) < 0)
  1417. perror ("ADM.msgsnd: BUF->FINIT");
  1418.       if (msgrcv (msgidb, (MSGBUFP)&rbuf, 1, ANSBUF, 0) < 0)
  1419. perror ("ADM.msgrcv: FINIT BUF");
  1420.       PRINTF (("ADM.finit: after BUF finishn"));
  1421.     }
  1422.   
  1423.   if (pidsn)
  1424.     {
  1425.       if (msgsnd (msgids, (MSGBUFP)&sbuf, 0, 0) < 0)
  1426. perror ("ADM.msgsnd: SYN->FINIT");
  1427.       PRINTF (("ADM.finit: after SYN finishn"));
  1428.     }
  1429.   
  1430.   if (pidsr)
  1431.     {
  1432.       if (msgsnd (msgidq, (MSGBUFP)&sbuf, 0, 0) < 0)
  1433. perror ("ADM.msgsnd: SORT->FINIT");
  1434.       PRINTF (("ADM.finit: after SRT finishn"));
  1435.     }
  1436.   
  1437.   sleep(3); /* let's give to subprocess a chance to stop by itself */
  1438.   printf ("ADM.finit.e:n");
  1439.   kill_all (err); /* kill rest of them */
  1440. } /* finit */
  1442. void
  1443. dyn_change_parameters(void)
  1444. {
  1445.   i4_t fddp, length;
  1446.   struct DGSPARAM dyn_par;
  1447.   char *p;
  1448.   i4_t optbufnum, maxtact;  
  1450.   if ( (fddp = open (DYNPARS, O_RDWR, DEFAULT_ACCESS_RIGHTS)) <0)
  1451.     {
  1452.       perror ("DYNPARS: open error");
  1453.       exit (1);
  1454.     }
  1455.   if (lseek (fddp, 0, SEEK_SET) < 0)
  1456.     { 
  1457.       perror ("DYNPARS.lseek: lseek dynpars");
  1458.       exit (1);
  1459.     }
  1460.   length = sizeof (struct DGSPARAM);      
  1461.   if (read (fddp, (char *)&dyn_par, length) != length) {
  1462.     perror ("DYNPARSE: read error");
  1463.     exit (1);
  1464.   }      
  1465.   close (fddp);
  1466.   unlink (DYNPARS);
  1467.   
  1468.   maxfrext = dyn_par.d_max_free_extents_num;
  1469.   rjzl = dyn_par.d_lj_red_boundary;
  1470.   optbufnum = dyn_par.d_opt_buf_num;
  1471.   maxtact = dyn_par.d_max_tact_num;
  1473.   sbuf.mtype = OPTNUM;
  1474.   p = sbuf.mtext;
  1475.   t4bpack (optbufnum, p);
  1476.   t4bpack (maxtact, p + sizeof(i4_t));
  1477.   if (msgsnd (msgidb, (MSGBUFP)&sbuf, 2 * sizeof(i4_t), 0) < 0)
  1478.     perror ("ADM.msgsnd: BUF->OPTNUM");
  1479.   printf ("ADM.dyn_change_parameters: new parameters has setn");  
  1480. }