Skip to content

Commit 41429a7

Browse files
committed
update the bytes allow to delivery after we delivery one event
1 parent 6965633 commit 41429a7

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

source/s3_meta_request.c

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2041,9 +2041,11 @@ static void s_s3_meta_request_event_delivery_task(struct aws_task *task, void *a
20412041
* callback. */
20422042
aws_byte_cursor_advance(&response_body, bytes_delivered_for_request);
20432043
if (response_body.len > (size_t)bytes_allowed_to_deliver) {
2044-
response_body.len = bytes_allowed_to_deliver;
2044+
response_body.len = (size_t)bytes_allowed_to_deliver;
20452045
delivery_incomplete = true;
20462046
}
2047+
/* Update the remaining bytes we allow to delivery. */
2048+
bytes_allowed_to_deliver -= response_body.len;
20472049
} else {
20482050
/* We should not have any incomplete delivery in this case. */
20492051
AWS_FATAL_ASSERT(bytes_delivered_for_request == 0);

0 commit comments

Comments
 (0)