@@ -9,7 +9,7 @@ import (

 	"fmt"

 	"sync"

-	log "github.com/Sirupsen/logrus"

+	"github.com/Sirupsen/logrus"

 	"github.com/docker/libnetwork/datastore"

 	"github.com/docker/libnetwork/types"

 )

@@ -286,7 +286,7 @@ func (h *Handle) CheckConsistency() error {

 			continue

 		}

-		log.Infof("Fixed inconsistent bit sequence in datastore:\n%s\n%s", h, nh)

+		logrus.Infof("Fixed inconsistent bit sequence in datastore:\n%s\n%s", h, nh)

 		h.Lock()

 		h.head = nh.head

@@ -6,7 +6,7 @@ import (

 	"strings"

 	"github.com/BurntSushi/toml"

-	log "github.com/Sirupsen/logrus"

+	"github.com/Sirupsen/logrus"

 	"github.com/docker/docker/pkg/discovery"

 	"github.com/docker/docker/pkg/plugingetter"

 	"github.com/docker/go-connections/tlsconfig"

@@ -100,7 +100,7 @@ type Option func(c *Config)

 // OptionDefaultNetwork function returns an option setter for a default network

 func OptionDefaultNetwork(dn string) Option {

 	return func(c *Config) {

-		log.Debugf("Option DefaultNetwork: %s", dn)

+		logrus.Debugf("Option DefaultNetwork: %s", dn)

 		c.Daemon.DefaultNetwork = strings.TrimSpace(dn)

 	}

 }

@@ -108,7 +108,7 @@ func OptionDefaultNetwork(dn string) Option {

 // OptionDefaultDriver function returns an option setter for default driver

 func OptionDefaultDriver(dd string) Option {

 	return func(c *Config) {

-		log.Debugf("Option DefaultDriver: %s", dd)

+		logrus.Debugf("Option DefaultDriver: %s", dd)

 		c.Daemon.DefaultDriver = strings.TrimSpace(dd)

 	}

 }

@@ -134,7 +134,7 @@ func OptionLabels(labels []string) Option {

 // OptionKVProvider function returns an option setter for kvstore provider

 func OptionKVProvider(provider string) Option {

 	return func(c *Config) {

-		log.Debugf("Option OptionKVProvider: %s", provider)

+		logrus.Debugf("Option OptionKVProvider: %s", provider)

 		if _, ok := c.Scopes[datastore.GlobalScope]; !ok {

 			c.Scopes[datastore.GlobalScope] = &datastore.ScopeCfg{}

 		}

@@ -145,7 +145,7 @@ func OptionKVProvider(provider string) Option {

 // OptionKVProviderURL function returns an option setter for kvstore url

 func OptionKVProviderURL(url string) Option {

 	return func(c *Config) {

-		log.Debugf("Option OptionKVProviderURL: %s", url)

+		logrus.Debugf("Option OptionKVProviderURL: %s", url)

 		if _, ok := c.Scopes[datastore.GlobalScope]; !ok {

 			c.Scopes[datastore.GlobalScope] = &datastore.ScopeCfg{}

 		}

@@ -157,14 +157,14 @@ func OptionKVProviderURL(url string) Option {

 func OptionKVOpts(opts map[string]string) Option {

 	return func(c *Config) {

 		if opts["kv.cacertfile"] != "" && opts["kv.certfile"] != "" && opts["kv.keyfile"] != "" {

-			log.Info("Option Initializing KV with TLS")

+			logrus.Info("Option Initializing KV with TLS")

 			tlsConfig, err := tlsconfig.Client(tlsconfig.Options{

 				CAFile:   opts["kv.cacertfile"],

 				CertFile: opts["kv.certfile"],

 				KeyFile:  opts["kv.keyfile"],

 			})

 			if err != nil {

-				log.Errorf("Unable to set up TLS: %s", err)

+				logrus.Errorf("Unable to set up TLS: %s", err)

 				return

 			}

 			if _, ok := c.Scopes[datastore.GlobalScope]; !ok {

@@ -182,7 +182,7 @@ func OptionKVOpts(opts map[string]string) Option {

 				KeyFile:    opts["kv.keyfile"],

 			}

 		} else {

-			log.Info("Option Initializing KV without TLS")

+			logrus.Info("Option Initializing KV without TLS")

 		}

 	}

 }

@@ -242,7 +242,7 @@ func ValidateName(name string) error {

 // OptionLocalKVProvider function returns an option setter for kvstore provider

 func OptionLocalKVProvider(provider string) Option {

 	return func(c *Config) {

-		log.Debugf("Option OptionLocalKVProvider: %s", provider)

+		logrus.Debugf("Option OptionLocalKVProvider: %s", provider)

 		if _, ok := c.Scopes[datastore.LocalScope]; !ok {

 			c.Scopes[datastore.LocalScope] = &datastore.ScopeCfg{}

 		}

@@ -253,7 +253,7 @@ func OptionLocalKVProvider(provider string) Option {

 // OptionLocalKVProviderURL function returns an option setter for kvstore url

 func OptionLocalKVProviderURL(url string) Option {

 	return func(c *Config) {

-		log.Debugf("Option OptionLocalKVProviderURL: %s", url)

+		logrus.Debugf("Option OptionLocalKVProviderURL: %s", url)

 		if _, ok := c.Scopes[datastore.LocalScope]; !ok {

 			c.Scopes[datastore.LocalScope] = &datastore.ScopeCfg{}

 		}

@@ -264,7 +264,7 @@ func OptionLocalKVProviderURL(url string) Option {

 // OptionLocalKVProviderConfig function returns an option setter for kvstore config

 func OptionLocalKVProviderConfig(config *store.Config) Option {

 	return func(c *Config) {

-		log.Debugf("Option OptionLocalKVProviderConfig: %v", config)

+		logrus.Debugf("Option OptionLocalKVProviderConfig: %v", config)

 		if _, ok := c.Scopes[datastore.LocalScope]; !ok {

 			c.Scopes[datastore.LocalScope] = &datastore.ScopeCfg{}

 		}

@@ -51,7 +51,7 @@ import (

 	"sync"

 	"time"

-	log "github.com/Sirupsen/logrus"

+	"github.com/Sirupsen/logrus"

 	"github.com/docker/docker/pkg/discovery"

 	"github.com/docker/docker/pkg/locker"

 	"github.com/docker/docker/pkg/plugingetter"

@@ -212,7 +212,7 @@ func New(cfgOptions ...config.Option) (NetworkController, error) {

 		if err := c.initDiscovery(c.cfg.Cluster.Watcher); err != nil {

 			// Failing to initialize discovery is a bad situation to be in.

 			// But it cannot fail creating the Controller

-			log.Errorf("Failed to Initialize Discovery : %v", err)

+			logrus.Errorf("Failed to Initialize Discovery : %v", err)

 		}

 	}

@@ -283,7 +283,7 @@ func (c *controller) SetKeys(keys []*types.EncryptionKey) error {

 		if clusterConfigAvailable {

 			return c.agentSetup()

 		}

-		log.Debugf("received encryption keys before cluster config")

+		logrus.Debug("received encryption keys before cluster config")

 		return nil

 	}

 	if agent == nil {

@@ -441,7 +441,7 @@ func (c *controller) ReloadConfiguration(cfgOptions ...config.Option) error {

 	c.drvRegistry.WalkIPAMs(func(name string, driver ipamapi.Ipam, cap *ipamapi.Capability) bool {

 		err := driver.DiscoverNew(discoverapi.DatastoreConfig, *dsConfig)

 		if err != nil {

-			log.Errorf("Failed to set datastore in driver %s: %v", name, err)

+			logrus.Errorf("Failed to set datastore in driver %s: %v", name, err)

 		}

 		return false

 	})

@@ -449,14 +449,14 @@ func (c *controller) ReloadConfiguration(cfgOptions ...config.Option) error {

 	c.drvRegistry.WalkDrivers(func(name string, driver driverapi.Driver, capability driverapi.Capability) bool {

 		err := driver.DiscoverNew(discoverapi.DatastoreConfig, *dsConfig)

 		if err != nil {

-			log.Errorf("Failed to set datastore in driver %s: %v", name, err)

+			logrus.Errorf("Failed to set datastore in driver %s: %v", name, err)

 		}

 		return false

 	})

 	if c.discovery == nil && c.cfg.Cluster.Watcher != nil {

 		if err := c.initDiscovery(c.cfg.Cluster.Watcher); err != nil {

-			log.Errorf("Failed to Initialize Discovery after configuration update: %v", err)

+			logrus.Errorf("Failed to Initialize Discovery after configuration update: %v", err)

 		}

 	}

@@ -561,7 +561,7 @@ func (c *controller) pushNodeDiscovery(d driverapi.Driver, cap driverapi.Capabil

 			err = d.DiscoverDelete(discoverapi.NodeDiscovery, nodeData)

 		}

 		if err != nil {

-			log.Debugf("discovery notification error : %v", err)

+			logrus.Debugf("discovery notification error : %v", err)

 		}

 	}

 }

@@ -687,7 +687,7 @@ func (c *controller) NewNetwork(networkType, name string, id string, options ...

 	defer func() {

 		if err != nil {

 			if e := network.deleteNetwork(); e != nil {

-				log.Warnf("couldn't roll back driver network on network %s creation failure: %v", network.name, err)

+				logrus.Warnf("couldn't roll back driver network on network %s creation failure: %v", network.name, err)

 			}

 		}

 	}()

@@ -702,7 +702,7 @@ func (c *controller) NewNetwork(networkType, name string, id string, options ...

 	defer func() {

 		if err != nil {

 			if e := c.deleteFromStore(epCnt); e != nil {

-				log.Warnf("could not rollback from store, epCnt %v on failure (%v): %v", epCnt, err, e)

+				logrus.Warnf("could not rollback from store, epCnt %v on failure (%v): %v", epCnt, err, e)

 			}

 		}

 	}()

@@ -723,7 +723,7 @@ func (c *controller) NewNetwork(networkType, name string, id string, options ...

 var joinCluster NetworkWalker = func(nw Network) bool {

 	n := nw.(*network)

 	if err := n.joinCluster(); err != nil {

-		log.Errorf("Failed to join network %s (%s) into agent cluster: %v", n.Name(), n.ID(), err)

+		logrus.Errorf("Failed to join network %s (%s) into agent cluster: %v", n.Name(), n.ID(), err)

 	}

 	n.addDriverWatches()

 	return false

@@ -732,7 +732,7 @@ var joinCluster NetworkWalker = func(nw Network) bool {

 func (c *controller) reservePools() {

 	networks, err := c.getNetworksForScope(datastore.LocalScope)

 	if err != nil {

-		log.Warnf("Could not retrieve networks from local store during ipam allocation for existing networks: %v", err)

+		logrus.Warnf("Could not retrieve networks from local store during ipam allocation for existing networks: %v", err)

 		return

 	}

@@ -764,22 +764,22 @@ func (c *controller) reservePools() {

 		}

 		// Reserve pools

 		if err := n.ipamAllocate(); err != nil {

-			log.Warnf("Failed to allocate ipam pool(s) for network %q (%s): %v", n.Name(), n.ID(), err)

+			logrus.Warnf("Failed to allocate ipam pool(s) for network %q (%s): %v", n.Name(), n.ID(), err)

 		}

 		// Reserve existing endpoints' addresses

 		ipam, _, err := n.getController().getIPAMDriver(n.ipamType)

 		if err != nil {

-			log.Warnf("Failed to retrieve ipam driver for network %q (%s) during address reservation", n.Name(), n.ID())

+			logrus.Warnf("Failed to retrieve ipam driver for network %q (%s) during address reservation", n.Name(), n.ID())

 			continue

 		}

 		epl, err := n.getEndpointsFromStore()

 		if err != nil {

-			log.Warnf("Failed to retrieve list of current endpoints on network %q (%s)", n.Name(), n.ID())

+			logrus.Warnf("Failed to retrieve list of current endpoints on network %q (%s)", n.Name(), n.ID())

 			continue

 		}

 		for _, ep := range epl {

 			if err := ep.assignAddress(ipam, true, ep.Iface().AddressIPv6() != nil); err != nil {

-				log.Warnf("Failed to reserve current adress for endpoint %q (%s) on network %q (%s)",

+				logrus.Warnf("Failed to reserve current adress for endpoint %q (%s) on network %q (%s)",

 					ep.Name(), ep.ID(), n.Name(), n.ID())

 			}

 		}

@@ -789,7 +789,7 @@ func (c *controller) reservePools() {

 func doReplayPoolReserve(n *network) bool {

 	_, caps, err := n.getController().getIPAMDriver(n.ipamType)

 	if err != nil {

-		log.Warnf("Failed to retrieve ipam driver for network %q (%s): %v", n.Name(), n.ID(), err)

+		logrus.Warnf("Failed to retrieve ipam driver for network %q (%s): %v", n.Name(), n.ID(), err)

 		return false

 	}

 	return caps.RequiresRequestReplay

@@ -816,7 +816,7 @@ func (c *controller) Networks() []Network {

 	networks, err := c.getNetworksFromStore()

 	if err != nil {

-		log.Error(err)

+		logrus.Error(err)

 	}

 	for _, n := range networks {

@@ -1133,18 +1133,18 @@ func (c *controller) clearIngress(clusterLeave bool) {

 	if ingressSandbox != nil {

 		if err := ingressSandbox.Delete(); err != nil {

-			log.Warnf("Could not delete ingress sandbox while leaving: %v", err)

+			logrus.Warnf("Could not delete ingress sandbox while leaving: %v", err)

 		}

 	}

 	n, err := c.NetworkByName("ingress")

 	if err != nil && clusterLeave {

-		log.Warnf("Could not find ingress network while leaving: %v", err)

+		logrus.Warnf("Could not find ingress network while leaving: %v", err)

 	}

 	if n != nil {

 		if err := n.Delete(); err != nil {

-			log.Warnf("Could not delete ingress network while leaving: %v", err)

+			logrus.Warnf("Could not delete ingress network while leaving: %v", err)

 		}

 	}

 }

@@ -4,7 +4,7 @@ import (

 	"fmt"

 	"net"

-	log "github.com/Sirupsen/logrus"

+	"github.com/Sirupsen/logrus"

 	"github.com/docker/libnetwork/iptables"

 	"github.com/docker/libnetwork/types"

 )

@@ -44,7 +44,7 @@ func (l *link) Disable() {

 	// -D == iptables delete flag

 	err := linkContainers("-D", l.parentIP, l.childIP, l.ports, l.bridge, true)

 	if err != nil {

-		log.Errorf("Error removing IPTables rules for a link %s due to %s", l.String(), err.Error())

+		logrus.Errorf("Error removing IPTables rules for a link %s due to %s", l.String(), err.Error())

 	}

 	// Return proper error once we move to use a proper iptables package

 	// that returns typed errors

@@ -6,7 +6,7 @@ import (

 	"net"

 	"path/filepath"

-	log "github.com/Sirupsen/logrus"

+	"github.com/Sirupsen/logrus"

 	"github.com/docker/libnetwork/types"

 	"github.com/vishvananda/netlink"

 )

@@ -39,7 +39,7 @@ func setupBridgeIPv4(config *networkConfiguration, i *bridgeInterface) error {

 				return fmt.Errorf("failed to remove current ip address from bridge: %v", err)

 			}

 		}

-		log.Debugf("Assigning address to bridge interface %s: %s", config.BridgeName, config.AddressIPv4)

+		logrus.Debugf("Assigning address to bridge interface %s: %s", config.BridgeName, config.AddressIPv4)

 		if err := i.nlh.AddrAdd(i.Link, &netlink.Addr{IPNet: config.AddressIPv4}); err != nil {

 			return &IPv4AddrAddError{IP: config.AddressIPv4, Err: err}

 		}

@@ -4,7 +4,7 @@ import (

 	"fmt"

 	"strings"

-	log "github.com/Sirupsen/logrus"

+	"github.com/Sirupsen/logrus"

 	"github.com/docker/libnetwork/ns"

 	"github.com/docker/libnetwork/types"

 	"github.com/vishvananda/netlink"

@@ -39,7 +39,7 @@ func setupVerifyAndReconcile(config *networkConfiguration, i *bridgeInterface) e

 	for _, addrv6 := range addrsv6 {

 		if addrv6.IP.IsGlobalUnicast() && !types.CompareIPNet(addrv6.IPNet, i.bridgeIPv6) {

 			if err := i.nlh.AddrDel(i.Link, &addrv6); err != nil {

-				log.Warnf("Failed to remove residual IPv6 address %s from bridge: %v", addrv6.IPNet, err)

+				logrus.Warnf("Failed to remove residual IPv6 address %s from bridge: %v", addrv6.IPNet, err)

 			}

 		}

 	}

@@ -12,7 +12,7 @@ import (

 	"strconv"

-	log "github.com/Sirupsen/logrus"

+	"github.com/Sirupsen/logrus"

 	"github.com/docker/libnetwork/iptables"

 	"github.com/docker/libnetwork/ns"

 	"github.com/docker/libnetwork/types"

@@ -77,7 +77,7 @@ func (e *encrMap) String() string {

 }

 func (d *driver) checkEncryption(nid string, rIP net.IP, vxlanID uint32, isLocal, add bool) error {

-	log.Debugf("checkEncryption(%s, %v, %d, %t)", nid[0:7], rIP, vxlanID, isLocal)

+	logrus.Debugf("checkEncryption(%s, %v, %d, %t)", nid[0:7], rIP, vxlanID, isLocal)

 	n := d.network(nid)

 	if n == nil || !n.secure {

@@ -100,7 +100,7 @@ func (d *driver) checkEncryption(nid string, rIP net.IP, vxlanID uint32, isLocal

 			}

 			return false

 		}); err != nil {

-			log.Warnf("Failed to retrieve list of participating nodes in overlay network %s: %v", nid[0:5], err)

+			logrus.Warnf("Failed to retrieve list of participating nodes in overlay network %s: %v", nid[0:5], err)

 		}

 	default:

 		if len(d.network(nid).endpoints) > 0 {

@@ -108,18 +108,18 @@ func (d *driver) checkEncryption(nid string, rIP net.IP, vxlanID uint32, isLocal

 		}

 	}

-	log.Debugf("List of nodes: %s", nodes)

+	logrus.Debugf("List of nodes: %s", nodes)

 	if add {

 		for _, rIP := range nodes {

 			if err := setupEncryption(lIP, aIP, rIP, vxlanID, d.secMap, d.keys); err != nil {

-				log.Warnf("Failed to program network encryption between %s and %s: %v", lIP, rIP, err)

+				logrus.Warnf("Failed to program network encryption between %s and %s: %v", lIP, rIP, err)

 			}

 		}

 	} else {

 		if len(nodes) == 0 {

 			if err := removeEncryption(lIP, rIP, d.secMap); err != nil {

-				log.Warnf("Failed to remove network encryption between %s and %s: %v", lIP, rIP, err)

+				logrus.Warnf("Failed to remove network encryption between %s and %s: %v", lIP, rIP, err)

 			}

 		}

 	}

@@ -128,14 +128,14 @@ func (d *driver) checkEncryption(nid string, rIP net.IP, vxlanID uint32, isLocal

 }

 func setupEncryption(localIP, advIP, remoteIP net.IP, vni uint32, em *encrMap, keys []*key) error {

-	log.Debugf("Programming encryption for vxlan %d between %s and %s", vni, localIP, remoteIP)

+	logrus.Debugf("Programming encryption for vxlan %d between %s and %s", vni, localIP, remoteIP)

 	rIPs := remoteIP.String()

 	indices := make([]*spi, 0, len(keys))

 	err := programMangle(vni, true)

 	if err != nil {

-		log.Warn(err)

+		logrus.Warn(err)

 	}

 	for i, k := range keys {

@@ -146,7 +146,7 @@ func setupEncryption(localIP, advIP, remoteIP net.IP, vni uint32, em *encrMap, k

 		}

 		fSA, rSA, err := programSA(localIP, remoteIP, spis, k, dir, true)

 		if err != nil {

-			log.Warn(err)

+			logrus.Warn(err)

 		}

 		indices = append(indices, spis)

 		if i != 0 {

@@ -154,7 +154,7 @@ func setupEncryption(localIP, advIP, remoteIP net.IP, vni uint32, em *encrMap, k

 		}

 		err = programSP(fSA, rSA, true)

 		if err != nil {

-			log.Warn(err)

+			logrus.Warn(err)

 		}

 	}

@@ -179,14 +179,14 @@ func removeEncryption(localIP, remoteIP net.IP, em *encrMap) error {

 		}

 		fSA, rSA, err := programSA(localIP, remoteIP, idxs, nil, dir, false)

 		if err != nil {

-			log.Warn(err)

+			logrus.Warn(err)

 		}

 		if i != 0 {

 			continue

 		}

 		err = programSP(fSA, rSA, false)

 		if err != nil {

-			log.Warn(err)

+			logrus.Warn(err)

 		}

 	}

 	return nil

@@ -213,7 +213,7 @@ func programMangle(vni uint32, add bool) (err error) {

 	}

 	if err = iptables.RawCombinedOutput(append([]string{"-t", string(iptables.Mangle), a, chain}, rule...)...); err != nil {

-		log.Warnf("could not %s mangle rule: %v", action, err)

+		logrus.Warnf("could not %s mangle rule: %v", action, err)

 	}

 	return

@@ -248,9 +248,9 @@ func programSA(localIP, remoteIP net.IP, spi *spi, k *key, dir int, add bool) (f

 		}

 		if add != exists {

-			log.Debugf("%s: rSA{%s}", action, rSA)

+			logrus.Debugf("%s: rSA{%s}", action, rSA)

 			if err := xfrmProgram(rSA); err != nil {

-				log.Warnf("Failed %s rSA{%s}: %v", action, rSA, err)

+				logrus.Warnf("Failed %s rSA{%s}: %v", action, rSA, err)

 			}

 		}

 	}

@@ -273,9 +273,9 @@ func programSA(localIP, remoteIP net.IP, spi *spi, k *key, dir int, add bool) (f

 		}

 		if add != exists {

-			log.Debugf("%s fSA{%s}", action, fSA)

+			logrus.Debugf("%s fSA{%s}", action, fSA)

 			if err := xfrmProgram(fSA); err != nil {

-				log.Warnf("Failed %s fSA{%s}: %v.", action, fSA, err)

+				logrus.Warnf("Failed %s fSA{%s}: %v.", action, fSA, err)

 			}

 		}

 	}

@@ -319,9 +319,9 @@ func programSP(fSA *netlink.XfrmState, rSA *netlink.XfrmState, add bool) error {

 	}

 	if add != exists {

-		log.Debugf("%s fSP{%s}", action, fPol)

+		logrus.Debugf("%s fSP{%s}", action, fPol)

 		if err := xfrmProgram(fPol); err != nil {

-			log.Warnf("%s fSP{%s}: %v", action, fPol, err)

+			logrus.Warnf("%s fSP{%s}: %v", action, fPol, err)

 		}

 	}

@@ -337,7 +337,7 @@ func saExists(sa *netlink.XfrmState) (bool, error) {

 		return false, nil

 	default:

 		err = fmt.Errorf("Error while checking for SA existence: %v", err)

-		log.Warn(err)

+		logrus.Warn(err)

 		return false, err

 	}

 }

@@ -351,7 +351,7 @@ func spExists(sp *netlink.XfrmPolicy) (bool, error) {

 		return false, nil

 	default:

 		err = fmt.Errorf("Error while checking for SP existence: %v", err)

-		log.Warn(err)

+		logrus.Warn(err)

 		return false, err

 	}

 }

@@ -397,16 +397,16 @@ func (d *driver) setKeys(keys []*key) error {

 	d.keys = keys

 	d.secMap = &encrMap{nodes: map[string][]*spi{}}

 	d.Unlock()

-	log.Debugf("Initial encryption keys: %v", d.keys)

+	logrus.Debugf("Initial encryption keys: %v", d.keys)

 	return nil

 }

 // updateKeys allows to add a new key and/or change the primary key and/or prune an existing key

 // The primary key is the key used in transmission and will go in first position in the list.

 func (d *driver) updateKeys(newKey, primary, pruneKey *key) error {

-	log.Debugf("Updating Keys. New: %v, Primary: %v, Pruned: %v", newKey, primary, pruneKey)

+	logrus.Debugf("Updating Keys. New: %v, Primary: %v, Pruned: %v", newKey, primary, pruneKey)

-	log.Debugf("Current: %v", d.keys)

+	logrus.Debugf("Current: %v", d.keys)

 	var (

 		newIdx = -1

@@ -459,7 +459,7 @@ func (d *driver) updateKeys(newKey, primary, pruneKey *key) error {

 	}

 	d.Unlock()

-	log.Debugf("Updated: %v", d.keys)

+	logrus.Debugf("Updated: %v", d.keys)

 	return nil

 }

@@ -472,10 +472,10 @@ func (d *driver) updateKeys(newKey, primary, pruneKey *key) error {

 // Spis and keys are sorted in such away the one in position 0 is the primary

 func updateNodeKey(lIP, rIP net.IP, idxs []*spi, curKeys []*key, newIdx, priIdx, delIdx int) []*spi {

-	log.Debugf("Updating keys for node: %s (%d,%d,%d)", rIP, newIdx, priIdx, delIdx)

+	logrus.Debugf("Updating keys for node: %s (%d,%d,%d)", rIP, newIdx, priIdx, delIdx)

 	spis := idxs

-	log.Debugf("Current: %v", spis)

+	logrus.Debugf("Current: %v", spis)

 	// add new

 	if newIdx != -1 {

@@ -520,9 +520,9 @@ func updateNodeKey(lIP, rIP net.IP, idxs []*spi, curKeys []*key, newIdx, priIdx,

 				},

 			},

 		}

-		log.Debugf("Updating fSP{%s}", fSP1)

+		logrus.Debugf("Updating fSP{%s}", fSP1)

 		if err := ns.NlHandle().XfrmPolicyUpdate(fSP1); err != nil {

-			log.Warnf("Failed to update fSP{%s}: %v", fSP1, err)

+			logrus.Warnf("Failed to update fSP{%s}: %v", fSP1, err)

 		}

 		// -fSA1

@@ -543,7 +543,7 @@ func updateNodeKey(lIP, rIP net.IP, idxs []*spi, curKeys []*key, newIdx, priIdx,

 		spis = append(spis[:delIdx], spis[delIdx+1:]...)

 	}

-	log.Debugf("Updated: %v", spis)

+	logrus.Debugf("Updated: %v", spis)

 	return spis

 }

@@ -5,7 +5,7 @@ import (

 	"net"

 	"syscall"

-	log "github.com/Sirupsen/logrus"

+	"github.com/Sirupsen/logrus"

 	"github.com/docker/libnetwork/driverapi"

 	"github.com/docker/libnetwork/ns"

 	"github.com/docker/libnetwork/types"

@@ -109,7 +109,7 @@ func (d *driver) Join(nid, eid string, sboxKey string, jinfo driverapi.JoinInfo,

 			continue

 		}

 		if err := jinfo.AddStaticRoute(sub.subnetIP, types.NEXTHOP, s.gwIP.IP); err != nil {

-			log.Errorf("Adding subnet %s static route in network %q failed\n", s.subnetIP, n.id)

+			logrus.Errorf("Adding subnet %s static route in network %q failed\n", s.subnetIP, n.id)

 		}

 	}

@@ -124,7 +124,7 @@ func (d *driver) Join(nid, eid string, sboxKey string, jinfo driverapi.JoinInfo,

 		net.ParseIP(d.advertiseAddress), true)

 	if err := d.checkEncryption(nid, nil, n.vxlanID(s), true, true); err != nil {

-		log.Warn(err)

+		logrus.Warn(err)

 	}

 	buf, err := proto.Marshal(&PeerRecord{

@@ -137,7 +137,7 @@ func (d *driver) Join(nid, eid string, sboxKey string, jinfo driverapi.JoinInfo,

 	}

 	if err := jinfo.AddTableEntry(ovPeerTable, eid, buf); err != nil {

-		log.Errorf("overlay: Failed adding table entry to joininfo: %v", err)

+		logrus.Errorf("overlay: Failed adding table entry to joininfo: %v", err)

 	}

 	d.pushLocalEndpointEvent("join", nid, eid)

@@ -147,7 +147,7 @@ func (d *driver) Join(nid, eid string, sboxKey string, jinfo driverapi.JoinInfo,

 func (d *driver) EventNotify(etype driverapi.EventType, nid, tableName, key string, value []byte) {

 	if tableName != ovPeerTable {

-		log.Errorf("Unexpected table notification for table %s received", tableName)

+		logrus.Errorf("Unexpected table notification for table %s received", tableName)

 		return

 	}

@@ -155,7 +155,7 @@ func (d *driver) EventNotify(etype driverapi.EventType, nid, tableName, key stri

 	var peer PeerRecord

 	if err := proto.Unmarshal(value, &peer); err != nil {

-		log.Errorf("Failed to unmarshal peer record: %v", err)

+		logrus.Errorf("Failed to unmarshal peer record: %v", err)

 		return

 	}

@@ -167,19 +167,19 @@ func (d *driver) EventNotify(etype driverapi.EventType, nid, tableName, key stri

 	addr, err := types.ParseCIDR(peer.EndpointIP)

 	if err != nil {

-		log.Errorf("Invalid peer IP %s received in event notify", peer.EndpointIP)

+		logrus.Errorf("Invalid peer IP %s received in event notify", peer.EndpointIP)

 		return

 	}

 	mac, err := net.ParseMAC(peer.EndpointMAC)

 	if err != nil {

-		log.Errorf("Invalid mac %s received in event notify", peer.EndpointMAC)

+		logrus.Errorf("Invalid mac %s received in event notify", peer.EndpointMAC)

 		return

 	}

 	vtep := net.ParseIP(peer.TunnelEndpointIP)

 	if vtep == nil {

-		log.Errorf("Invalid VTEP %s received in event notify", peer.TunnelEndpointIP)

+		logrus.Errorf("Invalid VTEP %s received in event notify", peer.TunnelEndpointIP)

 		return

 	}

@@ -219,7 +219,7 @@ func (d *driver) Leave(nid, eid string) error {

 	n.leaveSandbox()

 	if err := d.checkEncryption(nid, nil, 0, true, false); err != nil {

-		log.Warn(err)

+		logrus.Warn(err)

 	}

 	return nil

@@ -5,7 +5,7 @@ import (

 	"fmt"

 	"net"

-	log "github.com/Sirupsen/logrus"

+	"github.com/Sirupsen/logrus"

 	"github.com/docker/libnetwork/datastore"

 	"github.com/docker/libnetwork/driverapi"

 	"github.com/docker/libnetwork/netutils"

@@ -116,7 +116,7 @@ func (d *driver) DeleteEndpoint(nid, eid string) error {

 	n.deleteEndpoint(eid)

 	if err := d.deleteEndpointFromStore(ep); err != nil {

-		log.Warnf("Failed to delete overlay endpoint %s from local store: %v", ep.id[0:7], err)

+		logrus.Warnf("Failed to delete overlay endpoint %s from local store: %v", ep.id[0:7], err)

 	}

 	if ep.ifName == "" {

@@ -125,11 +125,11 @@ func (d *driver) DeleteEndpoint(nid, eid string) error {

 	link, err := nlh.LinkByName(ep.ifName)

 	if err != nil {

-		log.Debugf("Failed to retrieve interface (%s)'s link on endpoint (%s) delete: %v", ep.ifName, ep.id, err)

+		logrus.Debugf("Failed to retrieve interface (%s)'s link on endpoint (%s) delete: %v", ep.ifName, ep.id, err)

 		return nil

 	}

 	if err := nlh.LinkDel(link); err != nil {

-		log.Debugf("Failed to delete interface (%s)'s link on endpoint (%s) delete: %v", ep.ifName, ep.id, err)

+		logrus.Debugf("Failed to delete interface (%s)'s link on endpoint (%s) delete: %v", ep.ifName, ep.id, err)

 	}

 	return nil

@@ -111,7 +111,7 @@ func Init(dc driverapi.DriverCallback, config map[string]interface{}) error {

 // Endpoints are stored in the local store. Restore them and reconstruct the overlay sandbox

 func (d *driver) restoreEndpoints() error {

 	if d.localStore == nil {

-		logrus.Warnf("Cannot restore overlay endpoints because local datastore is missing")

+		logrus.Warn("Cannot restore overlay endpoints because local datastore is missing")

 		return nil

 	}

 	kvol, err := d.localStore.List(datastore.Key(overlayEndpointPrefix), &endpoint{})

@@ -6,7 +6,7 @@ import (

 	"sync"

 	"syscall"

-	log "github.com/Sirupsen/logrus"

+	"github.com/Sirupsen/logrus"

 )

 const ovPeerTable = "overlay_peer_table"

@@ -90,7 +90,7 @@ func (d *driver) peerDbNetworkWalk(nid string, f func(*peerKey, *peerEntry) bool

 	for pKeyStr, pEntry := range pMap.mp {

 		var pKey peerKey

 		if _, err := fmt.Sscan(pKeyStr, &pKey); err != nil {

-			log.Warnf("Peer key scan on network %s failed: %v", nid, err)

+			logrus.Warnf("Peer key scan on network %s failed: %v", nid, err)

 		}

 		if f(&pKey, &pEntry) {

@@ -289,7 +289,7 @@ func (d *driver) peerAdd(nid, eid string, peerIP net.IP, peerIPMask net.IPMask,

 	}

 	if err := d.checkEncryption(nid, vtep, n.vxlanID(s), false, true); err != nil {

-		log.Warn(err)

+		logrus.Warn(err)

 	}

 	// Add neighbor entry for the peer IP

@@ -349,7 +349,7 @@ func (d *driver) peerDelete(nid, eid string, peerIP net.IP, peerIPMask net.IPMas

 	}

 	if err := d.checkEncryption(nid, vtep, 0, false, false); err != nil {

-		log.Warn(err)

+		logrus.Warn(err)

 	}

 	return nil

@@ -4,7 +4,7 @@ import (

 	"fmt"

 	"net"

-	log "github.com/Sirupsen/logrus"

+	"github.com/Sirupsen/logrus"

 	"github.com/docker/docker/pkg/plugins"

 	"github.com/docker/libnetwork/datastore"

 	"github.com/docker/libnetwork/discoverapi"

@@ -39,11 +39,11 @@ func Init(dc driverapi.DriverCallback, config map[string]interface{}) error {

 		d := newDriver(name, client)

 		c, err := d.(*driver).getCapabilities()

 		if err != nil {

-			log.Errorf("error getting capability for %s due to %v", name, err)

+			logrus.Errorf("error getting capability for %s due to %v", name, err)

 			return

 		}

 		if err = dc.RegisterDriver(name, d, *c); err != nil {

-			log.Errorf("error registering driver for %s due to %v", name, err)

+			logrus.Errorf("error registering driver for %s due to %v", name, err)

 		}

 	})

 	return nil

@@ -390,7 +390,7 @@ func bridgeSetup(config *networkConfiguration) error {

 			"/usr/bin/grep " + config.DefaultBindingIP.String()

 		out, err := exec.Command("/usr/bin/bash", "-c", ipadmCmd).Output()

 		if err != nil {

-			logrus.Warnf("cannot find binding interface")

+			logrus.Warn("cannot find binding interface")

 			return err

 		}

 		bindingIntf = strings.SplitN(string(out), "/", 2)[0]

@@ -456,21 +456,21 @@ func bridgeCleanup(config *networkConfiguration, logErr bool) {

 	err = exec.Command("/usr/sbin/pfctl", "-a", pfAnchor, "-F", "all").Run()

 	if err != nil && logErr {

-		logrus.Warnf("cannot flush firewall rules")

+		logrus.Warn("cannot flush firewall rules")

 	}

 	err = exec.Command("/usr/sbin/ifconfig", gwName, "unplumb").Run()

 	if err != nil && logErr {

-		logrus.Warnf("cannot remove gateway interface")

+		logrus.Warn("cannot remove gateway interface")

 	}

 	err = exec.Command("/usr/sbin/dladm", "delete-vnic",

 		"-t", gwName).Run()

 	if err != nil && logErr {

-		logrus.Warnf("cannot delete vnic")

+		logrus.Warn("cannot delete vnic")

 	}

 	err = exec.Command("/usr/sbin/dladm", "delete-etherstub",

 		"-t", config.BridgeNameInternal).Run()

 	if err != nil && logErr {

-		logrus.Warnf("cannot delete etherstub")

+		logrus.Warn("cannot delete etherstub")

 	}

 	err = exec.Command("/usr/sbin/pfctl", "-a", tableAnchor, "-t", tableName, "-T", "delete", gwIP).Run()

 	if err != nil && logErr {

@@ -36,7 +36,7 @@ func addPFRules(epid, bindIntf string, bs []types.PortBinding) {

 	f, err := os.OpenFile(fname,

 		os.O_CREATE|os.O_WRONLY|os.O_APPEND, 0600)

 	if err != nil {

-		logrus.Warnf("cannot open temp pf file")

+		logrus.Warn("cannot open temp pf file")

 		return

 	}

 	for _, b := range bs {

@@ -9,7 +9,7 @@ import (

 	"net"

 	"sync"

-	log "github.com/Sirupsen/logrus"

+	"github.com/Sirupsen/logrus"

 	"github.com/docker/libnetwork/types"

 )

@@ -71,7 +71,7 @@ func (e *encrMap) String() string {

 }

 func (d *driver) checkEncryption(nid string, rIP net.IP, vxlanID uint32, isLocal, add bool) error {

-	log.Debugf("checkEncryption(%s, %v, %d, %t)", nid[0:7], rIP, vxlanID, isLocal)

+	logrus.Debugf("checkEncryption(%s, %v, %d, %t)", nid[0:7], rIP, vxlanID, isLocal)

 	n := d.network(nid)

 	if n == nil || !n.secure {

@@ -94,7 +94,7 @@ func (d *driver) checkEncryption(nid string, rIP net.IP, vxlanID uint32, isLocal

 			}

 			return false

 		}); err != nil {

-			log.Warnf("Failed to retrieve list of participating nodes in overlay network %s: %v", nid[0:5], err)

+			logrus.Warnf("Failed to retrieve list of participating nodes in overlay network %s: %v", nid[0:5], err)

 		}

 	default:

 		if len(d.network(nid).endpoints) > 0 {

@@ -102,18 +102,18 @@ func (d *driver) checkEncryption(nid string, rIP net.IP, vxlanID uint32, isLocal

 		}

 	}

-	log.Debugf("List of nodes: %s", nodes)

+	logrus.Debugf("List of nodes: %s", nodes)

 	if add {

 		for _, rIP := range nodes {

 			if err := setupEncryption(lIP, aIP, rIP, vxlanID, d.secMap, d.keys); err != nil {

-				log.Warnf("Failed to program network encryption between %s and %s: %v", lIP, rIP, err)

+				logrus.Warnf("Failed to program network encryption between %s and %s: %v", lIP, rIP, err)

 			}

 		}

 	} else {

 		if len(nodes) == 0 {

 			if err := removeEncryption(lIP, rIP, d.secMap); err != nil {

-				log.Warnf("Failed to remove network encryption between %s and %s: %v", lIP, rIP, err)

+				logrus.Warnf("Failed to remove network encryption between %s and %s: %v", lIP, rIP, err)

 			}

 		}

 	}

@@ -122,14 +122,14 @@ func (d *driver) checkEncryption(nid string, rIP net.IP, vxlanID uint32, isLocal

 }

 func setupEncryption(localIP, advIP, remoteIP net.IP, vni uint32, em *encrMap, keys []*key) error {

-	log.Debugf("Programming encryption for vxlan %d between %s and %s", vni, localIP, remoteIP)

+	logrus.Debugf("Programming encryption for vxlan %d between %s and %s", vni, localIP, remoteIP)

 	rIPs := remoteIP.String()

 	indices := make([]*spi, 0, len(keys))

 	err := programMangle(vni, true)

 	if err != nil {

-		log.Warn(err)

+		logrus.Warn(err)

 	}

 	em.Lock()

@@ -177,16 +177,16 @@ func (d *driver) setKeys(keys []*key) error {

 		return types.ForbiddenErrorf("initial keys are already present")

 	}

 	d.keys = keys

-	log.Debugf("Initial encryption keys: %v", d.keys)

+	logrus.Debugf("Initial encryption keys: %v", d.keys)

 	return nil

 }

 // updateKeys allows to add a new key and/or change the primary key and/or prune an existing key

 // The primary key is the key used in transmission and will go in first position in the list.

 func (d *driver) updateKeys(newKey, primary, pruneKey *key) error {

-	log.Debugf("Updating Keys. New: %v, Primary: %v, Pruned: %v", newKey, primary, pruneKey)

+	logrus.Debugf("Updating Keys. New: %v, Primary: %v, Pruned: %v", newKey, primary, pruneKey)

-	log.Debugf("Current: %v", d.keys)

+	logrus.Debugf("Current: %v", d.keys)

 	var (

 		newIdx = -1

@@ -216,7 +216,7 @@ func (d *driver) updateKeys(newKey, primary, pruneKey *key) error {