[deb_libcec.git] / src / lib / adapter / AdapterMessage.h

#pragma once
/*
 * This file is part of the libCEC(R) library.
 *
 * libCEC(R) is Copyright (C) 2011 Pulse-Eight Limited.  All rights reserved.
 * libCEC(R) is an original work, containing original code.
 *
 * libCEC(R) is a trademark of Pulse-Eight Limited.
 *
 * This program is dual-licensed; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
 *
 *
 * Alternatively, you can license this library under a commercial license,
 * please contact Pulse-Eight Licensing for more information.
 *
 * For more information contact:
 * Pulse-Eight Licensing       <license@pulse-eight.com>
 *     http://www.pulse-eight.com/
 *     http://www.pulse-eight.net/
 */

#include "../platform/util/StdString.h"

namespace CEC
{
  typedef enum cec_adapter_message_state
  {
    ADAPTER_MESSAGE_STATE_UNKNOWN = 0,
    ADAPTER_MESSAGE_STATE_WAITING_TO_BE_SENT,
    ADAPTER_MESSAGE_STATE_SENT,
    ADAPTER_MESSAGE_STATE_SENT_NOT_ACKED,
    ADAPTER_MESSAGE_STATE_SENT_ACKED,
    ADAPTER_MESSAGE_STATE_INCOMING,
    ADAPTER_MESSAGE_STATE_ERROR
  } cec_adapter_message_state;


  class CCECAdapterMessage
  {
  public:
    CCECAdapterMessage(void)
    {
      Clear();
    }

    CCECAdapterMessage(const cec_command &command)
    {
      Clear();

      //set ack polarity to high when transmitting to the broadcast address
      //set ack polarity low when transmitting to any other address
      PushBack(MSGSTART);
      PushEscaped(MSGCODE_TRANSMIT_ACK_POLARITY);
      if (command.destination == CECDEVICE_BROADCAST)
        PushEscaped(CEC_TRUE);
      else
        PushEscaped(CEC_FALSE);
      PushBack(MSGEND);

      // add source and destination
      PushBack(MSGSTART);
      PushEscaped(command.opcode_set == 0 ? (uint8_t)MSGCODE_TRANSMIT_EOM : (uint8_t)MSGCODE_TRANSMIT);
      PushBack(((uint8_t)command.initiator << 4) + (uint8_t)command.destination);
      PushBack(MSGEND);

      // add opcode
      if (command.opcode_set == 1)
      {
        PushBack(MSGSTART);
        PushEscaped(command.parameters.IsEmpty() ? (uint8_t)MSGCODE_TRANSMIT_EOM : (uint8_t)MSGCODE_TRANSMIT);
        PushBack((uint8_t) command.opcode);
        PushBack(MSGEND);

        // add parameters
        for (int8_t iPtr = 0; iPtr < command.parameters.size; iPtr++)
        {
          PushBack(MSGSTART);

          if (iPtr == command.parameters.size - 1)
            PushEscaped( MSGCODE_TRANSMIT_EOM);
          else
            PushEscaped(MSGCODE_TRANSMIT);

          PushEscaped(command.parameters[iPtr]);

          PushBack(MSGEND);
        }
      }

      // set timeout
      transmit_timeout = command.transmit_timeout;
      //TODO
    }

    CCECAdapterMessage &operator=(const CCECAdapterMessage &msg)
    {
      packet = msg.packet;
      state  = msg.state;
      return *this;
    }

    CStdString ToString(void) const
    {
      CStdString strMsg;
      if (Size() == 0)
      {
        strMsg = "empty message";
      }
      else
      {
        strMsg = MessageCodeAsString();

        switch (Message())
        {
        case MSGCODE_TIMEOUT_ERROR:
        case MSGCODE_HIGH_ERROR:
        case MSGCODE_LOW_ERROR:
          {
            uint32_t iLine = (Size() >= 3) ? (At(1) << 8) | At(2) : 0;
            uint32_t iTime = (Size() >= 7) ? (At(3) << 24) | (At(4) << 16) | (At(5) << 8) | At(6) : 0;
            strMsg.AppendFormat(" line:%u", iLine);
            strMsg.AppendFormat(" time:%u", iTime);
          }
          break;
        case MSGCODE_FRAME_START:
          if (Size() >= 2)
            strMsg.AppendFormat(" initiator:%1x destination:%1x ack:%s %s", Initiator(), Destination(), IsACK() ? "high" : "low", IsEOM() ? "eom" : "");
          break;
        case MSGCODE_FRAME_DATA:
          if (Size() >= 2)
            strMsg.AppendFormat(" %02x %s", At(1), IsEOM() ? "eom" : "");
          break;
        default:
          break;
        }
      }

      return strMsg;
    }

