98 static void fuse_reply(const fuse_data* fd, uint64_t unique, const void* data, size_t len) {  in fuse_reply()  argument
110   int res = writev(fd->ffd, vec, 2);  in fuse_reply()
116 static int handle_init(void* data, fuse_data* fd, const fuse_in_header* hdr) {  in handle_init()  argument
147   fuse_reply(fd, hdr->unique, &out, fuse_struct_size);  in handle_init()
152 static void fill_attr(fuse_attr* attr, const fuse_data* fd, uint64_t nodeid, uint64_t size,  in fill_attr()  argument
156   attr->uid = fd->uid;  in fill_attr()
157   attr->gid = fd->gid;  in fill_attr()
166 static int handle_getattr(void* /* data */, const fuse_data* fd, const fuse_in_header* hdr) {  in handle_getattr()  argument
171     fill_attr(&(out.attr), fd, hdr->nodeid, 4096, S_IFDIR | 0555);  in handle_getattr()
173     fill_attr(&(out.attr), fd, PACKAGE_FILE_ID, fd->file_size, S_IFREG | 0444);  in handle_getattr()
175     fill_attr(&(out.attr), fd, EXIT_FLAG_ID, 0, S_IFREG | 0);  in handle_getattr()
180   fuse_reply(fd, hdr->unique, &out, sizeof(out));  in handle_getattr()
184 static int handle_lookup(void* data, const fuse_data* fd, const fuse_in_header* hdr) {  in handle_lookup()  argument
195     fill_attr(&(out.attr), fd, PACKAGE_FILE_ID, fd->file_size, S_IFREG | 0444);  in handle_lookup()
199     fill_attr(&(out.attr), fd, EXIT_FLAG_ID, 0, S_IFREG | 0);  in handle_lookup()
204   fuse_reply(fd, hdr->unique, &out, sizeof(out));  in handle_lookup()
208 static int handle_open(void* /* data */, const fuse_data* fd, const fuse_in_header* hdr) {  in handle_open()  argument
214   fuse_reply(fd, hdr->unique, &out, sizeof(out));  in handle_open()
228 static int fetch_block(fuse_data* fd, uint32_t block) {  in fetch_block()  argument
229   if (block == fd->curr_block) {  in fetch_block()
233   if (block >= fd->file_blocks) {  in fetch_block()
234     memset(fd->block_data, 0, fd->block_size);  in fetch_block()
235     fd->curr_block = block;  in fetch_block()
239   uint32_t fetch_size = fd->block_size;  in fetch_block()
240   if (block * fd->block_size + fetch_size > fd->file_size) {  in fetch_block()
243     fetch_size = fd->file_size - (block * fd->block_size);  in fetch_block()
244     memset(fd->block_data + fetch_size, 0, fd->block_size - fetch_size);  in fetch_block()
247   if (!fd->provider->ReadBlockAlignedData(fd->block_data, fetch_size, block)) {  in fetch_block()
251   fd->curr_block = block;  in fetch_block()
261   SHA256(fd->block_data, fd->block_size, hash.data());  in fetch_block()
263   const SHA256Digest& blockhash = fd->hashes[block];  in fetch_block()
270       fd->curr_block = -1;  in fetch_block()
275   fd->hashes[block] = hash;  in fetch_block()
279 static int handle_read(void* data, fuse_data* fd, const fuse_in_header* hdr) {  in handle_read()  argument
303   uint32_t block = offset / fd->block_size;  in handle_read()
304   int result = fetch_block(fd, block);  in handle_read()
315   uint32_t block_offset = offset - (block * fd->block_size);  in handle_read()
318   if (size + block_offset <= fd->block_size) {  in handle_read()
321     vec[1].iov_base = fd->block_data + block_offset;  in handle_read()
327     memcpy(fd->extra_block, fd->block_data + block_offset, fd->block_size - block_offset);  in handle_read()
328     vec[1].iov_base = fd->extra_block;  in handle_read()
329     vec[1].iov_len = fd->block_size - block_offset;  in handle_read()
331     result = fetch_block(fd, block + 1);  in handle_read()
333     vec[2].iov_base = fd->block_data;  in handle_read()
338   if (writev(fd->ffd, vec, vec_used) == -1) {  in handle_read()
362   fuse_data fd = {};  in run_fuse_sideload()  local
363   fd.provider = provider.get();  in run_fuse_sideload()
364   fd.file_size = file_size;  in run_fuse_sideload()
365   fd.block_size = block_size;  in run_fuse_sideload()
366   fd.file_blocks = (file_size == 0) ? 0 : (((file_size - 1) / block_size) + 1);  in run_fuse_sideload()
369   if (fd.file_blocks > (1 << 18)) {  in run_fuse_sideload()
370     fprintf(stderr, "file has too many blocks (%u)\n", fd.file_blocks);  in run_fuse_sideload()
376   fd.hashes.resize(fd.file_blocks);  in run_fuse_sideload()
377   fd.uid = getuid();  in run_fuse_sideload()
378   fd.gid = getgid();  in run_fuse_sideload()
380   fd.curr_block = -1;  in run_fuse_sideload()
381   fd.block_data = static_cast<uint8_t*>(malloc(block_size));  in run_fuse_sideload()
382   if (fd.block_data == nullptr) {  in run_fuse_sideload()
387   fd.extra_block = static_cast<uint8_t*>(malloc(block_size));  in run_fuse_sideload()
388   if (fd.extra_block == nullptr) {  in run_fuse_sideload()
394   fd.ffd.reset(open("/dev/fuse", O_RDWR));  in run_fuse_sideload()
395   if (fd.ffd == -1) {  in run_fuse_sideload()
403         "fd=%d,user_id=%d,group_id=%d,max_read=%u,allow_other,rootmode=040000", fd.ffd.get(),  in run_fuse_sideload()
404         fd.uid, fd.gid, block_size);  in run_fuse_sideload()
416     ssize_t len = TEMP_FAILURE_RETRY(read(fd.ffd, request_buffer, sizeof(request_buffer)));  in run_fuse_sideload()
438         result = handle_init(data, &fd, hdr);  in run_fuse_sideload()
442         result = handle_lookup(data, &fd, hdr);  in run_fuse_sideload()
446         result = handle_getattr(data, &fd, hdr);  in run_fuse_sideload()
450         result = handle_open(data, &fd, hdr);  in run_fuse_sideload()
454         result = handle_read(data, &fd, hdr);  in run_fuse_sideload()
458         result = handle_flush(data, &fd, hdr);  in run_fuse_sideload()
462         result = handle_release(data, &fd, hdr);  in run_fuse_sideload()
480       TEMP_FAILURE_RETRY(write(fd.ffd, &outhdr, sizeof(outhdr)));  in run_fuse_sideload()
491   free(fd.block_data);  in run_fuse_sideload()
492   free(fd.extra_block);  in run_fuse_sideload()