Index: chrome/plugin/plugin_channel_base.cc |
=================================================================== |
--- chrome/plugin/plugin_channel_base.cc (revision 32429) |
+++ chrome/plugin/plugin_channel_base.cc (working copy) |
@@ -60,8 +60,8 @@ |
peer_pid_(0), |
in_remove_route_(false), |
channel_valid_(false), |
- in_dispatch_(0), |
- send_unblocking_only_during_dispatch_(false) { |
+ in_sync_dispatch_(0), |
+ send_unblocking_only_during_sync_dispatch_(false) { |
} |
PluginChannelBase::~PluginChannelBase() { |
@@ -100,7 +100,7 @@ |
return false; |
} |
- if (send_unblocking_only_during_dispatch_ && in_dispatch_ == 0 && |
+ if (send_unblocking_only_during_sync_dispatch_ && in_sync_dispatch_ == 0 && |
message->is_sync()) { |
message->set_unblock(false); |
} |
@@ -117,7 +117,8 @@ |
// ourself so that we can send the reply and decrement back in_dispatch_. |
scoped_refptr<PluginChannelBase> me(this); |
- in_dispatch_++; |
+ if (message.is_sync()) |
+ in_sync_dispatch_++; |
if (message.routing_id() == MSG_ROUTING_CONTROL) { |
OnControlMessageReceived(message); |
} else { |
@@ -130,7 +131,8 @@ |
Send(reply); |
} |
} |
- in_dispatch_--; |
+ if (message.is_sync()) |
+ in_sync_dispatch_--; |
} |
void PluginChannelBase::OnChannelConnected(int32 peer_pid) { |
@@ -214,6 +216,6 @@ |
channel_valid_ = false; |
} |
-void PluginChannelBase::SendUnblockingOnlyDuringDispatch() { |
- send_unblocking_only_during_dispatch_ = true; |
+void PluginChannelBase::SendUnblockingOnlyDuringSyncDispatch() { |
+ send_unblocking_only_during_sync_dispatch_ = true; |
} |