Chromium Code Reviews| OLD | NEW |
|---|---|
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "dbus/bus.h" | 5 #include "dbus/bus.h" |
| 6 | 6 |
| 7 #include "base/bind.h" | 7 #include "base/bind.h" |
| 8 #include "base/logging.h" | 8 #include "base/logging.h" |
| 9 #include "base/message_loop.h" | 9 #include "base/message_loop.h" |
| 10 #include "base/metrics/histogram.h" | 10 #include "base/metrics/histogram.h" |
| (...skipping 390 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 401 | 401 |
| 402 void ObjectProxy::OnConnected(OnConnectedCallback on_connected_callback, | 402 void ObjectProxy::OnConnected(OnConnectedCallback on_connected_callback, |
| 403 const std::string& interface_name, | 403 const std::string& interface_name, |
| 404 const std::string& signal_name, | 404 const std::string& signal_name, |
| 405 bool success) { | 405 bool success) { |
| 406 bus_->AssertOnOriginThread(); | 406 bus_->AssertOnOriginThread(); |
| 407 | 407 |
| 408 on_connected_callback.Run(interface_name, signal_name, success); | 408 on_connected_callback.Run(interface_name, signal_name, success); |
| 409 } | 409 } |
| 410 | 410 |
| 411 void ObjectProxy::SetNameOwnerChangedCallback(SignalCallback callback) { | |
| 412 bus_->AssertOnOriginThread(); | |
| 413 | |
| 414 name_owner_changed_callback_ = callback; | |
| 415 } | |
| 416 | |
| 411 DBusHandlerResult ObjectProxy::HandleMessage( | 417 DBusHandlerResult ObjectProxy::HandleMessage( |
| 412 DBusConnection* connection, | 418 DBusConnection* connection, |
| 413 DBusMessage* raw_message) { | 419 DBusMessage* raw_message) { |
| 414 bus_->AssertOnDBusThread(); | 420 bus_->AssertOnDBusThread(); |
| 415 | 421 |
| 416 if (dbus_message_get_type(raw_message) != DBUS_MESSAGE_TYPE_SIGNAL) | 422 if (dbus_message_get_type(raw_message) != DBUS_MESSAGE_TYPE_SIGNAL) |
| 417 return DBUS_HANDLER_RESULT_NOT_YET_HANDLED; | 423 return DBUS_HANDLER_RESULT_NOT_YET_HANDLED; |
| 418 | 424 |
| 419 // raw_message will be unrefed on exit of the function. Increment the | 425 // raw_message will be unrefed on exit of the function. Increment the |
| 420 // reference so we can use it in Signal. | 426 // reference so we can use it in Signal. |
| (...skipping 191 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 612 scoped_ptr<Response> response(Response::FromRawMessage(response_message)); | 618 scoped_ptr<Response> response(Response::FromRawMessage(response_message)); |
| 613 MessageReader reader(response.get()); | 619 MessageReader reader(response.get()); |
| 614 | 620 |
| 615 std::string new_service_name_owner; | 621 std::string new_service_name_owner; |
| 616 if (reader.PopString(&new_service_name_owner)) | 622 if (reader.PopString(&new_service_name_owner)) |
| 617 service_name_owner_ = new_service_name_owner; | 623 service_name_owner_ = new_service_name_owner; |
| 618 else | 624 else |
| 619 service_name_owner_.clear(); | 625 service_name_owner_.clear(); |
| 620 } | 626 } |
| 621 | 627 |
| 622 DBusHandlerResult ObjectProxy::HandleNameOwnerChanged(Signal* signal) { | 628 DBusHandlerResult ObjectProxy::HandleNameOwnerChanged(Signal* signal) { |
|
satorux1
2012/11/13 07:00:39
This should be scoped_ptr<Signal>
| |
| 623 DCHECK(signal); | 629 DCHECK(signal); |
| 624 bus_->AssertOnDBusThread(); | 630 bus_->AssertOnDBusThread(); |
| 625 | 631 |
| 626 // Confirm the validity of the NameOwnerChanged signal. | 632 // Confirm the validity of the NameOwnerChanged signal. |
| 627 if (signal->GetMember() == "NameOwnerChanged" && | 633 if (signal->GetMember() == "NameOwnerChanged" && |
| 628 signal->GetInterface() == "org.freedesktop.DBus" && | 634 signal->GetInterface() == "org.freedesktop.DBus" && |
| 629 signal->GetSender() == "org.freedesktop.DBus") { | 635 signal->GetSender() == "org.freedesktop.DBus") { |
| 630 MessageReader reader(signal); | 636 MessageReader reader(signal); |
| 631 std::string name, old_owner, new_owner; | 637 std::string name, old_owner, new_owner; |
| 632 if (reader.PopString(&name) && | 638 if (reader.PopString(&name) && |
| 633 reader.PopString(&old_owner) && | 639 reader.PopString(&old_owner) && |
| 634 reader.PopString(&new_owner) && | 640 reader.PopString(&new_owner) && |
| 635 name == service_name_) { | 641 name == service_name_) { |
| 636 service_name_owner_ = new_owner; | 642 service_name_owner_ = new_owner; |
| 643 if (!name_owner_changed_callback_.is_null()) | |
| 644 name_owner_changed_callback_.Run(signal); | |
|
satorux1
2012/11/13 07:00:39
Let's not call this here as we are now on the D-Bu
| |
| 637 return DBUS_HANDLER_RESULT_HANDLED; | 645 return DBUS_HANDLER_RESULT_HANDLED; |
| 638 } | 646 } |
| 639 } | 647 } |
| 640 | 648 |
| 641 // Untrusted or uninteresting signal | 649 // Untrusted or uninteresting signal |
| 642 return DBUS_HANDLER_RESULT_NOT_YET_HANDLED; | 650 return DBUS_HANDLER_RESULT_NOT_YET_HANDLED; |
| 643 } | 651 } |
| 644 | 652 |
| 645 } // namespace dbus | 653 } // namespace dbus |
| OLD | NEW |