| Index: content/browser/message_port_service.cc
|
| diff --git a/content/browser/message_port_service.cc b/content/browser/message_port_service.cc
|
| index 9ee4d70c24490c578e3335454adb471f5249dde7..3b7ef7e5eff9047c126fb259cbf406ce3a3bdfbf 100644
|
| --- a/content/browser/message_port_service.cc
|
| +++ b/content/browser/message_port_service.cc
|
| @@ -63,7 +63,7 @@
|
| void MessagePortService::UpdateMessagePort(int message_port_id,
|
| MessagePortDelegate* delegate,
|
| int routing_id) {
|
| - DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| + DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| if (!message_ports_.count(message_port_id)) {
|
| NOTREACHED();
|
| return;
|
| @@ -76,7 +76,6 @@
|
|
|
| void MessagePortService::OnMessagePortDelegateClosing(
|
| MessagePortDelegate* delegate) {
|
| - DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| // Check if the (possibly) crashed process had any message ports.
|
| for (MessagePorts::iterator iter = message_ports_.begin();
|
| iter != message_ports_.end();) {
|
| @@ -90,7 +89,7 @@
|
| void MessagePortService::Create(int route_id,
|
| MessagePortDelegate* delegate,
|
| int* message_port_id) {
|
| - DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| + DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| *message_port_id = ++next_message_port_id_;
|
|
|
| MessagePort port;
|
| @@ -105,7 +104,6 @@
|
| }
|
|
|
| void MessagePortService::Destroy(int message_port_id) {
|
| - DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| if (!message_ports_.count(message_port_id)) {
|
| NOTREACHED();
|
| return;
|
| @@ -118,7 +116,6 @@
|
|
|
| void MessagePortService::Entangle(int local_message_port_id,
|
| int remote_message_port_id) {
|
| - DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| if (!message_ports_.count(local_message_port_id) ||
|
| !message_ports_.count(remote_message_port_id)) {
|
| NOTREACHED();
|
| @@ -135,7 +132,6 @@
|
| int sender_message_port_id,
|
| const base::string16& message,
|
| const std::vector<int>& sent_message_port_ids) {
|
| - DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| if (!message_ports_.count(sender_message_port_id)) {
|
| NOTREACHED();
|
| return;
|
| @@ -199,7 +195,6 @@
|
| }
|
|
|
| void MessagePortService::QueueMessages(int message_port_id) {
|
| - DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| if (!message_ports_.count(message_port_id)) {
|
| NOTREACHED();
|
| return;
|
| @@ -216,7 +211,6 @@
|
| void MessagePortService::SendQueuedMessages(
|
| int message_port_id,
|
| const QueuedMessages& queued_messages) {
|
| - DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| if (!message_ports_.count(message_port_id)) {
|
| NOTREACHED();
|
| return;
|
| @@ -246,7 +240,6 @@
|
| }
|
|
|
| void MessagePortService::SendQueuedMessagesIfPossible(int message_port_id) {
|
| - DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| if (!message_ports_.count(message_port_id)) {
|
| NOTREACHED();
|
| return;
|
| @@ -264,7 +257,6 @@
|
| }
|
|
|
| void MessagePortService::HoldMessages(int message_port_id) {
|
| - DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| if (!message_ports_.count(message_port_id)) {
|
| NOTREACHED();
|
| return;
|
| @@ -279,7 +271,6 @@
|
| }
|
|
|
| void MessagePortService::ClosePort(int message_port_id) {
|
| - DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| if (!message_ports_.count(message_port_id)) {
|
| NOTREACHED();
|
| return;
|
| @@ -299,7 +290,6 @@
|
| }
|
|
|
| void MessagePortService::ReleaseMessages(int message_port_id) {
|
| - DCHECK_CURRENTLY_ON(BrowserThread::IO);
|
| if (!message_ports_.count(message_port_id)) {
|
| NOTREACHED();
|
| return;
|
|
|