Skip to content

Commit 1dd6694

Browse files
Locharla, SandeepLocharla, Sandeep
authored andcommitted
Addressed final set of comments
1 parent 48c4971 commit 1dd6694

File tree

15 files changed

+234
-227
lines changed

15 files changed

+234
-227
lines changed

.github/CODEOWNERS

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,7 @@
1717

1818
/plugins/storage/volume/linstor @rp-
1919
/plugins/storage/volume/storpool @slavkap
20+
/plugins/storage/volume/ontap @rajiv1 @sandeeplocharla @piyush5 @suryag
2021

2122
.pre-commit-config.yaml @jbampton
2223
/.github/linters/ @jbampton

plugins/storage/volume/ontap/pom.xml

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -39,6 +39,7 @@
3939
<junit-jupiter.version>5.8.1</junit-jupiter.version>
4040
<mockito.version>3.12.4</mockito.version>
4141
<mockito-junit-jupiter.version>5.2.0</mockito-junit-jupiter.version>
42+
<commons-lang3.version>3.12.0</commons-lang3.version>
4243
</properties>
4344
<dependencyManagement>
4445
<dependencies>
@@ -92,6 +93,11 @@
9293
<artifactId>swagger-annotations</artifactId>
9394
<version>${swagger-annotations.version}</version>
9495
</dependency>
96+
<dependency>
97+
<groupId>org.apache.commons</groupId>
98+
<artifactId>commons-lang3</artifactId>
99+
<version>${commons-lang3.version}</version>
100+
</dependency>
95101
<!-- JUnit 5 -->
96102
<dependency>
97103
<groupId>org.junit.jupiter</groupId>

plugins/storage/volume/ontap/src/main/java/org/apache/cloudstack/storage/driver/OntapPrimaryDatastoreDriver.java

Lines changed: 26 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -45,11 +45,11 @@
4545

