X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-inmemory-datastore%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fmd%2Fsal%2Fdom%2Fstore%2Fimpl%2FDatastoreTestTask.java;h=74202a51e44eca6fa7980c741a4a7394c4ff6de3;hb=refs%2Fheads%2Fmaster;hp=63e1498c0efe20d697584bb40114528aab507e09;hpb=a014c21dce3c024c1fb34ffdb419070ac26302f6;p=controller.git

diff --git a/opendaylight/md-sal/sal-inmemory-datastore/src/test/java/org/opendaylight/controller/md/sal/dom/store/impl/DatastoreTestTask.java b/opendaylight/md-sal/sal-inmemory-datastore/src/test/java/org/opendaylight/controller/md/sal/dom/store/impl/DatastoreTestTask.java
deleted file mode 100644
index 63e1498c0e..0000000000
--- a/opendaylight/md-sal/sal-inmemory-datastore/src/test/java/org/opendaylight/controller/md/sal/dom/store/impl/DatastoreTestTask.java
+++ /dev/null
@@ -1,183 +0,0 @@
-/*
- * Copyright (c) 2014 Cisco Systems, Inc. and others.  All rights reserved.
- *
- * This program and the accompanying materials are made available under the
- * terms of the Eclipse Public License v1.0 which accompanies this distribution,
- * and is available at http://www.eclipse.org/legal/epl-v10.html
- */
-package org.opendaylight.controller.md.sal.dom.store.impl;
-
-import static org.junit.Assert.assertTrue;
-import static org.junit.Assert.fail;
-
-import java.util.concurrent.ExecutionException;
-import java.util.concurrent.TimeUnit;
-import java.util.concurrent.TimeoutException;
-
-import org.opendaylight.controller.md.sal.common.api.data.AsyncDataBroker.DataChangeScope;
-import org.opendaylight.controller.md.sal.common.api.data.AsyncDataChangeEvent;
-import org.opendaylight.controller.md.sal.common.api.data.AsyncDataChangeListener;
-import org.opendaylight.controller.sal.core.spi.data.DOMStore;
-import org.opendaylight.controller.sal.core.spi.data.DOMStoreReadTransaction;
-import org.opendaylight.controller.sal.core.spi.data.DOMStoreReadWriteTransaction;
-import org.opendaylight.controller.sal.core.spi.data.DOMStoreThreePhaseCommitCohort;
-import org.opendaylight.yangtools.concepts.ListenerRegistration;
-import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
-import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode;
-
-import com.google.common.base.Preconditions;
-import com.google.common.util.concurrent.SettableFuture;
-
-public class DatastoreTestTask {
-
-    private final DOMStore store;
-    private AsyncDataChangeListener<YangInstanceIdentifier, NormalizedNode<?, ?>> changeListener;
-
-    private WriteTransactionCustomizer setup;
-    private WriteTransactionCustomizer write;
-    private ReadTransactionVerifier read;
-    private WriteTransactionCustomizer cleanup;
-    private YangInstanceIdentifier changePath;
-    private DataChangeScope changeScope;
-    private volatile boolean postSetup = false;
-    private final ChangeEventListener internalListener;
-    private final TestDCLExecutorService dclExecutorService;
-
-    public DatastoreTestTask(final DOMStore datastore, final TestDCLExecutorService dclExecutorService) {
-        this.store = datastore;
-        this.dclExecutorService = dclExecutorService;
-        internalListener = new ChangeEventListener();
-    }
-
-    public DatastoreTestTask changeListener(final YangInstanceIdentifier path, final DataChangeScope scope,
-            final AsyncDataChangeListener<YangInstanceIdentifier, NormalizedNode<?, ?>> changeListener) {
-        this.changeListener = changeListener;
-        this.changePath = path;
-        this.changeScope = scope;
-        return this;
-    }
-
-    public DatastoreTestTask changeListener(final YangInstanceIdentifier path, final DataChangeScope scope) {
-        this.changePath = path;
-        this.changeScope = scope;
-        return this;
-    }
-
-    public DatastoreTestTask setup(final WriteTransactionCustomizer setup) {
-        this.setup = setup;
-        return this;
-    }
-
-    public DatastoreTestTask test(final WriteTransactionCustomizer write) {
-        this.write = write;
-        return this;
-    }
-
-    public DatastoreTestTask read(final ReadTransactionVerifier read) {
-        this.read = read;
-        return this;
-    }
-
-    public DatastoreTestTask cleanup(final WriteTransactionCustomizer cleanup) {
-        this.cleanup = cleanup;
-        return this;
-    }
-
-    public void run() throws InterruptedException, ExecutionException, TimeoutException {
-        if (setup != null) {
-            execute(setup);
-        }
-        ListenerRegistration<ChangeEventListener> registration = null;
-        if (changePath != null) {
-            registration = store.registerChangeListener(changePath, internalListener, changeScope);
-        }
-
-        Preconditions.checkState(write != null, "Write Transaction must be set.");
-
-        postSetup = true;
-        dclExecutorService.afterTestSetup();
-
-        execute(write);
-        if (registration != null) {
-            registration.close();
-        }
-
-        if (changeListener != null) {
-            changeListener.onDataChanged(getChangeEvent());
-        }
-        if (read != null) {
-            read.verify(store.newReadOnlyTransaction());
-        }
-        if (cleanup != null) {
-            execute(cleanup);
-        }
-    }
-
-    public AsyncDataChangeEvent<YangInstanceIdentifier, NormalizedNode<?, ?>> getChangeEvent() {
-        try {
-            return internalListener.receivedChange.get(10, TimeUnit.SECONDS);
-        } catch( Exception e ) {
-            fail( "Error getting the AsyncDataChangeEvent from the Future: " + e );
-        }
-
-        // won't get here
-        return null;
-    }
-
-    public void verifyNoChangeEvent() {
-        try {
-            Object unexpected = internalListener.receivedChange.get(500, TimeUnit.MILLISECONDS);
-            fail( "Got unexpected AsyncDataChangeEvent from the Future: " + unexpected );
-        } catch( TimeoutException e ) {
-            // Expected
-        } catch( Exception e ) {
-            fail( "Error getting the AsyncDataChangeEvent from the Future: " + e );
-        }
-    }
-
-    private void execute(final WriteTransactionCustomizer writeCustomizer) throws InterruptedException,
-            ExecutionException {
-        DOMStoreReadWriteTransaction tx = store.newReadWriteTransaction();
-        writeCustomizer.customize(tx);
-        DOMStoreThreePhaseCommitCohort cohort = tx.ready();
-        assertTrue(cohort.canCommit().get());
-        cohort.preCommit().get();
-        cohort.commit().get();
-    }
-
-    public interface WriteTransactionCustomizer {
-        void customize(DOMStoreReadWriteTransaction tx);
-    }
-
-    public interface ReadTransactionVerifier {
-        void verify(DOMStoreReadTransaction tx);
-    }
-
-    private final class ChangeEventListener implements
-            AsyncDataChangeListener<YangInstanceIdentifier, NormalizedNode<?, ?>> {
-
-        protected final SettableFuture<AsyncDataChangeEvent<YangInstanceIdentifier, NormalizedNode<?, ?>>> receivedChange = SettableFuture
-                .create();
-
-        @Override
-        public void onDataChanged(final AsyncDataChangeEvent<YangInstanceIdentifier, NormalizedNode<?, ?>> change) {
-            if (postSetup) {
-                receivedChange.set(change);
-            }
-        }
-    }
-
-    public static final WriteTransactionCustomizer simpleWrite(final YangInstanceIdentifier path,
-            final NormalizedNode<?, ?> data) {
-        return tx -> tx.write(path, data);
-    }
-
-    public static final WriteTransactionCustomizer simpleMerge(final YangInstanceIdentifier path,
-            final NormalizedNode<?, ?> data) {
-        return tx -> tx.merge(path, data);
-    }
-
-    public static final WriteTransactionCustomizer simpleDelete(final YangInstanceIdentifier path) {
-        return tx -> tx.delete(path);
-    }
-}