src/lib/devices/CECBusDevice.cpp

   1 /*
   2  * This file is part of the libCEC(R) library.
   3  *
   4  * libCEC(R) is Copyright (C) 2011 Pulse-Eight Limited.  All rights reserved.
   5  * libCEC(R) is an original work, containing original code.
   6  *
   7  * libCEC(R) is a trademark of Pulse-Eight Limited.
   8  *
   9  * This program is dual-licensed; you can redistribute it and/or modify
  10  * it under the terms of the GNU General Public License as published by
  11  * the Free Software Foundation; either version 2 of the License, or
  12  * (at your option) any later version.
  13  *
  14  * This program is distributed in the hope that it will be useful,
  15  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  16  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  17  * GNU General Public License for more details.
  18  *
  19  * You should have received a copy of the GNU General Public License
  20  * along with this program; if not, write to the Free Software
  21  * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
  22  *
  23  *
  24  * Alternatively, you can license this library under a commercial license,
  25  * please contact Pulse-Eight Licensing for more information.
  26  *
  27  * For more information contact:
  28  * Pulse-Eight Licensing       <license@pulse-eight.com>
  29  *     http://www.pulse-eight.com/
  30  *     http://www.pulse-eight.net/
  31  */
  32
  33 #include "CECBusDevice.h"
  34 #include "../CECProcessor.h"
  35 #include "../implementations/ANCommandHandler.h"
  36 #include "../implementations/CECCommandHandler.h"
  37 #include "../implementations/SLCommandHandler.h"
  38 #include "../implementations/VLCommandHandler.h"
  39 #include "../platform/timeutils.h"
  40
  41 using namespace CEC;
  42
  43 #define ToString(p) CCECCommandHandler::ToString(p)
  44
  45 CCECBusDevice::CCECBusDevice(CCECProcessor *processor, cec_logical_address iLogicalAddress, uint16_t iPhysicalAddress) :
  46   m_type(CEC_DEVICE_TYPE_RESERVED),
  47   m_iPhysicalAddress(iPhysicalAddress),
  48   m_iStreamPath(0),
  49   m_iLogicalAddress(iLogicalAddress),
  50   m_powerStatus(CEC_POWER_STATUS_UNKNOWN),
  51   m_processor(processor),
  52   m_vendor(CEC_VENDOR_UNKNOWN),
  53   m_menuState(CEC_MENU_STATE_DEACTIVATED),
  54   m_bActiveSource(false),
  55   m_iLastCommandSent(0),
  56   m_iLastActive(0),
  57   m_cecVersion(CEC_VERSION_UNKNOWN)
  58 {
  59   m_handler = new CCECCommandHandler(this);
  60
  61   for (unsigned int iPtr = 0; iPtr < 4; iPtr++)
  62     m_menuLanguage.language[iPtr] = '?';
  63   m_menuLanguage.language[3] = 0;
  64   m_menuLanguage.device = iLogicalAddress;
  65
  66   m_strDeviceName = ToString(m_iLogicalAddress);
  67 }
  68
  69 CCECBusDevice::~CCECBusDevice(void)
  70 {
  71   m_condition.Broadcast();
  72   delete m_handler;
  73 }
  74
  75 void CCECBusDevice::AddLog(cec_log_level level, const CStdString &strMessage)
  76 {
  77   m_processor->AddLog(level, strMessage);
  78 }
  79
  80 bool CCECBusDevice::HandleCommand(const cec_command &command)
  81 {
  82   CLockObject lock(&m_mutex);
  83   m_iLastActive = GetTimeMs();
  84   m_handler->HandleCommand(command);
  85   m_condition.Signal();
  86   return true;
  87 }
  88
  89 void CCECBusDevice::PollVendorId(void)
  90 {
  91   CLockObject lock(&m_mutex);
  92   if (m_iLastActive > 0 && m_iLogicalAddress != CECDEVICE_BROADCAST &&
  93       m_vendor == CEC_VENDOR_UNKNOWN &&
  94       GetTimeMs() - m_iLastCommandSent > 5000 &&
  95       !m_processor->IsMonitoring())
  96   {
  97     CStdString strLog;
  98     strLog.Format("<< requesting vendor ID of '%s' (%X)", GetLogicalAddressName(), m_iLogicalAddress);
  99     AddLog(CEC_LOG_NOTICE, strLog);
 100     m_iLastCommandSent = GetTimeMs();
 101
 102     cec_command command;
 103     cec_command::format(command, GetMyLogicalAddress(), m_iLogicalAddress, CEC_OPCODE_GIVE_DEVICE_VENDOR_ID);
 104     if (m_processor->Transmit(command))
 105       m_condition.Wait(&m_mutex, 1000);
 106   }
 107 }
 108
 109 bool CCECBusDevice::PowerOn(void)
 110 {
 111   cec_power_status current = GetPowerStatus();
 112   if (current != CEC_POWER_STATUS_ON &&
 113       current != CEC_POWER_STATUS_IN_TRANSITION_STANDBY_TO_ON)
 114   {
 115     CStdString strLog;
 116     strLog.Format("<< powering on '%s' (%X)", GetLogicalAddressName(), m_iLogicalAddress);
 117     AddLog(CEC_LOG_DEBUG, strLog.c_str());
 118
 119     SetPowerStatus(CEC_POWER_STATUS_IN_TRANSITION_STANDBY_TO_ON);
 120
 121     cec_command command;
 122     cec_command::format(command, GetMyLogicalAddress(), m_iLogicalAddress, CEC_OPCODE_IMAGE_VIEW_ON);
 123
 124     return m_processor->Transmit(command);
 125   }
 126
 127   return true;
 128 }
 129
 130 bool CCECBusDevice::Standby(void)
 131 {
 132   CStdString strLog;
 133   strLog.Format("<< putting '%s' (%X) in standby mode", GetLogicalAddressName(), m_iLogicalAddress);
 134   AddLog(CEC_LOG_DEBUG, strLog.c_str());
 135
 136   cec_command command;
 137   cec_command::format(command, GetMyLogicalAddress(), m_iLogicalAddress, CEC_OPCODE_STANDBY);
 138
 139   return m_processor->Transmit(command);
 140 }
 141
 142 /** @name Getters */
 143 //@{
 144 cec_version CCECBusDevice::GetCecVersion(void)
 145 {
 146   if (m_cecVersion == CEC_VERSION_UNKNOWN)
 147   {
 148     if (!MyLogicalAddressContains(m_iLogicalAddress))
 149     {
 150       CStdString strLog;
 151       strLog.Format("<< requesting CEC version of '%s' (%X)", GetLogicalAddressName(), m_iLogicalAddress);
 152       AddLog(CEC_LOG_NOTICE, strLog);
 153       cec_command command;
 154       cec_command::format(command, GetMyLogicalAddress(), m_iLogicalAddress, CEC_OPCODE_GET_CEC_VERSION);
 155       CLockObject lock(&m_mutex);
 156       if (m_processor->Transmit(command))
 157         m_condition.Wait(&m_mutex, 1000);
 158     }
 159   }
 160
 161   return m_cecVersion;
 162 }
 163
 164 const char* CCECBusDevice::GetLogicalAddressName(void) const
 165 {
 166   return ToString(m_iLogicalAddress);
 167 }
 168
 169 cec_menu_language &CCECBusDevice::GetMenuLanguage(void)
 170 {
 171   if (!strcmp(m_menuLanguage.language, "???"))
 172   {
 173     if (!MyLogicalAddressContains(m_iLogicalAddress))
 174     {
 175       CStdString strLog;
 176       strLog.Format("<< requesting menu language of '%s' (%X)", GetLogicalAddressName(), m_iLogicalAddress);
 177       AddLog(CEC_LOG_NOTICE, strLog);
 178       cec_command command;
 179       cec_command::format(command, GetMyLogicalAddress(), m_iLogicalAddress, CEC_OPCODE_GET_MENU_LANGUAGE);
 180       CLockObject lock(&m_mutex);
 181       if (m_processor->Transmit(command))
 182         m_condition.Wait(&m_mutex, 1000);
 183     }
 184   }
 185
 186   return m_menuLanguage;
 187 }
 188
 189 cec_logical_address CCECBusDevice::GetMyLogicalAddress(void) const
 190 {
 191   return m_processor->GetLogicalAddress();
 192 }
 193
 194 uint16_t CCECBusDevice::GetMyPhysicalAddress(void) const
 195 {
 196   return m_processor->GetPhysicalAddress();
 197 }
 198
 199 cec_power_status CCECBusDevice::GetPowerStatus(void)
 200 {
 201   if (m_powerStatus == CEC_POWER_STATUS_UNKNOWN)
 202   {
 203     if (!MyLogicalAddressContains(m_iLogicalAddress))
 204     {
 205       CStdString strLog;
 206       strLog.Format("<< requesting power status of '%s' (%X)", GetLogicalAddressName(), m_iLogicalAddress);
 207       AddLog(CEC_LOG_NOTICE, strLog);
 208       cec_command command;
 209       cec_command::format(command, GetMyLogicalAddress(), m_iLogicalAddress, CEC_OPCODE_GIVE_DEVICE_POWER_STATUS);
 210       CLockObject lock(&m_mutex);
 211       if (m_processor->Transmit(command))
 212         m_condition.Wait(&m_mutex, 1000);
 213     }
 214   }
 215
 216   return m_powerStatus;
 217 }
 218
 219 const cec_vendor_id CCECBusDevice::GetVendorId(void)
 220 {
 221   if (m_vendor == CEC_VENDOR_UNKNOWN)
 222   {
 223     if (!MyLogicalAddressContains(m_iLogicalAddress))
 224     {
 225       CStdString strLog;
 226       strLog.Format("<< requesting vendor ID of '%s' (%X)", GetLogicalAddressName(), m_iLogicalAddress);
 227       AddLog(CEC_LOG_NOTICE, strLog);
 228       cec_command command;
 229       cec_command::format(command, GetMyLogicalAddress(), m_iLogicalAddress, CEC_OPCODE_GIVE_DEVICE_VENDOR_ID);
 230       CLockObject lock(&m_mutex);
 231
 232       if (m_processor->Transmit(command))
 233         m_condition.Wait(&m_mutex, 1000);
 234     }
 235   }
 236
 237   return m_vendor;
 238 }
 239
 240 const char *CCECBusDevice::GetVendorName(void)
 241 {
 242   GetVendorId();
 243   return ToString(m_vendor);
 244 }
 245
 246 bool CCECBusDevice::MyLogicalAddressContains(cec_logical_address address) const
 247 {
 248   return m_processor->HasLogicalAddress(address);
 249 }
 250
 251 //@}
 252
 253 /** @name Setters */
 254 //@{
 255 void CCECBusDevice::SetCecVersion(const cec_version newVersion)
 256 {
 257   m_cecVersion = newVersion;
 258
 259   CStdString strLog;
 260   strLog.Format("%s (%X): CEC version %s", GetLogicalAddressName(), m_iLogicalAddress, ToString(newVersion));
 261   AddLog(CEC_LOG_DEBUG, strLog);
 262 }
 263
 264 void CCECBusDevice::SetMenuLanguage(const cec_menu_language &language)
 265 {
 266   if (language.device == m_iLogicalAddress)
 267   {
 268     CStdString strLog;
 269     strLog.Format(">> %s (%X): menu language set to '%s'", GetLogicalAddressName(), m_iLogicalAddress, language.language);
 270     m_processor->AddLog(CEC_LOG_DEBUG, strLog);
 271     m_menuLanguage = language;
 272   }
 273 }
 274
 275 void CCECBusDevice::SetMenuState(const cec_menu_state state)
 276 {
 277   if (m_menuState != state)
 278   {
 279     CStdString strLog;
 280     strLog.Format(">> %s (%X): menu state set to '%s'", GetLogicalAddressName(), m_iLogicalAddress, ToString(m_menuState));
 281     m_processor->AddLog(CEC_LOG_DEBUG, strLog);
 282     m_menuState = state;
 283   }
 284 }
 285
 286 void CCECBusDevice::SetPhysicalAddress(uint16_t iNewAddress)
 287 {
 288   if (iNewAddress > 0)
 289   {
 290     CStdString strLog;
 291     strLog.Format(">> %s (%X): physical address changed from %04x to %04x", GetLogicalAddressName(), m_iLogicalAddress, m_iPhysicalAddress, iNewAddress);
 292     AddLog(CEC_LOG_DEBUG, strLog.c_str());
 293
 294     m_iPhysicalAddress = iNewAddress;
 295   }
 296 }
 297
 298 void CCECBusDevice::SetStreamPath(uint16_t iNewAddress, uint16_t iOldAddress /* = 0 */)
 299 {
 300   if (iNewAddress > 0)
 301   {
 302     CStdString strLog;
 303     strLog.Format(">> %s (%X): stream path changed from %04x to %04x", GetLogicalAddressName(), m_iLogicalAddress, iOldAddress, iNewAddress);
 304     AddLog(CEC_LOG_DEBUG, strLog.c_str());
 305
 306     m_iStreamPath = iNewAddress;
 307
 308     if (iNewAddress > 0)
 309       SetPowerStatus(CEC_POWER_STATUS_ON);
 310   }
 311 }
 312
 313 void CCECBusDevice::SetPowerStatus(const cec_power_status powerStatus)
 314 {
 315   if (m_powerStatus != powerStatus)
 316   {
 317     CStdString strLog;
 318     strLog.Format(">> %s (%X): power status changed from '%s' to '%s'", GetLogicalAddressName(), m_iLogicalAddress, ToString(m_powerStatus), ToString(powerStatus));
 319     m_processor->AddLog(CEC_LOG_DEBUG, strLog);
 320     m_powerStatus = powerStatus;
 321   }
 322 }
 323
 324 void CCECBusDevice::SetVendorId(uint64_t iVendorId)
 325 {
 326   m_vendor = (cec_vendor_id)iVendorId;
 327
 328   switch (iVendorId)
 329   {
 330   case CEC_VENDOR_SAMSUNG:
 331     if (m_handler->GetVendorId() != CEC_VENDOR_SAMSUNG)
 332     {
 333       delete m_handler;
 334       m_handler = new CANCommandHandler(this);
 335     }
 336     break;
 337   case CEC_VENDOR_LG:
 338     if (m_handler->GetVendorId() != CEC_VENDOR_LG)
 339     {
 340       delete m_handler;
 341       m_handler = new CSLCommandHandler(this);
 342     }
 343     break;
 344   case CEC_VENDOR_PANASONIC:
 345     if (m_handler->GetVendorId() != CEC_VENDOR_PANASONIC)
 346     {
 347       delete m_handler;
 348       m_handler = new CVLCommandHandler(this);
 349     }
 350     break;
 351   default:
 352     if (m_handler->GetVendorId() != CEC_VENDOR_UNKNOWN)
 353     {
 354       delete m_handler;
 355       m_handler = new CCECCommandHandler(this);
 356     }
 357     break;
 358   }
 359
 360   CStdString strLog;
 361   strLog.Format("%s (%X): vendor = %s (%06x)", GetLogicalAddressName(), m_iLogicalAddress, GetVendorName(), GetVendorId());
 362   m_processor->AddLog(CEC_LOG_DEBUG, strLog.c_str());
 363 }
 364 //@}
 365
 366 /** @name Transmit methods */
 367 //@{
 368 bool CCECBusDevice::TransmitActiveSource(void)
 369 {
 370   if (m_powerStatus != CEC_POWER_STATUS_ON)
 371   {
 372     CStdString strLog;
 373     strLog.Format("<< %s (%X) is not powered on", GetLogicalAddressName(), m_iLogicalAddress);
 374     AddLog(CEC_LOG_DEBUG, strLog);
 375   }
 376   else if (m_bActiveSource)
 377   {
 378     CStdString strLog;
 379     strLog.Format("<< %s (%X) -> broadcast (F): active source (%4x)", GetLogicalAddressName(), m_iLogicalAddress, m_iPhysicalAddress);
 380     AddLog(CEC_LOG_NOTICE, strLog);
 381
 382     cec_command command;
 383     cec_command::format(command, m_iLogicalAddress, CECDEVICE_BROADCAST, CEC_OPCODE_ACTIVE_SOURCE);
 384     command.parameters.push_back((uint8_t) ((m_iPhysicalAddress >> 8) & 0xFF));
 385     command.parameters.push_back((uint8_t) (m_iPhysicalAddress & 0xFF));
 386
 387     return m_processor->Transmit(command);
 388   }
 389   else
 390   {
 391     CStdString strLog;
 392     strLog.Format("<< %s (%X) is not the active source", GetLogicalAddressName(), m_iLogicalAddress);
 393     AddLog(CEC_LOG_DEBUG, strLog);
 394   }
 395
 396   return false;
 397 }
 398
 399 bool CCECBusDevice::TransmitCECVersion(cec_logical_address dest)
 400 {
 401   CStdString strLog;
 402   strLog.Format("<< %s (%X) -> %s (%X): cec version %s", GetLogicalAddressName(), m_iLogicalAddress, ToString(dest), dest, ToString(m_cecVersion));
 403   AddLog(CEC_LOG_NOTICE, strLog);
 404
 405   cec_command command;
 406   cec_command::format(command, m_iLogicalAddress, dest, CEC_OPCODE_CEC_VERSION);
 407   command.parameters.push_back((uint8_t)m_cecVersion);
 408
 409   return m_processor->Transmit(command);
 410 }
 411
 412 bool CCECBusDevice::TransmitInactiveView(void)
 413 {
 414   CStdString strLog;
 415   strLog.Format("<< %s (%X) -> broadcast (F): inactive view", GetLogicalAddressName(), m_iLogicalAddress);
 416   AddLog(CEC_LOG_NOTICE, strLog);
 417
 418   cec_command command;
 419   cec_command::format(command, m_iLogicalAddress, CECDEVICE_BROADCAST, CEC_OPCODE_INACTIVE_SOURCE);
 420   command.parameters.push_back((m_iPhysicalAddress >> 8) & 0xFF);
 421   command.parameters.push_back(m_iPhysicalAddress & 0xFF);
 422
 423   return m_processor->Transmit(command);
 424 }
 425
 426 bool CCECBusDevice::TransmitMenuState(cec_logical_address dest)
 427 {
 428   CStdString strLog;
 429   strLog.Format("<< %s (%X) -> %s (%X): menu state '%s'", GetLogicalAddressName(), m_iLogicalAddress, ToString(dest), dest, ToString(m_menuState));
 430   AddLog(CEC_LOG_NOTICE, strLog);
 431
 432   cec_command command;
 433   cec_command::format(command, m_iLogicalAddress, dest, CEC_OPCODE_MENU_STATUS);
 434   command.parameters.push_back((uint8_t)m_menuState);
 435
 436   return m_processor->Transmit(command);
 437 }
 438
 439 bool CCECBusDevice::TransmitOSDName(cec_logical_address dest)
 440 {
 441   CStdString strLog;
 442   strLog.Format("<< %s (%X) -> %s (%X): OSD name '%s'", GetLogicalAddressName(), m_iLogicalAddress, ToString(dest), dest, m_strDeviceName.c_str());
 443   AddLog(CEC_LOG_NOTICE, strLog.c_str());
 444
 445   cec_command command;
 446   cec_command::format(command, m_iLogicalAddress, dest, CEC_OPCODE_SET_OSD_NAME);
 447   for (unsigned int iPtr = 0; iPtr < m_strDeviceName.length(); iPtr++)
 448     command.parameters.push_back(m_strDeviceName.at(iPtr));
 449
 450   return m_processor->Transmit(command);
 451 }
 452
 453 bool CCECBusDevice::TransmitOSDString(cec_logical_address dest, cec_display_control duration, const char *strMessage)
 454 {
 455   CStdString strLog;
 456   strLog.Format("<< %s (%X) -> %s (%X): display OSD message '%s'", GetLogicalAddressName(), m_iLogicalAddress, ToString(dest), dest, strMessage);
 457   AddLog(CEC_LOG_NOTICE, strLog.c_str());
 458
 459   cec_command command;
 460   cec_command::format(command, m_iLogicalAddress, dest, CEC_OPCODE_SET_OSD_STRING);
 461   command.parameters.push_back((uint8_t)duration);
 462
 463   unsigned int iLen = strlen(strMessage);
 464   if (iLen > 13) iLen = 13;
 465
 466   for (unsigned int iPtr = 0; iPtr < iLen; iPtr++)
 467     command.parameters.push_back(strMessage[iPtr]);
 468
 469   return m_processor->Transmit(command);
 470 }
 471
 472 bool CCECBusDevice::TransmitPhysicalAddress(void)
 473 {
 474   CStdString strLog;
 475   strLog.Format("<< %s (%X) -> broadcast (F): physical adddress %4x", GetLogicalAddressName(), m_iLogicalAddress, m_iPhysicalAddress);
 476   AddLog(CEC_LOG_NOTICE, strLog.c_str());
 477
 478   cec_command command;
 479   cec_command::format(command, m_iLogicalAddress, CECDEVICE_BROADCAST, CEC_OPCODE_REPORT_PHYSICAL_ADDRESS);
 480   command.parameters.push_back((uint8_t) ((m_iPhysicalAddress >> 8) & 0xFF));
 481   command.parameters.push_back((uint8_t) (m_iPhysicalAddress & 0xFF));
 482   command.parameters.push_back((uint8_t) (m_type));
 483
 484   return m_processor->Transmit(command);
 485 }
 486
 487 bool CCECBusDevice::TransmitPoll(cec_logical_address dest)
 488 {
 489   bool bReturn(false);
 490
 491   if (dest == CECDEVICE_UNKNOWN)
 492     dest = m_iLogicalAddress;
 493
 494   CStdString strLog;
 495   strLog.Format("<< %s (%X) -> %s (%X): POLL", GetLogicalAddressName(), m_iLogicalAddress, ToString(dest), dest);
 496   AddLog(CEC_LOG_NOTICE, strLog.c_str());
 497
 498   cec_command command;
 499   cec_command::format(command, m_iLogicalAddress, dest, CEC_OPCODE_NONE);
 500   CLockObject lock(&m_mutex);
 501
 502   bReturn = m_processor->Transmit(command);
 503   AddLog(CEC_LOG_DEBUG, bReturn ? ">> POLL sent" : ">> POLL not sent");
 504   return bReturn;
 505 }
 506
 507 bool CCECBusDevice::TransmitPowerState(cec_logical_address dest)
 508 {
 509   CStdString strLog;
 510   strLog.Format("<< %s (%X) -> %s (%X): %s", GetLogicalAddressName(), m_iLogicalAddress, ToString(dest), dest, ToString(m_powerStatus));
 511   AddLog(CEC_LOG_NOTICE, strLog.c_str());
 512
 513   cec_command command;
 514   cec_command::format(command, m_iLogicalAddress, dest, CEC_OPCODE_REPORT_POWER_STATUS);
 515   command.parameters.push_back((uint8_t) m_powerStatus);
 516
 517   return m_processor->Transmit(command);
 518 }
 519
 520 bool CCECBusDevice::TransmitVendorID(cec_logical_address dest)
 521 {
 522   if (m_vendor == CEC_VENDOR_UNKNOWN)
 523   {
 524     CStdString strLog;
 525     strLog.Format("<< %s (%X) -> %s (%X): vendor id feature abort", GetLogicalAddressName(), m_iLogicalAddress, ToString(dest), dest);
 526     AddLog(CEC_LOG_NOTICE, strLog);
 527
 528     m_processor->TransmitAbort(dest, CEC_OPCODE_GIVE_DEVICE_VENDOR_ID);
 529     return false;
 530   }
 531   else
 532   {
 533     CStdString strLog;
 534     strLog.Format("<< %s (%X) -> %s (%X): vendor id %s (%x)", GetLogicalAddressName(), m_iLogicalAddress, ToString(dest), dest, ToString(m_vendor), (uint64_t)m_vendor);
 535     AddLog(CEC_LOG_NOTICE, strLog);
 536
 537     cec_command command;
 538     cec_command::format(command, m_iLogicalAddress, dest, CEC_OPCODE_GIVE_DEVICE_VENDOR_ID);
 539
 540     command.parameters.push_back((uint8_t) (((uint64_t)m_vendor >> 16) & 0xFF));
 541     command.parameters.push_back((uint8_t) (((uint64_t)m_vendor >> 8) & 0xFF));
 542     command.parameters.push_back((uint8_t) ((uint64_t)m_vendor & 0xFF));
 543
 544     return m_processor->Transmit(command);
 545   }
 546 }
 547 //@}