Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -762,7 +762,7 @@ OzoneKey headObject(String volumeName, String bucketName,
* 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.
Expand All @@ -773,7 +773,7 @@ OzoneKey headObject(String volumeName, String bucketName,
/**
* Clears the S3 Authentication information attached to the thread.
*/
void clearTheadLocalS3Auth();
void clearThreadLocalS3Auth();

/**
* Sets the owner of bucket.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -1632,7 +1632,7 @@ public OzoneKey headObject(String volumeName, String bucketName,
}

@Override
public void setTheadLocalS3Auth(
public void setThreadLocalS3Auth(
S3Auth ozoneSharedSecretAuth) {
ozoneManagerClient.setThreadLocalS3Auth(ozoneSharedSecretAuth);
}
Expand All @@ -1643,7 +1643,7 @@ public S3Auth getThreadLocalS3Auth() {
}

@Override
public void clearTheadLocalS3Auth() {
public void clearThreadLocalS3Auth() {
ozoneManagerClient.clearThreadLocalS3Auth();
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -77,7 +77,7 @@ public synchronized OzoneClient createClient() throws WebApplicationException,

@PreDestroy
public void destroy() throws IOException {
client.getObjectStore().getClientProxy().clearTheadLocalS3Auth();
client.getObjectStore().getClientProxy().clearThreadLocalS3Auth();
}
@Produces
public S3Auth getSignature() {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -74,9 +74,9 @@ protected OzoneBucket getBucket(OzoneVolume volume, String bucketName)
@PostConstruct
public void initialization() {
LOG.debug("S3 access id: {}", s3Auth.getAccessID());
getClient().getObjectStore().
getClientProxy().
setTheadLocalS3Auth(s3Auth);
getClient().getObjectStore()
.getClientProxy()
.setThreadLocalS3Auth(s3Auth);
init();
}

Expand Down