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>

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;
}

///////////////////////////////////////////////////////////////////////////////

void test_cloud (saga::job::description jd, 
                 std::string            type, 
                 std::string            instance = "")
{

  saga::url js_url (type + "://" + instance);

  std::cout << " ----------------------- (" << type << " - " << js_url << ") \n";


  // create a context for that cloud type
  saga::context c (type);
  c.set_defaults ();

  // attach it to the session
  saga::session s;
  s.add_context (c);

  // create a job service in that session
  saga::job::service js (s, js_url);

  // create and run a job on that job service (i.e. on that VM)
  saga::job::job j = js.create_job (jd);
  j.run ();

  // print job output
  print_io (j);
}

///////////////////////////////////////////////////////////////////////////////
int main (int argc, char* argv[])
{
  try
  {
    // job description is shared by all sessions
    saga::job::description jd;

    jd.set_attribute (saga::job::attributes::description_executable,  "hostname");
    jd.set_attribute (saga::job::attributes::description_executable, "/usr/local/packages/saga-1.1/bin/saga-file");
    jd.set_attribute (saga::job::attributes::description_executable, "/bin/ls");
    jd.set_attribute (saga::job::attributes::description_interactive, "True");

    std::vector <std::string> args;

    // args.push_back ("list_dir");
    args.push_back ("/");

    jd.set_vector_attribute (saga::job::attributes::description_arguments, args);


    //  FIXME: the job service contact should point to the ec2 service instance.
    //  Problem: what protocol to use?  We need to denotify the context type (do
    //  we?), _and_ the ec2 service protocol (http/https).  Anyway, this needs to 
    //  be fixed in the adaptor.
    //
    // "https://ec2.amazonaws.com/"
    // "http://mayhem9.cs.ucsb.edu:8773/services/Eucalyptus"
    // "https://tp-vm1.ci.uchicago.edu:8445/wsrf/services/ElasticNimbusService"
    // "https://vm02.cct.lsu.edu:8443/"

    // create a new instance on ec2, and run a test job
    test_cloud (jd, "ec2");

    // access a running VM instance on ec2, and run a test job
 // test_cloud (jd, "ec2",        "i-d642c7bf");

    // samoe for eucalyptus
 // test_cloud (jd, "eucalyptus");
 // test_cloud (jd, "eucalyptus", "i-417E085F");

    // samoe for nimbus
 // test_cloud (jd, "nimbus");
 // test_cloud (jd, "nimbus",     "i-3247A527");
  
  }
  catch ( saga::exception const & e )
  {
    std::cerr << e.what ();
  }

  return 0;
}