OSC-receive.c File Reference

#include "OSC-common.h"
#include "OSC-timetag.h"
#include "OSC-address-space.h"
#include "NetworkReturnAddress.h"
#include "OSC-receive.h"
#include "OSC-priority-queue.h"
#include "OSC-string-help.h"
#include "OSC-drop.h"
#include "OSC-dispatch.h"
#include <string.h>
#include "OSC-internal-messages.h"

Classes
struct	OSCPacketBuffer_struct
struct	queuedDataStruct
Defines
#define	NOT_DISPATCHED_YET   ((callbackList) -1)
#define	MIN_REASONABLE_RCV_BUFSIZE   128
Typedefs
typedef struct queuedDataStruct	queuedData
Functions
static Boolean	InitPackets (int receiveBufferSize, int clientAddrSize, int numReceiveBuffers)
static Boolean	InitQueuedData (int numQueuedObjects)
static queuedData *	AllocQD (void)
static void	FreeQD (queuedData *qd)
static void	CallWholeCallbackList (callbackList l, int argLength, void *args, OSCTimeTag when, NetworkReturnAddressPtr returnAddr)
static void	InsertBundleOrMessage (char *buf, int n, OSCPacketBuffer packet, OSCTimeTag enclosingTimeTag)
static void	ParseBundle (queuedData *qd)
static Boolean	ParseMessage (queuedData *qd)
static void	PacketAddRef (OSCPacketBuffer packet)
static void	PacketRemoveRef (OSCPacketBuffer packet)
Boolean	OSCInitReceive (struct OSCReceiveMemoryTuner *t)
char *	OSCPacketBufferGetBuffer (OSCPacketBuffer p)
int *	OSCPacketBufferGetSize (OSCPacketBuffer p)
int	OSCGetReceiveBufferSize (void)
NetworkReturnAddressPtr	OSCPacketBufferGetClientAddr (OSCPacketBuffer p)
OSCPacketBuffer	OSCAllocPacketBuffer (void)
void	OSCFreePacket (OSCPacketBuffer p)
void	OSCAcceptPacket (OSCPacketBuffer packet)
Boolean	OSCBeProductiveWhileWaiting (void)
Boolean	OSCInvokeMessagesThatAreReady (OSCTimeTag now)
void	OSCInvokeAllMessagesThatAreReady (OSCTimeTag now)
Boolean	OSCSendInternalMessage (char *address, int arglen, void *args)
Boolean	OSCSendInternalMessageWithRSVP (char *address, int arglen, void *args, NetworkReturnAddressPtr returnAddr)
Boolean	OSCScheduleInternalMessages (OSCTimeTag when, int numMessages, char **addresses, int *arglens, void **args)
Variables
struct {
OSCQueue   TheQueue
OSCTimeTag   lastTimeTag
Boolean   timePassed
int   recvBufSize
void *(*   InitTimeMalloc )(int numBytes)
void *(*   RealTimeMemoryAllocator )(int numBytes)
}	globals
static struct OSCPacketBuffer_struct *	freePackets
static queuedData *	freeQDList

---

Define Documentation

#define NOT_DISPATCHED_YET   ((callbackList) -1)

Referenced by InsertBundleOrMessage(), OSCBeProductiveWhileWaiting(), and OSCInvokeMessagesThatAreReady().

#define MIN_REASONABLE_RCV_BUFSIZE   128

Referenced by InitPackets().

---

Typedef Documentation

typedef struct queuedDataStruct queuedData

---

Function Documentation

static Boolean InitPackets	(	int	receiveBufferSize,
		int	clientAddrSize,
		int	numReceiveBuffers
	)			[static]

References OSCPacketBuffer_struct::buf, FALSE, fatal_error(), globals, MIN_REASONABLE_RCV_BUFSIZE, OSCPacketBuffer_struct::nextFree, OSCPacketBuffer_struct::returnAddr, and TRUE.

Referenced by OSCInitReceive().

static Boolean InitQueuedData

(

int

numQueuedObjects

)

[static]

References FALSE, globals, queuedDataStruct::nextFree, and TRUE.

Referenced by OSCInitReceive().

static queuedData * AllocQD

(

void

)

[static]

References queuedDataStruct::nextFree, and OSCWarning().

Referenced by InsertBundleOrMessage(), and OSCScheduleInternalMessages().

static void FreeQD

