//  Copyright (c) 2008 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)

#ifndef ADAPTORS_LSF_JOB_SERVICE_HPP
#define ADAPTORS_LSF_JOB_SERVICE_HPP

#include "lsf_job_adaptor.hpp"

#include <saga/saga/adaptors/adaptor_data.hpp>
#include <saga/impl/packages/job/job_service_cpi.hpp>

////////////////////////////////////////////////////////////////////////
namespace saga { namespace adaptors { namespace lsf
{
  class job_service_cpi_impl 
    : public saga::adaptors::v1_0::job_service_cpi <job_service_cpi_impl>
  {
    private:
      typedef saga::adaptors::v1_0::job_service_cpi <job_service_cpi_impl> 
              base_cpi;

      // adaptor data
      typedef saga::adaptors::adaptor_data<job_adaptor> adaptor_data;
      
    public:
      // constructor of the job_service cpi
      job_service_cpi_impl  (proxy                           * p, 
                             cpi_info const                  & info,
                             saga::ini::ini const            & glob_ini, 
                             saga::ini::ini const            & adap_ini,
                             TR1::shared_ptr <saga::adaptor>   adaptor);

      // destructor of the job_service cpi
      ~job_service_cpi_impl (void);

      // CPI functions
      void sync_create_job (saga::job::job            & ret, 
                            saga::job::description      jd);
      
      void sync_run_job    (saga::job::job            & ret, 
                            std::string                 cmd, 
                            std::string                 host, 
                            saga::job::ostream        & in, 
                            saga::job::istream        & out, 
                            saga::job::istream        & err);
      
      void sync_run_job_noio      (saga::job::job & ret, 
                                   std::string commandline,
                                   std::string host);
      
      void sync_list       (std::vector <std::string> & ret);
      
      void sync_get_job    (saga::job::job            & ret,
                            std::string                 jobid);
      
      void sync_get_self   (saga::job::self           & ret);

      // This adaptor implements the async functions 
      // based on its own synchronous functions.
      saga::task async_create_job (saga::job::description      jd);
      saga::task async_run_job    (std::string                 cmd, 
                                   std::string                 host, 
                                   saga::job::ostream        & in, 
                                   saga::job::istream        & out, 
                                   saga::job::istream        & err);
      saga::task async_list       (void);
      saga::task async_get_job    (std::string                 jobid);
      saga::task async_get_self   (void);

  };  // class job_service_cpi_impl

}}}  // namespace lsf_job
////////////////////////////////////////////////////////////////////////

#endif // ADAPTORS_LSF_JOB_SERVICE_HPP