IPP Software Navigation Tools IPP Links Communication Pan-STARRS Links

Ignore:
Timestamp:
Aug 1, 2005, 4:54:17 AM (21 years ago)
Author:
eugene
Message:

moved sched/scheduler to psched

Location:
trunk/Ohana/src/opihi/pantasks
Files:
1 added
31 edited

Legend:

Unmodified
Added
Removed

  • trunk/Ohana/src/opihi/pantasks/CheckJobs.c

    r4689 r4693  
    1 # include "scheduler.h"
     1# include "psched.h"
    22
    33int CheckJobs () {

  • trunk/Ohana/src/opihi/pantasks/CheckSystem.c

    r4689 r4693  
    1 # include "scheduler.h"
     1# include "psched.h"
    22
    33int CheckSystem () {

  • trunk/Ohana/src/opihi/pantasks/CheckTasks.c

    r4689 r4693  
    1 # include "scheduler.h"
     1# include "psched.h"
    22
    33int CheckTasks () {

  • trunk/Ohana/src/opihi/pantasks/CheckTimeRanges.c

    r4602 r4693  
    1 # include "scheduler.h"
     1# include "psched.h"
    22
    33int CheckTimeRanges (TimeRange *ranges, int Nranges) {

  • trunk/Ohana/src/opihi/pantasks/ControllerOps.c

    r4689 r4693  
    1 # include "scheduler.h"
     1# include "psched.h"
    22# define CONTROLLER_TIMEOUT 20
    33# define CONNECT_TIMEOUT 300
    … …  
    350350      exit (2);
    351351    case -1:  /* no data in pipe */
    352       break;
    353     case 0:   /* pipe is closed */
    354       /** change child state? **/
    355       break;
     352    case 0:   /* pipe is closed, change child state? **/
    356353    default:  /* data in pipe */
    357354      break;
    … …  
    365362      exit (2);
    366363    case -1:  /* no data in pipe */
    367       break;
    368     case 0:   /* pipe is closed */
    369       /** change child state? **/
    370       break;
     364    case 0:   /* pipe is closed, change child state? **/
    371365    default:  /* data in pipe */
    372366      break;

  • trunk/Ohana/src/opihi/pantasks/JobIDOps.c

    r4689 r4693  
    1 # include "scheduler.h"
     1# include "psched.h"
    22
    33# define MAX_N_JOBS 1000

  • trunk/Ohana/src/opihi/pantasks/JobOps.c

    r4689 r4693  
    1 # include "scheduler.h"
     1# include "psched.h"
    22
    33static Job **jobs;

  • trunk/Ohana/src/opihi/pantasks/LocalJob.c

    r4691 r4693  
    1 # include "scheduler.h"
     1# include "psched.h"
    22
    33/* this could be written a just a one-way pipe */
    … …  
    6666  CheckLocalJobStatus (job);
    6767
    68   /* read stdout buffer */
    69   Nread = ReadtoIOBuffer (&job[0].stdout, job[0].stdout_fd);
    70   switch (Nread) {
    71     case -2:  /* error in read (programming error?  system level error?) */
    72       fprintf (stderr, "serious IO error\n");
    73       exit (2);
    74     case -1:  /* no data in pipe */
    75       break;
    76     case 0:   /* pipe is closed */
    77       /** change child state? **/
    78       break;
    79     default:  /* data in pipe */
    80       break;
    81   }
     68  if ((job[0].state == JOB_EXIT) || (job[0].state == JOB_CRASH)) {
     69    EmptyIOBuffer (&job[0].stdout, job[0].stdout_fd);
     70    EmptyIOBuffer (&job[0].stderr, job[0].stderr_fd);
     71  } else {
     72    /* read stdout buffer */
     73    Nread = ReadtoIOBuffer (&job[0].stdout, job[0].stdout_fd);
     74    switch (Nread) {
     75      case -2:  /* error in read (programming error?  system level error?) */
     76        fprintf (stderr, "serious IO error\n");
     77        exit (2);
     78      case -1:  /* no data in pipe */
     79      case 0:   /* pipe is closed, change child state? **/
     80      default:  /* data in pipe */
     81        break;
     82    }
    8283 
    83   /* read stderr buffer */
    84   Nread = ReadtoIOBuffer (&job[0].stderr, job[0].stderr_fd);
    85   switch (Nread) {
    86     case -2:  /* error in read (programming error?  system level error?) */
    87       fprintf (stderr, "serious IO error\n");
    88       exit (2);
    89     case -1:  /* no data in pipe */
    90       break;
    91     case 0:   /* pipe is closed */
    92       /** change child state? **/
    93       break;
    94     default:  /* data in pipe */
    95       break;
     84    /* read stderr buffer */
     85    Nread = ReadtoIOBuffer (&job[0].stderr, job[0].stderr_fd);
     86    switch (Nread) {
     87      case -2:  /* error in read (programming error?  system level error?) */
     88        fprintf (stderr, "serious IO error\n");
     89        exit (2);
     90      case -1:  /* no data in pipe */
     91      case 0:   /* pipe is closed, change child state? **/
     92      default:  /* data in pipe */
     93        break;
     94    }
    9695  }
    9796  return (TRUE);
    … …  
    101100
    102101  int result, waitstatus;
     102
     103  /*** if child has exited, does the pipe hang around until it is flushed? ***/
     104  /*** who closes the child stdout/stderr fd? */
    103105
    104106  /* check local job status */

  • trunk/Ohana/src/opihi/pantasks/Makefile

    r4691 r4693  
    77LIB     =       $(HOME)/lib
    88INC     =       $(HOME)/include
    9 SDIR    =       $(HOME)/sched
     9SDIR    =       $(HOME)/psched
    1010#
    1111DESTBIN =       $(LBIN)
    … …  
    1313DESTINC =       $(LINC)
    1414DESTMAN =       $(LMAN)
    15 DESTHLP =       $(LHLP)/sched
     15DESTHLP =       $(LHLP)/psched
    1616# 
    1717INCS    =       -I$(INC) -I$(LINC) -I$(XINC)
    … …  
    2727funcs = \
    2828$(SDIR)/init.$(ARCH).o \
    29 $(SDIR)/scheduler.$(ARCH).o \
     29$(SDIR)/psched.$(ARCH).o \
    3030$(SDIR)/CheckJobs.$(ARCH).o \
    3131$(SDIR)/CheckSystem.$(ARCH).o \
    … …  
    3636$(SDIR)/JobOps.$(ARCH).o \
    3737$(SDIR)/JobIDOps.$(ARCH).o \
    38 $(SDIR)/TaskOps.$(ARCH).o \
    39 $(SDIR)/IOBufferOps.$(ARCH).o
     38$(SDIR)/TaskOps.$(ARCH).o
    4039
    4140cmds = \
    … …  
    6766$(DESTLIB)/libdatacmd.a
    6867
    69 all: scheduler
     68all: psched
    7069
    71 scheduler: $(BIN)/scheduler.$(ARCH)
     70psched: $(BIN)/psched.$(ARCH)
    7271        @echo done
    7372
    74 $(BIN)/scheduler.$(ARCH) : $(funcs) $(cmds) $(libs)
     73$(BIN)/psched.$(ARCH) : $(funcs) $(cmds) $(libs)
    7574
    76 install: $(DESTBIN)/scheduler help
     75install: $(DESTBIN)/psched help
    7776
    78 help: cmd.basic.help cmd.data.help cmd.astro.help sched.help
     77help: cmd.basic.help cmd.data.help cmd.astro.help psched.help
    7978
    8079# utilities #################################################

  • trunk/Ohana/src/opihi/pantasks/TaskOps.c

    r4684 r4693  
    1 # include "scheduler.h"
     1# include "psched.h"
    22
    33static Task **tasks;

  • trunk/Ohana/src/opihi/pantasks/controller.c

    r4689 r4693  
    1 # include "scheduler.h"
     1# include "psched.h"
    22
    33int controller_host    PROTO((int, char **));

  • trunk/Ohana/src/opihi/pantasks/controller_check.c

    r4573 r4693  
    1 # include "scheduler.h"
     1# include "psched.h"
    22
    33int controller_check (int argc, char **argv) {

  • trunk/Ohana/src/opihi/pantasks/controller_exit.c

    r4689 r4693  
    1 # include "scheduler.h"
     1# include "psched.h"
    22
    33int controller_exit (int argc, char **argv) {

  • trunk/Ohana/src/opihi/pantasks/controller_host.c

    r4573 r4693  
    1 # include "scheduler.h"
     1# include "psched.h"
    22
    33int controller_host (int argc, char **argv) {

  • trunk/Ohana/src/opihi/pantasks/controller_output.c

    r4689 r4693  
    1 # include "scheduler.h"
     1# include "psched.h"
    22
    33int controller_output (int argc, char **argv) {

  • trunk/Ohana/src/opihi/pantasks/controller_status.c

    r4573 r4693  
    1 # include "scheduler.h"
     1# include "psched.h"
    22
    33int controller_status (int argc, char **argv) {

  • trunk/Ohana/src/opihi/pantasks/delete.c

    r4689 r4693  
    1 # include "scheduler.h"
     1# include "psched.h"
    22
    33int delete_job (int argc, char **argv) {

  • trunk/Ohana/src/opihi/pantasks/init.c

    r4603 r4693  
    1 # include "scheduler.h"
     1# include "psched.h"
    22
    33int controller      PROTO((int, char **));
    … …  
    4747*/
    4848
    49 void InitSched () {
     49void InitPsched () {
    5050 
    5151  int i;

  • trunk/Ohana/src/opihi/pantasks/job.c

    r4552 r4693  
    1 # include "scheduler.h"
     1# include "psched.h"
    22
    33/* this will require a bit of care: to define a job, we need

  • trunk/Ohana/src/opihi/pantasks/kill.c

    r4689 r4693  
    1 # include "scheduler.h"
     1# include "psched.h"
    22
    33int kill_job (int argc, char **argv) {

  • trunk/Ohana/src/opihi/pantasks/run.c

    r4552 r4693  
    1 # include "scheduler.h"
     1# include "psched.h"
    22
    33int run (int argc, char **argv) {

  • trunk/Ohana/src/opihi/pantasks/status.c

    r4689 r4693  
    1 # include "scheduler.h"
     1# include "psched.h"
    22
    33int status_sys (int argc, char **argv) {

  • trunk/Ohana/src/opihi/pantasks/stop.c

    r4552 r4693  
    1 # include "scheduler.h"
     1# include "psched.h"
    22
    33int stop (int argc, char **argv) {

  • trunk/Ohana/src/opihi/pantasks/task.c

    r4689 r4693  
    1 # include "scheduler.h"
     1# include "psched.h"
    22# define prompt "> "
    33

  • trunk/Ohana/src/opihi/pantasks/task_command.c

    r4684 r4693  
    1 # include "scheduler.h"
     1# include "psched.h"
    22
    33int task_command (int argc, char **argv) {

  • trunk/Ohana/src/opihi/pantasks/task_host.c

    r4689 r4693  
    1 # include "scheduler.h"
     1# include "psched.h"
    22
    33int task_host (int argc, char **argv) {

  • trunk/Ohana/src/opihi/pantasks/task_macros.c

    r4689 r4693  
    1 # include "scheduler.h"
     1# include "psched.h"
    22# define D_NLINES 100
    33# define prompt "> "

  • trunk/Ohana/src/opihi/pantasks/task_nmax.c

    r4684 r4693  
    1 # include "scheduler.h"
     1# include "psched.h"
    22
    33int task_nmax (int argc, char **argv) {

  • trunk/Ohana/src/opihi/pantasks/task_periods.c

    r4689 r4693  
    1 # include "scheduler.h"
     1# include "psched.h"
    22
    33int task_periods (int argc, char **argv) {

  • trunk/Ohana/src/opihi/pantasks/task_trange.c

    r4689 r4693  
    1 # include "scheduler.h"
     1# include "psched.h"
    22
    33int task_trange (int argc, char **argv) {

  • trunk/Ohana/src/opihi/pantasks/verbose.c

    r4602 r4693  
    1 # include "scheduler.h"
     1# include "psched.h"
    22
    33static int VERBOSE = FALSE;
Note: See TracChangeset for help on using the changeset viewer.