From e0d989cba30a931ba1f7efb304ae267541ea2c48 Mon Sep 17 00:00:00 2001 From: Aaron Jacobs Date: Fri, 24 Jul 2015 14:52:54 +1000 Subject: [PATCH] InMessage.Header --- internal/buffer/in_message.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/internal/buffer/in_message.go b/internal/buffer/in_message.go index 2611f9d..c4a5107 100644 --- a/internal/buffer/in_message.go +++ b/internal/buffer/in_message.go @@ -43,7 +43,8 @@ const bufSize = pageSize + MaxWriteSize // struct. Provides storage for messages and convenient access to their // contents. type InMessage struct { - buf [bufSize]byte + remaining []byte + storage [bufSize]byte } // Initialize with the data read by a single call to r.Read. The first call to @@ -56,7 +57,8 @@ func (m *InMessage) Init(r io.Reader) (err error) { // Return a reference to the header read in the most recent call to Init. func (m *InMessage) Header() (h *fusekernel.InHeader) { - panic("TODO") + h = (*fusekernel.InHeader)(unsafe.Pointer(&m.storage[0])) + return } // Return the number of bytes left to consume.