system service: remove unnecessary pointer to listner

Since the listener is already an interface there is no reason to use a
extra pointer for it.

Signed-off-by: Paul Holzinger <pholzing@redhat.com>
This commit is contained in:
Paul Holzinger 2022-04-21 12:55:31 +02:00
parent 02ab86a68a
commit 13c6fd067c
No known key found for this signature in database
GPG Key ID: EB145DD938A3CAF2
2 changed files with 10 additions and 13 deletions

View File

@ -23,7 +23,7 @@ import (
func restService(flags *pflag.FlagSet, cfg *entities.PodmanConfig, opts entities.ServiceOptions) error { func restService(flags *pflag.FlagSet, cfg *entities.PodmanConfig, opts entities.ServiceOptions) error {
var ( var (
listener *net.Listener listener net.Listener
err error err error
) )
@ -44,17 +44,15 @@ func restService(flags *pflag.FlagSet, cfg *entities.PodmanConfig, opts entities
// If it is activated by systemd, use the first LISTEN_FD (3) // If it is activated by systemd, use the first LISTEN_FD (3)
// instead of opening the socket file. // instead of opening the socket file.
f := os.NewFile(uintptr(3), "podman.sock") f := os.NewFile(uintptr(3), "podman.sock")
l, err := net.FileListener(f) listener, err = net.FileListener(f)
if err != nil { if err != nil {
return err return err
} }
listener = &l
} else { } else {
l, err := net.Listen(uri.Scheme, path) listener, err = net.Listen(uri.Scheme, path)
if err != nil { if err != nil {
return errors.Wrapf(err, "unable to create socket") return errors.Wrapf(err, "unable to create socket")
} }
listener = &l
} }
case "tcp": case "tcp":
host := uri.Host host := uri.Host
@ -62,11 +60,10 @@ func restService(flags *pflag.FlagSet, cfg *entities.PodmanConfig, opts entities
// For backward compatibility, support "tcp:<host>:<port>" and "tcp://<host>:<port>" // For backward compatibility, support "tcp:<host>:<port>" and "tcp://<host>:<port>"
host = uri.Opaque host = uri.Opaque
} }
l, err := net.Listen(uri.Scheme, host) listener, err = net.Listen(uri.Scheme, host)
if err != nil { if err != nil {
return errors.Wrapf(err, "unable to create socket %v", host) return errors.Wrapf(err, "unable to create socket %v", host)
} }
listener = &l
default: default:
logrus.Debugf("Attempting API Service endpoint scheme %q", uri.Scheme) logrus.Debugf("Attempting API Service endpoint scheme %q", uri.Scheme)
} }
@ -101,7 +98,7 @@ func restService(flags *pflag.FlagSet, cfg *entities.PodmanConfig, opts entities
err = server.Serve() err = server.Serve()
if listener != nil { if listener != nil {
_ = (*listener).Close() _ = listener.Close()
} }
return err return err
} }

View File

@ -60,11 +60,11 @@ func NewServer(runtime *libpod.Runtime) (*APIServer, error) {
} }
// NewServerWithSettings will create and configure a new API server using provided settings // NewServerWithSettings will create and configure a new API server using provided settings
func NewServerWithSettings(runtime *libpod.Runtime, listener *net.Listener, opts entities.ServiceOptions) (*APIServer, error) { func NewServerWithSettings(runtime *libpod.Runtime, listener net.Listener, opts entities.ServiceOptions) (*APIServer, error) {
return newServer(runtime, listener, opts) return newServer(runtime, listener, opts)
} }
func newServer(runtime *libpod.Runtime, listener *net.Listener, opts entities.ServiceOptions) (*APIServer, error) { func newServer(runtime *libpod.Runtime, listener net.Listener, opts entities.ServiceOptions) (*APIServer, error) {
// If listener not provided try socket activation protocol // If listener not provided try socket activation protocol
if listener == nil { if listener == nil {
if _, found := os.LookupEnv("LISTEN_PID"); !found { if _, found := os.LookupEnv("LISTEN_PID"); !found {
@ -78,7 +78,7 @@ func newServer(runtime *libpod.Runtime, listener *net.Listener, opts entities.Se
if len(listeners) != 1 { if len(listeners) != 1 {
return nil, fmt.Errorf("wrong number of file descriptors for socket activation protocol (%d != 1)", len(listeners)) return nil, fmt.Errorf("wrong number of file descriptors for socket activation protocol (%d != 1)", len(listeners))
} }
listener = &listeners[0] listener = listeners[0]
} }
if opts.CorsHeaders == "" { if opts.CorsHeaders == "" {
logrus.Debug("CORS Headers were not set") logrus.Debug("CORS Headers were not set")
@ -86,7 +86,7 @@ func newServer(runtime *libpod.Runtime, listener *net.Listener, opts entities.Se
logrus.Debugf("CORS Headers were set to %q", opts.CorsHeaders) logrus.Debugf("CORS Headers were set to %q", opts.CorsHeaders)
} }
logrus.Infof("API service listening on %q", (*listener).Addr()) logrus.Infof("API service listening on %q", listener.Addr())
router := mux.NewRouter().UseEncodedPath() router := mux.NewRouter().UseEncodedPath()
tracker := idle.NewTracker(opts.Timeout) tracker := idle.NewTracker(opts.Timeout)
@ -101,7 +101,7 @@ func newServer(runtime *libpod.Runtime, listener *net.Listener, opts entities.Se
IdleTimeout: opts.Timeout * 2, IdleTimeout: opts.Timeout * 2,
}, },
CorsHeaders: opts.CorsHeaders, CorsHeaders: opts.CorsHeaders,
Listener: *listener, Listener: listener,
PProfAddr: opts.PProfAddr, PProfAddr: opts.PProfAddr,
idleTracker: tracker, idleTracker: tracker,
} }