--- /dev/null
+/*
+ * Copyright (C) 2014 Red Hat, Inc.
+ *
+ * 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
+ *
+ * Authors : Madhu Venugopal
+ */
+package org.opendaylight.ovsdb.lib.operations;
+
+
+public class Commit extends Operation {
+
+ public static final String COMMIT = "commit";
+ Boolean durable;
+
+ public Commit(Boolean durable) {
+ super(null, COMMIT);
+ this.durable = durable;
+ }
+
+ public Boolean isDurable() {
+ return durable;
+ }
+}
+++ /dev/null
-/*
- * Copyright (C) 2013 Red Hat, Inc.
- *
- * 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
- *
- * Authors : Madhu Venugopal
- */
-package org.opendaylight.ovsdb.lib.operations;
-
-public class CommitOperation extends Operation {
-
-}
*/
package org.opendaylight.ovsdb.lib.operations;
+import org.opendaylight.ovsdb.lib.schema.TableSchema;
+
import com.fasterxml.jackson.annotation.JsonIgnore;
import com.fasterxml.jackson.annotation.JsonProperty;
-import org.opendaylight.ovsdb.lib.schema.TableSchema;
public abstract class Operation<E extends TableSchema<E>> {
@JsonProperty
public String getTable() {
- return tableSchema.getName();
+ return (tableSchema == null) ? null : tableSchema.getName();
}
@Override
return new Delete<>(schema);
}
+ public Commit commit(Boolean durable) {
+ return new Commit(durable);
+ }
}
\ No newline at end of file
*/
package org.opendaylight.ovsdb.lib;
-import com.google.common.collect.Lists;
-import com.google.common.util.concurrent.ListenableFuture;
+import static org.opendaylight.ovsdb.lib.operations.Operations.op;
+
+import java.io.IOException;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+
import junit.framework.Assert;
+
import org.junit.Before;
import org.junit.Test;
import org.opendaylight.ovsdb.lib.message.MonitorRequest;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import java.io.IOException;
-import java.util.List;
-import java.util.Map;
-import java.util.concurrent.ExecutionException;
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
-
-import static org.opendaylight.ovsdb.lib.operations.Operations.op;
+import com.google.common.collect.Lists;
+import com.google.common.util.concurrent.ListenableFuture;
public class OvsDBClientTestIT extends OvsdbTestBase {
.add(op.delete(bridge)
.where(name.opEqual("br-int"))
.operation())
+ .add(op.commit(true))
.execute();
List<OperationResult> operationResults = results.get();