xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix(stream): fix syntax error.

This commit is contained in:
Haojun Liao 2023-09-28 00:53:36 +08:00
parent 8477271240
commit 0a2b70fd7f
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
source/libs/stream/src/streamQueue.c
View File

@ -401,14 +401,14 @@ static void fillTokenBucket(STokenBucket* pBucket) {
int32_t incNum = (delta / 1000.0) * pBucket->numRate; int32_t incNum = (delta / 1000.0) * pBucket->numRate;
if (incNum > 0) { if (incNum > 0) {
pBucket->numOfToken = MIN(pBucket->numOfToken + incNum, pBucket->numCapacity); pBucket->numOfToken = TMIN(pBucket->numOfToken + incNum, pBucket->numCapacity);
pBucket->fillTimestamp = now; pBucket->fillTimestamp = now;
} }
// increase the new available quota as time goes on // increase the new available quota as time goes on
double incSize = (delta / 1000.0) * pBucket->bytesRate; double incSize = (delta / 1000.0) * pBucket->bytesRate;
if (incSize > 0) { if (incSize > 0) {
pBucket->bytesRemain = MIN(pBucket->bytesRemain + incSize, pBucket->bytesCapacity); pBucket->bytesRemain = TMIN(pBucket->bytesRemain + incSize, pBucket->bytesCapacity);
} }
if (incNum > 0) { if (incNum > 0) {
@ -434,7 +434,7 @@ bool streamTaskExtractAvailableToken(STokenBucket* pBucket) {
} }
void streamTaskPutbackToken(STokenBucket* pBucket) { void streamTaskPutbackToken(STokenBucket* pBucket) {
pBucket->numOfToken = MIN(pBucket->numOfToken + 1, pBucket->numCapacity); pBucket->numOfToken = TMIN(pBucket->numOfToken + 1, pBucket->numCapacity);
} }
// size in KB // size in KB