diff options
author | Wataru Ishida <ishida.wataru@lab.ntt.co.jp> | 2016-11-21 04:47:34 -0500 |
---|---|---|
committer | Wataru Ishida <ishida.wataru@lab.ntt.co.jp> | 2016-11-21 19:41:38 -0500 |
commit | 5d4e9154b063aee1ecc1a90212965b561c6def99 (patch) | |
tree | 8cbfd0be28995757e5e86d8ae42cb37f9db4220a | |
parent | 7006ec15fe72bdcf41f03d9e76db6783e7970b0a (diff) |
server: fix memory leak in infinite channel goroutine
infinite channel has internal goroutine which won't stop until all items in
the buffer are dequeued.
Signed-off-by: Wataru Ishida <ishida.wataru@lab.ntt.co.jp>
-rw-r--r-- | server/server.go | 3 | ||||
-rw-r--r-- | server/util.go | 25 |
2 files changed, 27 insertions, 1 deletions
diff --git a/server/server.go b/server/server.go index d18cf641..fd0ebf1f 100644 --- a/server/server.go +++ b/server/server.go @@ -703,7 +703,7 @@ func (server *BgpServer) handleFSMMessage(peer *Peer, e *FsmMsg) { } } - peer.outgoing.Close() + cleanInfiniteChannel(peer.outgoing) peer.outgoing = channels.NewInfiniteChannel() if nextState == bgp.BGP_FSM_ESTABLISHED { // update for export policy @@ -1740,6 +1740,7 @@ func (server *BgpServer) deleteNeighbor(c *config.Neighbor, code, subcode uint8) n.fsm.sendNotification(code, subcode, nil, "") n.stopPeerRestarting() + cleanInfiniteChannel(n.outgoing) go func(addr string) { t1 := time.AfterFunc(time.Minute*5, func() { diff --git a/server/util.go b/server/util.go new file mode 100644 index 00000000..43c85bc1 --- /dev/null +++ b/server/util.go @@ -0,0 +1,25 @@ +// Copyright (C) 2016 Nippon Telegraph and Telephone Corporation. +// +// Licensed under the Apache License, Version 2.0 (the "License"); +// you may not use this file except in compliance with the License. +// You may obtain a copy of the License at +// +// http://www.apache.org/licenses/LICENSE-2.0 +// +// Unless required by applicable law or agreed to in writing, software +// distributed under the License is distributed on an "AS IS" BASIS, +// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or +// implied. +// See the License for the specific language governing permissions and +// limitations under the License. + +package server + +import "github.com/eapache/channels" + +func cleanInfiniteChannel(ch *channels.InfiniteChannel) { + ch.Close() + // drain all remaining items + for range ch.Out() { + } +} |