Commit db277f66 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 77ffd1bf
......@@ -325,9 +325,7 @@ func NewFileSock() *FileSock {
func (sk *FileSock) File() nodefs.File {
// nonseekable & directio for opened file to have streaming semantic as
// if it was a socket. FOPEN_STREAM is used so that both read and write
// could be run simultaneously:
//
// git.kernel.org/linus/10dce8af3422
// could be run simultaneously: git.kernel.org/linus/10dce8af3422
return &nodefs.WithFlags{
File: sk.file,
FuseFlags: fuse.FOPEN_STREAM | fuse.FOPEN_NONSEEKABLE | fuse.FOPEN_DIRECT_IO,
......@@ -340,7 +338,6 @@ func (sk *FileSock) File() nodefs.File {
// The data will be read by client reading from filesock's file.
// Write semantic is that of xio.Writer.
func (sk *FileSock) Write(ctx context.Context, data []byte) (n int, err error) {
// XXX err ctx?
return sk.tx.Write(ctx, data)
}
......@@ -366,7 +363,6 @@ func (f *skFile) Read(dest []byte, /*ignored*/off int64, fctx *fuse.Context) (fu
// The data read will be that the client writes into filesock's file.
// Read semantic is that of xio.Reader.
func (sk *FileSock) Read(ctx context.Context, dest []byte) (n int, err error) {
// XXX err ctx?
return sk.rx.Read(ctx, dest)
}
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment