MCPcopy Create free account
hub / github.com/PostHog/duckgres / returnPrebound

Method returnPrebound

controlplane/worker_mgr.go:276–280  ·  view source on GitHub ↗
(ps *preboundSocket)

Source from the content-addressed store, hash-verified

274 // Workers can still LISTEN on inherited FDs, but the CP can't CONNECT
275 // because the Unix socket paths don't exist on disk.
276 if _, err := os.Stat(ps.socketPath); err != nil {
277 slog.Warn("Pre-bound socket file disappeared, discarding all pre-bound sockets.", "path", ps.socketPath, "error", err)
278 _ = ps.listener.Close()
279 p.closeAllPrebound() // if one is gone, all are gone (same mount)
280 return nil
281 }
282 return ps
283}

Callers 4

releaseWorkerSocketMethod · 0.95
SpawnWorkerMethod · 0.95
TestConcurrentTakeReturnFunction · 0.95

Calls

no outgoing calls

Tested by 2

TestConcurrentTakeReturnFunction · 0.76