Merge pull request containers#16781 from matejvasek/fix-event-reading…

…-size

fix: event read from syslog when syslog entry too long

libpod/events/journal_linux.go

@@ -101,6 +101,10 @@ func (e EventJournalD) Read(ctx context.Context, options ReadOptions) error {
 			logrus.Errorf("Unable to close journal :%v", err)
 		}
 	}()
+	err = j.SetDataThreshold(0)
+	if err != nil {
+		logrus.Warnf("cannot set data threshold: %v", err)
+	}
 	// match only podman journal entries
 	podmanJournal := sdjournal.Match{Field: "SYSLOG_IDENTIFIER", Value: "podman"}
 	if err := j.AddMatch(podmanJournal.String()); err != nil {

test/python/docker/compat/test_containers.py

@@ -3,6 +3,8 @@
 """
 import io
 import tarfile
+import threading
+import time
 from typing import IO, List, Optional
 
 from docker import errors
@@ -260,3 +262,24 @@ def test_mount_rw_by_default(self):
                 ctr.remove()
             if vol is not None:
                 vol.remove(force=True)
+
+    def test_wait_next_exit(self):
+        self.skipTest("Skip until fix container-selinux#196 is available.")
+        ctr: Container = self.docker.containers.create(
+            image=constant.ALPINE,
+            name="test-exit",
+            command=["true"],
+            labels={"my-label": "0" * 250_000})
+
+        try:
+            def wait_and_start():
+                time.sleep(5)
+                ctr.start()
+
+            t = threading.Thread(target=wait_and_start)
+            t.start()
+            ctr.wait(condition="next-exit", timeout=300)
+            t.join()
+        finally:
+            ctr.stop()
+            ctr.remove(force=True)