a75fc20a5ce7c5317a5649cc1dd1328a144f4dd5
[plewww.git] / planetlab / sirius / sirius_func.php
1 <?php
2
3 function authorizeSlice($sn) {
4
5         global $api;
6
7   $slice_list= array();
8   $result= $api->GetSlices( Null, array( "name", "slice_id" ) );
9
10   foreach ( $result AS $slice )
11   {
12         if ( $slice["name"] == $sn )
13                 return 1;
14
15   }
16
17   return 0;
18
19 }
20
21 //can a request be satisfied?  Currently, answer is yes unless
22 //either this time is taken or you asked for more than one unit
23 //probably will need to change this.
24 function validateRequest ($units, $timesOccupied, $requestedTime, $currentTime) {
25   if ($units != 1)
26     return TOO_MANY_UNITS;
27
28   // buffer so we aren't too close to deadline, if your request is late
29   // OR if it's within 1 minute of deadline, it's too late
30   if ($requestedTime - 60 <= $currentTime)
31     return TIME_ALREADY_OCCURRED;
32
33   if (array_key_exists($requestedTime, $timesOccupied)) {
34     if ($timesOccupied[$requestedTime] == MAX_JOBS)
35       return NO_ROOM;
36   }
37   return SUCCESS;
38 }
39
40 //can a request be satisfied?  Currently, answer is yes unless
41 //either this time is taken or you asked for more than one unit
42 //probably will need to change this.
43 function validateAndMarkRequest ($units, &$timesOccupied, $requestedTime, $currentTime, $sn, $jobArray) {
44   // buffer so we aren't too close to deadline, if your request is late
45   // OR if it's within 1 minute of deadline, it's too late
46   if ($requestedTime - 60 <= $currentTime)
47     return TIME_ALREADY_OCCURRED;
48
49   if (array_key_exists($requestedTime, $timesOccupied)) {
50     if ($timesOccupied[$requestedTime] == MAX_JOBS)
51       return NO_ROOM;
52     else
53       $timesOccupied[$requestedTime]++;
54   }
55   else {
56     $timesOccupied[$requestedTime] = 1;
57     if (array_key_exists($sn, $jobArray)) {
58       $ts = $jobArray[$sn]["timestamp"];
59       $timesOccupied[$ts]--;
60     }
61   }
62
63   if ($units != 1)
64     return TOO_MANY_UNITS;
65
66   return SUCCESS;
67 }
68
69 function findNextFreeSlot($units, $timesOccupied) {
70   $currYear = gmdate("y");
71   $currMonth = gmdate("m");
72   $currDate = gmdate("d");
73   $currHour = gmdate("H") + 1;
74   $currentTime = time();
75   $reqTime = gmmktime($currHour, 0, 0, $currMonth, $currDate, $currYear);
76   $retVal = 1;
77   while ($retVal != SUCCESS) {
78     $retVal = validateRequest($units, $timesOccupied, $reqTime, $currentTime);
79     if ($retVal == NO_ROOM || $retVal == TIME_ALREADY_OCCURRED) { // advance timestamp one hour (3600 seconds)
80       $reqTime = $reqTime + 3600;
81     }
82   }
83   return $reqTime;
84 }
85
86 function dumpToFile($fileName, $buffer, $which, $timesOccupied) {
87   //open file, and dump newly list into it (buffer is the list)
88   //we're just currently overwriting (fopen with "w" truncates)
89
90   $fileHandle = fopen($fileName, "w");
91   //periodically, updateSliceUnits program will update the slices file
92   //this function is general, works for schedule or slices file
93
94   //lock in case of concurrent accesses
95   flock($fileHandle, LOCK_EX);
96
97   if ($which == "schedule") {  // need to write timestamp in this case
98     $s = gettimeofday();
99     fwrite($fileHandle, $s['sec']);
100     fwrite($fileHandle, "\n");
101   }
102
103   //do the dump here
104   foreach ($buffer as $value) {
105     $t = "";
106     if ($which == "schedule") {
107       if (strcmp($value["timestamp"], time()) > 0) {
108         $numReps = $value["reps"];
109         $ts = $value["timestamp"];
110         $t = $value["sliceName"]." ".$value["id"]." ".$value["timestamp"]." ".$value["units"]." ".$value["reps"]." \n";
111       }
112       else {  // job expired, does it need be run again?
113         if ($value["reps"] > 0) {
114           $ts = findNextFreeSlot($value["units"], $timesOccupied);
115         }
116         $numReps = $value["reps"] - 1;
117       }
118       if ($numReps >= 0)
119         $t = $value["sliceName"]." ".$value["id"]." ".$ts." ".$value["units"]." ".$numReps." \n";
120     }
121     else if ($which == "slices") {
122       $t = $value["sliceName"]." ".$value["units"]." \n";
123     }
124
125     if ($t != "")
126       fwrite($fileHandle, $t);
127
128   }
129
130   flock($fileHandle, LOCK_UN);
131
132   fclose($fileHandle);
133 }
134
135 //update the slice file, takes a slice name (name) and number of units
136 function updateSliceFile($name, $units) {
137   $dummyArray = array();
138
139   $sliceFile = fopen("slices.txt", "rw");
140   if (!$sliceFile) {
141     echo "<p>Unable to open remote file.</p>";
142
143   }
144
145   flock($sliceFile, LOCK_EX);
146
147   //we'll construct a new list here, will be current slice file except
148   //the slice in question will have it's units decreased, if there are any...
149   while (!feof($sliceFile)) {
150     $num = fscanf($sliceFile, "%s %d\n", $sliceName, $unitsAvailable);
151     //for some reason feof seems to not quite work
152     //precisely, the last entry in the file is read twice (!?!), so hack here
153     if ($num == 0)
154       break;
155
156     $newArray["sliceName"] = $sliceName;
157     if ($name == $sliceName) {
158       $newUnits = $unitsAvailable - $units;
159       if ($newUnits < 0)  // error, slice has no more units
160         return -1;
161       else
162         $newArray["units"] = $newUnits;
163     }
164     else
165       $newArray["units"] = $unitsAvailable;
166     //append this tuple to the entire array
167     $sliceArray[] = $newArray;
168   }
169   flock($sliceFile, LOCK_UN);
170   fclose($sliceFile);
171   //do the dump to new file
172   dumpToFile("slices.txt", $sliceArray, "slices", dummyArray);
173   return 0;
174 }
175
176
177 //pretty obvious what this does; basically, does the slice exist in
178 //the slice file yet?  (New user of calendar service user may not have
179 //an entry)
180 function isFirstSliceRequest($name) {
181   $sliceFile = fopen("slices.txt", "r");
182   if (!$sliceFile) {
183     echo "<p>Unable to open remote file.</p>";
184
185   }
186
187   flock($sliceFile, LOCK_EX);
188
189   while (!feof($sliceFile)) {
190     $num = fscanf($sliceFile, "%s %d\n", $sliceName, $unitsAvailable);
191     //for some reason feof seems to not quite work
192     //precisely, the last entry in the file is read twice (!?!), so hack here
193     if ($num == 0)
194       break;
195
196     if ($name == $sliceName) {
197       flock($sliceFile, LOCK_UN);
198       fclose($sliceFile);
199       return 0;
200     }
201   }
202
203   flock($sliceFile, LOCK_UN);
204   fclose($sliceFile);
205   return 1;
206 }
207
208
209 function cmp ($a, $b) {
210   if ($a["timestamp"] == $b["timestamp"])
211     return 0;
212   else
213     return ($a["timestamp"] < $b["timestamp"]) ? -1 : 1;
214 }
215
216 function checkForErrors($requestStatus) {
217   if ($requestStatus == NO_ROOM) {
218     printf("<b> Error: Cannot add your request; that time slot is currently full. </b> <p>");
219   }
220   else if ($requestStatus == TOO_MANY_UNITS) {
221     printf("<b> Error: Cannot add your request; only 1 extra unit is allowed.</b> <p>");
222   }
223   else if ($requestStatus == NO_UNITS_LEFT) {
224     printf("<b> Error: Cannot add your request; no more units remaining.</b> <p>");
225   }
226   else if ($requestStatus == TIME_ALREADY_OCCURRED) {
227     printf("<b> Error: Cannot add your request; that time has already occurred, or is too close to the current time.</b> <p>");
228   }
229   else if ($requestStatus == NO_SUCH_SLICE) {
230     printf("<b> Error: Cannot delete nonexistent slice.</b> <p>");
231   }
232   else if ($requestStatus == NOT_SLICE_OWNER) {
233     printf("<b> Error: Only authorized user can manipulate slice.</b> <p>");
234   }
235   else if ($requestStatus == TOO_CLOSE_TO_DEADLINE) {
236     printf("<b> Error: Cannot delete your request; it is too close to the time that your slice will receive its priority increase.</b> <p>");
237   }
238 }
239
240 function getCurrentSchedule (&$jobArray, &$timesOccupied, &$maxId) {
241
242   $schedFile = fopen("schedule.txt", "r");
243   if (!$schedFile) {
244     echo "<p>Unable to open remote file.</p>";
245
246   }
247
248   flock($schedFile, LOCK_EX);
249
250   //first line is timestamp, throw it away.
251   fscanf($schedFile, "%s\n", $str);
252
253   //read in current file into array
254   $jobArray = array();
255   $newArray = array();
256   $timesOccupied = array();
257   $maxId = 0;
258   while (!feof($schedFile)) {
259     $num = fscanf($schedFile, "%s %d %s %d %d\n", $sliceName, $id, $timestamp, $units, $reps);
260
261     if ($id > $maxId)
262       $maxId = $id;
263
264     //for some reason feof seems to not quite work
265     //precisely, the last entry in the file is read twice (!?!), so hack here
266     if ($num == 0)
267       break;
268     $newArray["sliceName"] = $sliceName;
269     $newArray["id"] = $id;
270     $newArray["units"] = $units;
271     $newArray["timestamp"] = $timestamp;
272     $newArray["reps"] = $reps;
273     $jobArray[$sliceName] = $newArray;
274
275     if (array_key_exists($timestamp, $timesOccupied)) {
276       $timesOccupied[$timestamp]++;
277     }
278     else {
279       $timesOccupied[$timestamp] = 1;
280     }
281
282   }
283
284   flock($schedFile, LOCK_UN);
285   fclose($schedFile);
286
287 }
288
289
290 function findNextQueue($units, $timesOccupied) {
291   global $arr;
292   $currYear = gmdate("y");
293   $currMonth = gmdate("m");
294   $currDate = gmdate("d");
295   $currHour = gmdate("H") + 1;
296   $currentTime = time();
297   $reqTime = gmmktime($currHour, 0, 0, $currMonth, $currDate, $currYear);
298   $retVal = 1;
299   $i = 0;
300
301         // DAVE
302         // outputting table to display the queue
303         // green background will mean slot is open, and red will mean the slot is used
304         //
305   echo "<table cellspacing=\"2\" cellpadding=\"1\" border=\"0\" width=550>\n";
306   echo "<tr><td colspan=\"3\"><span class='bold'>24 hour Queue:</span> Choose the GMT time slot you desire (<font color=\"#339933\">green</font> slots are open, <font color=\"#CC3333\">red</font> are taken) <p></td></tr>\n";
307   echo "<tr><td width=\"47%\" align=\"right\"><table cellspacing=1 cellpadding=1 border=0 width=130>\n";
308
309   // here's what this does below: it goes through each hour, and sees if the slot is occupied
310   // if so, it outputs in red, w/ slice name ($arr[$x], where $x is the number request, i.e.
311   // earlier when we dump out the list of slices on the schedule, we do $arr[$x++] = $slicename
312   $x= 0;
313   //  while ($reqTime < ( $reqTime + ( 24 * 3600 ) ) ) {
314   while ($i < 12) {
315     $retVal = validateRequest($units, $timesOccupied, $reqTime, $currentTime);
316     if ($retVal == SUCCESS) { // advance timestamp one hour (3600 seconds)
317
318         echo "<tr bgcolor=\"#339933\"><td><input type=\"radio\" name=\"queue_time\" value=\"" . gmdate("H:i:s", $reqTime) . "\"> " . gmdate("H:i:s", $reqTime) . " &nbsp;  </td></tr>\n";
319     }
320     else {
321         echo"<tr bgcolor=\"#CC3333\"><td align=center> " . $arr[$x] . " </td></tr>\n";
322         $x++;
323     }
324
325     $reqTime = $reqTime + 3600;
326     $i++;
327   }
328   echo "</table></td><td width=\"6%\"> &nbsp; </td><td><table cellspacing=1 cellpadding=1 border=0 width=130>\n";
329
330   while ($i < 24 && $i > 11) {
331     $retVal = validateRequest($units, $timesOccupied, $reqTime, $currentTime);
332     if ($retVal == SUCCESS) { // advance timestamp one hour (3600 seconds)
333
334         echo "<tr bgcolor=\"#339933\"><td><input type=\"radio\" name=\"queue_time\" value=\"" . gmdate("H:i:s", $reqTime) . "\"> " . gmdate("H:i:s", $reqTime) . " &nbsp;  </td></tr>\n";     }
335     else {
336         echo"<tr bgcolor=\"#CC3333\"><td align=center> " . $arr[$x] . " </td></tr>\n";
337         $x++;
338     }
339
340     $reqTime = $reqTime + 3600;
341     $i++;
342   }
343   echo "</table></td></tr>\n";
344
345   echo "</table>\n";
346
347 }
348
349
350 function sliceDropDown() {
351
352         global $api;
353
354   $slice_list= array();
355   $result= $api->GetSlices( Null, array( "name", "slice_id" ) );
356   // sort_slices( $result ); --> slice sort on name
357   function __cmp_slices($a, $b) {
358     return strcasecmp($a['name'], $b['name']);
359   }
360   usort($result, '__cmp_slices');
361
362   foreach ( $result AS $slice )
363   {
364         echo "<option value='" . $slice["name"] . "'>" . $slice["name"] . "\n";
365
366   }
367
368 }
369
370
371
372
373
374 ?>