1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135
|
#ifndef JobInterface_h
#define JobInterface_h
/******************************************************************************
*
* Copyright (C) 2002 Hugo PEREIRA <mailto: hugo.pereira@free.fr>
*
* This is free software; you can redistribute it and/or modify it under the
* terms of the GNU General Public License as published by the Free Software
* Foundation; either version 2 of the License, or (at your option) any later
* version.
*
* This software is distributed in the hope that it will be useful, but WITHOUT
* Any WARRANTY; without even the implied warranty of MERCHANTABILITY or
* FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
* for more details.
*
* You should have received a copy of the GNU General Public License along with
* this program. If not, see <http://www.gnu.org/licenses/>.
*
*******************************************************************************/
#include "JobCommand.h"
#include "Debug.h"
#include "Job.h"
#include "MessageBuffer.h"
#include "UserSet.h"
#include <QHash>
#include <QObject>
#include <QProcess>
#include <QString>
class CustomProcess;
class JobThread;
//* Job managment
class JobInterface:public QObject, public Counter
{
//* Qt meta object declaration
Q_OBJECT
public:
//* constructor
JobInterface( QObject* parent = nullptr );
Q_SIGNALS:
//* emitted when job list is available
void jobListReady( Job::Set );
//* emitted when user list is available
void userListReady( UserSet );
//* command completed
void commandCompleted( JobCommand );
//* emitted when there is no more commands in pile
void ready( void );
//* message
void messageAvailable( const QString& );
public Q_SLOTS:
//* add command
void addCommand( JobCommand );
private Q_SLOTS:
//* error from process
void _error( QProcess::ProcessError );
//* take action when current command completed
void _commandCompleted( int = 0, QProcess::ExitStatus = QProcess::NormalExit );
//* read on-fly from process
void _readStdout( void );
//* read on-fly from process
void _readStderr( void );
protected:
//* process job set (using top)
void _processJobList( void );
//* reset buffers
void _resetBuffers( void );
//* run next command in pile
bool _runCommand( void );
//* reset process
void _resetProcess( void );
//* process
bool _hasProcess( void ) const
{ return process_; }
//* create new process to run command
CustomProcess& _newProcess( void );
//* process
CustomProcess& _process( void ) const
{ return *process_; }
//* convert string number (using k, M, G) into a number
static qint64 _memoryStringToInteger( const QString& value );
//* convert string time into a number
static qint64 _cpuTimeToInteger( const QString& value );
private:
//* custom process
CustomProcess* process_ = nullptr;
//* thread
JobThread* thread_ = nullptr;
//* stdout buffer
MessageBuffer stdoutBuffer_;
//* stderr buffer
MessageBuffer stderrBuffer_;
//* map command type to name
JobCommand::List commands_;
};
#endif
|