fce0642860ffaa1827fe09f399911a3b50095ab2
[controller.git] / opendaylight / md-sal / benchmark-data-store / src / main / java / org / opendaylight / controller / md / sal / dom / store / benchmark / AbstractInMemoryDatastoreWriteTransactionBenchmark.java
1 /*
2  * Copyright (c) 2013 Cisco Systems, Inc. and others.  All rights reserved.
3  *
4  * This program and the accompanying materials are made available under the
5  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6  * and is available at http://www.eclipse.org/legal/epl-v10.html
7  */
8 package org.opendaylight.controller.md.sal.dom.store.benchmark;
9
10 import java.util.concurrent.TimeUnit;
11 import org.opendaylight.controller.md.sal.dom.store.impl.InMemoryDOMDataStore;
12 import org.opendaylight.controller.sal.core.spi.data.DOMStoreReadWriteTransaction;
13 import org.opendaylight.controller.sal.core.spi.data.DOMStoreThreePhaseCommitCohort;
14 import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
15 import org.openjdk.jmh.annotations.Benchmark;
16 import org.openjdk.jmh.annotations.Measurement;
17 import org.openjdk.jmh.annotations.Warmup;
18
19 /**
20  * @author Lukas Sedlak <lsedlak@cisco.com>
21  */
22 public abstract class AbstractInMemoryDatastoreWriteTransactionBenchmark extends AbstractInMemoryWriteTransactionBenchmark {
23
24     protected InMemoryDOMDataStore domStore;
25
26     protected void initTestNode() throws Exception {
27         final YangInstanceIdentifier testPath = YangInstanceIdentifier.builder(BenchmarkModel.TEST_PATH)
28             .build();
29         DOMStoreReadWriteTransaction writeTx = domStore.newReadWriteTransaction();
30         writeTx.write(testPath, provideOuterListNode());
31
32         DOMStoreThreePhaseCommitCohort cohort = writeTx.ready();
33         cohort.canCommit().get();
34         cohort.preCommit().get();
35         cohort.commit().get();
36     }
37
38     @Benchmark
39     @Warmup(iterations = WARMUP_ITERATIONS, timeUnit = TimeUnit.MILLISECONDS)
40     @Measurement(iterations = MEASUREMENT_ITERATIONS, timeUnit = TimeUnit.MILLISECONDS)
41     public void write100KSingleNodeWithOneInnerItemInOneCommitBenchmark() throws Exception {
42         DOMStoreReadWriteTransaction writeTx = domStore.newReadWriteTransaction();
43         for (int outerListKey = 0; outerListKey < OUTER_LIST_100K; ++outerListKey) {
44             writeTx.write(OUTER_LIST_100K_PATHS[outerListKey], OUTER_LIST_ONE_ITEM_INNER_LIST[outerListKey]);
45         }
46         DOMStoreThreePhaseCommitCohort cohort = writeTx.ready();
47         cohort.canCommit().get();
48         cohort.preCommit().get();
49         cohort.commit().get();
50     }
51
52     @Benchmark
53     @Warmup(iterations = WARMUP_ITERATIONS, timeUnit = TimeUnit.MILLISECONDS)
54     @Measurement(iterations = MEASUREMENT_ITERATIONS, timeUnit = TimeUnit.MILLISECONDS)
55     public void write100KSingleNodeWithOneInnerItemInCommitPerWriteBenchmark() throws Exception {
56         for (int outerListKey = 0; outerListKey < OUTER_LIST_100K; ++outerListKey) {
57             DOMStoreReadWriteTransaction writeTx = domStore.newReadWriteTransaction();
58             writeTx.write(OUTER_LIST_100K_PATHS[outerListKey], OUTER_LIST_ONE_ITEM_INNER_LIST[outerListKey]);
59
60             DOMStoreThreePhaseCommitCohort cohort = writeTx.ready();
61             cohort.canCommit().get();
62             cohort.preCommit().get();
63             cohort.commit().get();
64         }
65     }
66
67     @Benchmark
68     @Warmup(iterations = WARMUP_ITERATIONS, timeUnit = TimeUnit.MILLISECONDS)
69     @Measurement(iterations = MEASUREMENT_ITERATIONS, timeUnit = TimeUnit.MILLISECONDS)
70     public void write50KSingleNodeWithTwoInnerItemsInOneCommitBenchmark() throws Exception {
71         DOMStoreReadWriteTransaction writeTx = domStore.newReadWriteTransaction();
72         for (int outerListKey = 0; outerListKey < OUTER_LIST_50K; ++outerListKey) {
73             writeTx.write(OUTER_LIST_50K_PATHS[outerListKey], OUTER_LIST_TWO_ITEM_INNER_LIST[outerListKey]);
74         }
75         DOMStoreThreePhaseCommitCohort cohort = writeTx.ready();
76         cohort.canCommit().get();
77         cohort.preCommit().get();
78         cohort.commit().get();
79     }
80
81     @Benchmark
82     @Warmup(iterations = WARMUP_ITERATIONS, timeUnit = TimeUnit.MILLISECONDS)
83     @Measurement(iterations = MEASUREMENT_ITERATIONS, timeUnit = TimeUnit.MILLISECONDS)
84     public void write50KSingleNodeWithTwoInnerItemsInCommitPerWriteBenchmark() throws Exception {
85         for (int outerListKey = 0; outerListKey < OUTER_LIST_50K; ++outerListKey) {
86             DOMStoreReadWriteTransaction writeTx = domStore.newReadWriteTransaction();
87             writeTx.write(OUTER_LIST_50K_PATHS[outerListKey], OUTER_LIST_TWO_ITEM_INNER_LIST[outerListKey]);
88             DOMStoreThreePhaseCommitCohort cohort = writeTx.ready();
89             cohort.canCommit().get();
90             cohort.preCommit().get();
91             cohort.commit().get();
92         }
93     }
94
95     @Benchmark
96     @Warmup(iterations = WARMUP_ITERATIONS, timeUnit = TimeUnit.MILLISECONDS)
97     @Measurement(iterations = MEASUREMENT_ITERATIONS, timeUnit = TimeUnit.MILLISECONDS)
98     public void write10KSingleNodeWithTenInnerItemsInOneCommitBenchmark() throws Exception {
99         DOMStoreReadWriteTransaction writeTx = domStore.newReadWriteTransaction();
100         for (int outerListKey = 0; outerListKey < OUTER_LIST_10K; ++outerListKey) {
101             writeTx.write(OUTER_LIST_10K_PATHS[outerListKey], OUTER_LIST_TEN_ITEM_INNER_LIST[outerListKey]);
102         }
103         DOMStoreThreePhaseCommitCohort cohort = writeTx.ready();
104         cohort.canCommit().get();
105         cohort.preCommit().get();
106         cohort.commit().get();
107     }
108
109     @Benchmark
110     @Warmup(iterations = WARMUP_ITERATIONS, timeUnit = TimeUnit.MILLISECONDS)
111     @Measurement(iterations = MEASUREMENT_ITERATIONS, timeUnit = TimeUnit.MILLISECONDS)
112     public void write10KSingleNodeWithTenInnerItemsInCommitPerWriteBenchmark() throws Exception {
113         for (int outerListKey = 0; outerListKey < OUTER_LIST_10K; ++outerListKey) {
114             DOMStoreReadWriteTransaction writeTx = domStore.newReadWriteTransaction();
115             writeTx.write(OUTER_LIST_10K_PATHS[outerListKey], OUTER_LIST_TEN_ITEM_INNER_LIST[outerListKey]);
116             DOMStoreThreePhaseCommitCohort cohort = writeTx.ready();
117             cohort.canCommit().get();
118             cohort.preCommit().get();
119             cohort.commit().get();
120         }
121     }
122 }

©2013 OpenDaylight, A Linux Foundation Collaborative Project. All Rights Reserved.
OpenDaylight is a registered trademark of The OpenDaylight Project, Inc.
Linux Foundation and OpenDaylight are registered trademarks of the Linux Foundation.
Linux is a registered trademark of Linus Torvalds.