MirrorHub/construct
0
0
Fork 0
mirror of https://github.com/matrix-construct/construct synced 2024-11-19 00:10:59 +01:00
Code Issues Releases Wiki Activity

ircd::db: Disable AIO for fsync related for now.

Browse source
This commit is contained in:
Jason Volk 2018-11-29 10:19:45 -08:00
parent 58d80ddc53
commit 731c154b19
1 changed files with 24 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

30
ircd/db.cc
View file

@ -4432,7 +4432,10 @@ noexcept try
}; };
#endif #endif
fs::fdsync(fd); //TODO: AIO fdsync() throwing -EINVAL.
fs::fsync_opts opts;
opts.use_aio = false;
fs::fdsync(fd, opts);
return Status::OK(); return Status::OK();
} }
catch(const fs::error &e) catch(const fs::error &e)
@ -4478,7 +4481,10 @@ noexcept try
}; };
#endif #endif
fs::fdsync(fd); //TODO: AIO fdsync() throwing -EINVAL.
fs::fsync_opts opts;
opts.use_aio = false;
fs::fdsync(fd, opts);
return Status::OK(); return Status::OK();
} }
catch(const fs::error &e) catch(const fs::error &e)
@ -4522,7 +4528,10 @@ noexcept try
}; };
#endif #endif
fs::fsync(fd); //TODO: AIO fdsync() throwing -EINVAL.
fs::fsync_opts opts;
opts.use_aio = false;
fs::fsync(fd, opts);
return Status::OK(); return Status::OK();
} }
catch(const fs::error &e) catch(const fs::error &e)
@ -6595,7 +6604,10 @@ noexcept try
}; };
#endif #endif
fs::fsync(fd); //TODO: AIO fdsync() throwing -EINVAL.
fs::fsync_opts opts;
opts.use_aio = false;
fs::fsync(fd, opts);
return Status::OK(); return Status::OK();
} }
catch(const fs::error &e) catch(const fs::error &e)
@ -6641,7 +6653,10 @@ noexcept try
}; };
#endif #endif
fs::fdsync(fd); //TODO: AIO fdsync() throwing -EINVAL.
fs::fsync_opts opts;
opts.use_aio = false;
fs::fdsync(fd, opts);
return Status::OK(); return Status::OK();
} }
catch(const fs::error &e) catch(const fs::error &e)
@ -6687,7 +6702,10 @@ noexcept try
}; };
#endif #endif
fs::fdsync(fd); //TODO: AIO fdsync() throwing -EINVAL.
fs::fsync_opts opts;
opts.use_aio = false;
fs::fdsync(fd, opts);
return Status::OK(); return Status::OK();
} }
catch(const fs::error &e) catch(const fs::error &e)