[Saga-devel] async object creation
Hartmut Kaiser
hartmut.kaiser at gmail.com
Sun Jan 25 10:19:50 CST 2009
> > > I tried to use the brand new async object creation, with the
> following
> > > code:
> > >
> > > #include <saga/saga.hpp>
> > >
> > > int main ()
> > > {
> > > saga::url u ("fork://localhost");
> > > saga::task t = saga::job::service::create
> > > <saga::task::Async> (u);
> > > saga::job::service js = t.get_result <saga::job::service> ();
> > >
> > > return 0;
> > > }
> >
> > This works fine for me. What error do you actually see?
> > Sorry if I missed the point in your initial mail.
>
> Sorry if I wasn't clear. For me, the main problem is that
> the aws_job adaptor gets active, because the
> instance_data->rm_ URL is empty.
>
> Its not a high priority at the moment - Probably won't be
> able to change MapReduce to use this in time...
Sorry, I'm not able to follow. What are you talking about?
Regards Hartmut
>
> Best, Andre.
>
>
> > Regards Hartmut
> >
> > >
> > > For some reason that does not really what it should: for now, the
> aws
> > > job adaptor c'tor jumps in (and calls the posix adaptor, whose
> messages
> > > you see, incidentically with the fork://localhost URL again). The
> aws
> > > adaptor does not accept fork:// of course - so the URL gets lost:
> > >
> > > INFO : aws_job_service.cpp : ========== logging aws
> job
> > > service rm
> > > INFO : aws_job_service.cpp :
> > >
> > >
> > > Also, the log is here shortened, but it seems somewhere an
> additional
> > > session gets created, and all adaptors get loaded again. (complete
> log
> > > attached).
> > >
> > > I did not debug this further, but wanted to ask the list for quick
> > > ideas. Did anybody use the factories successfully, yet?
> > >
> > > [...]
> > > dynamic loading ok:
> > > /usr/local/packages/saga//lib/libsaga_adaptor_ssh_job.dylib -
> ssh_job
> > > Created exception: SAGA(BadParameter): aws_job:
> > > aws_job_service.cpp(84): Adaptor only supports 'aws' and 'any' URL
> > > schemes, not fork
> > > Trying to create CPI: job_service_cpi for operation: __init__
> > > from proxy for CPI: job_service_cpi using adaptor instance:
> > > default_job (b9e8f75e-ea83-11dd-9c1d-17c70b789026)
> > > INFO : posix_job_service.cpp : fork://localhost/
> > > INFO : posix_job_service.cpp : localhost
> > > INFO : posix_job_service.cpp : fork
> > > Successfully created CPI: job_service_cpi using adaptor
> instance:
> > > default_job
> > > Testing adaptor default_job for job_service_cpi ->
> sync_create_job :
> > > 1
> > > Trying to create CPI: job_cpi for operation: __init__
> > > from proxy for CPI: job_cpi using adaptor instance: default_job
> > > (b9e8f75e-ea83-11dd-9c1d-17c70b789026)
> > > INFO : posix_job.cpp : posix job ctor
> > > Successfully created CPI: job_cpi using adaptor instance:
> > > default_job
> > > Testing adaptor default_job for job_cpi -> sync_get_stdout : 1
> > > Testing adaptor default_job for job_cpi -> sync_get_stderr : 1
> > > Testing adaptor default_job for job_cpi -> sync_run : 1
> > > INFO : posix_job.cpp : posix job run
> > > INFO : posix_job.cpp :
> > > /usr/local/packages/saga//bin/aws-tools/bin//ec2-run-instances
> > > INFO : posix_job.cpp : -k
> > > INFO : posix_job.cpp : ec2-saga-keypair-ec2
> > > INFO : posix_job.cpp : ami-038a6d6a
> > > LOG : posix_job.cpp : >>
> > > /usr/local/packages/saga//bin/aws-tools/bin//ec2-run-instances -k
> ec2-
> > > saga-keypair-ec2 ami-038a6d6a
> > > Testing adaptor default_job for job_cpi -> sync_wait : 1
> > > Testing adaptor default_job for job_cpi -> sync_get_state : 1
> > > LOG : aws_job_service.cpp : pending
> > > [killed here...]
> > >
> > >
> > > Thanks, Andre
> > >
> > > --
> > > Nothing is ever easy.
> >
> > _______________________________________________
> > saga-devel mailing list
> > saga-devel at cct.lsu.edu
> > https://mail.cct.lsu.edu/mailman/listinfo/saga-devel
>
>
>
> --
> Nothing is ever easy.
More information about the saga-devel
mailing list