mirror of
https://github.com/trapexit/mergerfs.git
synced 2026-10-20 00:17:43 +00:00
Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
c06db9c3a0 | ||
|
|
bcd5fde5d8 | ||
|
|
ed0c1db3a8 |
@@ -79,8 +79,8 @@ fuse_do_work(void *data)
|
||||
struct fuse_buf fbuf;
|
||||
struct fuse_chan *ch = mt->prevch;
|
||||
|
||||
fbuf.mem = w->buf;
|
||||
fbuf.size = w->bufsize;
|
||||
fbuf = (struct fuse_buf){ .mem = w->buf,
|
||||
.size = w->bufsize };
|
||||
|
||||
pthread_setcancelstate(PTHREAD_CANCEL_ENABLE, NULL);
|
||||
res = fuse_session_receive_buf(mt->se, &fbuf, &ch);
|
||||
|
||||
+3
-1
@@ -119,7 +119,9 @@ namespace l
|
||||
{
|
||||
uint64_t offset;
|
||||
|
||||
offset = s_.find_first_of('/');
|
||||
offset = s_.find_first_not_of("+<>-=");
|
||||
if(offset > 1)
|
||||
offset = 2;
|
||||
*instr_ = s_.substr(0,offset);
|
||||
if(offset != std::string::npos)
|
||||
*values_ = s_.substr(offset);
|
||||
|
||||
@@ -204,6 +204,9 @@ namespace eppfrd
|
||||
uint64_t idx;
|
||||
uint64_t threshold;
|
||||
|
||||
if(sum_ == 0)
|
||||
return NULL;
|
||||
|
||||
idx = 0;
|
||||
threshold = RND::rand64(sum_);
|
||||
for(size_t i = 0; i < branchinfo_.size(); i++)
|
||||
|
||||
@@ -130,6 +130,9 @@ namespace msppfrd
|
||||
uint64_t idx;
|
||||
uint64_t threshold;
|
||||
|
||||
if(sum_ == 0)
|
||||
return NULL;
|
||||
|
||||
idx = 0;
|
||||
threshold = RND::rand64(sum_);
|
||||
for(size_t i = 0; i < branchinfo_.size(); i++)
|
||||
|
||||
@@ -98,6 +98,9 @@ namespace pfrd
|
||||
uint64_t idx;
|
||||
uint64_t threshold;
|
||||
|
||||
if(sum_ == 0)
|
||||
return NULL;
|
||||
|
||||
idx = 0;
|
||||
threshold = RND::rand64(sum_);
|
||||
for(size_t i = 0; i < branchinfo_.size(); i++)
|
||||
|
||||
Reference in New Issue
Block a user