21 #undef ZYPP_BASE_LOGGER_LOGGROUP 22 #define ZYPP_BASE_LOGGER_LOGGROUP "zypp::plugin" 57 DBG <<
"+++++++++++++++ load " << pi << endl;
60 std::list<Pathname> entries;
63 WAR <<
"Plugin dir is not readable: " << pi << endl;
66 for_( it, entries.begin(), entries.end() )
78 WAR <<
"Plugin file is not executable: " << pi << endl;
82 WAR <<
"Plugin path is neither dir nor file: " << pi << endl;
84 DBG <<
"--------------- load " << pi << endl;
89 DBG <<
"+++++++++++++++ send " << frame_r << endl;
98 DBG <<
"--------------- send " << frame_r << endl;
108 MIL <<
"Load plugin: " << pi_r << endl;
118 if ( plugin.isOpen() )
123 WAR <<
"Failed to load plugin " << pi_r << endl;
132 script_r.
send( frame_r );
144 WAR <<
"Bad plugin response from " << script_r <<
": " << ret << endl;
162 : _pimpl( new
Impl() )
PluginExecutor()
Default ctor: Empty plugin list.
Impl & operator=(const Impl &)=delete
const Pathname & path() const
Return current Pathname.
size_t size() const
Number of open plugins.
static ZConfig & instance()
Singleton ctor.
Command frame for communication with PluginScript.
const std::string & command() const
Return the frame command.
#define for_(IT, BEG, END)
Convenient for-loops using iterator.
Parallel execution of stateful PluginScripts.
String related utilities and Regular expression matching.
const Pathname & script() const
Return the script path if set.
std::ostream & operator<<(std::ostream &str, const SerialNumber &obj)
PluginFrame receive() const
Receive a PluginFrame.
bool empty() const
Whether no plugins are waiting.
PluginFrame doSend(PluginScript &script_r, const PluginFrame &frame_r)
~PluginExecutor()
Dtor: Send PLUGINEND and close all plugins.
bool isEnomethodCommand() const
Convenience to identify an _ENOMETHOD command.
std::list< PluginScript > _scripts
static const std::string & enomethodCommand()
"_ENOMETHOD" command.
void send(const PluginFrame &frame_r)
Send PluginFrame to all open plugins.
void send(const PluginFrame &frame_r) const
Send a PluginFrame.
std::string asUserHistory() const
A single (multiline) string composed of asUserString and historyAsString.
void load(const Pathname &path_r)
void send(const PluginFrame &frame_r)
static const std::string & ackCommand()
"ACK" command.
void open()
Setup connection and execute script.
int readdir(std::list< std::string > &retlist_r, const Pathname &path_r, bool dots_r)
Return content of directory via retlist.
bool isAckCommand() const
Convenience to identify an ACK command.
#define ZYPP_CAUGHT(EXCPT)
Drops a logline telling the Exception was caught (in order to handle it).
RW_pointer< Impl > _pimpl
Implementation class.
int close()
Close any open connection.
Base class for Exception.
void load(const Pathname &path_r)
Find and launch plugins sending PLUGINBEGIN.
PluginExecutor implementation.
void doLoad(const PathInfo &pi_r)
Launch a plugin sending PLUGINSTART message.
Wrapper class for ::stat/::lstat.
void setHeader(const std::string &key_r, const std::string &value_r=std::string())
Set header for key_r removing all other occurrences of key_r.
Interface to plugin scripts using a Stomp inspired communication protocol.
Easy-to use interface to the ZYPP dependency resolver.
const std::list< PluginScript > scripts() const
boost::noncopyable NonCopyable
Ensure derived classes cannot be copied.