Compare commits

...

1 Commits

Author SHA1 Message Date
717c348786 add debug log
Signed-off-by: Benjamin Wang <benjamin.ahrtr@gmail.com>
2024-01-22 10:19:06 +00:00
2 changed files with 4 additions and 2 deletions

View File

@ -70,7 +70,7 @@ func newListener(addr, scheme string, opts ...ListenerOption) (net.Listener, err
// timeout listener with socket options.
ln, err := newKeepAliveListener(&lnOpts.ListenConfig, addr)
if err != nil {
return nil, err
return nil, fmt.Errorf("case: lnOpts.IsTimeout(), lnOpts.IsSocketOpts(): %w", err)
}
lnOpts.Listener = &rwTimeoutListener{
Listener: ln,
@ -80,7 +80,7 @@ func newListener(addr, scheme string, opts ...ListenerOption) (net.Listener, err
case lnOpts.IsTimeout():
ln, err := newKeepAliveListener(nil, addr)
if err != nil {
return nil, err
return nil, fmt.Errorf("case: lnOpts.IsTimeout(): %w", err)
}
lnOpts.Listener = &rwTimeoutListener{
Listener: ln,
@ -90,6 +90,7 @@ func newListener(addr, scheme string, opts ...ListenerOption) (net.Listener, err
default:
ln, err := newKeepAliveListener(nil, addr)
if err != nil {
return nil, fmt.Errorf("case: default: %w", err)
return nil, err
}
lnOpts.Listener = ln

View File

@ -534,6 +534,7 @@ func configurePeerListeners(cfg *Config) (peers []*peerListener, err error) {
transport.WithTimeout(rafthttp.ConnReadTimeout, rafthttp.ConnWriteTimeout),
)
if err != nil {
cfg.logger.Error("########## transport.NewListenerWithOpts failed", zap.Error(err))
return nil, err
}
// once serve, overwrite with 'http.Server.Shutdown'