blob: 5b401aab10757060e6451cd82bd120179acc98ab [file] [log] [blame]
// Copyright 2018 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#ifndef SERVICES_AUDIO_TEST_SERVICE_LIFETIME_TEST_TEMPLATE_H_
#define SERVICES_AUDIO_TEST_SERVICE_LIFETIME_TEST_TEMPLATE_H_
#include "base/run_loop.h"
#include "mojo/public/cpp/bindings/remote.h"
#include "services/audio/public/mojom/constants.mojom.h"
#include "services/audio/public/mojom/system_info.mojom.h"
#include "services/audio/test/service_observer_mock.h"
namespace audio {
// Template for Audio service lifetime tests regarding client
// connect/disconnect events. Audio service under test must be configured to
// quit after a timeout if there are no incoming connections.
template <class TestBase>
class ServiceLifetimeTestTemplate : public TestBase {
public:
ServiceLifetimeTestTemplate() {}
~ServiceLifetimeTestTemplate() override {}
protected:
void SetUp() override {
TestBase::SetUp();
mojo::Remote<service_manager::mojom::ServiceManager> service_manager;
TestBase::connector()->Connect(
service_manager::mojom::kServiceName,
service_manager.BindNewPipeAndPassReceiver());
mojo::PendingRemote<service_manager::mojom::ServiceManagerListener>
listener;
service_observer_ = std::make_unique<ServiceObserverMock>(
mojom::kServiceName, listener.InitWithNewPipeAndPassReceiver());
base::RunLoop wait_loop;
EXPECT_CALL(*service_observer_, Initialized())
.WillOnce(testing::Invoke(&wait_loop, &base::RunLoop::Quit));
service_manager->AddListener(std::move(listener));
wait_loop.Run();
}
protected:
std::unique_ptr<ServiceObserverMock> service_observer_;
private:
DISALLOW_COPY_AND_ASSIGN(ServiceLifetimeTestTemplate);
};
TYPED_TEST_SUITE_P(ServiceLifetimeTestTemplate);
TYPED_TEST_P(ServiceLifetimeTestTemplate,
DISABLED_ServiceQuitsWhenClientDisconnects) {
mojom::SystemInfoPtr info;
{
base::RunLoop wait_loop;
EXPECT_CALL(*this->service_observer_, ServiceStarted())
.WillOnce(testing::Invoke(&wait_loop, &base::RunLoop::Quit));
this->connector()->BindInterface(mojom::kServiceName, &info);
wait_loop.Run();
}
{
base::RunLoop wait_loop;
EXPECT_CALL(*this->service_observer_, ServiceStopped())
.WillOnce(testing::Invoke(&wait_loop, &base::RunLoop::Quit));
info.reset();
wait_loop.Run();
}
}
TYPED_TEST_P(ServiceLifetimeTestTemplate,
DISABLED_ServiceQuitsWhenLastClientDisconnects) {
mojom::SystemInfoPtr info;
{
base::RunLoop wait_loop;
EXPECT_CALL(*this->service_observer_, ServiceStarted())
.WillOnce(testing::Invoke(&wait_loop, &base::RunLoop::Quit));
this->connector()->BindInterface(mojom::kServiceName, &info);
wait_loop.Run();
}
{
base::RunLoop wait_loop;
EXPECT_CALL(*this->service_observer_, ServiceStopped())
.WillOnce(testing::Invoke(&wait_loop, &base::RunLoop::Quit));
EXPECT_CALL(*this->service_observer_, ServiceStarted())
.Times(testing::Exactly(0));
mojom::SystemInfoPtr info2;
this->connector()->BindInterface(mojom::kServiceName, &info2);
info2.FlushForTesting();
mojom::SystemInfoPtr info3;
this->connector()->BindInterface(mojom::kServiceName, &info3);
info3.FlushForTesting();
info.reset();
info2.reset();
info3.reset();
wait_loop.Run();
}
}
TYPED_TEST_P(ServiceLifetimeTestTemplate,
DISABLED_ServiceRestartsWhenClientReconnects) {
mojom::SystemInfoPtr info;
{
base::RunLoop wait_loop;
EXPECT_CALL(*this->service_observer_, ServiceStarted())
.WillOnce(testing::Invoke(&wait_loop, &base::RunLoop::Quit));
this->connector()->BindInterface(mojom::kServiceName, &info);
wait_loop.Run();
}
{
base::RunLoop wait_loop;
EXPECT_CALL(*this->service_observer_, ServiceStopped())
.WillOnce(testing::Invoke(&wait_loop, &base::RunLoop::Quit));
info.reset();
wait_loop.Run();
}
{
base::RunLoop wait_loop;
EXPECT_CALL(*this->service_observer_, ServiceStarted())
.WillOnce(testing::Invoke(&wait_loop, &base::RunLoop::Quit));
this->connector()->BindInterface(mojom::kServiceName, &info);
wait_loop.Run();
}
{
base::RunLoop wait_loop;
EXPECT_CALL(*this->service_observer_, ServiceStopped())
.WillOnce(testing::Invoke(&wait_loop, &base::RunLoop::Quit));
info.reset();
wait_loop.Run();
}
}
REGISTER_TYPED_TEST_SUITE_P(ServiceLifetimeTestTemplate,
DISABLED_ServiceQuitsWhenClientDisconnects,
DISABLED_ServiceQuitsWhenLastClientDisconnects,
DISABLED_ServiceRestartsWhenClientReconnects);
} // namespace audio
#endif // SERVICES_AUDIO_TEST_SERVICE_LIFETIME_TEST_TEMPLATE_H_