View Javadoc

1   package fr.in2p3.jsaga.impl.namespace;
2   
3   import fr.in2p3.jsaga.engine.factories.DataAdaptorFactory;
4   import fr.in2p3.jsaga.impl.task.AbstractThreadedTask;
5   import org.ogf.saga.error.*;
6   import org.ogf.saga.namespace.*;
7   import org.ogf.saga.session.Session;
8   import org.ogf.saga.task.Task;
9   import org.ogf.saga.task.TaskMode;
10  import org.ogf.saga.url.URL;
11  
12  /* ***************************************************
13   * *** Centre de Calcul de l'IN2P3 - Lyon (France) ***
14   * ***             http://cc.in2p3.fr/             ***
15   * ***************************************************
16   * File:   AbstractAsyncNSFactoryImpl
17   * Author: Sylvain Reynaud (sreynaud@in2p3.fr)
18   * Date:   29 mai 2009
19   * ***************************************************
20   * Description:                                      */
21  /**
22   *
23   */
24  public abstract class AbstractAsyncNSFactoryImpl extends AbstractSyncNSFactoryImpl {
25      public AbstractAsyncNSFactoryImpl(DataAdaptorFactory adaptorFactory) {
26          super(adaptorFactory);
27      }
28  
29      ////////////////////////////////////////// interface NSFactory //////////////////////////////////////////
30  
31      protected Task<NSFactory, NSEntry> doCreateNSEntry(TaskMode mode, final Session session, final URL name, final int flags) throws NotImplementedException {
32          return new AbstractThreadedTask<NSFactory,NSEntry>(mode) {
33              public NSEntry invoke() throws NotImplementedException, IncorrectURLException, AuthenticationFailedException, AuthorizationFailedException, PermissionDeniedException, BadParameterException, IncorrectStateException, AlreadyExistsException, DoesNotExistException, TimeoutException, NoSuccessException {
34                  return AbstractAsyncNSFactoryImpl.super.doCreateNSEntrySync(session, name, flags);
35              }
36          };
37      }
38  
39      protected Task<NSFactory, NSDirectory> doCreateNSDirectory(TaskMode mode, final Session session, final URL name, final int flags) throws NotImplementedException {
40          return new AbstractThreadedTask<NSFactory,NSDirectory>(mode) {
41              public NSDirectory invoke() throws NotImplementedException, IncorrectURLException, AuthenticationFailedException, AuthorizationFailedException, PermissionDeniedException, BadParameterException, IncorrectStateException, AlreadyExistsException, DoesNotExistException, TimeoutException, NoSuccessException {
42                  return AbstractAsyncNSFactoryImpl.super.doCreateNSDirectorySync(session, name, flags);
43              }
44          };
45      }
46  }