Method stop_channels

lib_acl_cpp/src/redis/redis_client_pipeline.cpp:805–826

}

void redis_client_pipeline::stop_channels() const
{
	const token_node* iter = channels_->first_node();
	std::vector<redis_pipeline_channel*> channels;
	while (iter) {
		redis_pipeline_channel* channel =
			static_cast<redis_pipeline_channel*>(iter->get_ctx());
		// Notify and wait for the channel thread to exit
		channel->stop_thread();
		channels.push_back(channel);
		iter = channels_->next_node();
	}

	// Delete all channels threads
	for (std::vector<redis_pipeline_channel*>::iterator
		   it = channels.begin(); it != channels.end(); ++it) {
		channels_->remove((*it)->get_addr());
		delete *it;
	}

	logger("All channels in pipeline have been stopped!");
}

void redis_client_pipeline::start_channels()
{