home *** CD-ROM | disk | FTP | other *** search
/ Netware Super Library / Netware Super Library.iso / remote / jservr / jsubmit.c < prev    next >
Encoding:
C/C++ Source or Header  |  1990-01-15  |  9.5 KB  |  293 lines
  1. /***************************************************************************** 
  2.  * 
  3.  * Program Name:jsubmit - Generic Job Server Front-End 
  4.  * 
  5.  * Filename:jsubmit.c 
  6.  * 
  7.  * Date Created:  November 21, 1988 
  8.  * 
  9.  * Version: 1.0 
  10.  * 
  11.  * Programmers:Greg Peto 
  12.  * 
  13.  * Files used:..\genjob.obj 
  14.  * 
  15.  * Date Modified: Jan. 28, 1989 
  16.  * 
  17.  * Comments:   
  18.  * 
  19.  *  This command line utility works in conjucntion with the generic job 
  20.  *     server utilities JSUPER, and JSERVER.  It is designed to let the 
  21.  *     user submit a dos command line to the job queue for remote 
  22.  *     execution on a job server machine. 
  23.  *  See the function of badUsage for summary of possible command line arguments 
  24.  *     to this utility.  All command line arguments are expected in the 
  25.  *     form: 
  26.  *       /<command keyword>=<command argument> 
  27.  *  To locate where global variables are initialized or set, look at 
  28.  *     ComAndInit for command line settings or for the variables as 
  29.  *     output variables passed to a function call. 
  30.  ****************************************************************************/ 
  31.  
  32. /* functions in this file: 
  33. */                           
  34. #include"..\genjob.h" 
  35. #include<sys\types.h> 
  36. #include<sys\stat.h> 
  37.  
  38. /* constants definitions */ 
  39. #defineVERB_TEST1       /* want verbose test messages */ 
  40.  
  41.  
  42. /* global variables and data types */ 
  43. COMMAND_ARGS command_args[] = 
  44.   /* token,     keyword      num sig,req. string,req. int */ 
  45. { 
  46. # defineCOM_ACKNOWLEDGE1 
  47.   {COM_ACKNOWLEDGE,"ACKNOWLEDGE",2, FALSE,    FALSE}, 
  48.  
  49. # defineCOM_SERVER COM_ACKNOWLEDGE + 1 
  50.   {COM_SERVER,"SERVER",   1,     TRUE,        FALSE}, 
  51.  
  52. # defineCOM_NACKNOWLEDGECOM_SERVER + 1 
  53.   {COM_NACKNOWLEDGE,"NACKNOWLEDGE",3,FALSE,FALSE} 
  54. }; 
  55.  
  56. JOBFILE     jobFile;    /* buffer of job file */ 
  57. CLIENT_REC_AREAjobClientArea;/* buffer of job client record area */ 
  58. JobStruct   job;          /* QMS job struct to be used in calls */ 
  59. WORD        jobType;    /* job type numer */ 
  60. BOOLEAN     wantServiceRestart= TRUE; 
  61. BOOLEAN     doAckMess     = TRUE;/* send message when job done */ 
  62.  
  63. /* module specific varables and data types */ 
  64. /* macro definitions */ 
  65.  
  66. /*****************************************************************************/ 
  67.  
  68.  
  69. main(argc,argv,envp) 
  70.   /* Descrip: 
  71.        This program supports the generic job server.  This utility 
  72.        allow the user ot submit DOS command lines to be executed 
  73.        remotely. 
  74.      Algorithm:// 
  75.          Parse and handle command line arguments, initialize defaults 
  76.          Get environment info for remote execution 
  77.          Put job in queue                                 
  78.   */ 
  79.   /* Input: */ 
  80. int argc; 
  81. char *argv[]; 
  82. char *envp[]; 
  83.    
  84. {   /* main // */ 
  85.   /*--------------------------------------------------main body */ 
  86.   if (argc == 1) 
  87.     BadUsage(NULL);/* missing command line arguments */ 
  88.  
  89.   ComAndInit(--argc,++argv);/* skip past program name */ 
  90.   GetJobEnviron(envp,&jobFile); 
  91.   PutJob(); 
  92. }   /* of main */ 
  93.  
  94. /********************************************************************/ 
  95.  
  96. BadUsage(message) 
  97.   /* Descrip: 
  98.        This function is called when a fatal error is detected in the 
  99.          command line.  It displays the command format and options 
  100.          and then exits the program. 
  101.   */ 
  102.   /* Input: */ 
  103. char*message;/* optional explanatory message */ 
  104.    
  105. {   /* BadUsage // */ 
  106.   /*--------------------------------------------------main body */ 
  107.   if (message) 
  108.     printf("Error: %s\n\n",message); 
  109.   printf("usage: jsubmit [<command parameters>] <command line>\n\n"); 
  110.   printf("   /ACknowledge\n"); 
  111.   printf("   /NACknowledge\n"); 
  112.   printf("   /Server=<target server with job queue>\n"); 
  113.   printf("   <command line> - DOS command line to be executed remotely\n"); 
  114.  
  115.   exit(1); 
  116. }   /* end of BadUsage */ 
  117.    
  118. /********************************************************************/ 
  119.  
  120. ComAndInit(argc,argv) 
  121.   /* Descrip: 
  122.          This function parses command line input and sets default values. 
  123.        Several global variables may be changed from their default values 
  124.          by command line arguments. 
  125.      Algorithm:// 
  126.          Scans command line arguments, overiding defaults as needed. 
  127.          See top of this file for notes on expected form of command 
  128.             line option and badUsage for specific form of commands. 
  129.        Saves remote execution command line in jobClientArea. 
  130.        Find server of target queue and save in global variable. 
  131.     BUGS: 
  132.        Not all command line options implemented yet. 
  133.   */ 
  134.   /* Input: */ 
  135. int argc; 
  136. char *argv[]; 
  137.    
  138. {   /* ComAndInit // */ 
  139.   /* name of server with job queue */ 
  140.   char queueServerName[MAX_FSERVER_NAME]; 
  141.   char argString[MAX_ARG_VAR];/* command parameter variable buffer */ 
  142.   long argInt;            /* numeric parameter variable */ 
  143.   JOB_TIMEargTime;        /* time parameter */ 
  144.   JOB_DATEargDate;        /* date parameter */ 
  145.   /*--------------------------------------------------main body */ 
  146.   queueServerName[0] = '\0'; 
  147.  
  148.   for (;argc; --argc, ++argv) 
  149.   { 
  150.     if (*argv[0] NOT= '/') 
  151.        break;/* no more command line options, quit for loop */ 
  152.     switch (ScanArg((*argv) + 1,command_args, 
  153.             sizeof(command_args)/sizeof(COMMAND_ARGS), 
  154.             argString,&argInt,&argTime,&argDate)) 
  155.     { 
  156.        caseCOM_ACKNOWLEDGE: 
  157.          doAckMess= TRUE; 
  158.          break; 
  159.        caseCOM_SERVER: 
  160.          if (strlen(argString) > (MAX_FSERVER_NAME - 1)) 
  161.          { 
  162.             printf("Server name length must be less than %d, aborting\n", 
  163.               MAX_FSERVER_NAME - 1); 
  164.             exit(1); 
  165.          } 
  166.          strcpy(queueServerName,argString); 
  167.          break; 
  168.        caseCOM_NACKNOWLEDGE: 
  169.          doAckMess= FALSE; 
  170.          break; 
  171.        default: 
  172.          printf("Internal error: ComAndInit"); 
  173.          exit(1); 
  174.     }   /* end of switch on ScanArg */ 
  175.      
  176.   } /* end of for argc loop */ 
  177.  
  178.   GetCopyCommand(argc,argv); 
  179.  
  180.   FindJobServer(queueServerName,TRUE); 
  181.   if (jobQueueID == NULL) 
  182.   { 
  183.     printf("Could not find any server with job queue.\n"); 
  184.     exit(1); 
  185.   } 
  186.  
  187. # if VERB_TEST 
  188.     printf("Found server %s, connection ID %x\n", 
  189.        queueServerName ? "(default)" : queueServerName, 
  190.        jobServerConID); 
  191. # endif 
  192. }   /* end of ComAndInit */ 
  193.    
  194. /********************************************************************/ 
  195.  
  196. GetCopyCommand(argc,argv) 
  197.   /* Descrip: 
  198.        This function copies the rest of the command line arguments 
  199.          into the buffer for the client record area. 
  200.   */ 
  201.   /* Input: */ 
  202. intargc; 
  203. char*argv[]; 
  204.    
  205. {   /* GetCopyCommand // */ 
  206.   /*--------------------------------------------------main body */ 
  207.   for (;argc; --argc, ++argv) 
  208.   { 
  209.     strncat((char *) jobClientArea.jobCommand,*argv); 
  210.     strncat(jobClientArea.jobCommand," "); 
  211.   } 
  212. # if VERB_TEST 
  213.     printf("Remote execute command line: %s\n",jobClientArea.jobCommand); 
  214. # endif 
  215. }   /* end of GetCopyCommand */ 
  216.    
  217. /********************************************************************/ 
  218.  
  219. PutJob() 
  220.   /* Descrip: 
  221.        This function attempts to put the job in the job queue. 
  222.      Algorithm:// 
  223.        Fill job structure with appropriate values. 
  224.        Create job in queue on server. 
  225.        Write associated file. 
  226.        Close job and file in queue, leave ready for processing. 
  227.   */ 
  228.    
  229. {   /* PutJob // */ 
  230.   int  i; 
  231.   int  assocFile;  /* DOS C handle to job associated file */ 
  232.   int  ccode; 
  233.   /*--------------------------------------------------main body */ 
  234.   SetPreferredConnectionID(jobServerConID); 
  235.   /* Set queue job default values */ 
  236.   if (wantServiceRestart) 
  237.     /* automatic requeue if server of job loses connection */ 
  238.     job.jobControlFlags   = QF_SERVICE_RESTART; 
  239.  
  240.   job.targetServerIDNumber= -1;/* any server */ 
  241.   for (i = 0;i < TARGET_TIME_BYTES; i++) 
  242.     job.targetExecutionTime[i]= -1;/* soonest time */ 
  243.  
  244.   job.jobType                = jobType; 
  245.   strcpy((char *) job.textJobDescription,"Command line job server"); 
  246.   jobClientArea.v         = 'v'; 
  247.   jobClientArea.period    = '.'; 
  248.   jobClientArea.versionNumber= '0' + JOB_REC_V_NUMBER; 
  249.   memcpy(job.clientRecordArea,&jobClientArea,sizeof(jobClientArea)); 
  250.  
  251.   if (ccode = CreateQueueJobAndFile(jobQueueID,&job,&assocFile)) 
  252.   { 
  253.     switch(ccode) 
  254.     { 
  255.        case NO_Q_RIGHTS: 
  256.        case INVALID_BINDERY_SECURITY: 
  257.        case NO_PROPERTY_CREATE_PRIVILEGE: 
  258.          printf("Insufficient rights to add a job to queue.\n"); 
  259.          break; 
  260.        case Q_FULL: 
  261.          printf("Queue is full, unable add job to queue.\n"); 
  262.          break; 
  263.        case SERVER_BINDERY_LOCKED: 
  264.          printf("Bindery locked, unable to add job to queue.\n"); 
  265.          break; 
  266.        case BINDERY_FAILURE: 
  267.          printf("Bindery failure, unable to add job to queue.\n"); 
  268.          break; 
  269.        default: 
  270.          printf("Unable to create job in queue.\n"); 
  271.     }   /* end of switch */ 
  272.     exit(1); 
  273.   } 
  274.  
  275.  
  276.   if (doAckMess) 
  277.     on_flag(jobFile.flags,DO_ACK_MESS); 
  278.   if (write(assocFile,&jobFile,sizeof(jobFile)) == -1) 
  279.   { 
  280.     printf("Unable to write to job associated file.\n"); 
  281.     exit(1); 
  282.   } 
  283.  
  284.   if (CloseFileAndStartQueueJob(jobQueueID,job.jobNumber,assocFile)) 
  285.   { 
  286.     printf("Unable to finish job entry in queue, submit failed.\n"); 
  287.     exit(1); 
  288.   } 
  289. }   /* end of PutJob */ 
  290.    
  291. /********************************************************************/ 
  292.  
  293.