This is an automated email from the ASF dual-hosted git repository.
adoroszlai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ozone.git
The following commit(s) were added to refs/heads/master by this push:
new 000902d HDDS-6325. Fix interface ClientProtocol methods typo
setThreadLocalS3Auth and clearThreadLocalS3Auth (#3093)
000902d is described below
commit 000902d7489a1d6f00972b3c1176e460f2755c8c
Author: Siyao Meng <[email protected]>
AuthorDate: Tue Feb 15 14:15:55 2022 -0800
HDDS-6325. Fix interface ClientProtocol methods typo setThreadLocalS3Auth
and clearThreadLocalS3Auth (#3093)
---
.../org/apache/hadoop/ozone/client/protocol/ClientProtocol.java | 4 ++--
.../src/main/java/org/apache/hadoop/ozone/client/rpc/RpcClient.java | 4 ++--
.../main/java/org/apache/hadoop/ozone/s3/OzoneClientProducer.java | 2 +-
.../main/java/org/apache/hadoop/ozone/s3/endpoint/EndpointBase.java | 6 +++---
4 files changed, 8 insertions(+), 8 deletions(-)
diff --git
a/hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/protocol/ClientProtocol.java
b/hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/protocol/ClientProtocol.java
index 8502fec..7da2108 100644
---
a/hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/protocol/ClientProtocol.java
+++
b/hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/protocol/ClientProtocol.java
@@ -762,7 +762,7 @@ public interface ClientProtocol {
* of the S3 API implementation within Ozone.
* @param s3Auth authentication information for each S3 API call.
*/
- void setTheadLocalS3Auth(S3Auth s3Auth);
+ void setThreadLocalS3Auth(S3Auth s3Auth);
/**
* Gets the S3 Authentication information that is attached to the thread.
@@ -773,7 +773,7 @@ public interface ClientProtocol {
/**
* Clears the S3 Authentication information attached to the thread.
*/
- void clearTheadLocalS3Auth();
+ void clearThreadLocalS3Auth();
/**
* Sets the owner of bucket.
diff --git
a/hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/rpc/RpcClient.java
b/hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/rpc/RpcClient.java
index 3280441..28efa8c 100644
---
a/hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/rpc/RpcClient.java
+++
b/hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/rpc/RpcClient.java
@@ -1632,7 +1632,7 @@ public class RpcClient implements ClientProtocol {
}
@Override
- public void setTheadLocalS3Auth(
+ public void setThreadLocalS3Auth(
S3Auth ozoneSharedSecretAuth) {
ozoneManagerClient.setThreadLocalS3Auth(ozoneSharedSecretAuth);
}
@@ -1643,7 +1643,7 @@ public class RpcClient implements ClientProtocol {
}
@Override
- public void clearTheadLocalS3Auth() {
+ public void clearThreadLocalS3Auth() {
ozoneManagerClient.clearThreadLocalS3Auth();
}
diff --git
a/hadoop-ozone/s3gateway/src/main/java/org/apache/hadoop/ozone/s3/OzoneClientProducer.java
b/hadoop-ozone/s3gateway/src/main/java/org/apache/hadoop/ozone/s3/OzoneClientProducer.java
index 0cd5b4a..28c3958 100644
---
a/hadoop-ozone/s3gateway/src/main/java/org/apache/hadoop/ozone/s3/OzoneClientProducer.java
+++
b/hadoop-ozone/s3gateway/src/main/java/org/apache/hadoop/ozone/s3/OzoneClientProducer.java
@@ -77,7 +77,7 @@ public class OzoneClientProducer {
@PreDestroy
public void destroy() throws IOException {
- client.getObjectStore().getClientProxy().clearTheadLocalS3Auth();
+ client.getObjectStore().getClientProxy().clearThreadLocalS3Auth();
}
@Produces
public S3Auth getSignature() {
diff --git
a/hadoop-ozone/s3gateway/src/main/java/org/apache/hadoop/ozone/s3/endpoint/EndpointBase.java
b/hadoop-ozone/s3gateway/src/main/java/org/apache/hadoop/ozone/s3/endpoint/EndpointBase.java
index ffd95cb6..b933363 100644
---
a/hadoop-ozone/s3gateway/src/main/java/org/apache/hadoop/ozone/s3/endpoint/EndpointBase.java
+++
b/hadoop-ozone/s3gateway/src/main/java/org/apache/hadoop/ozone/s3/endpoint/EndpointBase.java
@@ -74,9 +74,9 @@ public abstract class EndpointBase {
@PostConstruct
public void initialization() {
LOG.debug("S3 access id: {}", s3Auth.getAccessID());
- getClient().getObjectStore().
- getClientProxy().
- setTheadLocalS3Auth(s3Auth);
+ getClient().getObjectStore()
+ .getClientProxy()
+ .setThreadLocalS3Auth(s3Auth);
init();
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
