Fix stdin handling in engine.Sender and engine.Receiver

This introduces a superficial change to the Beam API:

* `beam.SendPipe` is renamed to the more accurate `beam.SendRPipe`
* `beam.SendWPipe` is introduced as a mirror to `SendRPipe`

There is no other change in the beam API.

Docker-DCO-1.1-Signed-off-by: Solomon Hykes <solomon@docker.com> (github: shykes)
This commit is contained in:
Solomon Hykes 2014-05-09 15:39:55 -07:00
parent 78848a31a5
commit c2a237f019
4 changed files with 40 additions and 9 deletions

View file

@ -29,17 +29,48 @@ type ReceiveSender interface {
Sender Sender
} }
func SendPipe(dst Sender, data []byte) (*os.File, error) { const (
R int = 1 << (32 - 1 - iota)
W
)
func sendPipe(dst Sender, data []byte, mode int) (*os.File, error) {
r, w, err := os.Pipe() r, w, err := os.Pipe()
if err != nil { if err != nil {
return nil, err return nil, err
} }
if err := dst.Send(data, r); err != nil { var (
r.Close() remote *os.File
w.Close() local *os.File
)
if mode == R {
remote = r
local = w
} else if mode == W {
remote = w
local = r
}
if err := dst.Send(data, remote); err != nil {
local.Close()
remote.Close()
return nil, err return nil, err
} }
return w, nil return local, nil
}
// SendRPipe create a pipe and sends its *read* end attached in a beam message
// to `dst`, with `data` as the message payload.
// It returns the *write* end of the pipe, or an error.
func SendRPipe(dst Sender, data []byte) (*os.File, error) {
return sendPipe(dst, data, R)
}
// SendWPipe create a pipe and sends its *read* end attached in a beam message
// to `dst`, with `data` as the message payload.
// It returns the *write* end of the pipe, or an error.
func SendWPipe(dst Sender, data []byte) (*os.File, error) {
return sendPipe(dst, data, W)
} }
func SendConn(dst Sender, data []byte) (conn *UnixConn, err error) { func SendConn(dst Sender, data []byte) (conn *UnixConn, err error) {

View file

@ -257,12 +257,12 @@ func Handlers(sink beam.Sender) (*beam.UnixConn, error) {
if handler == nil { if handler == nil {
return return
} }
stdout, err := beam.SendPipe(conn, data.Empty().Set("cmd", "log", "stdout").Set("fromcmd", cmd...).Bytes()) stdout, err := beam.SendRPipe(conn, data.Empty().Set("cmd", "log", "stdout").Set("fromcmd", cmd...).Bytes())
if err != nil { if err != nil {
return return
} }
defer stdout.Close() defer stdout.Close()
stderr, err := beam.SendPipe(conn, data.Empty().Set("cmd", "log", "stderr").Set("fromcmd", cmd...).Bytes()) stderr, err := beam.SendRPipe(conn, data.Empty().Set("cmd", "log", "stderr").Set("fromcmd", cmd...).Bytes())
if err != nil { if err != nil {
return return
} }

View file

@ -272,7 +272,7 @@ func CmdPrint(args []string, stdout, stderr io.Writer, in beam.Receiver, out bea
} }
// Skip commands // Skip commands
if a != nil && data.Message(payload).Get("cmd") == nil { if a != nil && data.Message(payload).Get("cmd") == nil {
dup, err := beam.SendPipe(out, payload) dup, err := beam.SendRPipe(out, payload)
if err != nil { if err != nil {
a.Close() a.Close()
return return

View file

@ -78,7 +78,7 @@ func (route *Route) Tee(dst Sender) *Route {
return inner(payload, attachment) return inner(payload, attachment)
} }
// Setup the tee // Setup the tee
w, err := SendPipe(dst, payload) w, err := SendRPipe(dst, payload)
if err != nil { if err != nil {
return err return err
} }