/* udpreceive~ started 20100110 by Martin Peach based on netreceive~:           */
/* ------------------------ netreceive~ --------------------------------------- */
/*                                                                              */
/* Tilde object to receive uncompressed audio data from netsend~.               */
/* Written by Olaf Matthes <olaf.matthes@gmx.de>.                               */
/* Based on streamin~ by Guenter Geiger.                                        */
/* Get source at http://www.akustische-kunst.org/                               */
/*                                                                              */
/* This program is free software; 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.                       */
/*                                                                              */
/* See file LICENSE for further informations on licensing terms.                */
/*                                                                              */
/* 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.  */
/*                                                                              */
/* Based on PureData by Miller Puckette and others.                             */
/*                                                                              */
/* This project was commissioned by the Society for Arts and Technology [SAT],  */
/* Montreal, Quebec, Canada, http://www.sat.qc.ca/.                             */
/*                                                                              */
/* ---------------------------------------------------------------------------- */


#include "m_pd.h"
#include "s_stuff.h"
#include "udpsend~.h"

#include <stdio.h>
#include <sys/types.h>
#include <string.h>
#ifndef _WIN32
#include <sys/socket.h>
#include <errno.h>
#include <netinet/in.h>
#include <netinet/tcp.h>
#include <arpa/inet.h>
#include <netdb.h>
#include <sys/time.h>
#include <unistd.h>
#include <fcntl.h>
#include <stdio.h>
#define SOCKET_ERROR -1
#endif
#ifdef _WIN32
#include <winsock2.h>
#include <ws2tcpip.h> /* for socklen_t */
#endif
#ifdef _MSC_VER
#define snprintf sprintf_s
#endif

#ifndef SOL_IP
#define SOL_IP IPPROTO_IP
#endif

#define DEFAULT_AUDIO_BUFFER_FRAMES 16  /* a small circ. buffer for 16 frames */
#define DEFAULT_AVERAGE_NUMBER 10       /* number of values we store for average history */
#define DEFAULT_NETWORK_POLLTIME 1      /* interval in ms for polling for input data (Max/MSP only) */
#define DEFAULT_QUEUE_LENGTH 3          /* min. number of buffers that can be used reliably on your hardware */

#ifndef _WIN32
#define CLOSESOCKET(fd) close(fd)
#endif
#ifdef _WIN32
#define CLOSESOCKET(fd) closesocket(fd)
#endif

/* ------------------------ udpreceive~ ----------------------------- */

typedef struct _udpreceive_tilde
{
    t_object        x_obj;
    t_outlet        *x_outlet1;
    t_outlet        *x_outlet2;
    t_outlet        *x_addrout;
    t_clock         *x_clock;
    t_atom          x_addrbytes[5];
    int             x_socket;
    int             x_connectsocket;
    int             x_multicast_joined;
    int             x_nconnections;
    long            x_addr;
    unsigned short  x_port;
    t_symbol        *x_hostname;
    int             x_error;
    int             x_buffering;
#define XMSG_SIZE 256
    char            x_msg[XMSG_SIZE];
    char            x_addr_name[256]; // a multicast address or 0

    /* buffering */
    int             x_framein;// index of next empty frame in x_frames[]
    int             x_frameout;// index of next frame to play back from x_frames[]
    t_frame         x_frames[DEFAULT_AUDIO_BUFFER_FRAMES];
    int             x_maxframes;
    long            x_tag_errors;
    int             x_sync;// zero if we didn't receive a tag when we expected one
    int             x_blocksize;
    int             x_blocksperrecv;
    int             x_blockssincerecv;

    int             x_nbytes;
    int             x_counter;// count of received frames
    int             x_average[DEFAULT_AVERAGE_NUMBER];
    int             x_averagecur;
    int             x_underflow;
    int             x_overflow;
    int             x_valid;
    long            x_samplerate;
    int             x_noutlets;
    int             x_vecsize;
    t_int           **x_myvec;  /* vector we pass on to the DSP routine */
} t_udpreceive_tilde;

