[Saga-devel] async object creation
'Andre Merzky'
andre at merzky.net
Sun Jan 25 02:10:35 CST 2009
Quoting [Hartmut Kaiser] (Jan 25 2009):
>
> Andre,
>
> > 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...
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