bugfix: bind an address for stream server

Signed-off-by: YaoZengzeng <yaozengzeng@zju.edu.cn>

cri/v1alpha1/cri_stream.go

@@ -13,11 +13,19 @@ import (
 	apitypes "github.com/alibaba/pouch/apis/types"
 	"github.com/alibaba/pouch/cri/stream/remotecommand"
 	"github.com/alibaba/pouch/daemon/mgr"
+	pouchnet "github.com/alibaba/pouch/pkg/net"
 
 	"github.com/sirupsen/logrus"
 )
 
 func newStreamServer(ctrMgr mgr.ContainerMgr, address string, port string) (Server, error) {
+	if address == "" {
+		a, err := pouchnet.ChooseBindAddress(nil)
+		if err != nil {
+			return nil, fmt.Errorf("failed to get stream server address: %v", err)
+		}
+		address = a.String()
+	}
 	config := DefaultConfig
 	config.Address = net.JoinHostPort(address, port)
 	runtime := newStreamRuntime(ctrMgr)

cri/v1alpha2/cri_stream.go

@@ -13,11 +13,19 @@ import (
 	apitypes "github.com/alibaba/pouch/apis/types"
 	"github.com/alibaba/pouch/cri/stream/remotecommand"
 	"github.com/alibaba/pouch/daemon/mgr"
+	pouchnet "github.com/alibaba/pouch/pkg/net"
 
 	"github.com/sirupsen/logrus"
 )
 
 func newStreamServer(ctrMgr mgr.ContainerMgr, address string, port string) (Server, error) {
+	if address == "" {
+		a, err := pouchnet.ChooseBindAddress(nil)
+		if err != nil {
+			return nil, fmt.Errorf("failed to get stream server address: %v", err)
+		}
+		address = a.String()
+	}
 	config := DefaultConfig
 	config.Address = net.JoinHostPort(address, port)
 	runtime := newStreamRuntime(ctrMgr)

pkg/net/doc.go

@@ -0,0 +1,5 @@
+package net
+
+// NOTE: The code in this package is directly copy from package "k8s.io/apimachinery/pkg/util/net".
+// We do this because we don't want to vendor too many irrelevant packages and try to make
+// the code simple and clean :)