go fmt
This commit is contained in:
parent
ccbb109d05
commit
6aef114372
|
@ -316,7 +316,7 @@ func (d *ESX5Driver) checkGuestIPHackEnabled() error {
|
|||
if record["IntValue"] != "1" {
|
||||
return errors.New(
|
||||
"GuestIPHack is required, enable by running this on the ESX machine:\n" +
|
||||
"esxcli system settings advanced set -o /Net/GuestIPHack -i 1")
|
||||
"esxcli system settings advanced set -o /Net/GuestIPHack -i 1")
|
||||
}
|
||||
|
||||
return nil
|
||||
|
|
|
@ -9,7 +9,7 @@ import (
|
|||
// over an RPC connection.
|
||||
type build struct {
|
||||
client *rpc.Client
|
||||
mux *MuxConn
|
||||
mux *MuxConn
|
||||
}
|
||||
|
||||
// BuildServer wraps a packer.Build implementation and makes it exportable
|
||||
|
|
|
@ -10,14 +10,14 @@ import (
|
|||
// over an RPC connection.
|
||||
type builder struct {
|
||||
client *rpc.Client
|
||||
mux *MuxConn
|
||||
mux *MuxConn
|
||||
}
|
||||
|
||||
// BuilderServer wraps a packer.Builder implementation and makes it exportable
|
||||
// as part of a Golang RPC server.
|
||||
type BuilderServer struct {
|
||||
builder packer.Builder
|
||||
mux *MuxConn
|
||||
mux *MuxConn
|
||||
}
|
||||
|
||||
type BuilderPrepareArgs struct {
|
||||
|
|
|
@ -9,19 +9,19 @@ import (
|
|||
// command is actually executed over an RPC connection.
|
||||
type command struct {
|
||||
client *rpc.Client
|
||||
mux *MuxConn
|
||||
mux *MuxConn
|
||||
}
|
||||
|
||||
// A CommandServer wraps a packer.Command and makes it exportable as part
|
||||
// of a Golang RPC server.
|
||||
type CommandServer struct {
|
||||
command packer.Command
|
||||
mux *MuxConn
|
||||
mux *MuxConn
|
||||
}
|
||||
|
||||
type CommandRunArgs struct {
|
||||
Args []string
|
||||
StreamId uint32
|
||||
Args []string
|
||||
StreamId uint32
|
||||
}
|
||||
|
||||
type CommandSynopsisArgs byte
|
||||
|
@ -42,7 +42,7 @@ func (c *command) Run(env packer.Environment, args []string) (result int) {
|
|||
go server.Serve()
|
||||
|
||||
rpcArgs := &CommandRunArgs{
|
||||
Args: args,
|
||||
Args: args,
|
||||
StreamId: nextId,
|
||||
}
|
||||
err := c.client.Call("Command.Run", rpcArgs, &result)
|
||||
|
|
|
@ -147,7 +147,7 @@ func (c *communicator) Download(path string, w io.Writer) (err error) {
|
|||
return
|
||||
}
|
||||
|
||||
func (c *CommunicatorServer) Start(args *CommunicatorStartArgs, reply *interface{}) (error) {
|
||||
func (c *CommunicatorServer) Start(args *CommunicatorStartArgs, reply *interface{}) error {
|
||||
// Build the RemoteCmd on this side so that it all pipes over
|
||||
// to the remote side.
|
||||
var cmd packer.RemoteCmd
|
||||
|
@ -197,7 +197,6 @@ func (c *CommunicatorServer) Start(args *CommunicatorStartArgs, reply *interface
|
|||
cmd.Stderr = conn
|
||||
}
|
||||
|
||||
|
||||
// Connect to the response address so we can write our result to it
|
||||
// when ready.
|
||||
responseC, err := c.mux.Dial(args.ResponseStreamId)
|
||||
|
|
|
@ -13,7 +13,7 @@ var endpointId uint64
|
|||
|
||||
const (
|
||||
DefaultArtifactEndpoint string = "Artifact"
|
||||
DefaultBuildEndpoint = "Build"
|
||||
DefaultBuildEndpoint = "Build"
|
||||
DefaultBuilderEndpoint = "Builder"
|
||||
DefaultCacheEndpoint = "Cache"
|
||||
DefaultCommandEndpoint = "Command"
|
||||
|
|
Loading…
Reference in New Issue