/* function prototypes */
static void udpreceive_tilde_reset(t_udpreceive_tilde* x, t_floatarg buffer);
static void udpreceive_tilde_datapoll(t_udpreceive_tilde *x);
static int udpreceive_tilde_createsocket(t_udpreceive_tilde* x, char *address, int portno);
static t_int *udpreceive_tilde_perform(t_int *w);
static void udpreceive_tilde_dsp(t_udpreceive_tilde *x, t_signal **sp);
static void udpreceive_tilde_info(t_udpreceive_tilde *x);
static void udpreceive_tilde_tick(t_udpreceive_tilde *x);
static void *udpreceive_tilde_new(t_symbol *s, int argc, t_atom *argv);
static void udpreceive_tilde_free(t_udpreceive_tilde *x);
void udpreceive_tilde_setup(void);
static void udpreceive_tilde_sock_err(t_udpreceive_tilde *x, char *err_string);
static int udpreceive_tilde_sockerror(char *s);
static int udpreceive_tilde_setsocketoptions(int sockfd);

static t_class *udpreceive_tilde_class;
static t_symbol *ps_format, *ps_channels, *ps_framesize, *ps_overflow, *ps_underflow, *ps_packets,
                *ps_queuesize, *ps_average, *ps_sf_float, *ps_sf_16bit, *ps_sf_8bit, 
                *ps_sf_mp3, *ps_sf_aac, *ps_sf_unknown, *ps_bitrate, *ps_hostname, *ps_nothing,
                *ps_tag_errors;

static void udpreceive_tilde_reset(t_udpreceive_tilde* x, t_floatarg buffer)
{
    int     i;

    x->x_counter = 0;
    x->x_nbytes = 0;
    x->x_framein = 0;
    x->x_frameout = 0;
    x->x_blockssincerecv = 0;
    x->x_blocksperrecv = x->x_blocksize / x->x_vecsize;
    x->x_tag_errors = 0;

    for (i = 0; i < DEFAULT_AVERAGE_NUMBER; i++)
        x->x_average[i] = x->x_maxframes;
    x->x_averagecur = 0;

    i = (int)buffer;    
    if ((i > 0)&&(i < DEFAULT_AUDIO_BUFFER_FRAMES))
    {
        x->x_maxframes = i;
        post("udpreceive~: set buffer to %d frames)", x->x_maxframes);
    }
    else if (i != 0) /* special case of 0 leaves buffer size unchanged */
    {
        post("udpreceive~: buffer must be between 1 and %d frames)", DEFAULT_AUDIO_BUFFER_FRAMES-1);
    }
    x->x_underflow = 0;
    x->x_overflow = 0;
    x->x_buffering = 1;
}

