/****************************************************************************
 * apps/examples/udpblaster/udpblaster_host.c
 *
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.  The
 * ASF licenses this file to you 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.
 *
 ****************************************************************************/

/****************************************************************************
 * Included Files
 ****************************************************************************/

#include "config.h"

#include <stdint.h>
#include <stdio.h>
#include <unistd.h>
#include <errno.h>

#include <sys/socket.h>
#include <netinet/in.h>

#include "udpblaster.h"

/****************************************************************************
 * Public Functions
 ****************************************************************************/

/****************************************************************************
 * main
 ****************************************************************************/

int main(int argc, char **argv, char **envp)
{
#ifdef CONFIG_EXAMPLES_UDPBLASTER_IPv4
  struct sockaddr_in target;
#else
  struct sockaddr_in6 target;
#endif
  socklen_t addrlen;
  size_t sendsize;
  unsigned long delay;
  int npackets;
  int ndots;
  int sockfd;
  int ret;

#ifdef CONFIG_EXAMPLES_UDPBLASTER_IPv4
  target.sin_family             = AF_INET;
  target.sin_port               = HTONS(UDPBLASTER_TARGET_PORTNO);
  target.sin_addr.s_addr        = HTONL(CONFIG_EXAMPLES_UDPBLASTER_TARGETIP);

  addrlen                       = sizeof(struct sockaddr_in);
  sockfd                        = socket(PF_INET, SOCK_DGRAM, 0);
  if (sockfd < 0)
    {
      fprintf(stderr, "ERROR: socket() failed: %d\n", errno);
      return 1;
    }

#else
  target.sin6_family            = AF_INET6;
  target.sin6_port              = HTONS(UDPBLASTER_TARGET_PORTNO);

  *(uint16_t *)&target.sin6_addr.s6_addr[0] =
      HTONS(CONFIG_EXAMPLES_UDPBLASTER_TARGETIPv6_1);
  *(uint16_t *)&target.sin6_addr.s6_addr[2] =
      HTONS(CONFIG_EXAMPLES_UDPBLASTER_TARGETIPv6_2);
  *(uint16_t *)&target.sin6_addr.s6_addr[4] =
      HTONS(CONFIG_EXAMPLES_UDPBLASTER_TARGETIPv6_3);
  *(uint16_t *)&target.sin6_addr.s6_addr[6] =
      HTONS(CONFIG_EXAMPLES_UDPBLASTER_TARGETIPv6_4);
  *(uint16_t *)&target.sin6_addr.s6_addr[8] =
      HTONS(CONFIG_EXAMPLES_UDPBLASTER_TARGETIPv6_5);
  *(uint16_t *)&target.sin6_addr.s6_addr[10] =
      HTONS(CONFIG_EXAMPLES_UDPBLASTER_TARGETIPv6_6);
  *(uint16_t *)&target.sin6_addr.s6_addr[12] =
      HTONS(CONFIG_EXAMPLES_UDPBLASTER_TARGETIPv6_7);
  *(uint16_t *)&target.sin6_addr.s6_addr[14] =
      HTONS(CONFIG_EXAMPLES_UDPBLASTER_TARGETIPv6_8);

  addrlen                       = sizeof(struct sockaddr_in6);
  sockfd                        = socket(PF_INET6, SOCK_DGRAM, 0);
  if (sockfd < 0)
    {
      fprintf(stderr, "ERROR: socket() failed: %d\n", errno);
      return 1;
    }
#endif

  /* bytes/packet = UDPBLASTER_SENDSIZE
   * bits/sec     = CONFIG_EXAMPLES_UDPBLASTER_HOSTRATE
   * bytes/sec    = CONFIG_EXAMPLES_UDPBLASTER_HOSTRATE / 8
   * packets/sec  = (bytes/sec) / (bytes/packet)
   *              = CONFIG_EXAMPLES_UDPBLASTER_HOSTRATE /
   *                UDPBLASTER_SENDSIZE / 8
   * delay        = microseconds/packet
   *              = (1000000 * UDPBLASTER_SENDSIZE) /
   *                CONFIG_EXAMPLES_UDPBLASTER_HOSTRATE / 8
   *              = (125000 * UDPBLASTER_SENDSIZE) /
   *                CONFIG_EXAMPLES_UDPBLASTER_HOSTRATE
   */

  sendsize = UDPBLASTER_SENDSIZE;
  delay    = (125000 * sendsize) / CONFIG_EXAMPLES_UDPBLASTER_HOSTRATE;

  npackets = 0;
  ndots    = 0;

  for (; ; )
    {
      ret = sendto(sockfd, g_udpblaster_text, sendsize, 0,
                   (struct sockaddr *)&target, addrlen);
      if (ret < 0)
        {
          fprintf(stderr, "ERROR: sendto() failed: %d\n", errno);
          return 1;
        }

      if (++npackets >= 10)
        {
          putchar('.');
          npackets = 0;

          if (++ndots >= 50)
            {
              putchar('\n');
              ndots = 0;
            }
        }

      usleep(delay);
    }

  return 0; /* Won't get here */
}