Skip to content

Commit

Permalink
tidy
Browse files Browse the repository at this point in the history
  • Loading branch information
Julusian committed Dec 22, 2023
1 parent 845031a commit 623b191
Show file tree
Hide file tree
Showing 5 changed files with 3 additions and 19 deletions.
2 changes: 0 additions & 2 deletions src/common/executor.h
Original file line number Diff line number Diff line change
Expand Up @@ -54,9 +54,7 @@ class executor final
}

~executor() {
CASPAR_LOG(info) << L"destroying exec: " << name_;
stop_and_wait();
CASPAR_LOG(info) << L"stopped exec: " << name_;
}

template <typename Func>
Expand Down
2 changes: 1 addition & 1 deletion src/protocol/amcp/AMCPCommandQueue.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,7 @@ AMCPCommandQueue::AMCPCommandQueue(const std::wstring& name, const std::shared_p
{
}

AMCPCommandQueue::~AMCPCommandQueue() { CASPAR_LOG(info) << "destry AMCPCommandQueue"; }
AMCPCommandQueue::~AMCPCommandQueue() { }

std::future<bool>
exec_cmd(std::shared_ptr<AMCPCommand> cmd, const std::shared_ptr<std::map<int, protocol::amcp::channel_context>>& channels, bool reply_without_req_id)
Expand Down
2 changes: 1 addition & 1 deletion src/protocol/amcp/AMCPProtocolStrategy.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -107,7 +107,7 @@ class AMCPProtocolStrategy
}
}

~AMCPProtocolStrategy() { CASPAR_LOG(info) << "destry AMCPProtocolStrategy"; }
~AMCPProtocolStrategy() { }

enum class error_state
{
Expand Down
1 change: 0 additions & 1 deletion src/protocol/util/AsyncEventServer.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -360,7 +360,6 @@ AsyncEventServer::AsyncEventServer(std::shared_ptr<boost::asio::io_service> s

AsyncEventServer::~AsyncEventServer()
{
CASPAR_LOG(info) << "destry AsyncEventServer";
impl_->stop(); }

void AsyncEventServer::add_client_lifecycle_object_factory(const lifecycle_factory_t& factory)
Expand Down
15 changes: 1 addition & 14 deletions src/shell/server.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -168,24 +168,11 @@ struct server::impl
destroy_producers_synchronously();
destroy_consumers_synchronously();

/*
std::vector<std::weak_ptr<caspar::core::stage>> weak_stages;
for (auto& channel: channels_) {
weak_stages.push_back(channel->stage());
}
channels_.clear();
*/
channels_->clear();

while (weak_io_service.lock())
std::this_thread::sleep_for(std::chrono::milliseconds(100));

/*
for (auto& stage : weak_stages) {
while (stage.lock())
std::this_thread::sleep_for(std::chrono::milliseconds(100));
}
*/

uninitialize_modules();
core::diagnostics::osd::shutdown();
}
Expand Down

0 comments on commit 623b191

Please sign in to comment.