Also reuse input buffers.

fuse/fuse.go

@@ -215,7 +215,7 @@ func (self *MountState) syncWrite(packet [][]byte) {
 func (self *MountState) loop() {
 	// See fuse_kern_chan_receive()
 	for {
-		buf := make([]byte, bufSize)
+		buf := self.buffers.GetBuffer(bufSize)
 		n, err := self.mountFile.Read(buf)
 		if err != nil {
 			errNo := OsErrorToFuseError(err)
@@ -262,6 +262,7 @@ func (self *MountState) handle(in_data []byte) {
 		return
 	}
 	self.Write(dispatch(self, header, r))
+	self.buffers.addBuffer(in_data)
 }