Lines Matching refs:handler
28 bool BlobManager::registerHandler(std::unique_ptr<GenericBlobInterface> handler) in registerHandler() argument
30 if (!handler) in registerHandler()
35 handlers.push_back(std::move(handler)); in registerHandler()
69 GenericBlobInterface* handler = getHandler(path); in open() local
72 if (!handler) in open()
93 cleanUpStaleSessions(handler); in open()
95 if (!handler->open(*session, flags, path)) in open()
101 sessions[*session] = SessionInfo(path, handler, flags); in open()
102 openSessions[handler].insert(*session); in open()
110 GenericBlobInterface* handler = getHandler(path); in stat() local
113 if (!handler) in stat()
118 return handler->stat(path, meta); in stat()
123 if (auto handler = getActionHandler(session)) in stat() local
125 return handler->stat(session, meta); in stat()
132 if (auto handler = getActionHandler(session)) in commit() local
134 return handler->commit(session, data); in commit()
141 if (auto handler = getActionHandler(session)) in close() local
143 if (!handler->close(session)) in close()
147 eraseSession(handler, session); in close()
170 if (auto handler = getActionHandler(session, OpenFlags::read)) in read() local
172 return handler->read(session, offset, requestedSize); in read()
180 if (auto handler = getActionHandler(session, OpenFlags::write)) in write() local
182 return handler->write(session, offset, data); in write()
189 GenericBlobInterface* handler = getHandler(path); in deleteBlob() local
192 if (!handler) in deleteBlob()
204 return handler->deleteBlob(path); in deleteBlob()
210 if (auto handler = getActionHandler(session)) in writeMeta() local
212 return handler->writeMeta(session, offset, data); in writeMeta()
266 return item->second.handler; in getActionHandler()
271 void BlobManager::eraseSession(GenericBlobInterface* const handler, in eraseSession() argument
279 openSessions[handler].erase(session); in eraseSession()
291 void BlobManager::cleanUpStaleSessions(GenericBlobInterface* const handler) in cleanUpStaleSessions() argument
293 if (openSessions.count(handler) == 0) in cleanUpStaleSessions()
301 for (auto sessionId : openSessions[handler]) in cleanUpStaleSessions()
317 if (handler->expire(sessionId)) in cleanUpStaleSessions()
319 eraseSession(handler, sessionId); in cleanUpStaleSessions()