Function handleTrace

core/ipc_handler.go:472–507

(n *Nylon, rw *bufio.ReadWriter)

}

func handleTrace(n *Nylon, rw *bufio.ReadWriter) error {
	if !n.DBG_trace_tc {
		if err := writeResponse(rw, errResponse("tracing not enabled; restart with --dbg-trace-tc")); err != nil {
			return err
		}
		return device.ErrIPCStatusHandled
	}
	// Send initial OK
	if err := writeResponse(rw, &protocol.IpcResponse{Ok: true}); err != nil {
		return err
	}
	ctx, cancel := context.WithCancel(context.Background())
	go func() {
		_, _ = rw.ReadByte() // wait for EOF / disconnect
		cancel()
	}()
	ch := make(chan interface{})
	n.Trace.Register(ch)
	defer n.Trace.Unregister(ch)
	for {
		select {
		case <-ctx.Done():
			return device.ErrIPCStatusHandled
		case msg := <-ch:
			if str, ok := msg.(string); ok {
				resp := &protocol.IpcResponse{
					Ok:       true,
					Response: &protocol.IpcResponse_Trace{Trace: &protocol.TraceEvent{Line: str}},
				}
				if err := writeResponse(rw, resp); err != nil {
					return device.ErrIPCStatusHandled
				}
			}
		}
	}
}