[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