StatsPullerManager.h revision 15f6bbc24f4d7a3d4481d90a18df33d402ddacba 
1/*
2 * Copyright (C) 2017 The Android Open Source Project
3 *
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at
7 *
8 *      http://www.apache.org/licenses/LICENSE-2.0
9 *
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
15 */
16
17#pragma once
18
19#include "StatsPullerManagerImpl.h"
20
21namespace android {
22namespace os {
23namespace statsd {
24
25class StatsPullerManager {
26 public:
27    virtual ~StatsPullerManager() {}
28
29    virtual void RegisterReceiver(int tagId, wp<PullDataReceiver> receiver, int64_t nextPullTimeNs,
30                                  int64_t intervalNs) {
31        mPullerManager.RegisterReceiver(tagId, receiver, nextPullTimeNs, intervalNs);
32    };
33
34    virtual void UnRegisterReceiver(int tagId, wp <PullDataReceiver> receiver) {
35        mPullerManager.UnRegisterReceiver(tagId, receiver);
36    };
37
38    // Verify if we know how to pull for this matcher
39    bool PullerForMatcherExists(int tagId) {
40        return mPullerManager.PullerForMatcherExists(tagId);
41    }
42
43    void OnAlarmFired(const int64_t currentTimeNs) {
44        mPullerManager.OnAlarmFired(currentTimeNs);
45    }
46
47    virtual bool Pull(const int tagId, const int64_t timesNs,
48                      vector<std::shared_ptr<LogEvent>>* data) {
49        return mPullerManager.Pull(tagId, timesNs, data);
50    }
51
52    int ForceClearPullerCache() {
53        return mPullerManager.ForceClearPullerCache();
54    }
55
56    void SetStatsCompanionService(sp<IStatsCompanionService> statsCompanionService) {
57        mPullerManager.SetStatsCompanionService(statsCompanionService);
58    }
59
60    int ClearPullerCacheIfNecessary(int64_t timestampNs) {
61        return mPullerManager.ClearPullerCacheIfNecessary(timestampNs);
62    }
63
64 private:
65    StatsPullerManagerImpl
66        & mPullerManager = StatsPullerManagerImpl::GetInstance();
67};
68
69}  // namespace statsd
70}  // namespace os
71}  // namespace android
72