(

queuedData *

qd

)

[static]

References queuedDataStruct::nextFree.

Referenced by InsertBundleOrMessage(), OSCBeProductiveWhileWaiting(), OSCInvokeMessagesThatAreReady(), OSCScheduleInternalMessages(), and ParseBundle().

static void CallWholeCallbackList	(	callbackList	l,
		int	argLength,
		void *	args,
		OSCTimeTag	when,
		NetworkReturnAddressPtr	returnAddr
	)			[static]

References callbackListNode::callback, callbackListNode::context, FreeCallbackListNode(), and callbackListNode::next.

Referenced by OSCInvokeMessagesThatAreReady(), and OSCSendInternalMessageWithRSVP().

static void InsertBundleOrMessage	(	char *	buf,
		int	n,
		OSCPacketBuffer	packet,
		OSCTimeTag	enclosingTimeTag
	)			[static]

References AllocQD(), Boolean, queuedDataStruct::bundle, queuedDataStruct::data, DropBundle(), DropMessage(), FALSE, FreeQD(), globals, queuedDataStruct::message, queuedDataStruct::myPacket, NOT_DISPATCHED_YET, OSCProblem(), OSCQueueInsert(), OSCTT_Compare(), PacketAddRef(), PacketRemoveRef(), queuedDataStruct::timetag, TRUE, and queuedDataStruct::type.

Referenced by OSCAcceptPacket(), and ParseBundle().

static void ParseBundle

(

queuedData *

qd

)

[static]

References queuedDataStruct::bundle, queuedDataStruct::data, DropBundle(), fatal_error(), FreeQD(), InsertBundleOrMessage(), queuedDataStruct::myPacket, OSCProblem(), PacketRemoveRef(), queuedDataStruct::timetag, and queuedDataStruct::type.

Referenced by OSCBeProductiveWhileWaiting(), and OSCInvokeMessagesThatAreReady().

static Boolean ParseMessage

(

queuedData *

qd

)

[static]

References queuedDataStruct::data, DropMessage(), FALSE, fatal_error(), queuedDataStruct::message, queuedDataStruct::myPacket, OSCDataAfterAlignedString(), OSCDispatchMessage(), OSCProblem(), OSCWarning(), TRUE, and queuedDataStruct::type.

Referenced by OSCBeProductiveWhileWaiting(), and OSCInvokeMessagesThatAreReady().

static void PacketAddRef

(

OSCPacketBuffer

packet

)

[static]

References OSCPacketBuffer_struct::refcount.

Referenced by InsertBundleOrMessage(), and OSCScheduleInternalMessages().

static void PacketRemoveRef

(

OSCPacketBuffer

packet

)

[static]

References OSCFreePacket(), and OSCPacketBuffer_struct::refcount.

Referenced by InsertBundleOrMessage(), OSCBeProductiveWhileWaiting(), OSCInvokeMessagesThatAreReady(), and ParseBundle().

Boolean OSCInitReceive

(

struct OSCReceiveMemoryTuner *

t

)

References FALSE, globals, InitCallbackListNodes(), InitPackets(), InitQueuedData(), OSCReceiveMemoryTuner::InitTimeMemoryAllocator, OSCReceiveMemoryTuner::numCallbackListNodes, OSCReceiveMemoryTuner::numQueuedObjects, OSCReceiveMemoryTuner::numReceiveBuffers, OSCNewQueue(), OSCTT_Immediately(), OSCReceiveMemoryTuner::RealTimeMemoryAllocator, OSCReceiveMemoryTuner::receiveBufferSize, SizeOfNetworkReturnAddress(), and TRUE.

char* OSCPacketBufferGetBuffer

(

OSCPacketBuffer

p

)

References OSCPacketBuffer_struct::buf.

Referenced by receiveOSCPacket().

int* OSCPacketBufferGetSize

(

OSCPacketBuffer

p

)

References OSCPacketBuffer_struct::n.

Referenced by receiveOSCPacket().

int OSCGetReceiveBufferSize

(

void

)

References globals.

Referenced by OSCScheduleInternalMessages(), and receiveOSCPacket().

NetworkReturnAddressPtr OSCPacketBufferGetClientAddr

(

OSCPacketBuffer

p

)

References OSCPacketBuffer_struct::returnAddr.

Referenced by receiveOSCPacket().

OSCPacketBuffer OSCAllocPacketBuffer