static void udpreceive_tilde_datapoll(t_udpreceive_tilde *x)
{
    int                 ret;
    int                 n;
    long                addr;
    unsigned short      port;
    struct sockaddr_in  from;
    socklen_t           fromlen = sizeof(from);
    t_tag               *tag_ptr;

    n = x->x_nbytes;

    if (x->x_nbytes == 0)   /* we ate all the samples and need a new header tag */
    {
        tag_ptr = &x->x_frames[x->x_framein].tag;
        /* receive header tag */
        ret = recvfrom(x->x_socket, (char*)tag_ptr, sizeof(t_tag), 0,
            (struct sockaddr *)&from, &fromlen);
        /* get the sender's ip */
        addr = ntohl(from.sin_addr.s_addr);
        port = ntohs(from.sin_port);
        /* output addr/port only if changed */
        if (!((addr == x->x_addr)&&(port == x->x_port)))
        {
            x->x_addr = addr;
            x->x_port = port;
            x->x_addrbytes[0].a_w.w_float = (x->x_addr & 0xFF000000)>>24;
            x->x_addrbytes[1].a_w.w_float = (x->x_addr & 0x0FF0000)>>16;
            x->x_addrbytes[2].a_w.w_float = (x->x_addr & 0x0FF00)>>8;
            x->x_addrbytes[3].a_w.w_float = (x->x_addr & 0x0FF);
            x->x_addrbytes[4].a_w.w_float = x->x_port;
            outlet_list(x->x_addrout, &s_list, 5L, x->x_addrbytes);
        }
        if (ret <= 0)   /* error */
        {
            if (0 == udpreceive_tilde_sockerror("recv tag")) return;
            udpreceive_tilde_reset(x, 0);
            return;
        }
        else if (ret != sizeof(t_tag))
        {
            /* incomplete header tag: return and try again later */
            /* in the hope that more data will be available */
            pd_error(x, "udpreceive~: got incomplete header tag");
            return;
        }
        /* make sure this is really a tag */
        if (!((tag_ptr->tag[0] == 'T')&&(tag_ptr->tag[1] == 'A')&&(tag_ptr->tag[2] == 'G')&&(tag_ptr->tag[3] == '!')))
        {
            ++x->x_tag_errors;
            if (x->x_sync) pd_error(x, "udpreceive~: bad header tag (%d)", x->x_tag_errors);
            x->x_sync = 0;
            /* tag length is 16 bytes, a multiple of the data frame size, so eventually we should resync on a tag */
            return;
        }
        /* adjust byte order if necessary */
        tag_ptr->count = ntohl(tag_ptr->count);
        tag_ptr->framesize = ntohl(tag_ptr->framesize);

        /* get info from header tag */
        if (tag_ptr->channels > (x->x_noutlets-1))
        {
            pd_error(x, "udpreceive~: incoming stream has too many channels (%d)", tag_ptr->channels);
            x->x_counter = 0;
            return;
        }
        x->x_nbytes = n = tag_ptr->framesize;
        x->x_sync = 1;
    }
    else    /* we already have header tag or some data and need more */
    {
        ret = recvfrom(x->x_socket, (char*)x->x_frames[x->x_framein].data + x->x_frames[x->x_framein].tag.framesize - n,
            n, 0, (struct sockaddr *)&from, &fromlen);
        if (ret > 0)
        {
            n -= ret;
        }
        else if (ret < 0)   /* error */
        {
            if ( 0 == (ret = udpreceive_tilde_sockerror("recv data"))) return;
#ifdef _WIN32
            if ( ret == WSAEFAULT)            
#else
            if ( ret == EFAULT)
#endif
            {
                post ("udpreceive~: EFAULT: %p %lu %d", x->x_frames[x->x_framein].data, x->x_frames[x->x_framein].tag.framesize, n);
                return; 
            }            
            udpreceive_tilde_reset(x, 0);
            return;
        }

        x->x_nbytes = n;
        if (n == 0) /* a complete packet is received */
        {
            if (x->x_frames[x->x_framein].tag.format == SF_AAC)
            {
                pd_error(x, "udpreceive~: don't know how to decode AAC format");
                return;
            }
            x->x_counter++;
            x->x_framein++;
            x->x_framein %= DEFAULT_AUDIO_BUFFER_FRAMES;

            /* check for buffer overflow */
            if (x->x_framein == x->x_frameout)
            {
                x->x_overflow++;
            }
        }
    }
}

