diff options
Diffstat (limited to 'pkg')
| -rw-r--r-- | pkg/server/mrt.go | 10 | ||||
| -rw-r--r-- | pkg/server/server.go | 3 |
2 files changed, 7 insertions, 6 deletions
diff --git a/pkg/server/mrt.go b/pkg/server/mrt.go index b4fe30b5..773f0ea5 100644 --- a/pkg/server/mrt.go +++ b/pkg/server/mrt.go @@ -282,15 +282,15 @@ func (m *mrtWriter) loop() error { } } -func mrtFileOpen(filename string, interval uint64) (*os.File, error) { +func mrtFileOpen(filename string, rInterval uint64) (*os.File, error) { realname := filename - if interval != 0 { + if rInterval != 0 { realname = time.Now().Format(filename) } log.WithFields(log.Fields{ - "Topic": "mrt", - "Filename": realname, - "Dump Interval": interval, + "Topic": "mrt", + "Filename": realname, + "RotationInterval": rInterval, }).Debug("Setting new MRT destination file") i := len(realname) diff --git a/pkg/server/server.go b/pkg/server/server.go index 4fd4aa25..68a43c0e 100644 --- a/pkg/server/server.go +++ b/pkg/server/server.go @@ -3280,7 +3280,8 @@ func (s *BgpServer) SetPolicyAssignment(ctx context.Context, r *api.SetPolicyAss func (s *BgpServer) EnableMrt(ctx context.Context, r *api.EnableMrtRequest) error { return s.mgmtOperation(func() error { return s.mrtManager.enable(&config.MrtConfig{ - RotationInterval: r.Interval, + DumpInterval: r.DumpInterval, + RotationInterval: r.RotationInterval, DumpType: config.IntToMrtTypeMap[int(r.DumpType)], FileName: r.Filename, }) |