10 #ifndef ZYPP_MEDIA_PROVIDE_WORKER_H_INCLUDED 11 #define ZYPP_MEDIA_PROVIDE_WORKER_H_INCLUDED 13 #include <zypp-core/zyppng/base/Base> 14 #include <zypp-core/zyppng/base/EventLoop> 15 #include <zypp-core/zyppng/base/Timer> 16 #include <zypp-core/zyppng/io/AsyncDataSource> 17 #include <zypp-core/zyppng/rpc/MessageStream> 18 #include <zypp-core/zyppng/pipelines/Expected> 21 #include <zypp-media/ng/HeaderValueMap> 22 #include <zypp-media/MediaException> 23 #include <zypp-media/Mount> 25 #include <string_view> 97 MediaChangeRes requestMediaChange (
const uint32_t
id,
const std::string &label,
const int32_t mediaNr,
const std::vector<std::string> &devices,
const std::optional<std::string> &desc = {} );
119 virtual void cancel (
const std::deque<ProvideWorkerItemRef>::iterator &request ) = 0;
127 virtual ProvideWorkerItemRef
makeItem (ProvideMessage &&spec );
151 void provideFailed (
const uint32_t
id,
const uint code,
const std::string &reason,
const bool transient,
const HeaderValueMap extra = {} );
163 void attachSuccess (
const uint32_t
id,
const std::optional<std::string> &localMountPoint = {} );
193 expected<ProvideMessage>
sendAndWaitForResponse (
const ProvideMessage &request,
const std::vector<uint> &responseCodes );
ProvideNotificatioMode provNotificationMode() const
ProvideNotificatioMode _provNotificationMode
void pushSingleMessage(const RpcMessage &msg)
std::exception_ptr _fatalError
virtual void cancel(const std::deque< ProvideWorkerItemRef >::iterator &request)=0
Timer::Ptr _delayedShutdown
expected< ProvideMessage > parseReceivedMessage(const RpcMessage &m)
void maybeDelayedShutdown()
expected< void > run(int recv=STDIN_FILENO, int send=STDOUT_FILENO)
RpcMessageStream::Ptr _stream
void readFdClosed(uint, AsyncDataSource::ChannelCloseReason)
std::string_view _workerName
void provideStart(const uint32_t id, const zypp::Url &url, const zypp::Pathname &localFile, const zypp::Pathname &stagingFile={})
bool _inControllerRequest
void provideFailed(const uint32_t id, const uint code, const std::string &reason, const bool transient, const HeaderValueMap extra={})
MediaChangeRes requestMediaChange(const uint32_t id, const std::string &label, const int32_t mediaNr, const std::vector< std::string > &devices, const std::optional< std::string > &desc={})
void invalidMessageReceived(std::exception_ptr p)
ProviderConfiguration _workerConf
expected< ProvideMessage > sendAndWaitForResponse(const ProvideMessage &request, const std::vector< uint > &responseCodes)
void setProvNotificationMode(const ProvideNotificatioMode &provNotificationMode)
virtual void immediateShutdown()
zyppng::WorkerCaps WorkerCaps
ProvideWorker(std::string_view workerName)
void messageLoop(Timer &)
virtual ProvideWorkerItemRef makeItem(ProvideMessage &&spec)
AsyncDataSource & controlIO()
void redirect(const uint32_t id, const zypp::Url &url, const zypp::Pathname &newPath)
expected< void > executeHandshake()
ProvideWorkerItem(ProvideMessage &&spec)
RpcMessageStream::Ptr messageStream() const
int64_t last_auth_timestamp
std::deque< ProvideWorkerItemRef > & requestQueue()
std::shared_ptr< Timer > Ptr
static std::shared_ptr< Timer > create()
Creates a new Timer object, the timer is not started at this point.
std::map< std::string, std::string > extraKeys
void attachSuccess(const uint32_t id, const std::optional< std::string > &localMountPoint={})
Base class for Exception.
void handleSingleMessage(const ProvideMessage &provide)
ZYPP_FWD_DECL_TYPE_WITH_REFS(DeviceDriver)
zyppng::ProviderConfiguration Configuration
AsyncDataSource::Ptr _controlIO
void detachSuccess(const uint32_t id)
void onInvalidMessageReceived()
expected< AuthInfo > requireAuthorization(const uint32_t id, const zypp::Url &url, const std::string &lastTriedUsername="", const int64_t lastTimestamp=-1, const std::map< std::string, std::string > &extraFields={})
void writeFdClosed(AsyncDataSource::ChannelCloseReason)
std::deque< ProvideWorkerItemRef > _pendingProvides
void provideSuccess(const uint32_t id, bool cacheHit, const zypp::Pathname &localFile, const HeaderValueMap extra={})
std::deque< ProvideMessage > _pendingMessages
virtual expected< WorkerCaps > initialize(const Configuration &conf)=0
std::shared_ptr< AsyncDataSource > Ptr
std::shared_ptr< RpcMessageStream > Ptr