static int udpreceive_tilde_createsocket(t_udpreceive_tilde* x, char *address, int portno)
{
    struct sockaddr_in  server;
    struct hostent      *hp;
    int                 sockfd;
    int                 intarg;
    int                 multicast_joined = 0;
#if defined __APPLE__ || defined _WIN32
    struct ip_mreq      mreq;
#else
    struct ip_mreqn     mreq;
#endif


    if (x->x_socket >= 0)
    {
        // close the existing socket first
        sys_rmpollfn(x->x_socket);
        sys_closesocket(x->x_socket);
    }
    /* create a socket */
    sockfd = socket(AF_INET, SOCK_DGRAM, 0);

    if (sockfd < 0)
    {
        udpreceive_tilde_sock_err(x, "udpreceive~: socket");
        return 0;
    }
    server.sin_family = AF_INET;
    if (address[0] == 0) server.sin_addr.s_addr = INADDR_ANY;
    else 
    {
        hp = gethostbyname(address);
        if (hp == 0)
        {
            pd_error(x, "udpreceive~: bad host?\n");
            return 0;
        }
        memcpy((char *)&server.sin_addr, (char *)hp->h_addr, hp->h_length);
    }
    /* enable delivery of all multicast or broadcast (but not unicast)
    * UDP datagrams to all sockets bound to the same port */
    intarg = 1;
    if (setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR,
        (char *)&intarg, sizeof(intarg)) < 0)
        udpreceive_tilde_sock_err(x, "udpreceive~: setsockopt (SO_REUSEADDR) failed");

    /* assign server port number */
    server.sin_port = htons((u_short)portno);
    post("udpreceive~: listening to port number %d", portno);

    udpreceive_tilde_setsocketoptions(sockfd);

    /* if a multicast address was specified, join the multicast group */
    /* hop count defaults to 1 so we won't leave the subnet*/
    if (0xE0000000 == (ntohl(server.sin_addr.s_addr) & 0xF0000000))
    {
        server.sin_addr.s_addr = INADDR_ANY;
        /* first bind the socket to INADDR_ANY */
        if (bind(sockfd, (struct sockaddr *)&server, sizeof(server)) < 0)
        {
            udpreceive_tilde_sock_err(x, "udpreceive~: bind");
            sys_closesocket(sockfd);
            return 0;
        }
        /* second join the multicast group */
        memcpy((char *)&server.sin_addr, (char *)hp->h_addr, hp->h_length);

#if defined __APPLE__ || defined _WIN32
        mreq.imr_multiaddr.s_addr = server.sin_addr.s_addr;
        mreq.imr_interface.s_addr = INADDR_ANY;/* can put a specific local IP address here if host is multihomed */
#else
        mreq.imr_multiaddr.s_addr = server.sin_addr.s_addr;
        mreq.imr_address.s_addr = INADDR_ANY;
        mreq.imr_ifindex = 0;
#endif //__APPLE__ || _WIN32
        if (setsockopt(sockfd, IPPROTO_IP, IP_ADD_MEMBERSHIP,
            (char *)&mreq, sizeof(mreq)) < 0)
            udpreceive_tilde_sock_err(x, "udpreceive~: setsockopt IP_ADD_MEMBERSHIP");
        else
        {
            multicast_joined = 1;
            post ("udpreceive~: added to multicast group");
        }
    }
    else
    {
        /* name the socket */
        if (bind(sockfd, (struct sockaddr *)&server, sizeof(server)) < 0)
        {
            udpreceive_tilde_sock_err(x, "udpreceive~: bind");
            CLOSESOCKET(sockfd);
            return 0;
        }
    }
    x->x_multicast_joined = multicast_joined;
    x->x_socket = sockfd;
    x->x_nbytes = 0;
    sys_addpollfn(x->x_socket, (t_fdpollfn)udpreceive_tilde_datapoll, x);
    return 1;
}

/* Queue is 1 to 16 frames long */
#define QUEUESIZE (int)((x->x_framein + DEFAULT_AUDIO_BUFFER_FRAMES - x->x_frameout) % DEFAULT_AUDIO_BUFFER_FRAMES)
/* Block is a set of sample vectors inside a frame, one vector per channel */
#define BLOCKOFFSET (x->x_blockssincerecv * x->x_vecsize * x->x_frames[x->x_frameout].tag.channels)

