[BACK]Return to jobtab.c CVS log [TXT] [DIR] Up to [Coherent Logic Development] / freem / src

Diff for /freem/src/jobtab.c between versions 1.5 and 1.8

version 1.5, 2025/03/24 02:57:49 version 1.8, 2025/04/30 20:03:09
Line 24 Line 24
  *   along with FreeM.  If not, see <https://www.gnu.org/licenses/>.   *   along with FreeM.  If not, see <https://www.gnu.org/licenses/>.
  *   *
  *   $Log$   *   $Log$
    *   Revision 1.8  2025/04/30 20:03:09  snw
    *   Work on entryref parser
    *
    *   Revision 1.7  2025/04/17 00:34:04  snw
    *   More logging improvements
    *
    *   Revision 1.6  2025/04/10 01:24:38  snw
    *   Remove C++ style comments
    *
  *   Revision 1.5  2025/03/24 02:57:49  snw   *   Revision 1.5  2025/03/24 02:57:49  snw
  *   Shared memory compatibility fixes for OS/2   *   Shared memory compatibility fixes for OS/2
  *   *
Line 38 Line 47
 #include <string.h>  #include <string.h>
 #include <time.h>  #include <time.h>
 #include <unistd.h>  #include <unistd.h>
   #include <errno.h>
   
 #include "mpsdef.h"  #include "mpsdef.h"
 #include "shmmgr.h"  #include "shmmgr.h"
 #include "jobtab.h"  #include "jobtab.h"
   #include "log.h"
   
 #if !defined(__OpenBSD__) && !defined(__APPLE__) && !defined(__OS2__)  #if !defined(__OpenBSD__) && !defined(__APPLE__) && !defined(__OS2__)
 union semun {  union semun {
Line 66  void jobtab_init(void) Line 77  void jobtab_init(void)
   
         semid_jobtab = semget (jt_sk, 1, 0666 | IPC_CREAT);          semid_jobtab = semget (jt_sk, 1, 0666 | IPC_CREAT);
         if (semid_jobtab == -1) {          if (semid_jobtab == -1) {
             fprintf (stderr, "jobtab_init:  failed to create job table semaphore\r\n");              logprintf (FM_LOG_FATAL, "jobtab_init:  failed to create job table semaphore (error code %d [%s])", errno, strerror (errno));
             exit (1);  
         }          }
         else {          else {
             fprintf (stderr, "jobtab_init:  job table semaphore created with semid %d\r\n", semid_jobtab);              logprintf (FM_LOG_INFO, "jobtab_init:  job table semaphore created with semid %d", semid_jobtab);
         }          }
   
         arg.val = 1;          arg.val = 1;
         if (semctl (semid_jobtab, 0, SETVAL, arg) == -1) {          if (semctl (semid_jobtab, 0, SETVAL, arg) == -1) {
             fprintf (stderr, "jobtab_init:  failed to initialize job table semaphore\r\n");              logprintf (FM_LOG_FATAL, "jobtab_init:  failed to initialize job table semaphore (error code %d [%s])", errno, strerror (errno));
             exit (1);  
         }          }
         else {          else {
             fprintf (stderr, "jobtab_init:  job table semaphore initialized\r\n");              logprintf (FM_LOG_INFO, "jobtab_init:  job table semaphore initialized");
         }          }
                   
     }      }
Line 87  void jobtab_init(void) Line 96  void jobtab_init(void)
   
         semid_jobtab = semget (jt_sk, 1, 0);          semid_jobtab = semget (jt_sk, 1, 0);
         if (semid_jobtab == -1) {          if (semid_jobtab == -1) {
             fprintf (stderr, "jobtab_init:  could not attach to job table semaphore\r\n");              logprintf (FM_LOG_FATAL, "jobtab_init:  could not attach to job table semaphore (error code %d [%s])", errno, strerror (errno));
             exit (1);          }
           else {
               logprintf (FM_LOG_INFO, "jobtab_init:  attached to job table semaphore (semid %d)", semid_jobtab);
         }          }
                   
     }      }
Line 102  short jobtab_get_sem(void) Line 113  short jobtab_get_sem(void)
     struct sembuf s = {0, -1, IPC_NOWAIT};      struct sembuf s = {0, -1, IPC_NOWAIT};
   
     if (have_jobtab_sem) {      if (have_jobtab_sem) {
 //        fprintf (stderr, "jobtab_get_sem:  this process already owns the job table semaphore\r\n");  
         return TRUE;          return TRUE;
     }      }
           
