Open Source Projects Europe

 *   Free Software Foundation, Inc.,

 *   Free Software Foundation, Inc.,

 *   59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.

 *   59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.

 */

 */

#ifndef _EXECMD_H_INCLUDED_

#ifndef _EXECMD_H_INCLUDED_

#define _EXECMD_H_INCLUDED_

#define _EXECMD_H_INCLUDED_

#include <signal.h>

#include <signal.h>

#include <string>

#include <string>

#include <vector>

#include <vector>

#include <stack>

#include <stack>

#include "netcon.h"

#include "netcon.h"

/** 

/** 

 * Callback function object to advise of new data arrival, or just periodic 

 * Callback function object to advise of new data arrival, or just periodic 

     * Add/replace environment variable before executing command. This must

     * Add/replace environment variable before executing command. This must

     * be called before doexec() to have an effect (possibly multiple

     * be called before doexec() to have an effect (possibly multiple

     * times for several variables).

     * times for several variables).

     * @param envassign an environment assignment string ("name=value")

     * @param envassign an environment assignment string ("name=value")

     */

     */

    void putenv(const string &envassign);

    void putenv(const string &name, const string& value);

    /** 

    /** 

     * Set function objects to call whenever new data is available or on

     * Set function objects to call whenever new data is available or on

     * select timeout / whenever new data is needed to send. Must be called

     * select timeout / whenever new data is needed to send. Must be called

     * before doexec()

     * before doexec()

     * usually go to the terminal or to wherever the desktop messages go).

     * usually go to the terminal or to wherever the desktop messages go).

     * There is currently no option to put stderr data into a program variable

     * There is currently no option to put stderr data into a program variable

     * If the parameter can't be opened for writing, the command's

     * If the parameter can't be opened for writing, the command's

     * stderr will be closed.

     * stderr will be closed.

     */

     */

    void setStderr(const string &stderrFile) {m_stderrFile = stderrFile;}

    /**

    /**

     * Execute command. 

     * Execute command. 

     *

     *

     * Both input and output can be specified, and asynchronous 

     * Both input and output can be specified, and asynchronous 

     * @param args the argument vector (NOT including argv[0]).

     * @param args the argument vector (NOT including argv[0]).

     * @param input Input to send TO the command.

     * @param input Input to send TO the command.

     * @param output Output FROM the command.

     * @param output Output FROM the command.

     * @return the exec ouput status (0 if ok), or -1

     * @return the exec ouput status (0 if ok), or -1

     */

     */

    int doexec(const string &cmd, const vector<string>& args, 

           const string *input = 0, 

           string *output = 0);

    /*

    /*

     * The next four methods can be used when a Q/A dialog needs to be 

     * The next four methods can be used when a Q/A dialog needs to be 

     * performed with the command

     * performed with the command

     */

     */

    int startExec(const string &cmd, const vector<string>& args, 

          bool has_input, bool has_output);

          bool has_input, bool has_output);

    int send(const string& data);

    int receive(string& data, int cnt = -1);

    int getline(string& data);

    int wait();

    int wait();

    /** Wait with WNOHANG set. 

    /** Wait with WNOHANG set. 

    @return true if process exited, false else.

    @return true if process exited, false else.

    @param O: status, the wait(2) call's status value */

    @param O: status, the wait(2) call's status value */

    bool maybereap(int *status);

    bool maybereap(int *status);

     * @param cmd command name

     * @param cmd command name

     * @param exe on return, executable path name if found

     * @param exe on return, executable path name if found

     * @param path exec seach path to use instead of getenv(PATH)

     * @param path exec seach path to use instead of getenv(PATH)

     * @return true if found

     * @return true if found

     */

     */

    static bool which(const string& cmd, string& exe, const char* path = 0);

    /**

    /**

     * Execute command and return stdout output in a string

     * Execute command and return stdout output in a string

     * @param cmd input: command and args

     * @param cmd input: command and args

     * @param out output: what the command printed

     * @param out output: what the command printed

    friend class ExecCmdRsrc;

    friend class ExecCmdRsrc;

 private:

 private:

    static bool      o_useVfork;

    static bool      o_useVfork;

    vector<string>   m_env;

    ExecCmdAdvise   *m_advise;

    ExecCmdAdvise   *m_advise;

    ExecCmdProvide  *m_provide;

    ExecCmdProvide  *m_provide;

    bool             m_killRequest;

    bool             m_killRequest;

    int              m_timeoutMs;

    int              m_timeoutMs;

    string           m_stderrFile;

    // Pipe for data going to the command

    // Pipe for data going to the command

    int              m_pipein[2];

    int              m_pipein[2];

    NetconP          m_tocmd;

    NetconP          m_tocmd;

    // Pipe for data coming out

    // Pipe for data coming out

    int              m_pipeout[2];

    int              m_pipeout[2];

    m_pipein[0] = m_pipein[1] = m_pipeout[0] = m_pipeout[1] = -1;

    m_pipein[0] = m_pipein[1] = m_pipeout[0] = m_pipeout[1] = -1;

    m_pid = -1;

    m_pid = -1;

    sigemptyset(&m_blkcld);

    sigemptyset(&m_blkcld);

    }

    }

    // Child process code

    // Child process code

    inline void dochild(const string &cmd, const char **argv, 

            const char **envv, bool has_input, bool has_output);

            const char **envv, bool has_input, bool has_output);

    /* Copyconst and assignment private and forbidden */

    /* Copyconst and assignment private and forbidden */

    ExecCmd(const ExecCmd &) {}

    ExecCmd(const ExecCmd &) {}

    ExecCmd& operator=(const ExecCmd &) {return *this;};

    ExecCmd& operator=(const ExecCmd &) {return *this;};

};

};

    {

    {

    m_atexitfuncs.push(function);

    m_atexitfuncs.push(function);

    return 0;

    return 0;

    }

    }

    void reexec();

    void reexec();

    const string& getreason() {return m_reason;}

    // Insert new args into the initial argv. idx designates the place

    // Insert new args into the initial argv. idx designates the place

    // before which the new args are inserted (the default of 1

    // before which the new args are inserted (the default of 1

    // inserts after argv[0] which would probably be an appropriate

    // inserts after argv[0] which would probably be an appropriate

    // place for additional options)

    // place for additional options)

    void insertArgs(const vector<string>& args, int idx = 1);

    void removeArg(const string& arg);

private:

private:

    vector<string> m_argv;

    string m_curdir;

    int    m_cfd;

    int    m_cfd;

    string m_reason;

    stack<void (*)(void)> m_atexitfuncs;

};

};

#endif /* _EXECMD_H_INCLUDED_ */

#endif /* _EXECMD_H_INCLUDED_ */