static t_int *udpreceive_tilde_perform(t_int *w)
{
    t_udpreceive_tilde      *x = (t_udpreceive_tilde*) (w[1]);
    int                     n = (int)(w[2]);
    t_float                 *out[DEFAULT_AUDIO_CHANNELS];
    const int               offset = 3;
    const int               channels = x->x_frames[x->x_frameout].tag.channels;
    int                     i = 0;

    x->x_valid = 0;
    for (i = 0; i < x->x_noutlets; i++)
    {
        out[i] = (t_float *)(w[offset + i]);
    }

    /* set our vector size to the local vector size */
    if (n != x->x_vecsize)
    {
        x->x_vecsize = n;
        x->x_blocksperrecv = x->x_blocksize / x->x_vecsize;
        x->x_blockssincerecv = 0;
    }

    /* check whether there is enough data in buffer */
    if (x->x_buffering && (x->x_counter < x->x_maxframes))
    {
        goto bail;
    }
    x->x_buffering = 0;

    /* check for buffer underflow */
    if (x->x_framein == x->x_frameout)
    {
        x->x_underflow++;
        goto bail;
    }

    x->x_valid = 1;
    /* queue balancing */
    x->x_average[x->x_averagecur] = QUEUESIZE;
    if (++x->x_averagecur >= DEFAULT_AVERAGE_NUMBER)
        x->x_averagecur = 0;

    switch (x->x_frames[x->x_frameout].tag.format)
    {
        case SF_FLOAT:
        {
            int32_t* buf = (int32_t *)x->x_frames[x->x_frameout].data + BLOCKOFFSET;
            flint   fl;

            /* swap bytes if necessary */
            while (n--)
            {
                for (i = 0; i < channels; i++)
                {
                    fl.i32 = ntohl(*buf++);
                    *out[i]++ = fl.f32;
                }
                for (i = channels; i < (x->x_noutlets-1); i++)
                {
                    *out[i]++ = 0.;
                }
                *out[i]++ = x->x_valid;
            }
            x->x_error = 0;
            break;
        }
        case SF_16BIT:
        {
            short* buf = (short *)x->x_frames[x->x_frameout].data + BLOCKOFFSET;
            /* swap bytes if necessary */
            while (n--)
            {
                for (i = 0; i < channels; i++)
                {
                    *out[i]++ = (t_float)((short)(ntohs(*buf++)) * 3.051850e-05);
                }
                for (i = channels; i < (x->x_noutlets-1); i++)
                {
                    *out[i]++ = 0.;
                }
                *out[i]++ = x->x_valid;
            }
            x->x_error = 0;
            break;
        }
        case SF_8BIT:     
        {
            unsigned char* buf = (unsigned char *)x->x_frames[x->x_frameout].data + BLOCKOFFSET;

            while (n--)
            {
                for (i = 0; i < channels; i++)
                {
                    *out[i]++ = (t_float)((0.0078125 * (*buf++)) - 1.0);
                }
                for (i = channels; i < (x->x_noutlets-1); i++)
                {
                    *out[i]++ = 0.;
                }
                *out[i]++ = x->x_valid;
            }
            x->x_error = 0;
            break;
        }
        case SF_MP3:
        {
            if (x->x_error != 1)
            {
                x->x_error = 1;
                snprintf(x->x_msg, XMSG_SIZE, "udpreceive~: mp3 format not supported");
                clock_delay(x->x_clock, 0);
            }
            break;
        }
        case SF_AAC:
        {
            if (x->x_error != 2)
            {
                x->x_error = 2;
                snprintf(x->x_msg, XMSG_SIZE, "udpreceive~: aac format not supported");
                clock_delay(x->x_clock, 0);
            }
            break;
        }
        default:
            if (x->x_error != 3)
            {
                x->x_error = 3;
                snprintf(x->x_msg, XMSG_SIZE, "udpreceive~: unknown format (%d)",x->x_frames[x->x_frameout].tag.format);
                clock_delay(x->x_clock, 0);
            }
            break;
    }

    if (!(x->x_blockssincerecv < x->x_blocksperrecv - 1))
    {
        x->x_blockssincerecv = 0;
        x->x_frameout++;
        x->x_frameout %= DEFAULT_AUDIO_BUFFER_FRAMES;
    }
    else x->x_blockssincerecv++;

    return (w + offset + x->x_noutlets);

bail:
    /* set output to zero */
    while (n--) for (i = 0; i < x->x_noutlets; i++) *(out[i]++) = 0.;
    return (w + offset + x->x_noutlets);
}

static void udpreceive_tilde_dsp(t_udpreceive_tilde *x, t_signal **sp)
{
    int i;

    x->x_myvec[0] = (t_int*)x;
    x->x_myvec[1] = (t_int*)sp[0]->s_n;

    x->x_samplerate = (long)sp[0]->s_sr;

    if (x->x_blocksize % sp[0]->s_n)
    {
        pd_error(x, "udpreceive~: signal vector size too large (needs to be even divisor of %d)", x->x_blocksize);
    }
    else
    {
        for (i = 0; i < x->x_noutlets; i++)
        {
            x->x_myvec[2 + i] = (t_int*)sp[i + 1]->s_vec;
        }
        dsp_addv(udpreceive_tilde_perform, x->x_noutlets + 2, (t_int*)x->x_myvec);
    }
}

