#include </home/abuild/rpmbuild/BUILD/libzypp-17.31.23/zypp-media/ng/private/providequeue_p.h>
|
| using | Config = zypp::proto::Capabilities |
| |
| using | TimePoint = std::chrono::time_point< std::chrono::steady_clock > |
| |
|
| static constexpr uint32_t | InvalidId = (uint32_t) -1 |
| |
Definition at line 32 of file providequeue_p.h.
◆ Config
◆ TimePoint
◆ ProvideQueue()
◆ ~ProvideQueue()
| zyppng::ProvideQueue::~ProvideQueue |
( |
| ) |
|
◆ startup()
| bool zyppng::ProvideQueue::startup |
( |
const std::string & |
workerScheme, |
|
|
const zypp::Pathname & |
workDir, |
|
|
const std::string & |
hostname = "" |
|
) |
| |
◆ enqueue()
| void zyppng::ProvideQueue::enqueue |
( |
ProvideRequestRef |
request | ) |
|
◆ cancel()
| void zyppng::ProvideQueue::cancel |
( |
ProvideRequest * |
item, |
|
|
std::exception_ptr |
error |
|
) |
| |
◆ detach()
| void zyppng::ProvideQueue::detach |
( |
const std::string & |
id | ) |
|
◆ scheduleNext()
| void zyppng::ProvideQueue::scheduleNext |
( |
| ) |
|
◆ canScheduleMore()
| bool zyppng::ProvideQueue::canScheduleMore |
( |
| ) |
const |
◆ empty()
| bool zyppng::ProvideQueue::empty |
( |
| ) |
const |
◆ isIdle()
| bool zyppng::ProvideQueue::isIdle |
( |
| ) |
const |
◆ idleSince()
Time point since the queue started to be idle
Definition at line 255 of file providequeue.cc.
◆ requestCount()
| uint zyppng::ProvideQueue::requestCount |
( |
| ) |
const |
How many items does this queue currently have
Definition at line 265 of file providequeue.cc.
◆ activeRequests()
| uint zyppng::ProvideQueue::activeRequests |
( |
| ) |
const |
How many active items does this queue currently have
Definition at line 270 of file providequeue.cc.
◆ expectedProvideSize()
How much bytes does this queue has to download / process, for pending requests this is only set if the ProvideSpec has a expected download size set.
Definition at line 275 of file providequeue.cc.
◆ hostname()
| const std::string & zyppng::ProvideQueue::hostname |
( |
| ) |
const |
Returns the hostname this worker belongs to. If the worker was not associated with a hostname this will return a empty string.
Definition at line 298 of file providequeue.cc.
◆ workerConfig()
◆ sigIdle()
| SignalProxy< void()> zyppng::ProvideQueue::sigIdle |
( |
| ) |
|
◆ doStartup()
| bool zyppng::ProvideQueue::doStartup |
( |
| ) |
|
|
private |
◆ processMessage()
| void zyppng::ProvideQueue::processMessage |
( |
| ) |
|
|
private |
◆ readAllStderr()
| void zyppng::ProvideQueue::readAllStderr |
( |
| ) |
|
|
private |
Reads all of the log lines from stderr, call only when shutting down the queue because this will also read partial lines and forwards them
Definition at line 706 of file providequeue.cc.
◆ forwardToLog()
| void zyppng::ProvideQueue::forwardToLog |
( |
std::string && |
logLine | ) |
|
|
private |
◆ processReadyRead()
| void zyppng::ProvideQueue::processReadyRead |
( |
int |
channel | ) |
|
|
private |
◆ procFinished()
| void zyppng::ProvideQueue::procFinished |
( |
int |
exitCode | ) |
|
|
private |
◆ nextRequestId()
| uint32_t zyppng::ProvideQueue::nextRequestId |
( |
| ) |
|
|
private |
◆ dequeueActive()
| std::list< ProvideQueue::Item >::iterator zyppng::ProvideQueue::dequeueActive |
( |
std::list< Item >::iterator |
it | ) |
|
|
private |
Dequeues the request referenced by it. Returns a iterator to the next element in the active list
Definition at line 132 of file providequeue.cc.
◆ fatalWorkerError()
| void zyppng::ProvideQueue::fatalWorkerError |
( |
const std::exception_ptr & |
reason = nullptr | ) |
|
|
private |
◆ immediateShutdown()
| void zyppng::ProvideQueue::immediateShutdown |
( |
const std::exception_ptr & |
reason | ) |
|
|
private |
◆ cancelActiveItem()
| std::list< ProvideQueue::Item >::iterator zyppng::ProvideQueue::cancelActiveItem |
( |
std::list< Item >::iterator |
i, |
|
|
const std::exception_ptr & |
error |
|
) |
| |
|
private |
Cancels the item the iterator i is pointing to, advancing the iterator to the next element in the list
Definition at line 180 of file providequeue.cc.
◆ ProvideResourceData
◆ InvalidId
| constexpr uint32_t zyppng::ProvideQueue::InvalidId = (uint32_t) -1 |
|
staticconstexpr |
◆ _queueShuttingDown
| bool zyppng::ProvideQueue::_queueShuttingDown = false |
|
private |
◆ _crashCounter
| uint8_t zyppng::ProvideQueue::_crashCounter = 0 |
|
private |
◆ _capabilities
| Config zyppng::ProvideQueue::_capabilities |
|
private |
◆ _currentExe
◆ _myHostname
| std::string zyppng::ProvideQueue::_myHostname |
|
private |
◆ _parent
◆ _waitQueue
| std::deque< Item > zyppng::ProvideQueue::_waitQueue |
|
private |
◆ _activeItems
| std::list< Item > zyppng::ProvideQueue::_activeItems |
|
private |
◆ _workerProc
| Process::Ptr zyppng::ProvideQueue::_workerProc |
|
private |
◆ _messageStream
◆ _sigIdle
| Signal<void()> zyppng::ProvideQueue::_sigIdle |
|
private |
◆ _idleSince
| std::optional<TimePoint> zyppng::ProvideQueue::_idleSince |
|
private |
The documentation for this class was generated from the following files:
