LogDog: Add Butler stream server package.

client/internal/logdog/butler/streamserver/npipe_windows.go

+// Copyright 2015 The Chromium Authors. All rights reserved.
+// Use of this source code is governed by a BSD-style license that can be
+// found in the LICENSE file.
+
+package streamserver
+
+import (
+        "fmt"
+        "net"
+
+        log "github.com/luci/luci-go/common/logging"
+        "golang.org/x/net/context"
+        "gopkg.in/natefinch/npipe.v2"
+)
+
+type namedPipeServer struct {
+        namedPipeServerBase
+
+        address string // The address of the Windows socket to create
+}
+
+// NewNamedPipeServer instantiates a new POSIX named pipe server instance.

[iannucci, 2015/11/12 22:44:24]

POSIX?

[dnj, 2015/11/13 20:17:15]

Done.

+func NewNamedPipeServer(ctx context.Context, address string) StreamServer {
+        s := &namedPipeServer{
+                address: address,
+        }
+        ctx = log.SetField(ctx, "address", address)
+        s.initBase(ctx)
+        return s
+}
+
+func (s *namedPipeServer) String() string {
+        return fmt.Sprintf("NamedPipeServer[%s]", s.address)

[iannucci, 2015/11/12 22:44:24]

we should distinguish these String()'s by something other than the capitalized
first letter :)

Also why the String() / GoString() disparity?

[dnj, 2015/11/13 20:17:15]

This was before logging, so I remove this altogether now.

+}
+
+// Wrapper around the "unix"-type Listener that cleans up the named pipe on
+// creation and 'Close()'
+type selfCleaningUNIXListener struct {
+        path     string
+        listener net.Listener
+}
+
+// OS-specific override to create a UNIX named socket listener
+func (s *namedPipeServer) createListener() (net.Listener, error) {
+        log.Debugf(s.ctx, "Creating Windows server socket Listener.")
+        return npipe.Listen(s.address)
+}