Skip to content

Commit

Permalink
Add MTU to connection status
Browse files Browse the repository at this point in the history
  • Loading branch information
bboreham committed Dec 1, 2016
1 parent d501c78 commit 1ae6cab
Show file tree
Hide file tree
Showing 6 changed files with 11 additions and 11 deletions.
2 changes: 1 addition & 1 deletion prog/weaver/http.go
Expand Up @@ -211,7 +211,7 @@ var targetsTemplate = defTemplate("targetsTemplate", `\

var connectionsTemplate = defTemplate("connectionsTemplate", `\
{{range .Router.Connections}}\
{{if .Outbound}}->{{else}}<-{{end}} {{printf "%-21v" .Address}} {{printf "%-11v" .State}} {{.Info}}
{{if .Outbound}}->{{else}}<-{{end}} {{printf "%-21v" .Address}} {{printf "%-11v" .State}} {{.Info}} {{range $key,$element := .Attrs}}{{$key}}={{$element}}{{end}}
{{end}}\
`)

Expand Down
4 changes: 2 additions & 2 deletions router/awsvpc.go
Expand Up @@ -32,8 +32,8 @@ func (conn *AWSVPCConnection) Stop() {}
func (conn *AWSVPCConnection) ControlMessage(tag byte, msg []byte) {
}

func (conn *AWSVPCConnection) DisplayName() string {
return "awsvpc"
func (conn *AWSVPCConnection) GetDisplayNameAndAttrs() (string, map[string]interface{}) {
return "awsvpc", nil
}

// OverlayForwarder
Expand Down
4 changes: 2 additions & 2 deletions router/fastdp.go
Expand Up @@ -771,8 +771,8 @@ func (fwd *fastDatapathForwarder) ControlMessage(tag byte, msg []byte) {
}
}

func (fwd *fastDatapathForwarder) DisplayName() string {
return "fastdp"
func (fwd *fastDatapathForwarder) GetDisplayNameAndAttrs() (string, map[string]interface{}) {
return "fastdp", map[string]interface{}{"mtu": fwd.fastdp.iface.MTU}
}

func (fwd *fastDatapathForwarder) handleHeartbeatAck() {
Expand Down
6 changes: 3 additions & 3 deletions router/overlay_switch.go
Expand Up @@ -424,7 +424,7 @@ func (fwd *overlaySwitchForwarder) ControlMessage(tag byte, msg []byte) {
}
}

func (fwd *overlaySwitchForwarder) DisplayName() string {
func (fwd *overlaySwitchForwarder) GetDisplayNameAndAttrs() (string, map[string]interface{}) {
var best OverlayForwarder

fwd.lock.Lock()
Expand All @@ -434,8 +434,8 @@ func (fwd *overlaySwitchForwarder) DisplayName() string {
fwd.lock.Unlock()

if best != nil {
return best.DisplayName()
return best.GetDisplayNameAndAttrs()
}

return "none"
return "none", nil
}
4 changes: 2 additions & 2 deletions router/sleeve.go
Expand Up @@ -606,8 +606,8 @@ func (fwd *sleeveForwarder) ControlMessage(tag byte, msg []byte) {
}
}

func (fwd *sleeveForwarder) DisplayName() string {
return "sleeve"
func (fwd *sleeveForwarder) GetDisplayNameAndAttrs() (string, map[string]interface{}) {
return "sleeve", map[string]interface{}{"mtu": fwd.mtu}
}

func (fwd *sleeveForwarder) Stop() {
Expand Down
2 changes: 1 addition & 1 deletion vendor/github.com/weaveworks/mesh
Submodule mesh updated 3 files
+2 −2 connection.go
+4 −3 overlay.go
+5 −3 status.go

0 comments on commit 1ae6cab

Please sign in to comment.