137 int32_t Accessor::Impl::sPid = getpid();
138 uint32_t Accessor::Impl::sSeqId = time(nullptr);
140 Accessor::Impl::Impl(  in Impl()
144 Accessor::Impl::~Impl() {  in ~Impl()
147 ResultStatus Accessor::Impl::connect(  in connect()
148         const sp<Accessor> &accessor, const sp<IObserver> &observer,  in connect()
178 ResultStatus Accessor::Impl::close(ConnectionId connectionId) {  in close()
191 ResultStatus Accessor::Impl::allocate(  in allocate()
217 ResultStatus Accessor::Impl::fetch(  in fetch()
242 void Accessor::Impl::cleanUp(bool clearCache) {  in cleanUp()
249 void Accessor::Impl::flush() {  in flush()
255 void Accessor::Impl::handleInvalidateAck() {  in handleInvalidateAck()
279 bool Accessor::Impl::isValid() {  in isValid()
283 Accessor::Impl::Impl::BufferPool::BufferPool()  in BufferPool()
299 std::atomic<std::uint32_t> Accessor::Impl::BufferPool::Invalidation::sInvSeqId(0);
301 Accessor::Impl::Impl::BufferPool::~BufferPool() {  in ~BufferPool()
314 void Accessor::Impl::BufferPool::Invalidation::onConnect(  in onConnect()
320 void Accessor::Impl::BufferPool::Invalidation::onClose(ConnectionId conId) {  in onClose()
325 void Accessor::Impl::BufferPool::Invalidation::onAck(  in onAck()
338 void Accessor::Impl::BufferPool::Invalidation::onBufferInvalidated(  in onBufferInvalidated()
359 void Accessor::Impl::BufferPool::Invalidation::onInvalidationRequest(  in onInvalidationRequest()
365         const std::shared_ptr<Accessor::Impl> &impl) {  in onInvalidationRequest()
386 void Accessor::Impl::BufferPool::Invalidation::onHandleAck(  in onHandleAck()
420 bool Accessor::Impl::BufferPool::handleOwnBuffer(  in handleOwnBuffer()
432 bool Accessor::Impl::BufferPool::handleReleaseBuffer(  in handleReleaseBuffer()
456 bool Accessor::Impl::BufferPool::handleTransferTo(const BufferStatusMessage &message) {  in handleTransferTo()
488 bool Accessor::Impl::BufferPool::handleTransferFrom(const BufferStatusMessage &message) {  in handleTransferFrom()
508 bool Accessor::Impl::BufferPool::handleTransferResult(const BufferStatusMessage &message) {  in handleTransferResult()
545 void Accessor::Impl::BufferPool::processStatusMessages() {  in processStatusMessages()
591 bool Accessor::Impl::BufferPool::handleClose(ConnectionId connectionId) {  in handleClose()
650 bool Accessor::Impl::BufferPool::getFreeBuffer(  in getFreeBuffer()
673 ResultStatus Accessor::Impl::BufferPool::addNewBuffer(  in addNewBuffer()
700 void Accessor::Impl::BufferPool::cleanUp(bool clearCache) {  in cleanUp()
732 void Accessor::Impl::BufferPool::invalidate(  in invalidate()
734         const std::shared_ptr<Accessor::Impl> &impl) {  in invalidate()
761 void Accessor::Impl::BufferPool::flush(const std::shared_ptr<Accessor::Impl> &impl) {  in flush()
772 void Accessor::Impl::invalidatorThread(  in invalidatorThread()
773             std::map<uint32_t, const std::weak_ptr<Accessor::Impl>> &accessors,  in invalidatorThread()
778         std::map<uint32_t, const std::weak_ptr<Accessor::Impl>> copied;  in invalidatorThread()
788             const std::shared_ptr<Accessor::Impl> impl = it->second.lock();  in invalidatorThread()
811 Accessor::Impl::AccessorInvalidator::AccessorInvalidator() : mReady(false) {  in AccessorInvalidator()
821 void Accessor::Impl::AccessorInvalidator::addAccessor(  in addAccessor()
822         uint32_t accessorId, const std::weak_ptr<Accessor::Impl> &impl) {  in addAccessor()
839 void Accessor::Impl::AccessorInvalidator::delAccessor(uint32_t accessorId) {  in delAccessor()
848 std::unique_ptr<Accessor::Impl::AccessorInvalidator> Accessor::Impl::sInvalidator;
850 void Accessor::Impl::createInvalidator() {  in createInvalidator()
852         sInvalidator = std::make_unique<Accessor::Impl::AccessorInvalidator>();  in createInvalidator()