<?xml version="1.0" encoding="UTF-8" ?>
<xsl:stylesheet version="1.0" xmlns:xsl="http://www.w3.org/1999/XSL/Transform"
xmlns:llrp="http://www.llrp.org/ltk/schema/core/encoding/binary/1.0">
<xsl:output omit-xml-declaration='yes' method='text' indent='yes'/>
<xsl:template match="/llrp:llrpdef">
/*
***************************************************************************
* Copyright 2007 Impinj, Inc.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*
***************************************************************************
*/
/*
***************************************************************************
* File Name: LLRPEndPoint.cs
*
* Version: 1.0
* Author: Impinj
* Organization: Impinj
* Date: Jan. 18, 2008
*
* Description: This file contains implementation of LLRP Endpoint. LLRP
* Endpoint is used to build simulator or LLRP based
* application
***************************************************************************
*/
using System;
using System.Collections.Generic;
using System.Text;
using System.Net;
using System.Net.Sockets;
using System.Threading;
using System.Runtime.Remoting;
using System.Collections;
using System.Xml;
using System.Xml.Serialization;
using System.Data;
using LLRP.DataType;
namespace LLRP
{
public class RAW_Message
{
public short version;
public short msg_type;
public int msg_id;
public byte[] msg_body;
public RAW_Message(short ver, short type, int id, byte[] data)
{
version = ver;
msg_id = id;
msg_type = type;
msg_body = new byte[data.Length];
Array.Copy(data, msg_body, data.Length);
}
}
//add comments
public class LLRPEndPoint : IDisposable
{
#region members
private CommunicationInterface cI;
private int LLRP1_TCP_PORT = 5084;
private ManualResetEvent transactEvt;
private short version;
private short msg_type;
private int msg_id;
private byte[] data;
private bool b_enqueue = false;
private Queue<xsl:text disable-output-escaping="yes"><RAW_Message></xsl:text>raw_message_queue;
public event delegateClientConnected OnClientConnected;
public event delegateMessageReceived OnMessageReceived;
#endregion
#region Methods
public LLRPEndPoint()
{
}
public bool Create(string llrp_reader_name, bool server)
{
try
{
if (server)
{
cI = new TCPIPServer();
cI.Open("", LLRP1_TCP_PORT);
}
else
{
cI = new TCPIPClient();
cI.Open(llrp_reader_name, LLRP1_TCP_PORT);
}
cI.OnMessageReceived += new delegateMessageReceived(cI_OnMessageReceived);
cI.OnClientConnected += new delegateClientConnected(cI_OnClientConnected);
}
catch
{
return false;
}
return true;
}
void cI_OnClientConnected()
{
if (OnClientConnected != null) OnClientConnected();
}
private void triggerMessageReceived(short ver, short msg_type, int msg_id, byte[] msg_data)
{
if(OnMessageReceived!=null)OnMessageReceived(ver, msg_type, msg_id, msg_data);
}
void cI_OnMessageReceived(short ver, short msg_type, int msg_id, byte[] msg_data)
{
if ( (msg_type == 100) || (msg_type == this.msg_type <xsl:text disable-output-escaping="yes">&&</xsl:text> msg_id == this.msg_id))
{
Array.Copy(msg_data, this.data, msg_data.Length);
this.msg_type = msg_type;
this.msg_id = msg_id;
this.version = ver;
transactEvt.Set();
}
if(OnMessageReceived!=null)
{
delegateMessageReceived dmr = new delegateMessageReceived(triggerMessageReceived);
dmr.BeginInvoke(ver, msg_type, msg_id, msg_data, null, null);
}
lock (this)
{
if (b_enqueue)
{
raw_message_queue.Enqueue(new RAW_Message(ver, msg_type, msg_id, msg_data));
b_enqueue = false;
}
}
}
public void Close()
{
cI.Close();
}
public void Dispose()
{
this.Close();
}
#endregion
public void SendMessage(Message msg)
{
bool[] bit_array = msg.ToBitArray();
byte[] data = Util.ConvertBitArrayToByteArray(bit_array);
lock(this)
{
b_enqueue = true;
}
try
{
Transaction.Send(cI, data);
}
catch
{
throw new Exception("Transaction Failed");
}
}
public RAW_Message GetMessage()
{
lock (this)
{
return raw_message_queue.Dequeue();
}
}
public Message TransactMessage(Message msg, int time_out)
{
bool[] bit_array = msg.ToBitArray();
byte[] data = Util.ConvertBitArrayToByteArray(bit_array);
try
{
transactEvt = new ManualResetEvent(false);
Transaction.Send(cI, data);
msg_id = (int)msg.MSG_ID;
if (msg.MSG_TYPE != (uint)ENUM_LLRP_MSG_TYPE.CUSTOM_MESSAGE) msg_type = (short)(msg.MSG_TYPE + 10);
else
msg_type = (short)msg.MSG_TYPE;
if (transactEvt.WaitOne(time_out, false))
{
BitArray bArr;
int length;
int cursor = 0;
switch ((ENUM_LLRP_MSG_TYPE)msg_type)
{
<xsl:for-each select="llrp:messageDefinition">
<xsl:if test="contains(@name, 'RESPONSE')">
case ENUM_LLRP_MSG_TYPE.<xsl:value-of select="@name"/>:
{
bArr = Util.ConvertByteArrayToBitArray(data);
length = bArr.Count;
MSG_<xsl:value-of select="@name"/> r_msg = MSG_<xsl:value-of select="@name"/>.FromBitArray(ref bArr, ref cursor, length);
return r_msg;
}
</xsl:if>
</xsl:for-each>
default:
return null;
}
}
else
{
return null;
}
}
catch
{
throw new Exception("Transaction Failed");
}
}
}
}
</xsl:template>
</xsl:stylesheet>
