asTrapWrite.c File Reference

#include <stdlib.h>
#include <stddef.h>
#include <stdio.h>
#include <string.h>
#include "ellLib.h"
#include "freeList.h"
#include "epicsStdio.h"
#include "cantProceed.h"
#include "epicsMutex.h"
#include "asLib.h"
#include "asTrapWrite.h"

Include dependency graph for asTrapWrite.c:

Go to the source code of this file.

Classes
struct	listenerPvt
struct	listener
struct	writeMessage
struct	asTrapWritePvt

Typedefs
typedef struct listenerPvt	listenerPvt
typedef struct listener	listener
typedef struct writeMessage	writeMessage
typedef struct asTrapWritePvt	asTrapWritePvt

Functions
asTrapWriteId epicsStdCall	asTrapWriteRegisterListener (asTrapWriteListener func)
	Register function to be called on asTrapWriteListener. More...
void epicsStdCall	asTrapWriteUnregisterListener (asTrapWriteId id)
	Unregister asTrapWriteListener. More...
void *epicsStdCall	asTrapWriteBeforeWithData (const char *userid, const char *hostid, void *addr, int dbrType, int no_elements, void *data)
void epicsStdCall	asTrapWriteAfterWrite (void *pvt)

Typedef Documentation

typedef struct asTrapWritePvt asTrapWritePvt

typedef struct listener listener

typedef struct listenerPvt listenerPvt

typedef struct writeMessage writeMessage

Function Documentation

void epicsStdCall asTrapWriteAfterWrite

(

void *

pvt

)

Definition at line 151 of file asTrapWrite.c.

{
    writeMessage *pwriteMessage = (writeMessage *)pvt;
    listenerPvt *plistenerPvt;

    if (pwriteMessage == 0 ||
        pasTrapWritePvt == 0) return;

    epicsMutexMustLock(pasTrapWritePvt->lock);
    plistenerPvt = (listenerPvt *)ellFirst(&pwriteMessage->listenerPvtList);
    while (plistenerPvt) {
        listenerPvt *pnext = (listenerPvt *)ellNext(&plistenerPvt->node);
        listener *plistener = plistenerPvt->plistener;

        pwriteMessage->message.userPvt = plistenerPvt->userPvt;
        plistener->func(&pwriteMessage->message, 1);
        ellDelete(&pwriteMessage->listenerPvtList, &plistenerPvt->node);
        freeListFree(pasTrapWritePvt->freeListListenerPvt, plistenerPvt);
        plistenerPvt = pnext;
    }
    ellDelete(&pasTrapWritePvt->writeMessageList, &pwriteMessage->node);
    freeListFree(pasTrapWritePvt->freeListWriteMessage, pwriteMessage);
    epicsMutexUnlock(pasTrapWritePvt->lock);
}

void* epicsStdCall asTrapWriteBeforeWithData	(	const char *	userid,
		const char *	hostid,
		void *	addr,
		int	dbrType,
		int	no_elements,
		void *	data
	)

Definition at line 113 of file asTrapWrite.c.

{
    writeMessage *pwriteMessage;
    listener *plistener;

    if (pasTrapWritePvt == 0 ||
        ellCount(&pasTrapWritePvt->listenerList) <= 0) return 0;

    pwriteMessage = (writeMessage *)freeListCalloc(
        pasTrapWritePvt->freeListWriteMessage);
    pwriteMessage->message.userid = userid;
    pwriteMessage->message.hostid = hostid;
    pwriteMessage->message.serverSpecific = addr;
    pwriteMessage->message.dbrType = dbrType;
    pwriteMessage->message.no_elements = no_elements;
    pwriteMessage->message.data = data;
    ellInit(&pwriteMessage->listenerPvtList);

    epicsMutexMustLock(pasTrapWritePvt->lock);
    ellAdd(&pasTrapWritePvt->writeMessageList, &pwriteMessage->node);
    plistener = (listener *)ellFirst(&pasTrapWritePvt->listenerList);
    while (plistener) {
        listenerPvt *plistenerPvt = (listenerPvt *)freeListCalloc(
            pasTrapWritePvt->freeListListenerPvt);

        plistenerPvt->plistener = plistener;
        pwriteMessage->message.userPvt = 0;
        plistener->func(&pwriteMessage->message, 0);
        plistenerPvt->userPvt = pwriteMessage->message.userPvt;
        ellAdd(&pwriteMessage->listenerPvtList, &plistenerPvt->node);
        plistener = (listener *)ellNext(&plistener->node);
    }
    epicsMutexUnlock(pasTrapWritePvt->lock);
    return pwriteMessage;
}

asTrapWriteId epicsStdCall asTrapWriteRegisterListener

(

asTrapWriteListener

func

)

Register function to be called on asTrapWriteListener.

Parameters

func	The listener function to be called.

Returns

A listener identifier for unregistering this listener.

Definition at line 73 of file asTrapWrite.c.

{
    listener *plistener;
    if(pasTrapWritePvt==0) asTrapWriteInit();
    plistener = callocMustSucceed(1,sizeof(listener),"asTrapWriteRegisterListener");
    plistener->func = func;
    epicsMutexMustLock(pasTrapWritePvt->lock);
    ellAdd(&pasTrapWritePvt->listenerList,&plistener->node);
    epicsMutexUnlock(pasTrapWritePvt->lock);
    return((asTrapWriteId)plistener);
}

void epicsStdCall asTrapWriteUnregisterListener

(

asTrapWriteId

id

)

Unregister asTrapWriteListener.

Parameters

id	Listener identifier from asTrapWriteRegisterListener().

Definition at line 86 of file asTrapWrite.c.

{
    listener *plistener = (listener *)id;
    writeMessage *pwriteMessage;

    if(pasTrapWritePvt==0) return;
    epicsMutexMustLock(pasTrapWritePvt->lock);
    pwriteMessage = (writeMessage *)ellFirst(&pasTrapWritePvt->writeMessageList);
    while(pwriteMessage) {
        listenerPvt *plistenerPvt
             = (listenerPvt *)ellFirst(&pwriteMessage->listenerPvtList);
        while(plistenerPvt) {
            listenerPvt *pnext
                 = (listenerPvt *)ellNext(&plistenerPvt->node);
            if(plistenerPvt->plistener == plistener) {
                ellDelete(&pwriteMessage->listenerPvtList,&plistenerPvt->node);
                freeListFree(pasTrapWritePvt->freeListListenerPvt, plistenerPvt);
            }
            plistenerPvt = pnext;
        }
        pwriteMessage = (writeMessage *)ellNext(&pwriteMessage->node);
    }
    ellDelete(&pasTrapWritePvt->listenerList,&plistener->node);
    free(plistener);
    epicsMutexUnlock(pasTrapWritePvt->lock);
}