mirror of
https://github.com/postmannen/ctrl.git
synced 2025-03-05 06:46:48 +00:00
added disabling av steward.sock
This commit is contained in:
parent
248258d8e8
commit
341d714361
1 changed files with 12 additions and 5 deletions
17
server.go
17
server.go
|
@ -110,11 +110,16 @@ func NewServer(c *Configuration, version string) (*server, error) {
|
|||
log.Printf(" * conn.Opts.ReconnectJitterTLS: %v\n", conn.Opts.ReconnectJitterTLS)
|
||||
log.Printf(" * conn.Opts.ReconnectJitter: %v\n", conn.Opts.ReconnectJitter)
|
||||
|
||||
var stewardSocket net.Listener
|
||||
var err error
|
||||
|
||||
// Open the steward socket file, and start the listener if enabled.
|
||||
stewardSocket, err := createSocket(c.SocketFolder, "steward.sock")
|
||||
if err != nil {
|
||||
cancel()
|
||||
return nil, err
|
||||
if c.EnableSocket {
|
||||
stewardSocket, err = createSocket(c.SocketFolder, "steward.sock")
|
||||
if err != nil {
|
||||
cancel()
|
||||
return nil, err
|
||||
}
|
||||
}
|
||||
|
||||
// Open the stew socket file, and start the listener if enabled.
|
||||
|
@ -218,7 +223,9 @@ func (s *server) Start() {
|
|||
}()
|
||||
|
||||
// Start the checking the input socket for new messages from operator.
|
||||
go s.readSocket()
|
||||
if s.configuration.EnableSocket {
|
||||
go s.readSocket()
|
||||
}
|
||||
|
||||
// Check if we should start the tcp listener for new messages from operator.
|
||||
if s.configuration.TCPListener != "" {
|
||||
|
|
Loading…
Add table
Reference in a new issue