writer.go 2.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114
  1. package buf
  2. import "io"
  3. // BufferToBytesWriter is a Writer that writes alloc.Buffer into underlying writer.
  4. type BufferToBytesWriter struct {
  5. writer io.Writer
  6. }
  7. // Write implements Writer.Write(). Write() takes ownership of the given buffer.
  8. func (w *BufferToBytesWriter) Write(mb MultiBuffer) error {
  9. defer mb.Release()
  10. bs := mb.ToNetBuffers()
  11. _, err := bs.WriteTo(w.writer)
  12. return err
  13. }
  14. type writerAdapter struct {
  15. writer MultiBufferWriter
  16. }
  17. // Write implements buf.MultiBufferWriter.
  18. func (w *writerAdapter) Write(mb MultiBuffer) error {
  19. return w.writer.WriteMultiBuffer(mb)
  20. }
  21. type mergingWriter struct {
  22. writer io.Writer
  23. buffer []byte
  24. }
  25. func (w *mergingWriter) Write(mb MultiBuffer) error {
  26. defer mb.Release()
  27. for !mb.IsEmpty() {
  28. nBytes, _ := mb.Read(w.buffer)
  29. if _, err := w.writer.Write(w.buffer[:nBytes]); err != nil {
  30. return err
  31. }
  32. }
  33. return nil
  34. }
  35. type seqWriter struct {
  36. writer io.Writer
  37. }
  38. func (w *seqWriter) Write(mb MultiBuffer) error {
  39. defer mb.Release()
  40. for _, b := range mb {
  41. if b.IsEmpty() {
  42. continue
  43. }
  44. if _, err := w.writer.Write(b.Bytes()); err != nil {
  45. return err
  46. }
  47. }
  48. return nil
  49. }
  50. var (
  51. _ MultiBufferWriter = (*bytesToBufferWriter)(nil)
  52. )
  53. type bytesToBufferWriter struct {
  54. writer Writer
  55. }
  56. // Write implements io.Writer.
  57. func (w *bytesToBufferWriter) Write(payload []byte) (int, error) {
  58. mb := NewMultiBuffer()
  59. mb.Write(payload)
  60. if err := w.writer.Write(mb); err != nil {
  61. return 0, err
  62. }
  63. return len(payload), nil
  64. }
  65. func (w *bytesToBufferWriter) WriteMultiBuffer(mb MultiBuffer) error {
  66. return w.writer.Write(mb)
  67. }
  68. func (w *bytesToBufferWriter) ReadFrom(reader io.Reader) (int64, error) {
  69. mbReader := NewReader(reader)
  70. totalBytes := int64(0)
  71. eof := false
  72. for !eof {
  73. mb, err := mbReader.Read()
  74. if err == io.EOF {
  75. eof = true
  76. } else if err != nil {
  77. return totalBytes, err
  78. }
  79. totalBytes += int64(mb.Len())
  80. if err := w.writer.Write(mb); err != nil {
  81. return totalBytes, err
  82. }
  83. }
  84. return totalBytes, nil
  85. }
  86. type noOpWriter struct{}
  87. func (noOpWriter) Write(b MultiBuffer) error {
  88. b.Release()
  89. return nil
  90. }
  91. var (
  92. Discard Writer = noOpWriter{}
  93. )