/* send stream info */
static void udpreceive_tilde_info(t_udpreceive_tilde *x)
{
    t_atom      list[2];
    t_symbol    *sf_format;
    t_float     bitrate;
    int         i, avg = 0;

    for (i = 0; i < DEFAULT_AVERAGE_NUMBER; i++)
        avg += x->x_average[i];

    bitrate = (t_float)((SF_SIZEOF(x->x_frames[x->x_frameout].tag.format) * x->x_samplerate * 8 * x->x_frames[x->x_frameout].tag.channels) / 1000.);

    switch (x->x_frames[x->x_frameout].tag.format)
    {
        case SF_FLOAT:
        {
            sf_format = ps_sf_float;
            break;
        }
        case SF_16BIT:
        {
            sf_format = ps_sf_16bit;
            break;
        }
        case SF_8BIT:
        {
            sf_format = ps_sf_8bit;
            break;
        }
        case SF_MP3:
        {
            sf_format = ps_sf_mp3;
            break;
        }
        case SF_AAC:
        {
            sf_format = ps_sf_aac;
            break;
        }
        default:
        {
            sf_format = ps_sf_unknown;
            break;
        }
    }

    /* --- stream information (t_tag) --- */
    /* audio format */
    SETSYMBOL(list, (t_symbol *)sf_format);
    outlet_anything(x->x_outlet2, ps_format, 1, list);

    /* channels */
    SETFLOAT(list, (t_float)x->x_frames[x->x_frameout].tag.channels);
    outlet_anything(x->x_outlet2, ps_channels, 1, list);

    /* framesize */
    SETFLOAT(list, (t_float)x->x_frames[x->x_frameout].tag.framesize);
    outlet_anything(x->x_outlet2, ps_framesize, 1, list);

    /* bitrate */
    SETFLOAT(list, (t_float)bitrate);
    outlet_anything(x->x_outlet2, ps_bitrate, 1, list);

    /* --- internal info (buffer and network) --- */
    /* overflow */
    SETFLOAT(list, (t_float)x->x_overflow);
    outlet_anything(x->x_outlet2, ps_overflow, 1, list);

    /* underflow */
    SETFLOAT(list, (t_float)x->x_underflow);
    outlet_anything(x->x_outlet2, ps_underflow, 1, list);

    /* queuesize */
    SETFLOAT(list, (t_float)QUEUESIZE);
    outlet_anything(x->x_outlet2, ps_queuesize, 1, list);

    /* average queuesize */
    SETFLOAT(list, (t_float)((t_float)avg / (t_float)DEFAULT_AVERAGE_NUMBER));
    outlet_anything(x->x_outlet2, ps_average, 1, list);

    /* total packets */
    SETFLOAT(list, (t_float)x->x_counter);
    outlet_anything(x->x_outlet2, ps_packets, 1, list);

    /* total tag errors */
    SETFLOAT(list, (t_float)x->x_tag_errors);
    outlet_anything(x->x_outlet2, ps_tag_errors, 1, list);

    outlet_list(x->x_addrout, &s_list, 5L, x->x_addrbytes);
}

static void udpreceive_tilde_tick(t_udpreceive_tilde *x)
{
/* post a message once, outside of perform routine */
    post("%s", x->x_msg);
}