4646
public class OntapPrimaryDatastoreDriver implements PrimaryDataStoreDriver {
4747

48-
private static final Logger s_logger = LogManager.getLogger(OntapPrimaryDatastoreDriver.class);
48+
private static final Logger logger = LogManager.getLogger(OntapPrimaryDatastoreDriver.class);
4949

5050
@Override
5151
public Map<String, String> getCapabilities() {
52-
s_logger.trace("OntapPrimaryDatastoreDriver: getCapabilities: Called");
52+
logger.trace("OntapPrimaryDatastoreDriver: getCapabilities: Called");
5353
Map<String, String> mapCapabilities = new HashMap<>();
5454
mapCapabilities.put(DataStoreCapabilities.STORAGE_SYSTEM_SNAPSHOT.toString(), Boolean.FALSE.toString());
5555
mapCapabilities.put(DataStoreCapabilities.CAN_CREATE_VOLUME_FROM_SNAPSHOT.toString(), Boolean.FALSE.toString());
@@ -63,27 +63,39 @@ public DataTO getTO(DataObject data) {
6363
}
6464

6565
@Override
66-
public DataStoreTO getStoreTO(DataStore store) { return null; }
66+
public DataStoreTO getStoreTO(DataStore store) {
67+
return null;
68+
}
6769

6870
@Override
69-
public void createAsync(DataStore dataStore, DataObject dataObject, AsyncCompletionCallback<CreateCmdResult> callback) {}
71+
public void createAsync(DataStore dataStore, DataObject dataObject, AsyncCompletionCallback<CreateCmdResult> callback) {
72+
throw new UnsupportedOperationException("Create operation is not supported for ONTAP primary storage.");
73+
}
7074

7175
@Override
72-
public void deleteAsync(DataStore store, DataObject data, AsyncCompletionCallback<CommandResult> callback) {}
76+
public void deleteAsync(DataStore store, DataObject data, AsyncCompletionCallback<CommandResult> callback) {
77+
throw new UnsupportedOperationException("Delete operation is not supported for ONTAP primary storage.");
78+
}
7379

7480
@Override
75-
public void copyAsync(DataObject srcData, DataObject destData, AsyncCompletionCallback<CopyCommandResult> callback) {}
81+
public void copyAsync(DataObject srcData, DataObject destData, AsyncCompletionCallback<CopyCommandResult> callback) {
82+
throw new UnsupportedOperationException("Copy operation is not supported for ONTAP primary storage.");
83+
}
7684

7785
@Override
78-
public void copyAsync(DataObject srcData, DataObject destData, Host destHost, AsyncCompletionCallback<CopyCommandResult> callback) {}
86+
public void copyAsync(DataObject srcData, DataObject destData, Host destHost, AsyncCompletionCallback<CopyCommandResult> callback) {
87+
throw new UnsupportedOperationException("Copy operation is not supported for ONTAP primary storage.");
88+
}
7989

8090
@Override
8191
public boolean canCopy(DataObject srcData, DataObject destData) {
8292
return false;
8393
}
8494

8595
@Override
86-
public void resize(DataObject data, AsyncCompletionCallback<CreateCmdResult> callback) {}
96+
public void resize(DataObject data, AsyncCompletionCallback<CreateCmdResult> callback) {
97+
throw new UnsupportedOperationException("Resize operation is not supported for ONTAP primary storage.");
98+
}
8799

88100
@Override
89101
public ChapInfo getChapInfo(DataObject dataObject) {
@@ -119,10 +131,14 @@ public long getUsedIops(StoragePool storagePool) {
119131
}
120132

121133
@Override
122-
public void takeSnapshot(SnapshotInfo snapshot, AsyncCompletionCallback<CreateCmdResult> callback) {}
134+
public void takeSnapshot(SnapshotInfo snapshot, AsyncCompletionCallback<CreateCmdResult> callback) {
135+
throw new UnsupportedOperationException("Snapshot operation is not supported for ONTAP primary storage.");
136+
}
123137

124138
@Override
125-
public void revertSnapshot(SnapshotInfo snapshotOnImageStore, SnapshotInfo snapshotOnPrimaryStore, AsyncCompletionCallback<CommandResult> callback) {}
139+
public void revertSnapshot(SnapshotInfo snapshotOnImageStore, SnapshotInfo snapshotOnPrimaryStore, AsyncCompletionCallback<CommandResult> callback) {
140+
throw new UnsupportedOperationException("Snapshot operation is not supported for ONTAP primary storage.");
141+
}
126142

127143
@Override
128144
public void handleQualityOfServiceForVolumeMigration(VolumeInfo volumeInfo, QualityOfServiceState qualityOfServiceState) {}

plugins/storage/volume/ontap/src/main/java/org/apache/cloudstack/storage/feign/FeignConfiguration.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,7 @@ public class FeignConfiguration {
5252
private static final Logger logger = LogManager.getLogger(FeignConfiguration.class);
5353

5454
private final int retryMaxAttempt = 3;
55-
private final int retryMaxInterval = 5;
55+
private final int retryMaxIntervalInSecs = 5;
5656
private final String ontapFeignMaxConnection = "80";
5757
private final String ontapFeignMaxConnectionPerRoute = "20";
5858
private final ObjectMapper objectMapper;
@@ -110,7 +110,7 @@ public RequestInterceptor createRequestInterceptor() {
110110
}
111111

112112
public Retryer createRetryer() {
113-
return new Retryer.Default(1000L, retryMaxInterval * 1000L, retryMaxAttempt);
113+
return new Retryer.Default(1000L, retryMaxIntervalInSecs * 1000L, retryMaxAttempt);
114114
}
115115

116116
public Encoder createEncoder() {

plugins/storage/volume/ontap/src/main/java/org/apache/cloudstack/storage/feign/model/ExportRule.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -41,13 +41,13 @@ public class ExportRule {
4141
private Integer index = null;
4242

4343
public enum ProtocolsEnum {
44-
any("any"),
44+
ANY("any"),
4545

46-
nfs("nfs"),
46+
NFS("nfs"),
4747

48-
nfs3("nfs3"),
48+
NFS3("nfs3"),
4949

50-
nfs4("nfs4");
50+
NFS4("nfs4");
5151

5252
private String value;
5353

plugins/storage/volume/ontap/src/main/java/org/apache/cloudstack/storage/feign/model/Igroup.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -56,15 +56,15 @@ public class Igroup {
5656
private String uuid = null;
5757

5858
public enum OsTypeEnum {
59-
hyper_v("hyper_v"),
59+
HyperV("hyper_v"),
6060

61-
linux("linux"),
61+
Linux("linux"),
6262

63-
vmware("vmware"),
63+
VMware("vmware"),
6464

65-
windows("windows"),
65+
Windows("windows"),
6666

67-
xen("xen");
67+
Xen("xen");
6868

6969
private String value;
7070

plugins/storage/volume/ontap/src/main/java/org/apache/cloudstack/storage/feign/model/Volume.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -128,7 +128,6 @@ public void setAntiRansomware(AntiRansomware antiRansomware) {
128128

129129
public void setSize (Long size) { this.size = size; }
130130

131-
132131
@Override
133132
public boolean equals(Object o) {
134133
if (o == null || getClass() != o.getClass()) return false;

0 commit comments

Comments
 (0)