DistRen Changeset - 1f986f0a72d1 · protofusion repositories

Changeset - 1f986f0a72d1

Parent rev.

Child rev.

[Not reviewed]

default

0 1 0

Nathan Brink (binki) - 16 years ago 2009-07-24 20:30:00
ohnobinki@ohnopublishing.net

struct blendjob*-ized frame_finder()

1 file changed with 56 insertions and 35 deletions:

src/server/distrend.c

0 comments (0 inline, 0 general)

src/server/distrend.c

➞

Show inline comments

@@ @@ -271,95 +271,116 @@ void status_report_generator(struct blen @@
+}
 // **** Structure Builder: This function creates frame array based on the total number of frames to be rendered, which will then be parsed by function frame_farmer.
 void frame_num_struct_builder(struct blendjob *job, unsigned int startframe, unsigned int numframes) {
   int jobnum_new = highest_jobnum + 1; /* global vars will someday leave us  */
   unsigned int counter;
 	job->frameset = malloc(sizeof(struct frameset) * numframes);
 	if(!job->frameset)
 	  fprintf(stderr, "error allocating memory");
 	job->total_frames = numframes; // sets the total number of frames in animation for status purposes
 	job->jobnum = jobnum_new;
 	for(counter = 0; counter < numframes; counter ++)
 	  /* This builds the array, with the array starting at zero and the frame_num starting at sframe */
 	  job->frameset[counter].frame_num = counter + startframe;
 	highest_jobnum++; // After it has created the job, it adds one to the highest_jobnum interger
+}
 // Frame Assigner: matches your computer up with a lovely frame to render
 // Major issue here, the client needs to know the frame number, AND the job number!
 int frame_finder(){
 	int your_frame = 0;  // your_frame is an interger value that will be given to the client as the frame number to render
 	int finder_jobnum = 0;
 	int frameset_count = 0; // the frameset number, note* frames in an animation don't start at zero
 	short int done = 0;
 	short int priority = 10;
 /**
   Frame Finder: matches your computer up with a lovely frame to render
   Major issue here, the client needs to know the frame number, AND the job number!
   Notice that this function starts by looking at the oldest job first
   @return 0 success, other: error
 */
 int frame_finder(struct blendjob *head, struct blendjob **job, struct frameset **frame)
+{
   int your_frame;  // your_frame is an interger value that will be given to the client as the frame number to render
   unsigned short int found;
   unsigned short int priority;
   struct blendjob *blendjob_ptr;
 	while(priority >= 1){ // start the scan for the next job with the highest priority, decreases priority before it loops
 		finder_jobnum = hcfjob + 1; // reset it to start scanning at first uncompleted job for the pass at each priority level
   found = 0;
   while(!found)
+    {
       /* enumerate through priority levels */
       for(priority = 10;
 	  priority > 0
 	    && !found;
 	  priority --)
 	/* Find the job with the highest priority */
 	for(blendjob_ptr = head;
 	    blendjob_ptr != NULL
 	      && !found;
 	    blendjob_ptr = blendjob_ptr->next)
 	  if(blendjob_ptr->priority == priority)
 	    found = 1;
 		while(finder_jobnum <= highest_jobnum){  // This keeps increasing the finder_jobnum until it is higher than the highest_jobnum
 			if(blendjob[finder_jobnum].priority == priority){  // looks for a job with the current priority value
 				done = 1;									  // notice it starts by looking at the oldest job first
 				break;
       if(!found)
+	{
 	  fprintf(stderr, "out of jobs to render\n");
 	  return 1;
+			}
 			if((done) == 1)  // If it has found a job with the current priority value, it will break out of the loop
 				break;    // If none is found it goes to the next job to see if it is of the current priority value
 			else
 				finder_jobnum++;
 		} // End of increasing finder_jobnum
       found = 0;
       for(your_frame = 0;
 	  your_frame < blendjob_ptr->total_frames;
 	  your_frame ++)
 	if(blendjob_ptr->frameset[your_frame].frame_status == 0)
 	  found = 1;
 		if(done == 1) // if job has been found, it lets it out of the priority changer loop
 			break;
       if(!found)
+	{
 	  /* there are no frames left in this job */
 	  blendjob_ptr->priority --;
 		priority--; // end of decreasing priority
+	}
 	  /* If that job had no open frames for some reason, run the status report generator so that */
 	  status_report_generator(&head);
 	while(your_frame < blendjob[finder_jobnum].total_frames){ // Finds the frameset number with a frame that needs to be rendered
 		if (blendjob[finder_jobnum].frameset[frameset_count].frame_status == 0)  // If frame that is not assigned has been found, frameset_count is not changed
 			break;																// and frameset_count is used to give the frame number later in this funciton
 		frameset_count++;  // If frame is assigned or done, it goes to next frame
 	  /* should the job be removed now? */
 	  fprintf(stderr, "Job %d is finished, this is probably the place to call the job-removal function\n", blendjob_ptr->jobnum);
+	}
 blendjob[jobnum].frameset[frameset_count].frame_status++; // sets the value of the frame to 2, which means its taken
     } /* while(!found) */
 your_frame = blendjob[jobnum].frameset[frameset_count].frame_num; //  Takes the frameset found in the while statement above, and extracts the frame number from it and assigns it to the int your_frame
   fprintf(stderr, "Missing apostrophe !!!!!!!!!!!!!!\n"); abort();
   /* sets the value of the frame to 1, which means its taken !!!!!! MISSSING APOSTROPHE!!!!!!! */
   blendjob_ptr->frameset[your_frame].frame_status++;
 if(your_frame == 0)  // If that job had no open frames for some reason, run the status report generator so that
 	status_report_generator(blendjobs_head);  //the job priority can be changed to 0
   blendjob_ptr->frameset[your_frame].start_time = clock();
 blendjob[jobnum].frameset[frameset_count].start_time = clock();
   *job = blendjob_ptr;
   *frame =  &blendjob_ptr->frameset[your_frame];
-return your_frame; // your_frame is returned as the frame to be rendered
+  return 0;
+}
 void blend_frame_watchdog(struct blendjob *blendjob_head)
+{
   unsigned short int watchdog_forgiveness; /*< seconds to wait on a frame before re-assigning it */
   struct blendjob *blendjob_ptr;
   unsigned int counter;
   watchdog_forgiveness = 3; /*< hours of forgiveness before frame is re-assigned */
   blendjob_ptr = blendjob_head;
   for(blendjob_ptr = blendjob_head; blendjob_ptr; blendjob_ptr = blendjob_ptr->next)
     /* iterate through jobs */
     for(counter = 0; counter < blendjob_ptr->total_frames; counter ++)
       /* iterate through all frames for this job*/
+      {
 	if((blendjob_ptr->frameset[counter].start_time + (watchdog_forgiveness * 3600)) < clock())
 	  /*
 	    If frame is not completed within the number of hours specified by watchdog_forgiveness
 	    Then change the frame status to unassigned
 	  */
 	  blendjob_ptr->frameset[counter].frame_status = 0;
+      }

0 comments (0 inline, 0 general)