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 |