(

void

)

References OSCPacketBuffer_struct::nextFree, OSCWarning(), and OSCPacketBuffer_struct::refcount.

Referenced by OSCScheduleInternalMessages(), and receiveOSCPacket().

void OSCFreePacket

(

OSCPacketBuffer

p

)

References OSCPacketBuffer_struct::nextFree, OSCWarning(), and OSCPacketBuffer_struct::refcount.

Referenced by PacketRemoveRef(), and receiveOSCPacket().

void OSCAcceptPacket

(

OSCPacketBuffer

packet

)

References OSCPacketBuffer_struct::buf, fatal_error(), globals, InsertBundleOrMessage(), OSCPacketBuffer_struct::n, OSCInvokeAllMessagesThatAreReady(), OSCProblem(), OSCTT_Immediately(), OSCPacketBuffer_struct::refcount, OSCPacketBuffer_struct::returnAddrOK, and TRUE.

Referenced by receiveOSCPacket().

Boolean OSCBeProductiveWhileWaiting

(

void

)

References queuedDataStruct::data, DropMessage(), FALSE, FreeQD(), globals, queuedDataStruct::message, queuedDataStruct::myPacket, NOT_DISPATCHED_YET, OSCQueueRemoveCurrentScanItem(), OSCQueueScanNext(), OSCQueueScanStart(), PacketRemoveRef(), ParseBundle(), ParseMessage(), TRUE, and queuedDataStruct::type.

Boolean OSCInvokeMessagesThatAreReady

(

OSCTimeTag

now

)

References queuedDataStruct::bundle, CallWholeCallbackList(), queuedDataStruct::data, FALSE, fatal_error(), FreeQD(), globals, queuedDataStruct::message, queuedDataStruct::myPacket, NOT_DISPATCHED_YET, OSCQueueEarliestTimeTag(), OSCQueueRemoveEarliest(), OSCTT_Compare(), PacketRemoveRef(), ParseBundle(), ParseMessage(), OSCPacketBuffer_struct::returnAddr, OSCPacketBuffer_struct::returnAddrOK, queuedDataStruct::timetag, TRUE, queuedDataStruct::type, and x.

Referenced by OSCInvokeAllMessagesThatAreReady().

void OSCInvokeAllMessagesThatAreReady

(

OSCTimeTag

now

)

References OSCInvokeMessagesThatAreReady().

Referenced by OSCAcceptPacket().

Boolean OSCSendInternalMessage	(	char *	address,
		int	arglen,
		void *	args
	)

References OSCSendInternalMessageWithRSVP().

Boolean OSCSendInternalMessageWithRSVP	(	char *	address,
		int	arglen,
		void *	args,
		NetworkReturnAddressPtr	returnAddr
	)

References CallWholeCallbackList(), FALSE, OSCDispatchMessage(), OSCTT_Immediately(), and TRUE.

Referenced by OSCSendInternalMessage().

Boolean OSCScheduleInternalMessages	(	OSCTimeTag	when,
		int	numMessages,
		char **	addresses,
		int *	arglens,
		void **	args
	)

References AllocQD(), OSCPacketBuffer_struct::buf, queuedDataStruct::bundle, queuedDataStruct::data, FALSE, fatal_error(), FreeQD(), globals, queuedDataStruct::myPacket, OSCPacketBuffer_struct::n, OSCAllocPacketBuffer(), OSCGetReceiveBufferSize(), OSCPaddedStrcpy(), OSCPaddedStrlen(), OSCQueueInsert(), PacketAddRef(), OSCPacketBuffer_struct::returnAddrOK, queuedDataStruct::timetag, TRUE, and queuedDataStruct::type.

---

Variable Documentation

OSCQueue TheQueue

OSCTimeTag lastTimeTag

Boolean timePassed

int recvBufSize

void*(* InitTimeMalloc)(int numBytes)

void*(* RealTimeMemoryAllocator)(int numBytes)

struct { ... } globals

Referenced by InitPackets(), InitQueuedData(), InsertBundleOrMessage(), OSCAcceptPacket(), OSCBeProductiveWhileWaiting(), OSCGetReceiveBufferSize(), OSCInitReceive(), OSCInvokeMessagesThatAreReady(), and OSCScheduleInternalMessages().

struct OSCPacketBuffer_struct* freePackets [static]

queuedData* freeQDList [static]