// 3. Process each step (schedule or skip based on reactor failure behavior)
                plan.sortedNodes().stream()
                        // 1. Filter steps that are in CREATED state
                        .filter(BuildStep::isCreated)
                        // 2. Check if all predecessors are in a terminal state

        assertEquals('S', (char) type2Bytes[4]);
        assertEquals('S', (char) type2Bytes[5]);
        assertEquals('P', (char) type2Bytes[6]);
        assertEquals(0, type2Bytes[7]); // Null terminator
        assertEquals(2, type2Bytes[8], "Message type should be 2"); // Type 2

        // Verify response status
        verify(mockResponse).setStatus(HttpServletResponse.SC_UNAUTHORIZED);

      }
    }

    @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait.
    void awaitWaiting() {
      while (!isBlocked()) {
        if (getState() == State.TERMINATED) {
          throw new RuntimeException("Thread exited");
        }
        Thread.yield();
      }
    }

    private boolean isBlocked() {

    * The specific behavior of the podGC controller to clean up terminated pods is still governed by the flag, but the podGC's responsibilities have evolved beyond just cleaning up terminated pods.

                assertNotNull(targetInfo);
                // Should only contain server info - but might have different structure than expected
                assertTrue(targetInfo.length >= 4, "Target info should have at least terminator");
                // Check if it contains server info (implementation dependent)
                if (targetInfo.length > 4) {
                    assertEquals(1, Type2Message.readUShort(targetInfo, 0)); // Type 0x0001

        String testString = "Hello World";
        ndrBuffer.enc_ndr_string(testString);

        // Expected length: 4 (actual_count) + 4 (offset) + 4 (max_count) + len*2 (unicode) + 2 (null terminator)
        int expectedLength = 4 + 4 + 4 + (testString.length() * 2) + 2;
        assertEquals(expectedLength, ndrBuffer.getIndex());
        assertEquals(expectedLength, ndrBuffer.getLength());

        assertEquals('S', messageBytes[4]);
        assertEquals('S', messageBytes[5]);
        assertEquals('P', messageBytes[6]);
        assertEquals(0, messageBytes[7]); // Null terminator
    }

    @Test
    @DisplayName("Should include message type indicator")
    void testMessageTypeIndicator() throws Exception {
        // Given
        Type2Message type2 = createMockType2Message();

      }
    }

    @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait.
    void awaitWaiting() {
      while (!isBlocked()) {
        if (getState() == State.TERMINATED) {
          throw new RuntimeException("Thread exited");
        }
        Thread.yield();
      }
    }

    private boolean isBlocked() {

labels.user_postalAddress=Adres pocztowy
labels.postalAddress=Adres pocztowy
labels.user_city=Miasto
labels.city=Miasto
labels.user_teletexTerminalIdentifier=Identyfikator terminala teletex
labels.teletexTerminalIdentifier=Identyfikator terminala teletex
labels.user_x121Address=x121Address
labels.x121Address=x121Address
labels.user_businessCategory=Kategoria biznesowa
labels.businessCategory=Kategoria biznesowa

labels.mobile=Mobiltelefon
labels.user_postalAddress=Postanschrift
labels.postalAddress=Postanschrift
labels.user_city=Stadt
labels.city=Stadt
labels.user_teletexTerminalIdentifier=Teletex-Terminal-Kennung
labels.teletexTerminalIdentifier=Teletex-Terminal-Kennung
labels.user_x121Address=x121Address
labels.x121Address=x121Address
labels.user_businessCategory=Geschäftskategorie
labels.businessCategory=Geschäftskategorie