job_service.hpp

Go to the documentation of this file.

#ifndef SAGA_PACKAGES_JOB_JOB_SERVICE_HPP
#define SAGA_PACKAGES_JOB_JOB_SERVICE_HPP

#if defined(__WAVE__) && defined(SAGA_CREATE_PREPROCESSED_FILES)
#pragma wave option(preserve: 2, line: 1, output: "preprocessed/job_service.hpp")
#endif
//  Copyright (c) 2005-2008 Hartmut Kaiser
//  Copyright (c) 2007 Ole Weidner (oweidner@cct.lsu.edu)
// 
//  Distributed under the Boost Software License, Version 1.0. (See accompanying 
//  file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)

#if defined(__WAVE__) && defined(SAGA_CREATE_PREPROCESSED_FILES)
#pragma wave option(output: null)
#endif

#include <string>
#include <vector>

// include dependent spec sections
#include <saga/saga/util.hpp>
#include <saga/saga/base.hpp>
#include <saga/saga/types.hpp>
#include <saga/saga/session.hpp>
#include <saga/saga/call.hpp>
#include <saga/saga/url.hpp>

#include <saga/saga/packages/job/config.hpp>
#include <saga/saga/job.hpp>

// suppress warnings about dependent classes not being exported from the dll
#if defined(BOOST_MSVC)
#pragma warning(push)
#pragma warning(disable: 4251 4231 4275 4660)
#endif

#ifdef SAGA_DEBUG
#include <saga/saga/packages/job/preprocessed/job_service.hpp>
#else

#if defined(__WAVE__) && defined(SAGA_CREATE_PREPROCESSED_FILES)
#pragma wave option(preserve: 2, line: 1, output: "preprocessed/job_service.hpp")
#endif
namespace saga
{
    namespace job {
    
    class SAGA_JOB_PACKAGE_EXPORT service 
        : public saga::object
    {
    private:
        SAGA_CALL_PRIV_1(create_job, description);
        SAGA_CALL_PRIV_5(run_job, std::string, std::string,
            saga::job::ostream&, saga::job::istream&, saga::job::istream&);
        SAGA_CALL_PRIV_2(run_job, std::string, std::string)
        SAGA_CALL_PRIV_0(list);
        SAGA_CALL_PRIV_1(get_job, std::string);
        SAGA_CALL_PRIV_0(get_self);

    protected:

        friend class saga::impl::job_service;
        TR1::shared_ptr <saga::impl::job_service> get_impl (void) const;
        explicit service(saga::impl::job_service *impl);

    public:
        explicit service (session const& s, saga::url rm = saga::url());

        explicit service (saga::url rm = saga::url());

        explicit service (saga::object const& o);

        ~service (void);

        service& operator= (saga::object const& o);

        job create_job(description job_desc) 
        {
            saga::task t = create_jobpriv(job_desc, saga::task_base::Sync()); 
            return t.get_result<saga::job::job>();
        }
        SAGA_CALL_PUB_1_DEF_0(create_job, description)

        
        job run_job(std::string hostname, std::string commandline,
            saga::job::ostream& stdin_stream, saga::job::istream& stdout_stream, 
            saga::job::istream& stderr_stream) 
        {
            saga::task t = run_jobpriv(hostname, commandline, stdin_stream, 
                stdout_stream, stderr_stream, saga::task_base::Sync()); 
            return t.get_result<saga::job::job>();
        }
        SAGA_CALL_PUB_5_DEF_0(run_job, std::string, std::string,
            saga::job::ostream&, saga::job::istream&, saga::job::istream&)

        job run_job(std::string hostname, std::string commandline)
        {
            saga::task t = run_jobpriv(hostname, commandline, saga::task_base::Sync()); 
            return t.get_result<saga::job::job>();
        }
        SAGA_CALL_PUB_2_DEF_0(run_job, std::string, std::string)


        
        std::vector<std::string> list(void) 
        {
            saga::task t = listpriv(saga::task_base::Sync()); 
            return t.get_result<std::vector<std::string> >();
        }
        SAGA_CALL_PUB_0_DEF_0(list)

        
        job get_job(std::string job_id) 
        {
            saga::task t = get_jobpriv(job_id, saga::task_base::Sync()); 
            return t.get_result<saga::job::job>();
        }
        SAGA_CALL_PUB_1_DEF_0(get_job, std::string);

        saga::job::self get_self() 
        {
            saga::task t = get_selfpriv(saga::task_base::Sync()); 
            return t.get_result<saga::job::self>();
        }
        SAGA_CALL_PUB_0_DEF_0(get_self)

    };

}}   // namespace saga::job

#if defined(__WAVE__) && defined(SAGA_CREATE_PREPROCESSED_FILES)
#pragma wave option(output: null)
#endif

#endif // !defined(SAGA_DEBUG)

// re-enable warnings about dependent classes not being exported from the dll
#if defined(BOOST_MSVC)
#pragma warning(pop)
#endif

#endif // !defined(SAGA_PACKAGES_JOB_JOB_SERVICE_HPP)

---