()
| 654 | } |
| 655 | |
| 656 | func (w *websocket) getMessages() []*tracer.WebsocketMessage { |
| 657 | w.mu.RLock() |
| 658 | defer w.mu.RUnlock() |
| 659 | return append([]*tracer.WebsocketMessage{}, w.msgs...) |
| 660 | } |
| 661 | |
| 662 | // readFull reads len(p) bytes from the client or server reader, enforcing a shared |
| 663 | // byte limit across both. Returns an error if the limit is exceeded. Safe for both |