Update schedulecommit/elfs/dlp.so to use latest version of DLP

Author: snawaz

test-integration/schedulecommit/elfs/dlp.so

@@ -147,7 +147,7 @@ async fn commit_single_account(
     .await;
 }
 
-// TODO(thlorenz): once delegation program supports larger commits
+// TODO(thlorenz/snawaz): once delegation program supports larger commits
 // add 1MB and 10MB tests
 
 // -----------------
@@ -213,7 +213,9 @@ async fn test_ix_commit_four_accounts_1kb_2kb_5kb_10kb_single_bundle() {
     .await;
 }
 
-#[tokio::test]
+// TODO (snawaz): use #[tokio::test] once CommitTask::new() stops using blocking RpcClient
+// # see the PR #575 for more context.
+#[tokio::test(flavor = "multi_thread", worker_threads = 2)]
 async fn test_commit_20_accounts_1kb_bundle_size_2() {
     commit_20_accounts_1kb(
         2,

test-integration/test-committor-service/tests/test_ix_commit_local.rs

@@ -120,7 +120,17 @@ pub async fn tx_logs_contain(
         .log_messages
         .clone()
         .unwrap_or_else(Vec::new);
-    logs.iter().any(|log| log.contains(needle))
+    logs.iter().any(|log| {
+        // Lots of existing tests pass "CommitState" as needle argument to this function, but since now CommitTask
+        // could invoke CommitState or CommitDiff depending on the size of the account, we also look for "CommitDiff"
+        // in the logs when needle == CommitState. It's easier to make this little adjustment here than computing
+        // the decision and passing either CommitState or CommitDiff from the tests themselves.
+        if needle == "CommitState" {
+            log.contains(needle) || log.contains("CommitDiff")
+        } else {
+            log.contains(needle)
+        }
+    })
 }
 
 /// This needs to be run for each test that required a new counter to be delegated