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

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

#define CHAR_BUFFER 256

int createBulkCmd(char *prog, char *params, char *addr, size_t adrrLength, int start, int end, int incr)
{       
        int i,count = (end-start+1)/incr;
        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_2_bulk");
                fprintf(fd,"# @ executable = %s\n",prog);
                fprintf(fd,"# @ arguments = %s\n",params);
                fprintf(fd,"# @ output = $(executable).$(jobid).$(stepid).out\n"); //stepname?
                fprintf(fd,"# @ error =  $(executable).$(jobid).$(stepid).err\n");
                fprintf(fd,"# @ job_type = parallel\n");
                for(i=0;i<count;i++)
                {       
                        //fprintf(fd,"# @ step_name = %s\n",start+i*incr);
                        fprintf(fd,"# @ queue\n");
                }
                fclose(fd);
        }
        else
        {
                perror("Can't create cmd file\n");  //przetestowac
                exit(1);
        }
        return 0;
}

int main(int argc, char *argv[])
{
        int i=0;
        LL_job test;
        int status;
        char templateCmd[] = "/tmp/drmaa_cmd_XXXXXX";
        char *prog;
        if(argc<6)
        {
                printf("./a <program> <start> <end> <incr> [params] \n");
                exit(1);
        }
        
        
        prog=mktemp(templateCmd);
        
        if(argc==6)
                createBulkCmd(argv[1],argv[5],prog,CHAR_BUFFER,atoi(argv[2]),atoi(argv[3]),atoi(argv[4]));
        else
                createBulkCmd(argv[1],"",prog,CHAR_BUFFER,atoi(argv[2]),atoi(argv[3]),atoi(argv[4]));
        
        status = llsubmit(prog,NULL,NULL,&test,LL_JOB_VERSION); 
        
        remove(prog);
        printf("submitted bulk job with jobids:\n");
        for(i=0;i<test.steps;i++)
                printf("\t\"%s.%s\"\n",test.job_name,test.step_list[i]->step_name);
        
        llfree_job_info(&test,LL_JOB_VERSION);
        
        return 0;
}