1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
|
// Copyright 2022 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#ifndef CHROMEOS_ASH_COMPONENTS_PHONEHUB_PING_MANAGER_IMPL_H_
#define CHROMEOS_ASH_COMPONENTS_PHONEHUB_PING_MANAGER_IMPL_H_
#include "base/memory/raw_ptr.h"
#include "base/timer/timer.h"
#include "chromeos/ash/components/phonehub/feature_status.h"
#include "chromeos/ash/components/phonehub/feature_status_provider.h"
#include "chromeos/ash/components/phonehub/message_receiver.h"
#include "chromeos/ash/components/phonehub/ping_manager.h"
#include "chromeos/ash/components/phonehub/proto/phonehub_api.pb.h"
namespace ash::secure_channel {
class ConnectionManager;
}
namespace ash::phonehub {
class MessageSender;
class PingManagerImpl : public PingManager,
public MessageReceiver::Observer,
public FeatureStatusProvider::Observer {
public:
PingManagerImpl(secure_channel::ConnectionManager* connection_manager,
FeatureStatusProvider* feature_status_provider,
MessageReceiver* message_receiver,
MessageSender* message_sender);
~PingManagerImpl() override;
// MessageReceiver::Observer:
void OnPhoneStatusSnapshotReceived(
proto::PhoneStatusSnapshot phone_status_snapshot) override;
void OnPhoneStatusUpdateReceived(
proto::PhoneStatusUpdate phone_status_update) override;
void OnPingResponseReceived() override;
// // FeatureStatusProvider::Observer:
void OnFeatureStatusChanged() override;
// PingManager:
void SendPingRequest() override;
bool IsPingTimeoutTimerRunning();
// Test Helpers
bool is_ping_supported_by_phone_for_test() {
return is_ping_supported_by_phone_;
}
bool is_waiting_for_response_for_test() { return is_waiting_for_response_; }
void set_is_ping_supported_by_phone_for_test(
bool is_ping_supported_by_phone) {
is_ping_supported_by_phone_ = is_ping_supported_by_phone;
}
void set_is_waiting_for_response_for_test(bool is_waiting_for_response) {
is_waiting_for_response_ = is_waiting_for_response;
}
private:
friend class PingManagerImplTest;
// PingManager:
void Reset() override;
void OnPingTimerFired();
void UpdatePhoneSupport(proto::PhoneProperties phone_properties);
base::OneShotTimer ping_timeout_timer_;
base::TimeTicks ping_sent_timestamp_;
raw_ptr<secure_channel::ConnectionManager> connection_manager_;
raw_ptr<FeatureStatusProvider> feature_status_provider_;
raw_ptr<MessageReceiver> message_receiver_;
raw_ptr<MessageSender> message_sender_;
bool is_ping_supported_by_phone_ = false;
bool is_waiting_for_response_ = false;
};
} // namespace ash::phonehub
#endif // CHROMEOS_ASH_COMPONENTS_PHONEHUB_PING_MANAGER_IMPL_H_
|
