make extra sure we got precedence correct here

jeromegn · jeromegn · commit 3b5b07ec38cb · 2025-01-22T14:25:50.000-05:00
diff --git a/crates/corro-agent/src/agent/handlers.rs b/crates/corro-agent/src/agent/handlers.rs
@@ -760,7 +760,7 @@ pub async fn handle_changes(
     // complicated loop to process changes efficiently w/ a max concurrency
     // and a minimum chunk size for bigger and faster SQLite transactions
     loop {
-        while (buf_cost >= max_changes_chunk || !queue.is_empty() && join_set.is_empty())
+        while (buf_cost >= max_changes_chunk || (!queue.is_empty() && join_set.is_empty()))
             && join_set.len() < MAX_CONCURRENT
         {
             // Process if we hit the chunk size OR if we have any items and available capacity

Original file line number	Diff line number	Diff line change
`@@ -760,7 +760,7 @@ pub async fn handle_changes(`
`760`	`760`	`// complicated loop to process changes efficiently w/ a max concurrency`
`761`	`761`	`// and a minimum chunk size for bigger and faster SQLite transactions`
`762`	`762`	`loop {`
`763`		`- while (buf_cost >= max_changes_chunk \|\| !queue.is_empty() && join_set.is_empty())`
	`763`	`+ while (buf_cost >= max_changes_chunk \|\| (!queue.is_empty() && join_set.is_empty()))`
`764`	`764`	`&& join_set.len() < MAX_CONCURRENT`
`765`	`765`	`{`
`766`	`766`	`// Process if we hit the chunk size OR if we have any items and available capacity`