143 lines
4.1 KiB
C++
143 lines
4.1 KiB
C++
// Copyright (c) 2012 The Chromium Authors. All rights reserved.
|
|
// Use of this source code is governed by a BSD-style license that can be
|
|
// found in the LICENSE file.
|
|
|
|
#include "chrome/browser/printing/printer_query.h"
|
|
|
|
#include "base/bind.h"
|
|
#include "base/bind_helpers.h"
|
|
#include "base/message_loop/message_loop.h"
|
|
#include "base/threading/thread_restrictions.h"
|
|
#include "base/values.h"
|
|
#include "chrome/browser/printing/print_job_worker.h"
|
|
#include "chrome/browser/printing/printing_ui_web_contents_observer.h"
|
|
|
|
namespace printing {
|
|
|
|
PrinterQuery::PrinterQuery()
|
|
: io_message_loop_(base::MessageLoop::current()),
|
|
worker_(new PrintJobWorker(this)),
|
|
is_print_dialog_box_shown_(false),
|
|
cookie_(PrintSettings::NewCookie()),
|
|
last_status_(PrintingContext::FAILED) {
|
|
DCHECK(base::MessageLoopForIO::IsCurrent());
|
|
}
|
|
|
|
PrinterQuery::~PrinterQuery() {
|
|
// The job should be finished (or at least canceled) when it is destroyed.
|
|
DCHECK(!is_print_dialog_box_shown_);
|
|
// If this fires, it is that this pending printer context has leaked.
|
|
DCHECK(!worker_.get());
|
|
}
|
|
|
|
void PrinterQuery::GetSettingsDone(const PrintSettings& new_settings,
|
|
PrintingContext::Result result) {
|
|
is_print_dialog_box_shown_ = false;
|
|
last_status_ = result;
|
|
if (result != PrintingContext::FAILED) {
|
|
settings_ = new_settings;
|
|
cookie_ = PrintSettings::NewCookie();
|
|
} else {
|
|
// Failure.
|
|
cookie_ = 0;
|
|
}
|
|
|
|
if (!callback_.is_null()) {
|
|
// This may cause reentrancy like to call StopWorker().
|
|
callback_.Run();
|
|
callback_.Reset();
|
|
}
|
|
}
|
|
|
|
PrintJobWorker* PrinterQuery::DetachWorker(PrintJobWorkerOwner* new_owner) {
|
|
DCHECK(callback_.is_null());
|
|
DCHECK(worker_.get());
|
|
|
|
worker_->SetNewOwner(new_owner);
|
|
return worker_.release();
|
|
}
|
|
|
|
base::MessageLoop* PrinterQuery::message_loop() {
|
|
return io_message_loop_;
|
|
}
|
|
|
|
const PrintSettings& PrinterQuery::settings() const {
|
|
return settings_;
|
|
}
|
|
|
|
int PrinterQuery::cookie() const {
|
|
return cookie_;
|
|
}
|
|
|
|
void PrinterQuery::GetSettings(
|
|
GetSettingsAskParam ask_user_for_settings,
|
|
scoped_ptr<PrintingUIWebContentsObserver> web_contents_observer,
|
|
int expected_page_count,
|
|
bool has_selection,
|
|
MarginType margin_type,
|
|
const base::Closure& callback) {
|
|
DCHECK_EQ(io_message_loop_, base::MessageLoop::current());
|
|
DCHECK(!is_print_dialog_box_shown_);
|
|
|
|
StartWorker(callback);
|
|
|
|
// Real work is done in PrintJobWorker::GetSettings().
|
|
is_print_dialog_box_shown_ = ask_user_for_settings == ASK_USER;
|
|
worker_->message_loop()->PostTask(
|
|
FROM_HERE,
|
|
base::Bind(&PrintJobWorker::GetSettings,
|
|
base::Unretained(worker_.get()),
|
|
is_print_dialog_box_shown_,
|
|
base::Passed(&web_contents_observer),
|
|
expected_page_count,
|
|
has_selection,
|
|
margin_type));
|
|
}
|
|
|
|
void PrinterQuery::SetSettings(const base::DictionaryValue& new_settings,
|
|
const base::Closure& callback) {
|
|
StartWorker(callback);
|
|
|
|
worker_->message_loop()->PostTask(
|
|
FROM_HERE,
|
|
base::Bind(&PrintJobWorker::SetSettings,
|
|
base::Unretained(worker_.get()),
|
|
new_settings.DeepCopy()));
|
|
}
|
|
|
|
void PrinterQuery::SetWorkerDestination(
|
|
PrintDestinationInterface* destination) {
|
|
worker_->SetPrintDestination(destination);
|
|
}
|
|
|
|
void PrinterQuery::StartWorker(const base::Closure& callback) {
|
|
DCHECK(callback_.is_null());
|
|
DCHECK(worker_.get());
|
|
|
|
// Lazily create the worker thread. There is one worker thread per print job.
|
|
if (!worker_->message_loop())
|
|
worker_->Start();
|
|
|
|
callback_ = callback;
|
|
}
|
|
|
|
void PrinterQuery::StopWorker() {
|
|
if (worker_.get()) {
|
|
// http://crbug.com/66082: We're blocking on the PrinterQuery's worker
|
|
// thread. It's not clear to me if this may result in blocking the current
|
|
// thread for an unacceptable time. We should probably fix it.
|
|
base::ThreadRestrictions::ScopedAllowIO allow_io;
|
|
worker_->Stop();
|
|
worker_.reset();
|
|
}
|
|
}
|
|
|
|
bool PrinterQuery::is_callback_pending() const {
|
|
return !callback_.is_null();
|
|
}
|
|
|
|
bool PrinterQuery::is_valid() const {
|
|
return worker_.get() != NULL;
|
|
}
|
|
|
|
} // namespace printing
|