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
14
15
16
17
18
19
20
21
22
23
24 public abstract class AbstractAsyncNSFactoryImpl extends AbstractSyncNSFactoryImpl {
25 public AbstractAsyncNSFactoryImpl(DataAdaptorFactory adaptorFactory) {
26 super(adaptorFactory);
27 }
28
29
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 }