EPICS_driver_modules/StreamDevice
0
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

add new utility function streamReportRecord

Browse Source
This commit is contained in:
zimoch
2018-03-20 17:33:53 +01:00
parent 943787bc0c
commit a9e0fb7beb
1 changed files with 48 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

55
src/StreamEpics.cc
View File

@ -60,6 +60,7 @@ extern DBBASE *pdbbase;
#include <epicsEvent.h> #include <epicsEvent.h>
#include <epicsTime.h> #include <epicsTime.h>
#include <epicsThread.h> #include <epicsThread.h>
#include <epicsString.h>
#include <registryFunction.h> #include <registryFunction.h>
#include <iocsh.h> #include <iocsh.h>
@ -92,7 +93,8 @@ enum MoreFlags {
extern "C" void streamExecuteCommand(CALLBACK *pcallback); extern "C" void streamExecuteCommand(CALLBACK *pcallback);
extern "C" void streamRecordProcessCallback(CALLBACK *pcallback); extern "C" void streamRecordProcessCallback(CALLBACK *pcallback);
extern "C" long streamReload(char* recordname); extern "C" long streamReload(const char* recordname);
extern "C" long streamReportRecord(const char* recordname);
class Stream : protected StreamCore class Stream : protected StreamCore
#ifndef EPICS_3_13 #ifndef EPICS_3_13
@ -144,6 +146,7 @@ class Stream : protected StreamCore
bool execute(); bool execute();
friend void streamExecuteCommand(CALLBACK *pcallback); friend void streamExecuteCommand(CALLBACK *pcallback);
friend void streamRecordProcessCallback(CALLBACK *pcallback); friend void streamRecordProcessCallback(CALLBACK *pcallback);
friend long streamReportRecord(const char* recordname);
// Stream Epics methods // Stream Epics methods
Stream(dbCommon* record, const struct link *ioLink, Stream(dbCommon* record, const struct link *ioLink,
@ -166,7 +169,7 @@ class Stream : protected StreamCore
friend long streamPrintf(dbCommon *record, format_t *format, ...); friend long streamPrintf(dbCommon *record, format_t *format, ...);
friend long streamScanfN(dbCommon *record, format_t *format, friend long streamScanfN(dbCommon *record, format_t *format,
void*, size_t maxStringSize); void*, size_t maxStringSize);
friend long streamReload(char* recordname); friend long streamReload(const char* recordname);
public: public:
long priority() { return record->prio; }; long priority() { return record->prio; };
@ -183,12 +186,12 @@ epicsExportAddress(int, streamDebug);
#endif #endif
// for subroutine record // for subroutine record
extern "C" long streamReloadSub() long streamReloadSub()
{ {
return streamReload(NULL); return streamReload(NULL);
} }
extern "C" long streamReload(char* recordname) long streamReload(const char* recordname)
{ {
DBENTRY dbentry; DBENTRY dbentry;
dbCommon* record; dbCommon* record;
@ -240,17 +243,30 @@ static const iocshArg streamReloadArg0 =
{ "recordname", iocshArgString }; { "recordname", iocshArgString };
static const iocshArg * const streamReloadArgs[] = static const iocshArg * const streamReloadArgs[] =
{ &streamReloadArg0 }; { &streamReloadArg0 };
static const iocshFuncDef reloadDef = static const iocshFuncDef streamReloadDef =
{ "streamReload", 1, streamReloadArgs }; { "streamReload", 1, streamReloadArgs };
extern "C" void streamReloadFunc (const iocshArgBuf *args) void streamReloadFunc (const iocshArgBuf *args)
{ {
streamReload(args[0].sval); streamReload(args[0].sval);
} }
static const iocshArg streamReportRecordArg0 =
{ "recordname", iocshArgString };
static const iocshArg * const streamReportRecordArgs[] =
{ &streamReportRecordArg0 };
static const iocshFuncDef streamReportRecordDef =
{ "streamReportRecord", 1, streamReportRecordArgs };
void streamReportRecordFunc (const iocshArgBuf *args)
{
streamReportRecord(args[0].sval);
}
static void streamRegistrar () static void streamRegistrar ()
{ {
iocshRegister(&reloadDef, streamReloadFunc); iocshRegister(&streamReloadDef, streamReloadFunc);
iocshRegister(&streamReportRecordDef, streamReportRecordFunc);
// make streamReload available for subroutine records // make streamReload available for subroutine records
registryFunctionAdd("streamReload", registryFunctionAdd("streamReload",
(REGISTRYFUNCTION)streamReloadSub); (REGISTRYFUNCTION)streamReloadSub);
@ -359,6 +375,31 @@ report(int interest)
return OK; return OK;
} }
long streamReportRecord(const char* recordname)
{
Stream* pstream;
for (pstream = static_cast<Stream*>(Stream::first); pstream;
pstream = static_cast<Stream*>(pstream->next))
{
if (!recordname ||
#ifdef EPICS_3_13
strcmp(pstream->name(), recordname) == 0)
#else
epicsStrGlobMatch(pstream->name(), recordname))
#endif
{
printf("%s: %s\n", pstream->name(),
pstream->ioLink->value.instio.string);
StreamBuffer buffer;
pstream->printStatus(buffer);
printf("%s\n", buffer());
pstream->printProtocol();
printf("\n");
}
}
return OK;
}
long Stream:: long Stream::
drvInit() drvInit()
{ {