rveppserver.c

h.248协议源码

#if (0)
******************************************************************************
Filename   :
Description:
******************************************************************************
                Copyright (c) 1999 RADVision Inc.
************************************************************************
NOTICE:
This document contains information that is proprietary to RADVision LTD.
No part of this publication may be reproduced in any form whatsoever 
without written prior approval by RADVision LTD..

RADVision LTD. reserves the right to revise this publication and make 
changes without obligation to notify any person of such revisions or 
changes.
******************************************************************************
$Revision:$
$Date:$
$Author: S. Cipolli$
******************************************************************************
#endif
#include <string.h>
#include <stdio.h>
#include <stdlib.h>
#include "rvstr.h"
#include "rvlog.h"
#include "rveppserver.h"

static void rvEppServerWrapper(RvThread* t, void* data) {
	static const char* ack = "reply ack";
	static const char* nak = "reply nak";
	RvEppServer* es = (RvEppServer*)data;
	char msg[256];
	char* command;
	RvSocketAddr fromAddr;
	RvStrTok tokenizer;

	while (!es->done) {
		
		int len = rvSocketRecvFrom(&es->s, msg, sizeof(msg), &fromAddr);
		if (len < 0)
			continue;

		msg[len] = '\0';
#ifndef RV_IO_NONE
		printf("Received request: %s\n", msg);
#endif		
		rvStrTokConstruct(&tokenizer, " \t\n", msg);
		command = rvStrTokGetToken(&tokenizer);

		if (strcmp(command, "open") == 0) {
			RvEppConnId connId;
                        char*  termId;
			RvEppConnParameters cp;
			char* connParamsStr;

			termId = rvStrTokGetToken(&tokenizer);
			connParamsStr = rvStrTokGetToken(&tokenizer);

			if (connParamsStr)
				rvEppConnParametersConstructDecode(&cp, connParamsStr);
			else
				rvEppConnParametersConstruct(&cp);

			if ((connId = es->eOpen(es, termId, &cp)) > 0) {
				sprintf(msg, "reply %d", connId);
				rvSocketSendTo(&es->s, msg, strlen(msg), &fromAddr);
			} else {
				rvSocketSendTo(&es->s, nak, strlen(nak), &fromAddr);
			}
			
		} else if (strcmp(command, "modify") == 0) {
			RvEppConnId connId = atoi(rvStrTokGetToken(&tokenizer));
			RvEppConnParameters cp;
			char* connParamsStr = rvStrTokGetToken(&tokenizer);

			if (connParamsStr)
				rvEppConnParametersConstructDecode(&cp, connParamsStr);
			else
				rvEppConnParametersConstruct(&cp);

			if ((connId > 0) && es->eModify(es, connId, &cp)) {
				rvSocketSendTo(&es->s, ack, strlen(ack), &fromAddr);			
			} else {
				rvSocketSendTo(&es->s, nak, strlen(nak), &fromAddr);
			}
			
		} else if (strcmp(command, "getport") == 0) { /* Deprecated */
			RvEppConnId connId = atoi(rvStrTokGetToken(&tokenizer));
			if (connId > 0) {
				char propertyValue[32], id[32];
				sprintf(id, "%d", connId);
				if (es->eQuery(es, id, "port", propertyValue)) {
					sprintf(msg, "reply %s", propertyValue);
					rvSocketSendTo(&es->s, msg, strlen(msg), &fromAddr);
				} else {
					rvSocketSendTo(&es->s, nak, strlen(nak), &fromAddr);
				}
			} else {
				rvSocketSendTo(&es->s, nak, strlen(nak), &fromAddr);
			}
			
		} else if (strcmp(command, "query") == 0) {
			char* termConnId;
			char propertyValue[128];
			char* propertyName;

			termConnId = rvStrTokGetToken(&tokenizer);
			propertyName = rvStrTokGetToken(&tokenizer);
				if (es->eQuery(es, termConnId, propertyName, propertyValue)) {
				sprintf(msg, "reply %s", propertyValue);
				rvSocketSendTo(&es->s, msg, strlen(msg), &fromAddr);
			} else {
				rvSocketSendTo(&es->s, nak, strlen(nak), &fromAddr);
			}
			
		} else if (strcmp(command, "set") == 0) {
			char* termId;
			char* propertyName;
			char* propertyValue;
			termId = rvStrTokGetToken(&tokenizer);
			propertyName = rvStrTokGetToken(&tokenizer);
			propertyValue = rvStrTokGetToken(&tokenizer);

			if (es->eSet(es, termId, propertyName, propertyValue)) {
				rvSocketSendTo(&es->s, ack, strlen(ack), &fromAddr);
			} else {
				rvSocketSendTo(&es->s, nak, strlen(nak), &fromAddr);
			}
			
		} else if (strcmp(command, "start") == 0) {
			char* termId;
			char* signal;
			termId = rvStrTokGetToken(&tokenizer);
			signal = rvStrTokGetToken(&tokenizer);

			if (es->eStart(es, termId, signal)) {
				rvSocketSendTo(&es->s, ack, strlen(ack), &fromAddr);
			} else {
				rvSocketSendTo(&es->s, nak, strlen(nak), &fromAddr);
			}
			
		} else if (strcmp(command, "stop") == 0) {
			char* termId;
			char* signal;
			termId = rvStrTokGetToken(&tokenizer);
			signal = rvStrTokGetToken(&tokenizer);

			if (es->eStop(es, termId, signal)) {
				rvSocketSendTo(&es->s, ack, strlen(ack), &fromAddr);
			} else {
				rvSocketSendTo(&es->s, nak, strlen(nak), &fromAddr);
			}
			
		} else if (strcmp(command, "close") == 0) {
			RvEppConnId connId = atoi(rvStrTokGetToken(&tokenizer));
			if (connId > 0)
				es->eClose(es, connId);
#if 0
			if (connId > 0 && es->eClose(es, connId)) {
				rvSocketSendTo(&es->s, ack, strlen(ack), &fromAddr);
			} else {
				rvSocketSendTo(&es->s, nak, strlen(nak), &fromAddr);
			}
#endif
			
		} else {
			char err[128];
			sprintf(err, "rvEppServerWrapper: Unknown EPP command %s", command);
			rvLogError(&rvLog, err);
		}
		rvStrTokDestruct(&tokenizer);
	}
}

