sub save($;$) {
my ($job, $fn) = @_;
-d "tmp" or mkdir "tmp" or die "Cannot create directory tmp: $!";
- $fn //= 'tmp/t-' . $job->{'ID'};
+ $fn //= 'tmp/' . $job->{'ID'};
open T, '>', $fn or die "Cannot create $fn: $!";
for my $k (sort grep { /^[A-Z]/ } keys %$job) {
print T "$k: ", $job->{$k}, "\n";
sub queue_file($$) {
my ($queue, $machine, $jid) = @_;
- return $queue->host_dir($machine) . '/q-' . $jid;
+ return $queue->host_dir($machine) . '/' . $jid . '.job';
}
sub status_file($$) {
my ($queue, $machine, $jid) = @_;
- return $queue->host_dir($machine) . '/s-' . $jid;
+ return $queue->host_dir($machine) . '/' . $jid . '.stat';
}
sub temp_file($$) {
my ($queue, $machine, $jid) = @_;
- return $queue->host_dir($machine) . '/t-' . $jid;
+ return $queue->host_dir($machine) . '/' . $jid . '.tmp';
}
sub job_file($$) {
my ($queue, $jid) = @_;
- return $queue->{'Name'} . '/jobs/j-' . $jid;
+ return $queue->{'Name'} . '/jobs/' . $jid. '.job';
}
sub enqueue($$$) {
-f $fn or $job->save($fn);
my $dir = $queue->host_dir($machine);
-d $dir or mkdir $dir or die "Cannot create directory $dir: $!";
- symlink "../../jobs/j-" . $job->{'ID'}, $qf or die "Cannot create $qf: $!";
+ symlink '../../jobs/' . $job->{'ID'} . '.job', $qf or die "Cannot create $qf: $!";
return 1;
}
my @list = ();
if (opendir D, $queue->host_dir($machine)) {
while ($_ = readdir D) {
- s/^q-// or next;
+ /^\./ and next;
+ s{\.job}{} or next;
push @list, $_;
}
closedir D;