#!/bin/bash
# Fetch the complete content of all modified dispatcher files
echo "=== AbstractIODispatcher.java ==="
cat core/src/main/java/io/questdb/network/AbstractIODispatcher.java

echo -e "\n=== IODispatcherLinux.java ==="
cat core/src/main/java/io/questdb/network/IODispatcherLinux.java

echo -e "\n=== IODispatcherOsx.java ==="
cat core/src/main/java/io/questdb/network/IODispatcherOsx.java

echo -e "\n=== IODispatcherWindows.java ==="
cat core/src/main/java/io/questdb/network/IODispatcherWindows.java

echo -e "\n=== Kqueue.java ==="
cat core/src/main/java/io/questdb/network/Kqueue.java

#!/bin/bash
# Search for all usages of nextOpId and nextEventId to trace ID generation patterns
echo "=== nextOpId() call sites ==="
rg -n "nextOpId\(\)" --type java

echo -e "\n=== nextEventId() call sites ==="
rg -n "nextEventId\(\)" --type java

echo -e "\n=== Binary searches on OPM_ID ==="
rg -n "binarySearch.*OPM_ID" --type java

echo -e "\n=== Early returns/continues in processRegistrations ==="
rg -n -A2 -B2 "processRegistrations.*continue" --type java

#!/bin/bash
# Find all places where nextOpId is called early and could be wasted
echo "=== processRegistrations with early continues ==="
rg -n -B5 -A15 "final long opId = nextOpId\(\)" core/src/main/java/io/questdb/network/

echo -e "\n=== All continue statements after nextOpId ==="
rg -n -B10 "nextOpId.*continue" core/src/main/java/io/questdb/network/ || echo "Pattern not found, checking manually..."

# Check for the specific pattern
echo -e "\n=== Heartbeat lookup failures leading to continue ==="
rg -n -A3 "could not find heartbeat" core/src/main/java/io/questdb/network/

#!/bin/bash
# Check for other early continue paths after nextOpId is called
echo "=== All continue statements in processRegistrations ==="
rg -n -B15 -A2 "^\s*continue;" core/src/main/java/io/questdb/network/IODispatcher*.java | grep -A15 -B15 "processRegistrations"

echo -e "\n=== Plaintext buffered early return path ==="
rg -n -B5 -A3 "isMorePlaintextBuffered.*publishOperation.*continue" core/src/main/java/io/questdb/network/

#!/bin/bash
# Extract the full processRegistrations method from each dispatcher
echo "=== IODispatcherLinux processRegistrations ==="
sed -n '/private boolean processRegistrations/,/^    }/p' core/src/main/java/io/questdb/network/IODispatcherLinux.java | grep -n "continue"

echo -e "\n=== IODispatcherOsx processRegistrations ==="
sed -n '/private boolean processRegistrations/,/^    }/p' core/src/main/java/io/questdb/network/IODispatcherOsx.java | grep -n "continue"

echo -e "\n=== IODispatcherWindows processRegistrations ==="
sed -n '/private boolean processRegistrations/,/^    }/p' core/src/main/java/io/questdb/network/IODispatcherWindows.java | grep -n "continue"

echo -e "\n=== Now check isMorePlaintextBuffered pattern ==="
rg -n "isMorePlaintextBuffered" core/src/main/java/io/questdb/network/IODispatcher*.java

#!/bin/bash
# Get context around isMorePlaintextBuffered to see if it's after nextOpId
echo "=== IODispatcherLinux isMorePlaintextBuffered context ==="
rg -n -B10 -A5 "isMorePlaintextBuffered" core/src/main/java/io/questdb/network/IODispatcherLinux.java

echo -e "\n=== IODispatcherOsx isMorePlaintextBuffered context ==="
rg -n -B10 -A5 "isMorePlaintextBuffered" core/src/main/java/io/questdb/network/IODispatcherOsx.java

echo -e "\n=== IODispatcherWindows isMorePlaintextBuffered context ==="
rg -n -B10 -A5 "isMorePlaintextBuffered" core/src/main/java/io/questdb/network/IODispatcherWindows.java