Partially implemented sendReply.
parent
4a2eeda4ca
commit
b6ae9475ba
|
@ -15,7 +15,6 @@
|
||||||
package fuse
|
package fuse
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"errors"
|
|
||||||
"fmt"
|
"fmt"
|
||||||
"log"
|
"log"
|
||||||
"path"
|
"path"
|
||||||
|
@ -236,13 +235,17 @@ func (c *Connection) ReadOp() (op fuseops.Op, err error) {
|
||||||
|
|
||||||
sendReply := func(
|
sendReply := func(
|
||||||
fuseID uint64,
|
fuseID uint64,
|
||||||
msg []byte,
|
replyMsg []byte,
|
||||||
opErr error) (err error) {
|
opErr error) (err error) {
|
||||||
// TODO(jacobsa): Turn this into a method and maybe kill the fuseID
|
// Clean up state for this op.
|
||||||
// parameter.
|
c.finishOp(m.Hdr.Opcode, m.Hdr.Unique)
|
||||||
//
|
|
||||||
// TODO(jacobsa): Don't forget to destroy the message.
|
// Send the reply to the kernel.
|
||||||
err = errors.New("TODO")
|
panic("TODO")
|
||||||
|
|
||||||
|
// Destroy the message, as required by fuseshim.Connection.ReadMessage.
|
||||||
|
m.Destroy()
|
||||||
|
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue