OLD | NEW |
---|---|
(Empty) | |
1 // Copyright 2016 The Chromium Authors. All rights reserved. | |
2 // Use of this source code is governed by a BSD-style license that can be | |
3 // found in the LICENSE file. | |
4 | |
5 #include "chromeos/printing/fake_printer_discoverer.h" | |
6 | |
7 #include <algorithm> | |
8 #include <iterator> | |
9 #include <memory> | |
10 | |
11 #include "base/bind.h" | |
12 #include "base/memory/ptr_util.h" | |
13 #include "base/strings/stringprintf.h" | |
14 #include "base/threading/sequenced_task_runner_handle.h" | |
15 #include "base/time/time.h" | |
16 #include "chromeos/printing/printer_discoverer.h" | |
17 | |
18 namespace chromeos { | |
19 | |
20 // static | |
21 std::unique_ptr<PrinterDiscoverer> PrinterDiscoverer::Create() { | |
22 return base::MakeUnique<FakePrinterDiscoverer>(); | |
xdai1
2016/10/03 23:34:38
It might be better to make it a lazy instance so t
skau
2016/10/03 23:52:30
My intention is that this object is only around wh
xdai1
2016/10/04 00:13:32
Acknowledged. Didn't thought about this way.
| |
23 } | |
24 | |
25 FakePrinterDiscoverer::~FakePrinterDiscoverer() {} | |
26 | |
27 bool FakePrinterDiscoverer::StartDiscovery() { | |
28 discovery_running_ = true; | |
29 base::SequencedTaskRunnerHandle::Get()->PostNonNestableDelayedTask( | |
30 FROM_HERE, base::Bind(&FakePrinterDiscoverer::EmitPrinters, | |
31 weak_ptr_factory_.GetWeakPtr(), 0, 2), | |
32 base::TimeDelta::FromMilliseconds(2000)); | |
33 return true; | |
34 } | |
35 | |
36 bool FakePrinterDiscoverer::StopDiscovery() { | |
37 discovery_running_ = false; | |
38 return true; | |
39 } | |
40 | |
41 void FakePrinterDiscoverer::AddObserver(PrinterDiscoverer::Observer* observer) { | |
42 observers_.push_back(observer); | |
43 } | |
44 | |
45 void FakePrinterDiscoverer::RemoveObserver( | |
46 PrinterDiscoverer::Observer* observer) { | |
47 auto found = std::find(observers_.begin(), observers_.end(), observer); | |
48 if (found != observers_.end()) | |
49 observers_.erase(found); | |
50 } | |
51 | |
52 FakePrinterDiscoverer::FakePrinterDiscoverer() | |
53 : discovery_running_(false), weak_ptr_factory_(this) { | |
54 for (int i = 0; i < 12; i++) { | |
55 // printer doesn't have a ppd | |
56 printers_.emplace_back(base::StringPrintf("GUID%2d", i)); | |
57 printers_[i].set_display_name(base::StringPrintf("PrinterName%2d", i)); | |
58 printers_[i].set_description( | |
59 base::StringPrintf("Printer%2dDescription", i)); | |
60 printers_[i].set_manufacturer("Chromium"); | |
61 printers_[i].set_model(i % 3 == 0 ? "Inkjet" : "Laser Maker"); | |
62 printers_[i].set_uri( | |
63 base::StringPrintf("lpr://192.168.1.%d:9100/bldg/printer", i)); | |
64 printers_[i].set_uuid( | |
65 base::StringPrintf("UUID-%4d-%4d-%4d-UUID", i * 3, i * 2, i)); | |
66 } | |
67 } | |
68 | |
69 void FakePrinterDiscoverer::EmitPrinters(size_t start, size_t end) { | |
70 if (!discovery_running_ || start >= printers_.size()) | |
Carlson
2016/10/03 23:13:23
For orthogonality, suggest adding
|| end < 0
to
skau
2016/10/03 23:34:48
Done.
| |
71 return; | |
xdai1
2016/10/03 23:34:38
notify when the discovery is done.
skau
2016/10/03 23:52:30
Whoops. Forgot about that.
| |
72 | |
73 size_t clipped_start = std::max(static_cast<size_t>(0), start); | |
74 size_t clipped_end = std::min(printers_.size(), end); | |
75 if (!observers_.empty()) { | |
76 std::vector<Printer> subset(printers_.cbegin() + clipped_start, | |
77 printers_.cbegin() + clipped_end); | |
78 | |
79 for (auto observer : observers_) | |
80 observer->OnPrintersFound(subset); | |
81 } | |
82 | |
83 // schedule another emit if elements remain. | |
84 if (end < printers_.size()) { | |
85 base::SequencedTaskRunnerHandle::Get()->PostNonNestableDelayedTask( | |
86 FROM_HERE, | |
87 base::Bind(&FakePrinterDiscoverer::EmitPrinters, | |
88 weak_ptr_factory_.GetWeakPtr(), clipped_end, end + end), | |
89 base::TimeDelta::FromMilliseconds(2000)); | |
90 } | |
91 } | |
92 | |
93 } // namespace chromeos | |
OLD | NEW |