ntpShm.cpp File Reference

#include <stdio.h>
#include <errno.h>
#include <sys/ipc.h>
#include <sys/shm.h>
#include <sys/time.h>
#include <epicsTime.h>
#include <epicsVersion.h>
#include <epicsMutex.h>
#include <epicsThread.h>
#include <epicsStdio.h>
#include <callback.h>
#include <drvSup.h>
#include <recGbl.h>
#include <longinRecord.h>
#include <aiRecord.h>
#include <menuConvert.h>
#include <dbScan.h>
#include <iocsh.h>
#include <initHooks.h>
#include "evr/evr.h"
#include <epicsExport.h>

Include dependency graph for ntpShm.cpp:

Go to the source code of this file.

Classes
struct	shmSegment
struct	ntpShmPriv
struct	commonset

Macros
#define	SYNC()   do{}while(0)
#define	NTPD_SEG0   0x4E545030
#define	RETRY_TIME   30.0

Functions
void	time2ntp (const char *evrname, int segid, int event)
	epicsExportAddress (drvet, ntpShared)
	epicsExportAddress (dset, devNtpShmLiOk)
	epicsExportAddress (dset, devNtpShmLiFail)
	epicsExportAddress (dset, devNtpShmAiDelta)
	epicsExportRegistrar (ntpShmRegister)

Macro Definition Documentation

NTPD_SEG0

#define NTPD_SEG0   0x4E545030

Definition at line 68 of file ntpShm.cpp.

RETRY_TIME

#define RETRY_TIME   30.0

Definition at line 70 of file ntpShm.cpp.

SYNC

#define SYNC

(

)

do{}while(0)

Definition at line 64 of file ntpShm.cpp.

Function Documentation

epicsExportAddress() [1/4]

epicsExportAddress	(	drvet	,
		ntpShared
	)

epicsExportAddress() [2/4]

epicsExportAddress	(	dset	,
		devNtpShmLiOk
	)

epicsExportAddress() [3/4]

epicsExportAddress	(	dset	,
		devNtpShmLiFail
	)

epicsExportAddress() [4/4]

epicsExportAddress	(	dset	,
		devNtpShmAiDelta
	)

epicsExportRegistrar()

epicsExportRegistrar

(

ntpShmRegister

)

time2ntp()

void time2ntp	(	const char *	evrname,
		int	segid,
		int	event
	)

Definition at line 266 of file ntpShm.cpp.

{
    try {
        if(event==0)
            event = MRF_EVENT_TS_COUNTER_RST;
        else if(event<=0 || event >255) {
            fprintf(stderr, "Invalid 1Hz event # %d\n", event);
            return;
        }
        if(segid<0 || segid>4) {
            fprintf(stderr, "Invalid segment ID %d\n", segid);
            return;
        }
        mrf::Object *obj = mrf::Object::getObject(evrname);
        if(!obj) {
            fprintf(stderr, "Unknown EVR: %s\n", evrname);
            return;
        }

        EVR *evr = dynamic_cast<EVR*>(obj);
        if(!evr) {
            fprintf(stderr, "\"%s\" is not an EVR\n", evrname);
            return;
        }

        epicsThreadOnce(&ntponce, &ntpshminit, 0);

        epicsMutexMustLock(ntpShm.ntplock);

        if(ntpShm.evr) {
            epicsMutexUnlock(ntpShm.ntplock);
            fprintf(stderr, "ntpShm already initialized.\n");
            return;
        }

        ntpShm.event = event;
        ntpShm.evr = evr;
        ntpShm.segid = segid;

        epicsMutexUnlock(ntpShm.ntplock);
    } catch(std::exception& e) {
        fprintf(stderr, "Error: %s\n", e.what());
    }
}