Michael Davidsaver
96 lines
2.3 KiB
C++
96 lines
2.3 KiB
C++
/**
|
|
* Copyright - See the COPYRIGHT that is included with this distribution.
|
|
* pvxs is distributed subject to a Software License Agreement found
|
|
* in file LICENSE that is included with this distribution.
|
|
*/
|
|
|
|
#include <iostream>
|
|
#include <typeinfo>
|
|
#include <set>
|
|
#include <string>
|
|
|
|
#include <epicsEvent.h>
|
|
|
|
#include <pvxs/server.h>
|
|
#include <pvxs/data.h>
|
|
#include <pvxs/nt.h>
|
|
#include <pvxs/log.h>
|
|
|
|
|
|
namespace {
|
|
using namespace pvxs;
|
|
using namespace pvxs::server;
|
|
|
|
DEFINE_LOGGER(dummy,"dummyserv");
|
|
|
|
const Value mytype = nt::NTScalar{TypeCode::Int32}.build().create();
|
|
|
|
struct DummyHandler : public Handler
|
|
{
|
|
virtual ~DummyHandler() {}
|
|
|
|
virtual void onIntrospect(std::unique_ptr<Introspect> &&op) override final
|
|
{
|
|
op->reply(mytype);
|
|
//op->error("Got nothing");
|
|
}
|
|
};
|
|
|
|
struct DummySource : public Source
|
|
{
|
|
std::set<std::string> names;
|
|
virtual ~DummySource() {}
|
|
|
|
// Source interface
|
|
public:
|
|
virtual void onSearch(Search &search) override final
|
|
{
|
|
for(auto& op : search) {
|
|
if(names.find(op.name())!=names.end()) {
|
|
log_printf(dummy, PLVL_INFO, "Claiming '%s'\n", op.name());
|
|
op.claim();
|
|
} else {
|
|
log_printf(dummy, PLVL_DEBUG, "Ignoring '%s'\n", op.name());
|
|
}
|
|
}
|
|
}
|
|
virtual void onCreate(std::unique_ptr<ChannelControl>&& op) override final
|
|
{
|
|
log_printf(dummy, PLVL_INFO, "Create '%s'\n", op->name.c_str());
|
|
op->setHandler(std::unique_ptr<Handler>{new DummyHandler});
|
|
}
|
|
};
|
|
|
|
} // namespace
|
|
|
|
int main(int argc, char *argv[])
|
|
{
|
|
int ret = 0;
|
|
try {
|
|
pvxs::logger_level_set("dummy", PLVL_INFO);
|
|
pvxs::logger_config_env();
|
|
|
|
std::shared_ptr<DummySource> src(new DummySource);
|
|
src->names.emplace("blah");
|
|
|
|
auto serv = Server::Config::from_env()
|
|
.build()
|
|
.addSource("dummy", src);
|
|
|
|
auto& conf = serv.config();
|
|
|
|
std::cout<<"Serving from :\n";
|
|
for(auto& iface : conf.interfaces) {
|
|
std::cout<<" "<<iface<<"\n";
|
|
}
|
|
|
|
serv.run();
|
|
|
|
}catch(std::exception& e){
|
|
std::cerr<<"Error "<<typeid(&e).name()<<" : "<<e.what()<<std::endl;
|
|
ret = 1;
|
|
}
|
|
pvxs::cleanup_for_valgrind();
|
|
return ret;
|
|
}
|