unistack-org/micro
4
0
Fork 3
Code Issues 19 Pull Requests 1 Actions Packages Projects Releases 266 Wiki Activity

Add some comments

Browse Source
This commit is contained in:
Asim 2016-06-06 14:05:02 +01:00
parent 05596cfae4
commit 69aa8537d3
1 changed files with 15 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
transport/http_transport.go
View File

@ -410,14 +410,17 @@ func (h *httpTransport) Listen(addr string, opts ...ListenOption) (Listener, err
fn := func(addr string) (net.Listener, error) { fn := func(addr string) (net.Listener, error) {
if config == nil { if config == nil {
hosts := []string{addr} hosts := []string{addr}
if h, _, e := net.SplitHostPort(addr); e == nil {
if len(h) == 0 { // check if its a valid host:port
if host, _, err := net.SplitHostPort(addr); err == nil {
if len(host) == 0 {
hosts = getIPAddrs() hosts = getIPAddrs()
} else { } else {
hosts = []string{h} hosts = []string{host}
} }
} }
// generate a certificate
cert, err := mls.Certificate(hosts...) cert, err := mls.Certificate(hosts...)
if err != nil { if err != nil {
return nil, err return nil, err
@ -449,14 +452,6 @@ func (h *httpTransport) String() string {
return "http" return "http"
} }
func newHTTPTransport(opts ...Option) *httpTransport {
var options Options
for _, o := range opts {
o(&options)
}
return &httpTransport{opts: options}
}
func getIPAddrs() []string { func getIPAddrs() []string {
ifaces, err := net.Interfaces() ifaces, err := net.Interfaces()
if err != nil { if err != nil {
@ -492,5 +487,14 @@ func getIPAddrs() []string {
ipAddrs = append(ipAddrs, ip.String()) ipAddrs = append(ipAddrs, ip.String())
} }
} }
return ipAddrs return ipAddrs
} }
func newHTTPTransport(opts ...Option) *httpTransport {
var options Options
for _, o := range opts {
o(&options)
}
return &httpTransport{opts: options}
}