in src/main/java/org/elasticsearch/aliyun/oss/service/OssStorageClient.java [145:157]
public PutObjectResult putObject(String bucketName, String key, InputStream input,
ObjectMetadata metadata) throws OSSException, ClientException {
if (isStsOssClient) {
readWriteLock.readLock().lock();
try {
return this.client.putObject(bucketName, key, input, metadata);
} finally {
readWriteLock.readLock().unlock();
}
} else {
return this.client.putObject(bucketName, key, input, metadata);
}
}