141 lines
4.0 KiB
C++
141 lines
4.0 KiB
C++
/*
|
|
* Copyright information and license terms for this software can be
|
|
* found in the file LICENSE that is included with the distribution
|
|
*/
|
|
|
|
/**
|
|
* @author mrk
|
|
* @date 2021.03.12
|
|
*/
|
|
#include <iocsh.h>
|
|
#include <pv/standardField.h>
|
|
#include <pv/standardPVField.h>
|
|
#include <pv/timeStamp.h>
|
|
#include <pv/pvTimeStamp.h>
|
|
#include <pv/alarm.h>
|
|
#include <pv/pvAlarm.h>
|
|
#include <pv/pvAccess.h>
|
|
#include <pv/serverContext.h>
|
|
|
|
#include <epicsExport.h>
|
|
#define epicsExportSharedSymbols
|
|
#include "pv/pvStructureCopy.h"
|
|
#include "pv/channelProviderLocal.h"
|
|
#include "pv/pvDatabase.h"
|
|
using namespace epics::pvData;
|
|
using namespace epics::pvAccess;
|
|
using namespace epics::pvDatabase;
|
|
using namespace std;
|
|
|
|
class PvdbcrRemoveRecord;
|
|
typedef std::tr1::shared_ptr<PvdbcrRemoveRecord> PvdbcrRemoveRecordPtr;
|
|
|
|
|
|
class epicsShareClass PvdbcrRemoveRecord :
|
|
public PVRecord
|
|
{
|
|
public:
|
|
POINTER_DEFINITIONS(PvdbcrRemoveRecord);
|
|
static PvdbcrRemoveRecordPtr create(
|
|
std::string const & recordName);
|
|
virtual bool init();
|
|
virtual void process();
|
|
private:
|
|
PvdbcrRemoveRecord(
|
|
std::string const & recordName,
|
|
epics::pvData::PVStructurePtr const & pvStructure);
|
|
epics::pvData::PVStringPtr pvRecordName;
|
|
epics::pvData::PVStringPtr pvResult;
|
|
};
|
|
|
|
PvdbcrRemoveRecordPtr PvdbcrRemoveRecord::create(
|
|
std::string const & recordName)
|
|
{
|
|
FieldCreatePtr fieldCreate = getFieldCreate();
|
|
PVDataCreatePtr pvDataCreate = getPVDataCreate();
|
|
StructureConstPtr topStructure = fieldCreate->createFieldBuilder()->
|
|
addNestedStructure("argument")->
|
|
add("recordName",pvString)->
|
|
endNested()->
|
|
addNestedStructure("result") ->
|
|
add("status",pvString) ->
|
|
endNested()->
|
|
createStructure();
|
|
PVStructurePtr pvStructure = pvDataCreate->createPVStructure(topStructure);
|
|
PvdbcrRemoveRecordPtr pvRecord(
|
|
new PvdbcrRemoveRecord(recordName,pvStructure));
|
|
if(!pvRecord->init()) pvRecord.reset();
|
|
return pvRecord;
|
|
}
|
|
|
|
PvdbcrRemoveRecord::PvdbcrRemoveRecord(
|
|
std::string const & recordName,
|
|
epics::pvData::PVStructurePtr const & pvStructure)
|
|
: PVRecord(recordName,pvStructure)
|
|
{
|
|
}
|
|
|
|
bool PvdbcrRemoveRecord::init()
|
|
{
|
|
initPVRecord();
|
|
PVStructurePtr pvStructure = getPVStructure();
|
|
pvRecordName = pvStructure->getSubField<PVString>("argument.recordName");
|
|
if(!pvRecordName) return false;
|
|
pvResult = pvStructure->getSubField<PVString>("result.status");
|
|
if(!pvResult) return false;
|
|
return true;
|
|
}
|
|
|
|
void PvdbcrRemoveRecord::process()
|
|
{
|
|
string name = pvRecordName->get();
|
|
PVRecordPtr pvRecord = PVDatabase::getMaster()->findRecord(name);
|
|
if(!pvRecord) {
|
|
pvResult->put(name + " not found");
|
|
return;
|
|
}
|
|
pvRecord->remove();
|
|
pvResult->put("success");
|
|
}
|
|
|
|
static const iocshArg arg0 = { "recordName", iocshArgString };
|
|
static const iocshArg arg1 = { "asLevel", iocshArgInt };
|
|
static const iocshArg arg2 = { "asGroup", iocshArgString };
|
|
static const iocshArg *args[] = {&arg0,&arg1,&arg2};
|
|
|
|
static const iocshFuncDef pvdbcrRemoveRecordFuncDef = {"pvdbcrRemoveRecord", 3,args};
|
|
|
|
static void pvdbcrRemoveRecordCallFunc(const iocshArgBuf *args)
|
|
{
|
|
char *sval = args[0].sval;
|
|
if(!sval) {
|
|
throw std::runtime_error("pvdbcrRemoveRecord recordName not specified");
|
|
}
|
|
string recordName = string(sval);
|
|
int asLevel = args[1].ival;
|
|
string asGroup("DEFAULT");
|
|
sval = args[2].sval;
|
|
if(sval) {
|
|
asGroup = string(sval);
|
|
}
|
|
PvdbcrRemoveRecordPtr record = PvdbcrRemoveRecord::create(recordName);
|
|
record->setAsLevel(asLevel);
|
|
record->setAsGroup(asGroup);
|
|
PVDatabasePtr master = PVDatabase::getMaster();
|
|
bool result = master->addRecord(record);
|
|
if(!result) cout << "recordname " << recordName << " not added" << endl;
|
|
}
|
|
|
|
static void pvdbcrRemoveRecordRegister(void)
|
|
{
|
|
static int firstTime = 1;
|
|
if (firstTime) {
|
|
firstTime = 0;
|
|
iocshRegister(&pvdbcrRemoveRecordFuncDef, pvdbcrRemoveRecordCallFunc);
|
|
}
|
|
}
|
|
|
|
extern "C" {
|
|
epicsExportRegistrar(pvdbcrRemoveRecordRegister);
|
|
}
|