Skip to content

Commit 347bb0f

Browse files
committed
Add in DefaultBlobWriteSession test
1 parent 53f86ca commit 347bb0f

File tree

1 file changed

+18
-1
lines changed

1 file changed

+18
-1
lines changed

storage-shared-benchmarking/src/main/java/com/google/cloud/storage/benchmarking/StorageSharedBenchmarkingCli.java

Lines changed: 18 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -109,9 +109,12 @@ public void run() {
109109
case "w1r3":
110110
runWorkload1();
111111
break;
112-
case "bidi-w1r3":
112+
case "bidi":
113113
runWorkloadBidi();
114114
break;
115+
case "default-nobidi":
116+
runWorkloadNoBidi();
117+
break;
115118
default:
116119
throw new IllegalStateException("Specify a workload to run");
117120
}
@@ -171,6 +174,20 @@ private void runWorkloadBidi() {
171174
}
172175
}
173176

177+
private void runWorkloadNoBidi() {
178+
StorageOptions options = StorageOptions.grpc()
179+
.setProjectId(project)
180+
.setBlobWriteSessionConfig(BlobWriteSessionConfigs.getDefault())
181+
.build();
182+
Storage storageClient = options.getService();
183+
try {
184+
runBidi(storageClient);
185+
} catch (Exception e) {
186+
System.err.println("Failed to run workload no bidi" + e.getMessage());
187+
System.exit(1);
188+
}
189+
}
190+
174191
private void runW1R3(Storage storageClient) throws ExecutionException, InterruptedException {
175192
ListeningExecutorService executorService =
176193
MoreExecutors.listeningDecorator(Executors.newFixedThreadPool(workers));

0 commit comments

Comments
 (0)