| 639 | } |
| 640 | |
| 641 | func (ws *Websocket) setWriteDeadline(opChain *chain) bool { |
| 642 | deadline := infiniteTime |
| 643 | if ws.writeTimeout != noDuration { |
| 644 | deadline = time.Now().Add(ws.writeTimeout) |
| 645 | } |
| 646 | |
| 647 | if err := ws.conn.SetWriteDeadline(deadline); err != nil { |
| 648 | opChain.fail(AssertionFailure{ |
| 649 | Type: AssertOperation, |
| 650 | Errors: []error{ |
| 651 | errors.New("failed to set write deadline for websocket"), |
| 652 | err, |
| 653 | }, |
| 654 | }) |
| 655 | return false |
| 656 | } |
| 657 | |
| 658 | return true |
| 659 | } |
| 660 | |
| 661 | func (ws *Websocket) printRead(typ int, content []byte, closeCode int) { |
| 662 | for _, printer := range ws.config.Printers { |