    CStdString MessageCodeAsString(void) const
    {
      CStdString strMsg;
      switch (Message())
      {
      case MSGCODE_NOTHING:
        strMsg = "NOTHING";
        break;
      case MSGCODE_PING:
        strMsg = "PING";
        break;
      case MSGCODE_TIMEOUT_ERROR:
        strMsg = "TIMEOUT";
        break;
      case MSGCODE_HIGH_ERROR:
        strMsg = "HIGH_ERROR";
        break;
      case MSGCODE_LOW_ERROR:
        strMsg = "LOW_ERROR";
        break;
      case MSGCODE_FRAME_START:
        strMsg = "FRAME_START";
        break;
      case MSGCODE_FRAME_DATA:
        strMsg = "FRAME_DATA";
        break;
      case MSGCODE_RECEIVE_FAILED:
        strMsg = "RECEIVE_FAILED";
        break;
      case MSGCODE_COMMAND_ACCEPTED:
        strMsg = "COMMAND_ACCEPTED";
        break;
      case MSGCODE_COMMAND_REJECTED:
        strMsg = "COMMAND_REJECTED";
        break;
      case MSGCODE_SET_ACK_MASK:
        strMsg = "SET_ACK_MASK";
        break;
      case MSGCODE_TRANSMIT:
        strMsg = "TRANSMIT";
        break;
      case MSGCODE_TRANSMIT_EOM:
        strMsg = "TRANSMIT_EOM";
        break;
      case MSGCODE_TRANSMIT_IDLETIME:
        strMsg = "TRANSMIT_IDLETIME";
        break;
      case MSGCODE_TRANSMIT_ACK_POLARITY:
        strMsg = "TRANSMIT_ACK_POLARITY";
        break;
      case MSGCODE_TRANSMIT_LINE_TIMEOUT:
        strMsg = "TRANSMIT_LINE_TIMEOUT";
        break;
      case MSGCODE_TRANSMIT_SUCCEEDED:
        strMsg = "TRANSMIT_SUCCEEDED";
        break;
      case MSGCODE_TRANSMIT_FAILED_LINE:
        strMsg = "TRANSMIT_FAILED_LINE";
        break;
      case MSGCODE_TRANSMIT_FAILED_ACK:
        strMsg = "TRANSMIT_FAILED_ACK";
        break;
      case MSGCODE_TRANSMIT_FAILED_TIMEOUT_DATA:
        strMsg = "TRANSMIT_FAILED_TIMEOUT_DATA";
        break;
      case MSGCODE_TRANSMIT_FAILED_TIMEOUT_LINE:
        strMsg = "TRANSMIT_FAILED_TIMEOUT_LINE";
        break;
      case MSGCODE_FIRMWARE_VERSION:
        strMsg = "FIRMWARE_VERSION";
        break;
      case MSGCODE_START_BOOTLOADER:
        strMsg = "START_BOOTLOADER";
        break;
      case MSGCODE_FRAME_EOM:
        strMsg = "FRAME_EOM";
        break;
      case MSGCODE_FRAME_ACK:
        strMsg = "FRAME_ACK";
        break;
      }

      return strMsg;
    }

    uint8_t operator[](uint8_t pos) const
    {
      return packet[pos];
    }

    uint8_t At(uint8_t pos) const
    {
      return packet[pos];
    }

    uint8_t Size(void) const
    {
      return packet.size;
    }

    bool IsEmpty(void) const
    {
      return packet.IsEmpty();
    }

    void Clear(void)
    {
      state               = ADAPTER_MESSAGE_STATE_UNKNOWN;
      transmit_timeout    = CEC_DEFAULT_TRANSMIT_TIMEOUT;
      packet.Clear();
      maxTries            = CEC_DEFAULT_TRANSMIT_RETRIES + 1;
      tries               = 0;
      reply               = MSGCODE_NOTHING;
      isTransmission      = true;
      expectControllerAck = true;
    }

