source: experiments/5_1_wait/a.c @ 16

#include <stdio.h>
#include <stdlib.h>

#include <llapi.h>
#include <unistd.h>
#include <fcntl.h>
#include <time.h>
#include <string.h>
#include <errno.h>

#include <sys/types.h>
#include <sys/stat.h>

#define CHAR_BUFFER 256
#define FILE_LENGTH 1024

int createCmd(char *prog, char *params, char *addr, size_t adrrLength)
{       

        FILE * fd;
        fd = fopen(addr,"wx");  
        if(fd!=NULL)
        {
                fprintf(fd,"# File created by LoadLeveler DRMAA. If no LL DRMAA aplications are running you can delete this file\n");
                fprintf(fd,"# @ initialdir = %s\n","/home/mamon/michal/5_1_wait");
                fprintf(fd,"# @ executable = %s\n",prog);
                fprintf(fd,"# @ arguments = %s\n",params);
                fprintf(fd,"# @ output = %s.out\n",prog);
                fprintf(fd,"# @ error = %s.err\n",prog);
                fprintf(fd,"# @ queue\n");
                fclose(fd);
        }
        else
        {
                perror("Can't create cmd file\n");  //przetestowac
                exit(1);
        }
        return 0;
}

int compare(char *ad1,char *ad2,size_t l1,size_t l2)
{
        int i = 0;
        size_t min = l2;
        char * inx = ad2;
        if(l1<l2) 
        {
                min = l1;
                inx = ad1;
        }
        
        for(i = 0;i<min;i++)
                if(ad1[i]!=ad2[i]) return 0;    

        return 1; 
}

int endState(char *buffer,size_t length)
{
        if(compare(buffer,"JOB_COMPLETED",length,sizeof("JOB_COMPLETED")) || 
                compare(buffer,"JOB_REJECTED",length,sizeof("JOB_REJECTED")) ||
                compare(buffer,"JOB_REMOVED",length,sizeof("JOB_REMOVED")) ||
                compare(buffer,"JOB_NOTRUN",length,sizeof("JOB_NOTRUN")) ||
                compare(buffer,"JOB_VACATED",length,sizeof("JOB_VACATED")) )
                return 1;
        else
                return 0;
}

int fgetline(char str[], int maxlen, FILE *fp)
{
        int last;
        if(!fgets(str, maxlen, fp))
                return -1;
        last = strlen(str)-1;
        if(str[last]=='\n') str[last] = '\0';
        return 0;
}

int main(int argc, char *argv[])
{
        LL_job test;
        int status;
        char *mon = "/home/mamon/michal/5_1_wait/mon";
        FILE * fd;
        char *prog;
        char *fifoAddr;
        char templateCmd[] = "/tmp/drmaa_cmd_XXXXXX";
        char templateFifo[] = "/tmp/drmaa_fifo_XXXXXX";

        if (argc<2) 
        {
                fprintf(stderr, "usage: example <path-to-job> [args]\n");
                return 1;
        }

        
        prog=mktemp(templateCmd);
        
        if(argc==3)
                createCmd(argv[1],argv[2],prog,CHAR_BUFFER);
        else
                createCmd(argv[1],"",prog,CHAR_BUFFER);
        
        fifoAddr=mktemp(templateFifo);

        status = llsubmit(prog,mon,fifoAddr,&test,LL_JOB_VERSION); 

        remove(prog);
        llfree_job_info(&test,LL_JOB_VERSION);

        if(status==0)
        {
                char buffer[CHAR_BUFFER];
                int idGot=1;
                //int i = 3;
                
                mkfifo(fifoAddr,0600);
                fd=fopen(fifoAddr,"r"); //x
                
                do
                {
                        if(fgetline(buffer,sizeof(buffer),fd)!=-1)
                        {
                                if(idGot==1)
                                {
                                        idGot=0;
                                        printf("Your job has been submitted with id %s\n",buffer);
                                }
                        }
                        //printf("a: %s\n",buffer);
                } while(!endState(buffer,sizeof(buffer)));
                printf("End state: %s\n",buffer);
                fgetline(buffer,sizeof(buffer),fd);
                printf("Exit status: %s\n",buffer);
                
                fclose(fd);

                unlink(fifoAddr);       
        }
        else
                printf("error\n");

        return 0;
}