int RTPTCPTransmitter::SendRTPRTCPData(const void *data, size_t len)
{
  if (!m_init)
    return ERR_RTP_TCPTRANS_NOTINIT;

  MAINMUTEX_LOCK
  
  if (!m_created)
  {
    MAINMUTEX_UNLOCK
    return ERR_RTP_TCPTRANS_NOTCREATED;
  }
  if (len > RTPTCPTRANS_MAXPACKSIZE)
  {
    MAINMUTEX_UNLOCK
    return ERR_RTP_TCPTRANS_SPECIFIEDSIZETOOBIG;
  }
  
  std::map<SocketType, SocketData>::iterator it = m_destSockets.begin();
  std::map<SocketType, SocketData>::iterator end = m_destSockets.end();

  vector<SocketType> errSockets;
  int flags = 0;
#ifdef RTP_HAVE_MSG_NOSIGNAL
  flags = MSG_NOSIGNAL;
#endif // RTP_HAVE_MSG_NOSIGNAL

  while (it != end)
  {
    uint8_t lengthBytes[2] = { (uint8_t)((len >> 8)&0xff), (uint8_t)(len&0xff) };
    SocketType sock = it->first;

    if (send(sock,(const char *)lengthBytes,2,flags) < 0 ||
      send(sock,(const char *)data,len,flags) < 0)
      errSockets.push_back(sock);
    ++it;
  }
  
  MAINMUTEX_UNLOCK

  if (errSockets.size() != 0)
  {
    for (size_t i = 0 ; i < errSockets.size() ; i++)
      OnSendError(errSockets[i]);
  }

  // Don't return an error code to avoid the poll thread exiting
  // due to one closed connection for example

  return 0;
}

  while (it != end)
  {
    uint8_t lengthBytes[2] = { (uint8_t)((len >> 8)&0xff), (uint8_t)(len&0xff) };
    SocketType sock = it->first;

    if (send(sock,(const char *)lengthBytes,2,flags) < 0 ||
      send(sock,(const char *)data,len,flags) < 0)
      errSockets.push_back(sock);
    ++it;
  }