static void *udpreceive_tilde_new(t_symbol *s, int argc, t_atom *argv)
{
    t_udpreceive_tilde  *x;
    int                 i, j = 0, portno = 0, outlets = 0, blocksize = 0;


    x = (t_udpreceive_tilde *)pd_new(udpreceive_tilde_class);
    if (NULL == x) return NULL;
    for (i = sizeof(t_object); i < (int)sizeof(t_udpreceive_tilde); i++)  
        ((char *)x)[i] = 0; /* do we need to do this?*/

#ifdef DEBUG
    post("udpreceive_tilde_new:argc is %d s is %s", argc, s->s_name);
#endif
    for (i = 0; i < argc ;++i)
    {
        if (argv[i].a_type == A_FLOAT)
        { // float is taken to be a port number, a channel count, then a buffer size in that order
#ifdef DEBUG
            post ("argv[%d] is a float: %f", i, argv[i].a_w.w_float);
#endif
            if (j == 0) portno = (int)argv[i].a_w.w_float;
            else if (j == 1) outlets = (int)argv[i].a_w.w_float;
            else if (j == 2) blocksize = (int)argv[i].a_w.w_float;
            ++j;
        }
        else if (argv[i].a_type == A_SYMBOL)
        { // symbol is taken to be an ip address (for multicast)
#ifdef DEBUG
            post ("argv[%d] is a symbol: %s", i, argv[i].a_w.w_symbol->s_name);
#endif
            atom_string(&argv[i], x->x_addr_name, 256);
        }
    }
#ifdef DEBUG
    post("Setting port %d, address %s", portno, x->addr);
#endif


    if (outlets < 1 || outlets > DEFAULT_AUDIO_CHANNELS)
    {
        pd_error(x, "udpreceive~: Number of channels must be between 1 and %d", DEFAULT_AUDIO_CHANNELS);
        return NULL;
    }

    x->x_noutlets = outlets + 1; // extra outlet for valid flag
    for (i = 0; i < x->x_noutlets; i++)
        outlet_new(&x->x_obj, &s_signal);
    x->x_outlet2 = outlet_new(&x->x_obj, &s_anything);
    x->x_addrout = outlet_new(&x->x_obj, &s_list);
    for (i = 0; i < 5; ++i)
    {
        x->x_addrbytes[i].a_type = A_FLOAT;
        x->x_addrbytes[i].a_w.w_float = 0;
    }
    x->x_addr = 0;
    x->x_port = 0;
    x->x_myvec = (t_int **)t_getbytes(sizeof(t_int *) * (x->x_noutlets + 3));
    if (!x->x_myvec)
    {
        pd_error(x, "udpreceive~: out of memory");
        return NULL;
    }
    x->x_connectsocket = x->x_socket = -1;
    x->x_nconnections = x->x_underflow = x->x_overflow = 0;
    x->x_hostname = ps_nothing;
/* allocate space for 16 frames of 1024 X numchannels floats*/
    for (i = 0; i < DEFAULT_AUDIO_BUFFER_FRAMES; i++)
    {
        x->x_frames[i].data = (char *)t_getbytes(DEFAULT_AUDIO_BUFFER_SIZE * (x->x_noutlets-1) * sizeof(t_float));
    }
    x->x_clock = clock_new(&x->x_obj.ob_pd, (t_method)udpreceive_tilde_tick);
    x->x_sync = 1;
    x->x_tag_errors = x->x_framein = x->x_frameout = x->x_valid = 0;
    x->x_maxframes = DEFAULT_QUEUE_LENGTH;
    x->x_vecsize = 64; /* we'll update this later */
    if (blocksize == 0) x->x_blocksize = DEFAULT_AUDIO_BUFFER_SIZE; 
    else if (DEFAULT_AUDIO_BUFFER_SIZE%(int)blocksize)
    {
        pd_error(x, "udpreceive~: blocksize must fit snugly in %d", DEFAULT_AUDIO_BUFFER_SIZE);
        return NULL;
    } 
    else x->x_blocksize = blocksize; //DEFAULT_AUDIO_BUFFER_SIZE; /* <-- the only place blocksize is set */
    x->x_blockssincerecv = 0;
    x->x_blocksperrecv = x->x_blocksize / x->x_vecsize;
    x->x_buffering = 1;
    if (!udpreceive_tilde_createsocket(x, x->x_addr_name, portno))
    {
        pd_error(x, "udpreceive~: failed to create listening socket");
        return NULL;
    }
    return (x);
}

static void udpreceive_tilde_free(t_udpreceive_tilde *x)
{
    int i;

    if (x->x_connectsocket != -1)
    {
        sys_rmpollfn(x->x_connectsocket);
        CLOSESOCKET(x->x_connectsocket);
    }
    if (x->x_socket != -1)
    {
        sys_rmpollfn(x->x_socket);
        CLOSESOCKET(x->x_socket);
    }

    /* free memory */
    t_freebytes(x->x_myvec, sizeof(t_int *) * (x->x_noutlets + 3));
    for (i = 0; i < DEFAULT_AUDIO_BUFFER_FRAMES; i++)
    {
         t_freebytes(x->x_frames[i].data, DEFAULT_AUDIO_BUFFER_SIZE * (x->x_noutlets-1) * sizeof(t_float));
    }
    clock_free(x->x_clock);
}

