testPeerPID() — netty Function Reference

Architecture documentation for the testPeerPID() function in KQueueSocketTest.java from the netty codebase.

Function java Buffer Telemetry calls 1

Entity Profile

Buffer→ Telemetry→ testPeerPID() — netty Function Reference

Dependency Diagram

graph TD
  5b5661d5_af64_72a2_303b_b1a1e89cece5["testPeerPID()"]
  3fa0790c_dc52_31cb_2dde_3ff6bcbc47d1["KQueueSocketTest"]
  5b5661d5_af64_72a2_303b_b1a1e89cece5 -->|defined in| 3fa0790c_dc52_31cb_2dde_3ff6bcbc47d1
  84649cee_faad_125c_616a_f8b7d816a7e5["BsdSocket()"]
  5b5661d5_af64_72a2_303b_b1a1e89cece5 -->|calls| 84649cee_faad_125c_616a_f8b7d816a7e5
  style 5b5661d5_af64_72a2_303b_b1a1e89cece5 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport-native-kqueue/src/test/java/io/netty/channel/kqueue/KQueueSocketTest.java lines 58–83

    @Test
    public void testPeerPID() throws IOException {
        BsdSocket s1 = BsdSocket.newSocketDomain();
        BsdSocket s2 = BsdSocket.newSocketDomain();

        try {
            DomainSocketAddress dsa = UnixTestUtils.newDomainSocketAddress();
            s1.bind(dsa);
            s1.listen(1);

            // PID of client socket is expected to be 0 before connection
            assertEquals(0, s2.getPeerCredentials().pid());
            assertTrue(s2.connect(dsa));
            byte [] addr = new byte[64];
            int clientFd = s1.accept(addr);
            assertNotEquals(-1, clientFd);
            PeerCredentials pc = new BsdSocket(clientFd).getPeerCredentials();
            assertNotEquals(0, pc.pid());
            assertNotEquals(0, s2.getPeerCredentials().pid());
            // Server socket FDs should not have pid field set:
            assertEquals(0, s1.getPeerCredentials().pid());
        } finally {
            s1.close();
            s2.close();
        }
    }