root/saga/trunk/examples/misc/aws.cpp

//  Copyright (c) 2005-2007 Andre Merzky <andre@merzky.net>
// 
//  Distributed under the Boost Software License, Version 1.0. 
//  (See accompanying file LICENSE file or copy at 
//  http://www.boost.org/LICENSE_1_0.txt)

#include <saga/saga.hpp>

#define COUNT 100

void print_io (saga::job::job j)
{
  saga::job::istream out = j.get_stdout ();

  while ( true )
  {
    char buffer[255];

    // get stdout
    out.read (buffer, sizeof (buffer));

    if ( out.gcount () > 0 )
    {
      std::cout << std::string (buffer, out.gcount ());
    }

    if ( out.fail () )
    {
      break;
    }
  }

  return;
}

///////////////////////////////////////////////////////////////////////////////
int main (int argc, char* argv[])
{

  // job description is shared by all sessions
  saga::job::description jd;

  jd.set_attribute ("Executable", "hostname");
  jd.set_attribute ("Interactive", "True");


  // 3 sessions
  saga::session s1;
  saga::session s2;
  saga::session s3;


  // 3 contexts
  saga::context c1 ("nimbus");
  saga::context c2 ("eucalyptus");
  saga::context c3 ("ec2");

  c1.set_defaults ();
  c2.set_defaults ();
  c3.set_defaults ();


  // one context per session
  s1.add_context (c1);
  s2.add_context (c2);
  s3.add_context (c3);


  // one job service per session
  saga::job::service js1 (s1);
  saga::job::service js2 (s2);
  saga::job::service js3 (s3);


  // run 1 job per job service

  saga::job::job j1 = js1.create_job (jd);
  saga::job::job j2 = js2.create_job (jd);
  saga::job::job j3 = js3.create_job (jd);

  j1.run ();   print_io (j1);
  j2.run ();   print_io (j2);
  j3.run ();   print_io (j3);

  return 0;
}