Line 113  short jobtab_get_sem(void) Line 123  short jobtab_get_sem(void)
             return TRUE;              return TRUE;
         }          }
   
         /* fprintf (stderr, "jobtab_get_sem:  sleeping for retry [tries = %d]\r\n", tries); */          logprintf (FM_LOG_INFO, "jobtab_get_sem:  sleeping for retry [tries = %d]", tries);
   
         sleep (1);          sleep (1);
   
     }      }
     fprintf (stderr, "jobtab_get_sem:  fail\r\n");      logprintf (FM_LOG_ERROR, "jobtab_get_sem:  failed to acquire job table semaphore");
           
     have_jobtab_sem = FALSE;      have_jobtab_sem = FALSE;
     return FALSE;      return FALSE;
Line 140  job_slot_t *job_init(short is_fmadm) Line 149  job_slot_t *job_init(short is_fmadm)
     job_slot_t *s;      job_slot_t *s;
                   
     if (jobtab_get_sem () == FALSE) {      if (jobtab_get_sem () == FALSE) {
         fprintf (stderr, "job_init:  failed to get job table semaphore\r\n");          logprintf (FM_LOG_FATAL, "job_init:  failed to get job table semaphore");
         exit (1);  
     }      }
   
     for (s = shm_config->hdr->jobtab_head; s != NULL; s = s->next) {      for (s = shm_config->hdr->jobtab_head; s != NULL; s = s->next) {
Line 191  void job_remove(const pid_t pid) Line 199  void job_remove(const pid_t pid)
     job_slot_t *t = shm_config->hdr->jobtab_head;      job_slot_t *t = shm_config->hdr->jobtab_head;
     job_slot_t *p = NULL;      job_slot_t *p = NULL;
   
     if (jobtab_get_sem() == FALSE) {      if (jobtab_get_sem () == FALSE) {
         fprintf (stderr, "job_remove:  failed to get job table semaphore\r\n");          logprintf (FM_LOG_FATAL, "job_remove:  failed to get job table semaphore");
         exit (1);          exit (1);
     }      }
           
Line 230  void job_request_stop(const pid_t target Line 238  void job_request_stop(const pid_t target
     job_slot_t *s;      job_slot_t *s;
   
     if (jobtab_get_sem() == FALSE) {      if (jobtab_get_sem() == FALSE) {
         fprintf (stderr, "job_request_stop:  failed to get job table semaphore\r\n");          logprintf (FM_LOG_FATAL, "job_request_stop:  failed to get job table semaphore");
         exit (1);  
     }      }
           
     for (s = shm_config->hdr->jobtab_head; s != NULL; s = s->next) {      for (s = shm_config->hdr->jobtab_head; s != NULL; s = s->next) {
Line 256  void job_set_ecode(const pid_t target_pi Line 263  void job_set_ecode(const pid_t target_pi
   
     job_slot_t *s;      job_slot_t *s;
   
     if (jobtab_get_sem() == FALSE) {      if (jobtab_get_sem () == FALSE) {
         fprintf (stderr, "job_set_ecode:  failed to get job table semaphore\r\n");          logprintf (FM_LOG_FATAL, "job_set_ecode:  failed to get job table semaphore");
         exit (1);  
     }      }
           
     for (s = shm_config->hdr->jobtab_head; s != NULL; s = s->next) {      for (s = shm_config->hdr->jobtab_head; s != NULL; s = s->next) {
Line 279  pid_t job_stop_requested (const pid_t ta Line 285  pid_t job_stop_requested (const pid_t ta
 {  {
   
     job_slot_t *s;      job_slot_t *s;
   
           
     for (s = shm_config->hdr->jobtab_head; s != NULL; s = s->next) {      for (s = shm_config->hdr->jobtab_head; s != NULL; s = s->next) {
         if (s->pid == target_pid) {          if (s->pid == target_pid) {
Line 347  job_slot_t *job_set_status(const pid_t t Line 352  job_slot_t *job_set_status(const pid_t t
   
     job_slot_t *s;      job_slot_t *s;
   
     if (jobtab_get_sem() == FALSE) {      if (jobtab_get_sem () == FALSE) {
         fprintf (stderr, "job_set_status:  failed to get job table semaphore\r\n");          logprintf (FM_LOG_FATAL, "job_set_status:  failed to get job table semaphore");
         exit (1);  
     }          }    
           
     for (s = shm_config->hdr->jobtab_head; s != NULL; s = s->next) {      for (s = shm_config->hdr->jobtab_head; s != NULL; s = s->next) {
Line 372  void job_gc_mark(void) Line 376  void job_gc_mark(void)
 {  {
   
     job_slot_t *s;      job_slot_t *s;
       int jobstat;
   
     if (jobtab_get_sem () == FALSE) {      if (jobtab_get_sem () == FALSE) {
         fprintf (stderr, "job_gc_mark:  failed to get job table semaphore\r\n");          logprintf (FM_LOG_FATAL, "job_gc_mark:  failed to get job table semaphore");
         exit (1);  
     }      }
   
     for (s = shm_config->hdr->jobtab_head; s != NULL; s = s->next) {      for (s = shm_config->hdr->jobtab_head; s != NULL; s = s->next) {
                 
         if (kill (s->pid, 0) != 0) {          if ((jobstat = kill (s->pid, 0)) != 0) {
             fprintf (stderr, "job_gc_mark:  marking pid %ld DEFUNCT\r\n", (long) s->pid);              
             s->flags = JFLG_DEFUNCT;              switch (jobstat) {
                   
                   case EPERM:
                       logprintf (FM_LOG_WARNING, "job_gc_mark:  environment daemon lacks permissions to pid %ld", (long) s->pid);
                       break;
                       
                   case ESRCH:
                       logprintf (FM_LOG_INFO, "job_gc_mark:  marking pid %ld DEFUNCT", (long) s->pid);
                       s->flags = JFLG_DEFUNCT;
                       break;
                       
               }
               
         }                 }       
   
         if ((s->flags & JFLG_NEW) == JFLG_NEW) {          if ((s->flags & JFLG_NEW) == JFLG_NEW) {
             if ((s->flags & JFLG_DAEMON) == JFLG_DAEMON) {              if ((s->flags & JFLG_DAEMON) == JFLG_DAEMON) {
                 fprintf (stderr, "job_gc_mark:  registering new daemon %ld\r\n", (long) s->pid);                  logprintf (FM_LOG_INFO, "job_gc_mark:  registering new daemon %ld", (long) s->pid);
                 s->flags = JFLG_ALIVE | JFLG_DAEMON;                  s->flags = JFLG_ALIVE | JFLG_DAEMON;
             }              }
             else {              else {
                 if ((s->flags & JFLG_FMADM) == JFLG_FMADM) {                  if ((s->flags & JFLG_FMADM) == JFLG_FMADM) {
                     fprintf (stderr, "job_gc_mark:  registering new fmadm process %ld\r\n", (long) s->pid);                      logprintf (FM_LOG_INFO, "job_gc_mark:  registering new fmadm process %ld", (long) s->pid);
                     s->flags = JFLG_ALIVE | JFLG_FMADM;                      s->flags = JFLG_ALIVE | JFLG_FMADM;
                 }                  }
                 else {                  else {
                     fprintf (stderr, "job_gc_mark:  registering new interpreter process %ld\r\n", (long) s->pid);                      logprintf (FM_LOG_INFO, "job_gc_mark:  registering new interpreter process %ld", (long) s->pid);
                     s->flags = JFLG_ALIVE;                      s->flags = JFLG_ALIVE;
                 }                  }
             }              }
Line 416  void job_gc_sweep(void) Line 432  void job_gc_sweep(void)
     NULLPTRCHK(k_buf,"job_gc_sweep");      NULLPTRCHK(k_buf,"job_gc_sweep");
   
     if (jobtab_get_sem () == FALSE) {      if (jobtab_get_sem () == FALSE) {
         fprintf (stderr, "job_gc_sweep:  failed to get job table semaphore\r\n");          logprintf (FM_LOG_FATAL, "job_gc_sweep:  failed to get job table semaphore");
         exit (1);  
     }      }
   
           
Line 425  void job_gc_sweep(void) Line 440  void job_gc_sweep(void)
   
         if ((s->flags & JFLG_DEFUNCT) == JFLG_DEFUNCT) {          if ((s->flags & JFLG_DEFUNCT) == JFLG_DEFUNCT) {
   
             fprintf (stderr, "job_gc_sweep:  sweeping DEFUNCT pid %ld\r\n", (long) s->pid);              logprintf (FM_LOG_INFO, "job_gc_sweep:  sweeping DEFUNCT pid %ld", (long) s->pid);
   
             snprintf (k_buf, STRLEN - 1, "^$JOB\202%d\201", s->pid);              snprintf (k_buf, STRLEN - 1, "^$JOB\202%d\201", s->pid);
   
Line 456  ipc_slot_t *job_send_ipc(const pid_t rec Line 471  ipc_slot_t *job_send_ipc(const pid_t rec
     ipc_slot_t *s = (ipc_slot_t *) shm_alloc (sizeof (ipc_slot_t));      ipc_slot_t *s = (ipc_slot_t *) shm_alloc (sizeof (ipc_slot_t));
     NULLPTRCHK(s,"job_send_ipc");      NULLPTRCHK(s,"job_send_ipc");
   
     if (jobtab_get_sem() == FALSE) {      if (jobtab_get_sem () == FALSE) {
         fprintf (stderr, "job_send_ipc:  failed to get job table semaphore\r\n");          logprintf (FM_LOG_FATAL, "job_send_ipc:  failed to get job table semaphore");
         exit (1);  
     }      }
   
           
Removed from v.1.5  
changed lines
  Added in v.1.8

FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>