open62541/open62541Stack/src/opcua_transportLayer.h

/*
 * opcua_transportLayer.h
 *
 *  Created on: Dec 19, 2013
 *      Author: opcua
 */

#ifndef OPCUA_TRANSPORTLAYER_H_
#define OPCUA_TRANSPORTLAYER_H_
#include <stdio.h>

#include "opcua_binaryEncDec.h"
#include "opcua_advancedDatatypes.h"
#include "opcua_connectionHelper.h"


//TODO : Implement this interface
#include "tcp_layer.h"
/*------------------Defined Error Codes------------------*/
//transport errors begin at 1000
#define UA_ERROR_MULTIPLY_HEL 1000
#define UA_ERROR_RCV_ERROR 1001


/*------------------Defined Lengths------------------*/
#define SIZE_OF_ACKNOWLEDGE_MESSAGE 28

//constants
static const UInt32 TL_HEADER_LENGTH = 8;
static const UInt32 TL_MESSAGE_TYPE_LEN = 3;
static const UInt32 TL_RESERVED_LEN = 1;

//variables which belong to layer
static const TL_SERVER_PROTOCOL_VERSION = 0;
static const TL_SERVER_MAX_CHUNK_COUNT = 1;
static const TL_SERVER_MAX_MESSAGE_SIZE = 8192;

enum TL_messageType_td
{
	TL_HEL = 1,
	TL_ACK = 2,
	TL_ERR = 3,
	TL_OPN = 4,
	TL_CLO = 5,
	TL_MSG = 6
}TL_messageType;

struct TL_header
{
	UInt32 MessageType;
	Byte Reserved;
	UInt32 MessageSize;
};
struct TL_message
{
	struct TL_header Header;
	char *message;
};

struct TL_messageBodyHEL
{
	UInt32 ProtocolVersion;
	UInt32 ReceiveBufferSize;
	UInt32 SendBufferSize;
	UInt32 MaxMessageSize;
	UInt32 MaxChunkCount;
	UA_String EndpointUrl;
};

struct TL_messageBodyACK
{
	UInt32 ProtocolVersion;
	UInt32 ReceiveBufferSize;
	UInt32 SendBufferSize;
	UInt32 MaxMessageSize;
	UInt32 MaxChunkCount;
	UA_String EndpointUrl;
};

struct TL_messageBodyERR
{
	UInt32 Error;
	UA_String Reason;

};
//functions
/**
 *
 * @param connection connection object
 * @param TL_message
 * @return
 */
Int32 TL_check(UA_connection *connection);
/**
 *
 * @param connection
 * @param TL_message
 */
Int32 TL_receive(UA_connection *connection,UA_ByteString *packet);
Int32 TL_send(UA_connection *connection, UA_ByteString *packet);
Int32 TL_getPacketType(UA_ByteString *packet, Int32 *pos);


#endif /* OPCUA_TRANSPORTLAYER_H_ */