RvEppServer* rvEppServerConstruct(RvEppServer* es, 
  const char* endpointName, const char* packageList,
  const char* mgIp, RvInetPort mgPort,
  RvEppServerOpen eOpen, RvEppServerModify eModify, RvEppServerClose eClose,
  RvEppServerQuery eQuery, RvEppServerStart eStart, RvEppServerStop eStop, RvEppServerSet eSet) {
	char msg[128];
	char str[64];
	RvHost h;

	if (!eOpen || !eModify || !eQuery || 
	  !eClose || !eStart || !eStop)
		return NULL;

	es->endpointName = endpointName;
	es->mgIp = mgIp;
	es->mgPort = mgPort;
	es->eOpen = eOpen;
	es->eModify = eModify;
	es->eQuery = eQuery;
	es->eClose = eClose;
	es->eStart = eStart;
	es->eStop = eStop;
	es->eSet = eSet;
	
	es->done = rvFalse;

	if (rvSocketConstructUdp(&es->s, 0) == NULL)
		return NULL;

	if (rvThreadConstruct(&es->thread, "EPP Server", RV_PRIORITYVALUE_NORMAL, 5120,
	  rvEppServerWrapper, es) == NULL)
		return NULL;
	
	rvThreadStart(&es->thread);

	rvHostConstructLocal(&h);
	
	sprintf(msg, "register %s %s %s %hu", 
	  es->endpointName, packageList, rvHostGetAddrAsString(&h, 0, str), 
	  rvSocketGetPort(&es->s));
#ifndef RV_IO_NONE
	printf("Sending event: %s\n", msg);
#endif
	rvSocketSendToInetEx(&es->s, msg, strlen(msg), 
	  es->mgIp, es->mgPort);

	return es;
}

void rvEppServerDestruct(RvEppServer* es) {
	char msg[128];
	sprintf(msg, "unregister %s ", es->endpointName);
#ifndef RV_IO_NONE
	printf("Sending event: %s\n", msg);
#endif
	rvSocketSendToInetEx(&es->s, msg, strlen(msg), 
	  es->mgIp, es->mgPort);
	rvSocketDestruct(&es->s);
	es->done = rvTrue;
	rvThreadDestruct(&es->thread);
}

void rvEppServerEvent(RvEppServer* es, const char* eventName) {
	char msg[128];
	sprintf(msg, "event %s %s", es->endpointName, eventName);
#ifndef RV_IO_NONE
	printf("Sending event: %s\n", msg);
#endif
	rvSocketSendToInetEx(&es->s, msg, strlen(msg), 
	  es->mgIp, es->mgPort);
}