Commit 84541c67 authored by Mitchell Hashimoto's avatar Mitchell Hashimoto

packer/rpc: get rid of trace level

parent e37e690e
...@@ -100,7 +100,7 @@ func (m *MuxConn) Close() error { ...@@ -100,7 +100,7 @@ func (m *MuxConn) Close() error {
// Accept accepts a multiplexed connection with the given ID. This // Accept accepts a multiplexed connection with the given ID. This
// will block until a request is made to connect. // will block until a request is made to connect.
func (m *MuxConn) Accept(id uint32) (io.ReadWriteCloser, error) { func (m *MuxConn) Accept(id uint32) (io.ReadWriteCloser, error) {
log.Printf("[TRACE] %p: Accept on stream ID: %d", m, id) //log.Printf("[TRACE] %p: Accept on stream ID: %d", m, id)
// Get the stream. It is okay if it is already in the list of streams // Get the stream. It is okay if it is already in the list of streams
// because we may have prematurely received a syn for it. // because we may have prematurely received a syn for it.
...@@ -146,7 +146,7 @@ func (m *MuxConn) Accept(id uint32) (io.ReadWriteCloser, error) { ...@@ -146,7 +146,7 @@ func (m *MuxConn) Accept(id uint32) (io.ReadWriteCloser, error) {
// Dial opens a connection to the remote end using the given stream ID. // Dial opens a connection to the remote end using the given stream ID.
// An Accept on the remote end will only work with if the IDs match. // An Accept on the remote end will only work with if the IDs match.
func (m *MuxConn) Dial(id uint32) (io.ReadWriteCloser, error) { func (m *MuxConn) Dial(id uint32) (io.ReadWriteCloser, error) {
log.Printf("[TRACE] %p: Dial on stream ID: %d", m, id) //log.Printf("[TRACE] %p: Dial on stream ID: %d", m, id)
m.muDial.Lock() m.muDial.Lock()
...@@ -293,9 +293,6 @@ func (m *MuxConn) loop() { ...@@ -293,9 +293,6 @@ func (m *MuxConn) loop() {
return return
} else { } else {
n += n2 n += n2
if n < int(length) {
log.Printf("[TRACE] %p: Stream %d read %d/%d bytes", m, id, n, length)
}
} }
} }
...@@ -330,7 +327,7 @@ func (m *MuxConn) loop() { ...@@ -330,7 +327,7 @@ func (m *MuxConn) loop() {
continue continue
} }
log.Printf("[TRACE] %p: Stream %d (%s) received packet %d", m, id, from, packetType) //log.Printf("[TRACE] %p: Stream %d (%s) received packet %d", m, id, from, packetType)
switch packetType { switch packetType {
case muxPacketSyn: case muxPacketSyn:
// If the stream is nil, this is the only case where we'll // If the stream is nil, this is the only case where we'll
...@@ -450,9 +447,6 @@ func (m *MuxConn) write(from muxPacketFrom, id uint32, dataType muxPacketType, p ...@@ -450,9 +447,6 @@ func (m *MuxConn) write(from muxPacketFrom, id uint32, dataType muxPacketType, p
var n2 int var n2 int
n2, err = m.rwc.Write(p) n2, err = m.rwc.Write(p)
n += n2 n += n2
if n < len(p) {
log.Printf("[TRACE] %p: Stream %d (%s) write %d/%d bytes", m, id, from, n, len(p))
}
if err != nil { if err != nil {
log.Printf("[ERR] %p: Stream %d (%s) write error: %s", m, id, from, err) log.Printf("[ERR] %p: Stream %d (%s) write error: %s", m, id, from, err)
break break
...@@ -568,7 +562,7 @@ func (s *Stream) closeWriter() { ...@@ -568,7 +562,7 @@ func (s *Stream) closeWriter() {
} }
func (s *Stream) setState(state streamState) { func (s *Stream) setState(state streamState) {
log.Printf("[TRACE] %p: Stream %d (%s) went to state %d", s.mux, s.id, s.from, state) //log.Printf("[TRACE] %p: Stream %d (%s) went to state %d", s.mux, s.id, s.from, state)
s.state = state s.state = state
s.stateUpdated = time.Now().UTC() s.stateUpdated = time.Now().UTC()
for ch, _ := range s.stateChange { for ch, _ := range s.stateChange {
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment