chrome/browser/chromeos/printing/fake_printer_discoverer.cc - Issue 2790603003: Make CUPS USB printing play better with the settings page. This change does several things:

Side by Side Diff: chrome/browser/chromeos/printing/fake_printer_discoverer.cc

Issue 2790603003: Make CUPS USB printing play better with the settings page. This change does several things: (Closed)

Patch Set: stop latching PrintersManager, add comments Created 3 years, 8 months ago

Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.

Jump to:

View unified diff | Download patch

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 "chrome/browser/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 "chrome/browser/chromeos/printing/printer_discoverer.h"

17

18 namespace chromeos {

19

20 // static

21 std::unique_ptr<PrinterDiscoverer> PrinterDiscoverer::Create() {

22 return base::MakeUnique<FakePrinterDiscoverer>();

23 }

24

25 FakePrinterDiscoverer::~FakePrinterDiscoverer() {}

26

27 bool FakePrinterDiscoverer::StartDiscovery() {

28 discovery_running_ = true;

29

30 for (auto* observer : observers_)

31 observer->OnDiscoveryStarted();

32

33 base::SequencedTaskRunnerHandle::Get()->PostNonNestableDelayedTask(

34 FROM_HERE, base::Bind(&FakePrinterDiscoverer::EmitPrinters,

35 weak_ptr_factory_.GetWeakPtr(), 0, 2),

36 base::TimeDelta::FromMilliseconds(2000));

37 return true;

38 }

39

40 bool FakePrinterDiscoverer::StopDiscovery() {

41 discovery_running_ = false;

42 for (auto* observer : observers_)

43 observer->OnDiscoveryStopping();

44

45 return true;

46 }

47

48 void FakePrinterDiscoverer::AddObserver(PrinterDiscoverer::Observer* observer) {

49 auto found = std::find(observers_.begin(), observers_.end(), observer);

50 if (found == observers_.end())

51 observers_.push_back(observer);

52 }

53

54 void FakePrinterDiscoverer::RemoveObserver(

55 PrinterDiscoverer::Observer* observer) {

56 auto found = std::find(observers_.begin(), observers_.end(), observer);

57 if (found != observers_.end())

58 observers_.erase(found);

59 }

60

61 FakePrinterDiscoverer::FakePrinterDiscoverer()

62 : discovery_running_(false), weak_ptr_factory_(this) {

63 for (int i = 0; i < 12; i++) {

64 // printer doesn't have a ppd

65 printers_.emplace_back(base::StringPrintf("GUID%2d", i));

66 printers_[i].set_display_name(base::StringPrintf("PrinterName%2d", i));

67 printers_[i].set_description(

68 base::StringPrintf("Printer%2dDescription", i));

69 printers_[i].set_manufacturer("Chromium");

70 printers_[i].set_model(i % 3 == 0 ? "Inkjet" : "Laser Maker");

71 printers_[i].set_uri(

72 base::StringPrintf("lpd://192.168.1.%d:9100/bldg/printer", i));

73 printers_[i].set_uuid(

74 base::StringPrintf("UUID-%4d-%4d-%4d-UUID", i * 3, i * 2, i));

75 }

76 }

77

78 void FakePrinterDiscoverer::EmitPrinters(size_t start, size_t end) {

79 if (!discovery_running_ \|\| start >= printers_.size() \|\| end < start)

80 return;

81

82 size_t clipped_start = std::max(static_cast<size_t>(0), start);

83 size_t clipped_end = std::min(printers_.size(), end);

84 if (!observers_.empty()) {

85 std::vector<Printer> subset(printers_.cbegin() + clipped_start,

86 printers_.cbegin() + clipped_end);

87

88 for (auto* observer : observers_)

89 observer->OnPrintersFound(subset);

90 }

91

92 // schedule another emit if elements remain.

93 if (end < printers_.size()) {

94 base::SequencedTaskRunnerHandle::Get()->PostNonNestableDelayedTask(

95 FROM_HERE,

96 base::Bind(&FakePrinterDiscoverer::EmitPrinters,

97 weak_ptr_factory_.GetWeakPtr(), clipped_end, end + end),

98 base::TimeDelta::FromMilliseconds(2000));

99 } else {

100 // We're done. Notify observers.

101 discovery_running_ = false;

102 for (auto* observer : observers_)

103 observer->OnDiscoveryDone();

104 }

105 }

106

107 } // namespace chromeos

OLD	NEW