MCPcopy Create free account
hub / github.com/baidu/BaikalDB / AfsFileCtrl

Class AfsFileCtrl

include/engine/external_filesystem.h:314–330  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

312};
313#ifdef ENABLE_OPEN_AFS_ASYNC
314class AfsFileCtrl {
315public:
316 AfsFileCtrl(uint32_t afs_cnt): _afs_cnt(afs_cnt), _success_ret(false) {}
317
318 // 解锁,设置success_
319 void action_finish(int64_t ret);
320
321 int64_t wait_onesucc_or_allfail();
322
323private:
324 std::condition_variable _cv;
325 std::mutex _mutex;
326 const uint32_t _afs_cnt;
327 bool _succeeded = false;
328 uint32_t _fail_cnt = 0;
329 int64_t _success_ret = -1;
330};
331
332struct OpenReaderInfo {
333 std::shared_ptr<AfsFileCtrl> reader_ctrl;

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected