| Index: chrome/browser/extensions/api/messaging/native_message_process_host.cc
|
| diff --git a/chrome/browser/extensions/api/messaging/native_message_process_host.cc b/chrome/browser/extensions/api/messaging/native_message_process_host.cc
|
| index 170a25e3a997064b8e606df11faf5a4670667f8b..8d3352a2f605de826dea161ddb3bf43ea0d020b1 100644
|
| --- a/chrome/browser/extensions/api/messaging/native_message_process_host.cc
|
| +++ b/chrome/browser/extensions/api/messaging/native_message_process_host.cc
|
| @@ -109,7 +109,7 @@ NativeMessageProcessHost::NativeMessageProcessHost(
|
| #endif
|
| read_pending_(false),
|
| write_pending_(false) {
|
| - DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI));
|
| + DCHECK_CURRENTLY_ON(content::BrowserThread::UI);
|
|
|
| // It's safe to use base::Unretained() here because NativeMessagePort always
|
| // deletes us on the IO thread.
|
| @@ -119,7 +119,7 @@ NativeMessageProcessHost::NativeMessageProcessHost(
|
| }
|
|
|
| NativeMessageProcessHost::~NativeMessageProcessHost() {
|
| - DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(content::BrowserThread::IO);
|
| Close(std::string());
|
| }
|
|
|
| @@ -145,7 +145,7 @@ NativeMessageProcessHost::CreateWithLauncher(
|
| const std::string& native_host_name,
|
| int destination_port,
|
| scoped_ptr<NativeProcessLauncher> launcher) {
|
| - DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI));
|
| + DCHECK_CURRENTLY_ON(content::BrowserThread::UI);
|
|
|
| scoped_ptr<NativeMessageProcessHost> process(new NativeMessageProcessHost(
|
| weak_client_ui, source_extension_id, native_host_name,
|
| @@ -155,7 +155,7 @@ NativeMessageProcessHost::CreateWithLauncher(
|
| }
|
|
|
| void NativeMessageProcessHost::LaunchHostProcess() {
|
| - DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(content::BrowserThread::IO);
|
|
|
| GURL origin(std::string(kExtensionScheme) + "://" + source_extension_id_);
|
| launcher_->Launch(origin, native_host_name_,
|
| @@ -168,7 +168,7 @@ void NativeMessageProcessHost::OnHostProcessLaunched(
|
| base::ProcessHandle process_handle,
|
| base::File read_file,
|
| base::File write_file) {
|
| - DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(content::BrowserThread::IO);
|
|
|
| switch (result) {
|
| case NativeProcessLauncher::RESULT_INVALID_NAME:
|
| @@ -212,7 +212,7 @@ void NativeMessageProcessHost::OnHostProcessLaunched(
|
| }
|
|
|
| void NativeMessageProcessHost::Send(const std::string& json) {
|
| - DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(content::BrowserThread::IO);
|
|
|
| if (closed_)
|
| return;
|
| @@ -271,7 +271,7 @@ void NativeMessageProcessHost::WaitRead() {
|
| }
|
|
|
| void NativeMessageProcessHost::DoRead() {
|
| - DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(content::BrowserThread::IO);
|
|
|
| while (!closed_ && !read_pending_) {
|
| read_buffer_ = new net::IOBuffer(kReadBufferSize);
|
| @@ -284,7 +284,7 @@ void NativeMessageProcessHost::DoRead() {
|
| }
|
|
|
| void NativeMessageProcessHost::OnRead(int result) {
|
| - DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(content::BrowserThread::IO);
|
| DCHECK(read_pending_);
|
| read_pending_ = false;
|
|
|
| @@ -293,7 +293,7 @@ void NativeMessageProcessHost::OnRead(int result) {
|
| }
|
|
|
| void NativeMessageProcessHost::HandleReadResult(int result) {
|
| - DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(content::BrowserThread::IO);
|
|
|
| if (closed_)
|
| return;
|
| @@ -314,7 +314,7 @@ void NativeMessageProcessHost::HandleReadResult(int result) {
|
|
|
| void NativeMessageProcessHost::ProcessIncomingData(
|
| const char* data, int data_size) {
|
| - DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(content::BrowserThread::IO);
|
|
|
| incoming_data_.append(data, data_size);
|
|
|
| @@ -345,7 +345,7 @@ void NativeMessageProcessHost::ProcessIncomingData(
|
| }
|
|
|
| void NativeMessageProcessHost::DoWrite() {
|
| - DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(content::BrowserThread::IO);
|
|
|
| while (!write_pending_ && !closed_) {
|
| if (!current_write_buffer_.get() ||
|
| @@ -367,7 +367,7 @@ void NativeMessageProcessHost::DoWrite() {
|
| }
|
|
|
| void NativeMessageProcessHost::HandleWriteResult(int result) {
|
| - DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(content::BrowserThread::IO);
|
|
|
| if (result <= 0) {
|
| if (result == net::ERR_IO_PENDING) {
|
| @@ -383,7 +383,7 @@ void NativeMessageProcessHost::HandleWriteResult(int result) {
|
| }
|
|
|
| void NativeMessageProcessHost::OnWritten(int result) {
|
| - DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(content::BrowserThread::IO);
|
|
|
| DCHECK(write_pending_);
|
| write_pending_ = false;
|
| @@ -393,7 +393,7 @@ void NativeMessageProcessHost::OnWritten(int result) {
|
| }
|
|
|
| void NativeMessageProcessHost::Close(const std::string& error_message) {
|
| - DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::IO));
|
| + DCHECK_CURRENTLY_ON(content::BrowserThread::IO);
|
|
|
| if (!closed_) {
|
| closed_ = true;
|
|
|