writer.go 2.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108
  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. for p := payload; len(p) > 0; {
  60. b := New()
  61. nBytes, _ := b.Write(p)
  62. p = p[nBytes:]
  63. mb.Append(b)
  64. }
  65. if err := w.writer.Write(mb); err != nil {
  66. return 0, err
  67. }
  68. return len(payload), nil
  69. }
  70. func (w *bytesToBufferWriter) WriteMultiBuffer(mb MultiBuffer) error {
  71. return w.writer.Write(mb)
  72. }
  73. func (w *bytesToBufferWriter) ReadFrom(reader io.Reader) (int64, error) {
  74. mbReader := NewReader(reader)
  75. totalBytes := int64(0)
  76. eof := false
  77. for !eof {
  78. mb, err := mbReader.Read()
  79. if err == io.EOF {
  80. eof = true
  81. } else if err != nil {
  82. return totalBytes, err
  83. }
  84. totalBytes += int64(mb.Len())
  85. if err := w.writer.Write(mb); err != nil {
  86. return totalBytes, err
  87. }
  88. }
  89. return totalBytes, nil
  90. }