INNER CODE UNIT · Go

waitForSocket

jwilder/dockerize · main.go:201

func waitForSocket(scheme, addr string, timeout time.Duration) {
	wg.Add(1)
	go func() {
		defer wg.Done()
		for {
			conn, err := dialTimeout(scheme, addr, timeout)
			if err != nil {
				log.Printf("Problem with dial %s://%s: %v. Sleeping %s\n", scheme, addr, err.Error(), waitRetryInterval)
				time.Sleep(waitRetryInterval)
			}
			if conn != nil {
				log.Printf("Connected to %s://%s\n", scheme, addr)
				_ = conn.Close()
				return
			}
		}
	}()
}

View source record →