2 // Use of this source code is governed by a BSD-style license that can be
185   for (std::vector<Arg>::iterator it = args->begin(); it != args->end(); ++it) {  in MatchMessageArgs()
221   for (std::vector<Arg>::iterator it = args->begin(); it != args->end(); ++it) {  in AppendArgsToMessage()
267              vit != arg.string_values.end(); ++vit) {  in AppendArgsToMessage()
268           const char* str_value = vit->c_str();  in AppendArgsToMessage()
296   dbus_bool_t success;  in SendMessage()  local
298   success = dbus_connection_send(conn, message, &serial);  in SendMessage()
300   if (success && expect_serial_)  in SendMessage()
351        it != expected_serials_.end(); ++it) {  in HandleClientMessage()
411          it != matches_.end(); ++it) {  in WaitForMatches()
424       dbus_connection_read_write(conn_, -1);  in WaitForMatches()
429          it != matches_.end(); ++it) {  in WaitForMatches()
443   matches_.erase(matches_.begin(), matches_.end());  in WaitForMatches()
450   // Create the D-Bus server that will accept a connection for us, since  in SetUp()
458   dbus_bool_t success;  in SetUp()  local
459   success = dbus_server_set_watch_functions(  in SetUp()
461   ASSERT_TRUE(success);  in SetUp()
463   success = dbus_server_set_timeout_functions(server_, AddTimeoutThunk,  in SetUp()
466   ASSERT_TRUE(success);  in SetUp()
492   // Close the client end of the connection, this will result in a signal  in TearDown()
506   // Clean up the server end of the connection and the server itself.  in TearDown()
525   test->NewConnection(server, conn);  in NewConnectionThunk()
531   dbus_bool_t success;  in NewConnection()  local
532   success = dbus_connection_set_watch_functions(  in NewConnection()
534   ASSERT_TRUE(success);  in NewConnection()
536   success = dbus_connection_set_timeout_functions(  in NewConnection()
539   ASSERT_TRUE(success);  in NewConnection()
541   success = dbus_connection_add_filter(conn, HandleMessageThunk, this, NULL);  in NewConnection()
542   ASSERT_TRUE(success);  in NewConnection()
550   return test->AddWatch(watch);  in AddWatchThunk()
560   test->RemoveWatch(watch);  in RemoveWatchThunk()
565       find(watches_.begin(), watches_.end(), watch);  in RemoveWatch()
566   if (it != watches_.end())  in RemoveWatch()
572   test->WatchToggled(watch);  in WatchToggledThunk()
579   return test->AddTimeout(timeout);  in AddTimeoutThunk()
589   test->RemoveTimeout(timeout);  in RemoveTimeoutThunk()
594       find(timeouts_.begin(), timeouts_.end(), timeout);  in RemoveTimeout()
595   if (it != timeouts_.end())  in RemoveTimeout()
601   test->TimeoutToggled(timeout);  in TimeoutToggledThunk()
610   return test->HandleMessage(conn, message);  in HandleMessageThunk()
622        it != matches_.end(); ++it) {  in HandleMessage()
637   return test->DispatchLoop();  in DispatchLoopThunk()
659        it != watches_.end(); ++it) {  in DispatchOnce()
677   // isn't quite right according to the D-Bus spec, since the interval is  in DispatchOnce()
684        it != timeouts_.end(); ++it) {  in DispatchOnce()
715        it != immutable_watches.end(); ++it) {  in DispatchOnce()
730   // Dispatch data on the server-side of the connection.  in DispatchOnce()