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

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

void test_cloud (saga::job::description jd, 
                 std::string            type, 
                 std::string            instance = "")
{
  saga::url js_url (type + "://" + instance);

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

  saga::session s1;

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

  saga::context c1 (type);

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

  c1.set_defaults ();

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

  s1.add_context (c1);

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

  saga::job::service js1 (s1, js_url);

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

  saga::job::job j1 = js1.create_job (jd);

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

  j1.run ();

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

  print_io (j1);

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

///////////////////////////////////////////////////////////////////////////////
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);

    saga::url t ("file://localhost//Users/merzky/links/saga/projects/applications/MapReduce/samples/file.txt");

    //  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).
    //
    // "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/"
    
 // test_cloud (jd, "ec2");
    test_cloud (jd, "ec2",        "i-d642c7bf");
 // test_cloud (jd, "eucalyptus", "i-417E085F");
 // test_cloud (jd, "nimbus");
  
  }
  catch ( saga::exception const & e )
  {
    std::cerr << e.what ();
  }

  return 0;
}