connection.withLock {
      if (!connection.isHealthy(System.nanoTime())) {
        throw ConnectionShutdownException()
      }
    }
    connection.writePing()
    connection.shutdown(ErrorCode.PROTOCOL_ERROR)
    assertThat(connection.openStreamCount()).isEqualTo(1)
    connection.awaitPong() // Prevent the peer from exiting prematurely.

    // Verify the peer received what was expected.

pkg syscall (freebsd-arm64), func Settimeofday(*Timeval) error
pkg syscall (freebsd-arm64), func Setuid(int) error
pkg syscall (freebsd-arm64), func Shutdown(int, int) error
pkg syscall (freebsd-arm64), func SlicePtrFromStrings([]string) ([]*uint8, error)
pkg syscall (freebsd-arm64), func Socket(int, int, int) (int, error)

* remove time waiting after create storage account (save 25s) ([#56679](https://github.com/kubernetes/kubernetes/pull/56679), [@andyzhangx](https://github.com/andyzhangx))
* Allow kubernetes components to react to SIGTERM signal and shutdown gracefully. ([#57756](https://github.com/kubernetes/kubernetes/pull/57756), [@mborsz](https://github.com/mborsz))

* Reduce time needed to attach Azure disks ([#40066](https://github.com/kubernetes/kubernetes/pull/40066), [@codablock](https://github.com/codablock))
* fixing Cassandra shutdown example to avoid data corruption ([#39199](https://github.com/kubernetes/kubernetes/pull/39199), [@deimosfr](https://github.com/deimosfr))

pkg syscall (freebsd-riscv64), func Settimeofday(*Timeval) error #53466
pkg syscall (freebsd-riscv64), func Setuid(int) error #53466
pkg syscall (freebsd-riscv64), func Shutdown(int, int) error #53466
pkg syscall (freebsd-riscv64), func SlicePtrFromStrings([]string) ([]*uint8, error) #53466
pkg syscall (freebsd-riscv64), func Socket(int, int, int) (int, error) #53466

- Fixed an error with stuck informers when an etcd watch receives update or delete events with missing data. ([#76675](https://github.com/kubernetes/kubernetes/pull/76675), [@ryanmcnamara](https://github.com/ryanmcnamara))
- `DelayingQueue.ShutDown()` can now be invoked multiple times without causing a closed channel panic. ([#77170](https://github.com/kubernetes/kubernetes/pull/77170), [@smarterclayton](https://github.com/smarterclayton))

pkg syscall (darwin-arm64), func SetsockoptTimeval(int, int, int, *Timeval) error
pkg syscall (darwin-arm64), func Settimeofday(*Timeval) error
pkg syscall (darwin-arm64), func Setuid(int) error
pkg syscall (darwin-arm64), func Shutdown(int, int) error
pkg syscall (darwin-arm64), func SlicePtrFromStrings([]string) ([]*uint8, error)
pkg syscall (darwin-arm64), func Socket(int, int, int) (int, error)

    enqueuedCall: AsyncCall? = null,
    finishedCall: RealCall? = null,
    finishedAsyncCall: AsyncCall? = null,
  ) {
    assertLockNotHeld()
    val executorIsShutdown = executorService.isShutdown

    // Actions to take outside the synchronized block.
    class Effects(
      val callsToExecute: List<AsyncCall>,
      val idleCallbackToRun: Runnable?,
    )

    val effects =

        boolean shutdownListenerAdded = false;

        @Override
        public void addShutdownListener(ShutdownListener listener) {
            shutdownListenerAdded = true;
            listener.onShutdown();
        }

        @Override
        public Object execute(String scriptType, String script) {
            return null;
        }
    }

        @Override
        public void addShutdownListener(ShutdownListener listener) {
            shutdownListenerAdded = true;
            // Optionally execute the listener to test its behavior
            listener.onShutdown();
        }

        @Override
        public Object execute(String scriptType, String script) {
            return null;
        }
    }