LSF::Queue - get information about LSF queues.

LSF documentation Contained in the LSF distribution.

Index

Code Index:

NAME

Top

LSF::Queue - get information about LSF queues.

SYNOPSIS

Top

use LSF::Queue;

use LSF::Queue RaiseError => 0, PrintError => 1, PrintOutput => 0;

($qinfo) = LSF::Queue->new( [QUEUE_NAME] );

@qinfo = LSF::Queue->new();

DESCRIPTION

Top

LSF::Queue is a wrapper arround the LSF 'bqueues' command used to obtain information about job queues. The hash keys of the object are LSF submission and control parameters. See the 'bqueues' man page for more information.

INHERITS FROM

Top

LSF

CONSTRUCTOR

Top

new( [ [QUEUE_NAME] ] );

With a valid queue name, reates a new LSF::JobInfo object. Without a queue name returns a list of LSF::Queue objects for all the queues in the system. Arguments are the LSF parameters normally passed to 'bqueues'

BUGS

Top

The use of the '-l' flag of the LSF command lines can be considered a bug. The parsing of LSF output is particularly unsafe if job and group names with non-alphanumeric characters are used. You probably shouldn't be doing this anyway. Otherwise, please report them.

HISTORY

Top

The LSF::Batch module on cpan didn't compile easily on all platforms i wanted. The LSF API didn't seem very perlish either. As a quick fix I knocked these modules together which wrap the LSF command line interface. It was enough for my simple usage. Hopefully they work in a much more perly manner.

SEE ALSO

Top

LSF, bqueues

AUTHOR

Top

Mark Southern (mark_southern@merck.com)

COPYRIGHT

Top

Copyright (c) 2002, Merck & Co. Inc. All Rights Reserved. This module is free software. It may be used, redistributed and/or modified under the terms of the Perl Artistic License (see http://www.perl.com/perl/misc/Artistic.html)

LSF documentation Contained in the LSF distribution. 
package LSF::Queue; $VERSION = 0.3;

use strict;
use warnings;
use base qw( LSF );
use IPC::Run qw( run );

sub import{
    my ($self, %p) = @_;
    $p{RaiseError}  ||= 1;
    $p{PrintOutput} ||= 1;
    $p{PrintError}  ||= 1;
    $self->PrintOutput($p{PrintOutput}) if exists $p{PrintOutput};
    $self->PrintError ($p{PrintError} ) if exists $p{PrintError};
    $self->RaiseError ($p{RaiseError} ) if exists $p{RaiseError};
}

sub new{
    my($class,@params) = @_;
    my @output = $class->do_it('bqueues','-l',@params);
    return unless @output;
    my @queue;
    for my $text (split(/^-+$/m,$output[0])){
        my $queue;
        for ('QUEUE','USERS','HOSTS','RES_REQ','PREEMPTION',
             'CHKPNTDIR','CHKPNTPERIOD','CHUNK_JOB_SIZE'){
            if( $text =~ /^($_):\s+(.+)$/m ){
                $queue->{$1} = $2;
            }
        }
        $text =~ /^  -- (.+)$/m;
        $queue->{DESC} = $1;
        for ('MEMLIMIT','PROCLIMIT','CPULIMIT'){
            if( $text =~ /\n ($_)\n ([^\n]+)/ ){
                $queue->{$1} = $2;
            }
        }
        $text =~ /PARAMETERS\/STATISTICS\n([^\n]+)\n\s*([^\n]+)/;
        my @keys = split(/\s+/,$1);
        my @vals = split(/\s+/,$2);
        for( my $i = 0; $i < @keys; $i++ ){
            $queue->{$keys[$i]} = $vals[$i];
        }
        bless $queue, $class;
        push @queue,$queue;
    }
    return @queue;
}

1;

__END__