void udpreceive_tilde_setup(void)
{
    udpreceive_tilde_class = class_new(gensym("udpreceive~"), 
        (t_newmethod) udpreceive_tilde_new, (t_method) udpreceive_tilde_free,
        sizeof(t_udpreceive_tilde), CLASS_DEFAULT, A_GIMME, 0);

    class_addmethod(udpreceive_tilde_class, nullfn, gensym("signal"), 0);
    class_addmethod(udpreceive_tilde_class, (t_method)udpreceive_tilde_info, gensym("info"), 0);
    class_addmethod(udpreceive_tilde_class, (t_method)udpreceive_tilde_dsp, gensym("dsp"), 0);
    class_addmethod(udpreceive_tilde_class, (t_method)udpreceive_tilde_reset, gensym("reset"), A_DEFFLOAT, 0);
    class_addmethod(udpreceive_tilde_class, (t_method)udpreceive_tilde_reset, gensym("buffer"), A_DEFFLOAT, 0);
    post("udpreceive~ v%s, (c) 2004 Olaf Matthes, 2010 Martin Peach", VERSION);

    ps_format = gensym("format");
    ps_tag_errors = gensym("tag_errors");
    ps_channels = gensym("channels");
    ps_framesize = gensym("framesize");
    ps_bitrate = gensym("bitrate");
    ps_overflow = gensym("overflow");
    ps_underflow = gensym("underflow");
    ps_queuesize = gensym("queuesize");
    ps_average = gensym("average");
    ps_packets = gensym("packets");
    ps_hostname = gensym("ipaddr");
    ps_sf_float = gensym("_float_");
    ps_sf_16bit = gensym("_16bit_");
    ps_sf_8bit = gensym("_8bit_");
    ps_sf_mp3 = gensym("_mp3_");
    ps_sf_aac = gensym("_aac_");
    ps_sf_unknown = gensym("_unknown_");
    ps_nothing = gensym("");
}

/* error handlers */
static void udpreceive_tilde_sock_err(t_udpreceive_tilde *x, char *err_string)
{
/* prints the last error from errno or WSAGetLastError() */
#ifdef _WIN32
    LPVOID  lpMsgBuf;
    DWORD   dwRetVal = WSAGetLastError();
    int     len = 0, i;
    char    *cp;

    if (len = FormatMessageA(FORMAT_MESSAGE_ALLOCATE_BUFFER | FORMAT_MESSAGE_FROM_SYSTEM | FORMAT_MESSAGE_IGNORE_INSERTS
        , NULL, dwRetVal, MAKELANGID(LANG_NEUTRAL, SUBLANG_DEFAULT), (LPSTR)&lpMsgBuf, 0, NULL))
    {
        cp = (char *)lpMsgBuf;
        for(i = 0; i < len; ++i)
        {
            if (cp[i] < 0x20)
            { /* end string at first weird character */
                cp[i] = 0;
                break;
            }
        }
        pd_error(x, "%s: %s (%d)", err_string, lpMsgBuf, dwRetVal);
        LocalFree(lpMsgBuf);
    }
#else
    pd_error(x, "%s: %s (%d)", err_string, strerror(errno), errno);
#endif
}

static int udpreceive_tilde_sockerror(char *s)
{
#ifdef _WIN32
    int err = WSAGetLastError();
    if (err == 10054) return 1;
    else if (err == 10040) post("udpreceive~: %s: message too long (%d)", s, err);
    else if (err == 10053) post("udpreceive~: %s: software caused connection abort (%d)", s, err);
    else if (err == 10055) post("udpreceive~: %s: no buffer space available (%d)", s, err);
    else if (err == 10060) post("udpreceive~: %s: connection timed out (%d)", s, err);
    else if (err == 10061) post("udpreceive~: %s: connection refused (%d)", s, err);
    else post("udpreceive~: %s: %s (%d)", s, strerror(err), err);
#else
    int err = errno;
    post("udpreceive~: %s: %s (%d)", s, strerror(err), err);
#endif
#ifdef _WIN32
    if (err == WSAEWOULDBLOCK)
#endif
#ifndef _WIN32
    if (err == EAGAIN)
#endif
    {
        return 0;   /* recoverable error */
    }
    return err;   /* indicate non-recoverable error */
}

static int udpreceive_tilde_setsocketoptions(int sockfd)
{
    int sockopt = 1;
    if (setsockopt(sockfd, SOL_IP, TCP_NODELAY, (const char*)&sockopt, sizeof(int)) < 0)
        post("udpreceive~: setsockopt NODELAY failed");

    sockopt = 1;
    if (setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, (const char*)&sockopt, sizeof(int)) < 0)
        post("udpreceive~: setsockopt REUSEADDR failed");
    return 0;
}

/* fin udpreceive~.c */