summaryrefslogtreecommitdiffhomepage
path: root/server/watcher.go
diff options
context:
space:
mode:
Diffstat (limited to 'server/watcher.go')
-rw-r--r--server/watcher.go4
1 files changed, 3 insertions, 1 deletions
diff --git a/server/watcher.go b/server/watcher.go
index 73c3f251..d186e9cf 100644
--- a/server/watcher.go
+++ b/server/watcher.go
@@ -64,6 +64,7 @@ type watcherEventUpdateMsg struct {
localAddress net.IP
fourBytesAs bool
timestamp time.Time
+ payload []byte
}
type watcher interface {
@@ -115,7 +116,8 @@ func (w *mrtWatcher) loop() error {
write := func(ev watcherEvent) {
m := ev.(*watcherEventUpdateMsg)
subtype := bgp.MESSAGE_AS4
- mp := bgp.NewBGP4MPMessage(m.peerAS, m.localAS, 0, m.peerAddress.String(), m.localAddress.String(), m.fourBytesAs, m.message)
+ mp := bgp.NewBGP4MPMessage(m.peerAS, m.localAS, 0, m.peerAddress.String(), m.localAddress.String(), m.fourBytesAs, nil)
+ mp.BGPMessagePayload = m.payload
if m.fourBytesAs == false {
subtype = bgp.MESSAGE
}