    void Shift(uint8_t iShiftBy)
    {
      packet.Shift(iShiftBy);
    }

    void PushBack(uint8_t add)
    {
      packet.PushBack(add);
    }

    void PushEscaped(uint8_t byte)
    {
      if (byte >= MSGESC)
      {
        PushBack(MSGESC);
        PushBack(byte - ESCOFFSET);
      }
      else
      {
        PushBack(byte);
      }
    }

    cec_adapter_messagecode Message(void) const
    {
      return packet.size >= 1 ?
          (cec_adapter_messagecode) (packet.At(0) & ~(MSGCODE_FRAME_EOM | MSGCODE_FRAME_ACK)) :
          MSGCODE_NOTHING;
    }

    bool IsEOM(void) const
    {
      return packet.size >= 1 ?
          (packet.At(0) & MSGCODE_FRAME_EOM) != 0 :
          false;
    }

    bool IsACK(void) const
    {
      return packet.size >= 1 ?
          (packet.At(0) & MSGCODE_FRAME_ACK) != 0 :
          false;
    }

    bool IsError(void) const
    {
      cec_adapter_messagecode code = Message();
      return (code == MSGCODE_HIGH_ERROR ||
              code == MSGCODE_LOW_ERROR ||
              code == MSGCODE_RECEIVE_FAILED ||
              code == MSGCODE_COMMAND_REJECTED ||
              code == MSGCODE_TRANSMIT_LINE_TIMEOUT ||
              code == MSGCODE_TRANSMIT_FAILED_LINE ||
              code == MSGCODE_TRANSMIT_FAILED_ACK ||
              code == MSGCODE_TRANSMIT_FAILED_TIMEOUT_DATA ||
              code == MSGCODE_TRANSMIT_FAILED_TIMEOUT_LINE);
    }

    bool NeedsRetry(void) const
    {
      return reply == MSGCODE_NOTHING ||
             reply == MSGCODE_RECEIVE_FAILED ||
             reply == MSGCODE_TIMEOUT_ERROR ||
             reply == MSGCODE_TRANSMIT_FAILED_LINE ||
             reply == MSGCODE_TRANSMIT_FAILED_TIMEOUT_DATA ||
             reply == MSGCODE_TRANSMIT_FAILED_TIMEOUT_LINE ||
             reply == MSGCODE_TRANSMIT_LINE_TIMEOUT;
    }

    cec_logical_address Initiator(void) const
    {
      return packet.size >= 2 ?
          (cec_logical_address) (packet.At(1) >> 4) :
          CECDEVICE_UNKNOWN;
    }

    cec_logical_address Destination(void) const
    {
      return packet.size >= 2 ?
          (cec_logical_address) (packet.At(1) & 0xF) :
          CECDEVICE_UNKNOWN;
    }

