Lines Matching refs:flow
37 type flow struct {
49 flows []flow
61 r.flows = append(r.flows, flow{flowType, message, buf})
91 for i, flow := range r.flows {
92 switch flow.flowType {
94 fmt.Fprintf(w, ">>> Flow %d (%s to %s)\n", i+1, r.peer, r.local)
96 fmt.Fprintf(w, ">>> Flow %d (%s to %s)\n", i+1, r.local, r.peer)
98 fmt.Fprintf(w, ">>> Flow %d %q\n", i+1, flow.message)
101 if flow.data != nil {
103 dumper.Write(flow.data)
111 for _, flow := range r.flows {
112 if flow.flowType != writeFlow {
117 ret = append(ret, byte(len(flow.data)>>16), byte(len(flow.data)>>8), byte(len(flow.data)))
119 ret = append(ret, flow.data...)
131 // of a new flow.
