ran 'go fmt'; cosmetic changes

consts.go

@@ -10,7 +10,7 @@ const (
 	EthernetOverhead  = 14
 	UDPOverhead       = 28 // 20 bytes for IPv4, 8 bytes for UDP
 	Port              = 6783
-	StatusPort        = Port+1
+	StatusPort        = Port + 1
 	DefaultPMTU       = 65535
 	MaxUDPPacketSize  = 65536
 	ChannelSize       = 16

http_responder.go

@@ -2,33 +2,33 @@ package weave
 
 import (
 	"fmt"
-    "net/http"
+	"net/http"
 )
 
 /* A simple http responder that will show the status of the router when asked,
- e.g. via http://172.17.0.2/status
+e.g. via http://172.17.0.2/status
 */
 type HttpStatusResponder struct {
-    router *Router
+	router *Router
 }
 
 func NewHttpStatusResponder(router *Router) *HttpStatusResponder {
-    resp := &HttpStatusResponder{router}
-    return resp
+	resp := &HttpStatusResponder{router}
+	return resp
 }
 
 func (resp *HttpStatusResponder) SetRouter(newRouter *Router) {
-    resp.router = newRouter
+	resp.router = newRouter
 }
 
 func (resp *HttpStatusResponder) ListenAndServe() {
-    http.HandleFunc("/status", func(w http.ResponseWriter, r *http.Request) {
-        if resp.router != nil {
-            fmt.Fprint(w, resp.router.Status())
-        } else {
-            fmt.Fprintf(w, "Not initialized")
-        }
-    })
-    address := fmt.Sprintf(":%d", StatusPort)
-    http.ListenAndServe(address, nil)
+	http.HandleFunc("/status", func(w http.ResponseWriter, r *http.Request) {
+		if resp.router != nil {
+			fmt.Fprint(w, resp.router.Status())
+		} else {
+			fmt.Fprintf(w, "Not initialized")
+		}
+	})
+	address := fmt.Sprintf(":%d", StatusPort)
+	http.ListenAndServe(address, nil)
 }

weaver/main.go

@@ -1,7 +1,7 @@
 package main
 
 import (
-	"github.com/bboreham/weave"
+	"github.com/zettio/weave"
 	"code.google.com/p/gopacket/layers"
 	"crypto/sha256"
 	"flag"
@@ -70,7 +70,7 @@ func main() {
 	flag.IntVar(&bufSz, "bufsz", 8, "capture buffer size in MB (defaults to 8MB)")
 	flag.Parse()
 	peers = flag.Args()
-    
+
 	if ifaceName == "" {
 		fmt.Println("Missing required parameter 'iface'")
 		os.Exit(1)
@@ -123,8 +123,8 @@ func main() {
 			}
 		}()
 	}
-    httpResponder := weave.NewHttpStatusResponder(router)
-    go httpResponder.ListenAndServe()
+	httpResponder := weave.NewHttpStatusResponder(router)
+	go httpResponder.ListenAndServe()
 	handleSignals(router)
 }
 

weaver/weave

@@ -106,7 +106,8 @@ ip netns exec $NSPID ip link set $GUEST_IFNAME name $CONTAINER_IFNAME
 ip netns exec $NSPID ip addr add $IPADDR dev $CONTAINER_IFNAME
 ip netns exec $NSPID ip link set $CONTAINER_IFNAME up
 
-if command -v ethtool >/dev/null 2>&1 ; then
+if [ command -v ethtool >/dev/null 2>&1 ]
+then
     ip netns exec $NSPID ethtool -K $IFACE tx off > /dev/null
 else
     echo "Cannot find ethtool; continuing without it" >&2