summaryrefslogtreecommitdiff
path: root/pkg/listenbuffer/buffer.go
blob: c350805a7d06e9f15b1ca413e529a4b22cf260bb (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
/*
   Package to allow go applications to immediately start
   listening on a socket, unix, tcp, udp but hold connections
   until the application has booted and is ready to accept them
*/
package listenbuffer

import (
	"fmt"
	"net"
	"time"
)

// NewListenBuffer returns a listener listening on addr with the protocol.  It sets the
// timeout to wait on first connection before an error is returned
func NewListenBuffer(proto, addr string, activate chan struct{}, timeout time.Duration) (net.Listener, error) {
	wrapped, err := net.Listen(proto, addr)
	if err != nil {
		return nil, err
	}

	return &defaultListener{
		wrapped:  wrapped,
		activate: activate,
		timeout:  timeout,
	}, nil
}

type defaultListener struct {
	wrapped  net.Listener // the real listener to wrap
	ready    bool         // is the listner ready to start accpeting connections
	activate chan struct{}
	timeout  time.Duration // how long to wait before we consider this an error
}

func (l *defaultListener) Close() error {
	return l.wrapped.Close()
}

func (l *defaultListener) Addr() net.Addr {
	return l.wrapped.Addr()
}

func (l *defaultListener) Accept() (net.Conn, error) {
	// if the listen has been told it is ready then we can go ahead and
	// start returning connections
	if l.ready {
		return l.wrapped.Accept()
	}

	select {
	case <-time.After(l.timeout):
		// close the connection so any clients are disconnected
		l.Close()
		return nil, fmt.Errorf("timeout (%s) reached waiting for listener to become ready", l.timeout.String())
	case <-l.activate:
		l.ready = true
		return l.Accept()
	}
	panic("unreachable")
}