Lines Matching refs:buffer

32 bool HandleLookUp(FuseAppLoop* loop, FuseBuffer* buffer, FuseAppLoopCallback* callback) {  in HandleLookUp()  argument
35 if (buffer->request.header.nodeid != FUSE_ROOT_ID) { in HandleLookUp()
37 return loop->ReplySimple(buffer->request.header.unique, -ENOENT); in HandleLookUp()
41 const size_t filename_length = buffer->request.header.len - sizeof(fuse_in_header); in HandleLookUp()
42 if (buffer->request.lookup_name[filename_length - 1] != 0) { in HandleLookUp()
44 return loop->ReplySimple(buffer->request.header.unique, -ENOENT); in HandleLookUp()
47 const uint64_t inode = static_cast<uint64_t>(atol(buffer->request.lookup_name)); in HandleLookUp()
50 return loop->ReplySimple(buffer->request.header.unique, -ENOENT); in HandleLookUp()
53 callback->OnLookup(buffer->request.header.unique, inode); in HandleLookUp()
57 bool HandleGetAttr(FuseAppLoop* loop, FuseBuffer* buffer, FuseAppLoopCallback* callback) { in HandleGetAttr() argument
58 if (buffer->request.header.nodeid == FUSE_ROOT_ID) { in HandleGetAttr()
59 return loop->ReplyGetAttr(buffer->request.header.unique, buffer->request.header.nodeid, 0, in HandleGetAttr()
62 callback->OnGetAttr(buffer->request.header.unique, buffer->request.header.nodeid); in HandleGetAttr()
67 bool HandleRead(FuseAppLoop* loop, FuseBuffer* buffer, FuseAppLoopCallback* callback) { in HandleRead() argument
68 if (buffer->request.read_in.size > kFuseMaxRead) { in HandleRead()
69 return loop->ReplySimple(buffer->request.header.unique, -EINVAL); in HandleRead()
72 callback->OnRead(buffer->request.header.unique, buffer->request.header.nodeid, in HandleRead()
73 buffer->request.read_in.offset, buffer->request.read_in.size); in HandleRead()
77 bool HandleWrite(FuseAppLoop* loop, FuseBuffer* buffer, FuseAppLoopCallback* callback) { in HandleWrite() argument
78 if (buffer->request.write_in.size > kFuseMaxWrite) { in HandleWrite()
79 return loop->ReplySimple(buffer->request.header.unique, -EINVAL); in HandleWrite()
82 callback->OnWrite(buffer->request.header.unique, buffer->request.header.nodeid, in HandleWrite()
83 buffer->request.write_in.offset, buffer->request.write_in.size, in HandleWrite()
84 buffer->request.write_data); in HandleWrite()
88 bool HandleMessage(FuseAppLoop* loop, FuseBuffer* buffer, int fd, FuseAppLoopCallback* callback) { in HandleMessage() argument
89 if (!buffer->request.Read(fd)) { in HandleMessage()
93 const uint32_t opcode = buffer->request.header.opcode; in HandleMessage()
101 return HandleLookUp(loop, buffer, callback); in HandleMessage()
104 return HandleGetAttr(loop, buffer, callback); in HandleMessage()
107 callback->OnOpen(buffer->request.header.unique, buffer->request.header.nodeid); in HandleMessage()
111 return HandleRead(loop, buffer, callback); in HandleMessage()
114 return HandleWrite(loop, buffer, callback); in HandleMessage()
117 callback->OnRelease(buffer->request.header.unique, buffer->request.header.nodeid); in HandleMessage()
121 callback->OnFsync(buffer->request.header.unique, buffer->request.header.nodeid); in HandleMessage()
125 buffer->HandleNotImpl(); in HandleMessage()
126 return buffer->response.Write(fd); in HandleMessage()
226 FuseBuffer buffer; in Start() local
239 if (!HandleMessage(this, &buffer, fd_, callback)) { in Start()