Viacheslav Klimov
7 months ago
Failed to extract signature
1 changed files with
3 additions and
3 deletions
-
common/dao-api/src/main/java/org/thingsboard/server/dao/nosql/TbResultSet.java
|
|
@ -109,9 +109,9 @@ public class TbResultSet implements AsyncResultSet { |
|
|
long maxResultSetSizeBytes, |
|
|
long maxResultSetSizeBytes, |
|
|
AtomicLong accumulatedBytes) { |
|
|
AtomicLong accumulatedBytes) { |
|
|
if (maxResultSetSizeBytes > 0) { |
|
|
if (maxResultSetSizeBytes > 0) { |
|
|
int pageSize = resultSet.getExecutionInfo().getResponseSizeInBytes(); |
|
|
int pageSizeInBytes = resultSet.getExecutionInfo().getResponseSizeInBytes(); |
|
|
if (pageSize > 0) { |
|
|
if (pageSizeInBytes > 0) { |
|
|
accumulatedBytes.addAndGet(pageSize); |
|
|
accumulatedBytes.addAndGet(pageSizeInBytes); |
|
|
} |
|
|
} |
|
|
if (accumulatedBytes.get() > maxResultSetSizeBytes) { |
|
|
if (accumulatedBytes.get() > maxResultSetSizeBytes) { |
|
|
resultFuture.setException(new ResultSetSizeLimitExceededException(maxResultSetSizeBytes, accumulatedBytes.get())); |
|
|
resultFuture.setException(new ResultSetSizeLimitExceededException(maxResultSetSizeBytes, accumulatedBytes.get())); |
|
|
|