    uint8_t                   maxTries;
    uint8_t                   tries;
    cec_adapter_messagecode   reply;
    cec_datapacket            packet;
    cec_adapter_message_state state;
    int32_t                   transmit_timeout;
    bool                      isTransmission;
    bool                      expectControllerAck;
    PLATFORM::CMutex          mutex;
    PLATFORM::CCondition      condition;
  };
}
Commit	Line	Data
	1	#pragma once
	2	/*
	3	* This file is part of the libCEC(R) library.
	4	*
	5	* libCEC(R) is Copyright (C) 2011 Pulse-Eight Limited. All rights reserved.
	6	* libCEC(R) is an original work, containing original code.
	7	*
	8	* libCEC(R) is a trademark of Pulse-Eight Limited.
	9	*
	10	* This program is dual-licensed; you can redistribute it and/or modify
	11	* it under the terms of the GNU General Public License as published by
	12	* the Free Software Foundation; either version 2 of the License, or
	13	* (at your option) any later version.
	14	*
	15	* This program is distributed in the hope that it will be useful,
	16	* but WITHOUT ANY WARRANTY; without even the implied warranty of
	17	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
	18	* GNU General Public License for more details.
	19	*
	20	* You should have received a copy of the GNU General Public License
	21	* along with this program; if not, write to the Free Software
	22	* Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
	23	*
	24	*
	25	* Alternatively, you can license this library under a commercial license,
	26	* please contact Pulse-Eight Licensing for more information.
	27	*
	28	* For more information contact:
	29	* Pulse-Eight Licensing <license@pulse-eight.com>
	30	* http://www.pulse-eight.com/
	31	* http://www.pulse-eight.net/
	32	*/
	33
	34	#include "../platform/util/StdString.h"
	35
	36	namespace CEC
	37	{
	38	typedef enum cec_adapter_message_state
	39	{
	40	ADAPTER_MESSAGE_STATE_UNKNOWN = 0,
	41	ADAPTER_MESSAGE_STATE_WAITING_TO_BE_SENT,
	42	ADAPTER_MESSAGE_STATE_SENT,
	43	ADAPTER_MESSAGE_STATE_SENT_NOT_ACKED,
	44	ADAPTER_MESSAGE_STATE_SENT_ACKED,
	45	ADAPTER_MESSAGE_STATE_INCOMING,
	46	ADAPTER_MESSAGE_STATE_ERROR
	47	} cec_adapter_message_state;
	48
	49
	50	class CCECAdapterMessage
	51	{
	52	public:
	53	CCECAdapterMessage(void)
	54	{
	55	Clear();
	56	}
	57
	58	CCECAdapterMessage(const cec_command &command)
	59	{
	60	Clear();
	61
	62	//set ack polarity to high when transmitting to the broadcast address
	63	//set ack polarity low when transmitting to any other address
	64	PushBack(MSGSTART);
	65	PushEscaped(MSGCODE_TRANSMIT_ACK_POLARITY);
	66	if (command.destination == CECDEVICE_BROADCAST)
	67	PushEscaped(CEC_TRUE);
	68	else
	69	PushEscaped(CEC_FALSE);
	70	PushBack(MSGEND);
	71
	72	// add source and destination
	73	PushBack(MSGSTART);
	74	PushEscaped(command.opcode_set == 0 ? (uint8_t)MSGCODE_TRANSMIT_EOM : (uint8_t)MSGCODE_TRANSMIT);
	75	PushBack(((uint8_t)command.initiator << 4) + (uint8_t)command.destination);
	76	PushBack(MSGEND);
	77
	78	// add opcode
	79	if (command.opcode_set == 1)
	80	{
	81	PushBack(MSGSTART);
	82	PushEscaped(command.parameters.IsEmpty() ? (uint8_t)MSGCODE_TRANSMIT_EOM : (uint8_t)MSGCODE_TRANSMIT);
	83	PushBack((uint8_t) command.opcode);
	84	PushBack(MSGEND);
	85
	86	// add parameters
	87	for (int8_t iPtr = 0; iPtr < command.parameters.size; iPtr++)
	88	{
	89	PushBack(MSGSTART);
	90
	91	if (iPtr == command.parameters.size - 1)
	92	PushEscaped( MSGCODE_TRANSMIT_EOM);
	93	else
	94	PushEscaped(MSGCODE_TRANSMIT);
	95
	96	PushEscaped(command.parameters[iPtr]);
	97
	98	PushBack(MSGEND);
	99	}
	100	}
	101
	102	// set timeout
	103	transmit_timeout = command.transmit_timeout;
	104	//TODO
	105	}
	106
	107	CCECAdapterMessage &operator=(const CCECAdapterMessage &msg)
	108	{
	109	packet = msg.packet;
	110	state = msg.state;
	111	return *this;
	112	}
	113
	114	CStdString ToString(void) const
	115	{
	116	CStdString strMsg;
	117	if (Size() == 0)
	118	{
	119	strMsg = "empty message";
	120	}
	121	else
	122	{
	123	strMsg = MessageCodeAsString();
	124
	125	switch (Message())
	126	{
	127	case MSGCODE_TIMEOUT_ERROR:
	128	case MSGCODE_HIGH_ERROR:
	129	case MSGCODE_LOW_ERROR:
	130	{
	131	uint32_t iLine = (Size() >= 3) ? (At(1) << 8) \| At(2) : 0;
	132	uint32_t iTime = (Size() >= 7) ? (At(3) << 24) \| (At(4) << 16) \| (At(5) << 8) \| At(6) : 0;
	133	strMsg.AppendFormat(" line:%u", iLine);
	134	strMsg.AppendFormat(" time:%u", iTime);
	135	}
	136	break;
	137	case MSGCODE_FRAME_START:
	138	if (Size() >= 2)
	139	strMsg.AppendFormat(" initiator:%1x destination:%1x ack:%s %s", Initiator(), Destination(), IsACK() ? "high" : "low", IsEOM() ? "eom" : "");
	140	break;
	141	case MSGCODE_FRAME_DATA:
	142	if (Size() >= 2)
	143	strMsg.AppendFormat(" %02x %s", At(1), IsEOM() ? "eom" : "");
	144	break;
	145	default:
	146	break;
	147	}
	148	}
	149
	150	return strMsg;
	151	}
	152
	153	CStdString MessageCodeAsString(void) const
	154	{
	155	CStdString strMsg;
	156	switch (Message())
	157	{
	158	case MSGCODE_NOTHING:
	159	strMsg = "NOTHING";
	160	break;
	161	case MSGCODE_PING:
	162	strMsg = "PING";
	163	break;
	164	case MSGCODE_TIMEOUT_ERROR:
	165	strMsg = "TIMEOUT";
	166	break;
	167	case MSGCODE_HIGH_ERROR:
	168	strMsg = "HIGH_ERROR";
	169	break;
	170	case MSGCODE_LOW_ERROR:
	171	strMsg = "LOW_ERROR";
	172	break;
	173	case MSGCODE_FRAME_START:
	174	strMsg = "FRAME_START";
	175	break;
	176	case MSGCODE_FRAME_DATA:
	177	strMsg = "FRAME_DATA";
	178	break;
	179	case MSGCODE_RECEIVE_FAILED:
	180	strMsg = "RECEIVE_FAILED";
	181	break;
	182	case MSGCODE_COMMAND_ACCEPTED:
	183	strMsg = "COMMAND_ACCEPTED";
	184	break;
	185	case MSGCODE_COMMAND_REJECTED:
	186	strMsg = "COMMAND_REJECTED";
	187	break;
	188	case MSGCODE_SET_ACK_MASK:
	189	strMsg = "SET_ACK_MASK";
	190	break;
	191	case MSGCODE_TRANSMIT:
	192	strMsg = "TRANSMIT";
	193	break;
	194	case MSGCODE_TRANSMIT_EOM:
	195	strMsg = "TRANSMIT_EOM";
	196	break;
	197	case MSGCODE_TRANSMIT_IDLETIME:
	198	strMsg = "TRANSMIT_IDLETIME";
	199	break;
	200	case MSGCODE_TRANSMIT_ACK_POLARITY:
	201	strMsg = "TRANSMIT_ACK_POLARITY";
	202	break;
	203	case MSGCODE_TRANSMIT_LINE_TIMEOUT:
	204	strMsg = "TRANSMIT_LINE_TIMEOUT";
	205	break;
	206	case MSGCODE_TRANSMIT_SUCCEEDED:
	207	strMsg = "TRANSMIT_SUCCEEDED";
	208	break;
	209	case MSGCODE_TRANSMIT_FAILED_LINE:
	210	strMsg = "TRANSMIT_FAILED_LINE";
	211	break;
	212	case MSGCODE_TRANSMIT_FAILED_ACK:
	213	strMsg = "TRANSMIT_FAILED_ACK";
	214	break;
	215	case MSGCODE_TRANSMIT_FAILED_TIMEOUT_DATA:
	216	strMsg = "TRANSMIT_FAILED_TIMEOUT_DATA";
	217	break;
	218	case MSGCODE_TRANSMIT_FAILED_TIMEOUT_LINE:
	219	strMsg = "TRANSMIT_FAILED_TIMEOUT_LINE";
	220	break;
	221	case MSGCODE_FIRMWARE_VERSION:
	222	strMsg = "FIRMWARE_VERSION";
	223	break;
	224	case MSGCODE_START_BOOTLOADER:
	225	strMsg = "START_BOOTLOADER";
	226	break;
	227	case MSGCODE_FRAME_EOM:
	228	strMsg = "FRAME_EOM";
	229	break;
	230	case MSGCODE_FRAME_ACK:
	231	strMsg = "FRAME_ACK";
	232	break;
	233	}
	234
	235	return strMsg;
	236	}
	237
	238	uint8_t operator[](uint8_t pos) const
	239	{
	240	return packet[pos];
	241	}
	242
	243	uint8_t At(uint8_t pos) const
	244	{
	245	return packet[pos];
	246	}
	247
	248	uint8_t Size(void) const
	249	{
	250	return packet.size;
	251	}
	252
	253	bool IsEmpty(void) const
	254	{
	255	return packet.IsEmpty();
	256	}
	257
	258	void Clear(void)
	259	{
	260	state = ADAPTER_MESSAGE_STATE_UNKNOWN;
	261	transmit_timeout = CEC_DEFAULT_TRANSMIT_TIMEOUT;
	262	packet.Clear();
	263	maxTries = CEC_DEFAULT_TRANSMIT_RETRIES + 1;
	264	tries = 0;
	265	reply = MSGCODE_NOTHING;
	266	isTransmission = true;
	267	expectControllerAck = true;
	268	}
	269
	270	void Shift(uint8_t iShiftBy)
	271	{
	272	packet.Shift(iShiftBy);
	273	}
	274
	275	void PushBack(uint8_t add)
	276	{
	277	packet.PushBack(add);
	278	}
	279
	280	void PushEscaped(uint8_t byte)
	281	{
	282	if (byte >= MSGESC)
	283	{
	284	PushBack(MSGESC);
	285	PushBack(byte - ESCOFFSET);
	286	}
	287	else
	288	{
	289	PushBack(byte);
	290	}
	291	}
	292
	293	cec_adapter_messagecode Message(void) const
	294	{
	295	return packet.size >= 1 ?
	296	(cec_adapter_messagecode) (packet.At(0) & ~(MSGCODE_FRAME_EOM \| MSGCODE_FRAME_ACK)) :
	297	MSGCODE_NOTHING;
	298	}
	299
	300	bool IsEOM(void) const
	301	{
	302	return packet.size >= 1 ?
	303	(packet.At(0) & MSGCODE_FRAME_EOM) != 0 :
	304	false;
	305	}
	306
	307	bool IsACK(void) const
	308	{
	309	return packet.size >= 1 ?
	310	(packet.At(0) & MSGCODE_FRAME_ACK) != 0 :
	311	false;
	312	}
	313
	314	bool IsError(void) const
	315	{
	316	cec_adapter_messagecode code = Message();
	317	return (code == MSGCODE_HIGH_ERROR \|\|
	318	code == MSGCODE_LOW_ERROR \|\|
	319	code == MSGCODE_RECEIVE_FAILED \|\|
	320	code == MSGCODE_COMMAND_REJECTED \|\|
	321	code == MSGCODE_TRANSMIT_LINE_TIMEOUT \|\|
	322	code == MSGCODE_TRANSMIT_FAILED_LINE \|\|
	323	code == MSGCODE_TRANSMIT_FAILED_ACK \|\|
	324	code == MSGCODE_TRANSMIT_FAILED_TIMEOUT_DATA \|\|
	325	code == MSGCODE_TRANSMIT_FAILED_TIMEOUT_LINE);
	326	}
	327
	328	bool NeedsRetry(void) const
	329	{
	330	return reply == MSGCODE_NOTHING \|\|
	331	reply == MSGCODE_RECEIVE_FAILED \|\|
	332	reply == MSGCODE_TIMEOUT_ERROR \|\|
	333	reply == MSGCODE_TRANSMIT_FAILED_LINE \|\|
	334	reply == MSGCODE_TRANSMIT_FAILED_TIMEOUT_DATA \|\|
	335	reply == MSGCODE_TRANSMIT_FAILED_TIMEOUT_LINE \|\|
	336	reply == MSGCODE_TRANSMIT_LINE_TIMEOUT;
	337	}
	338
	339	cec_logical_address Initiator(void) const
	340	{
	341	return packet.size >= 2 ?
	342	(cec_logical_address) (packet.At(1) >> 4) :
	343	CECDEVICE_UNKNOWN;
	344	}
	345
	346	cec_logical_address Destination(void) const
	347	{
	348	return packet.size >= 2 ?
	349	(cec_logical_address) (packet.At(1) & 0xF) :
	350	CECDEVICE_UNKNOWN;
	351	}
	352
	353	uint8_t maxTries;
	354	uint8_t tries;
	355	cec_adapter_messagecode reply;
	356	cec_datapacket packet;
	357	cec_adapter_message_state state;
	358	int32_t transmit_timeout;
	359	bool isTransmission;
	360	bool expectControllerAck;
	361	PLATFORM::CMutex mutex;
	362	PLATFORM::CCondition condition;
	363	};
	364	}