/*
Copyright (C) 2004-2006 Grame  

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.

  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., 675 Mass Ave, Cambridge, MA 02139, USA.

*/

#include "JackFifo.h"
#include "JackError.h"
#include "JackChannel.h"
#include <sys/types.h>
#include <sys/stat.h>
#include <unistd.h>
#include <fcntl.h>
#include <assert.h>

namespace Jack
{

void JackFifo::BuildName(const char* name, char* res)
{
    sprintf(res, "%s/jack_fifo.%s", jack_client_dir, name);
}

bool JackFifo::Signal()
{
    bool res;
    char c = 0;
    assert(fFifo >= 0);

    if (fFlush)
        return true;

    if ((res = (write(fFifo, &c, sizeof(c)) != sizeof(c)))) {
        jack_error("JackFifo::Signal name = %s err = %s", fName, strerror(errno));
    }
    return !res;
}

bool JackFifo::SignalAll()
{
    bool res;
    char c = 0;
    assert(fFifo >= 0);

    if (fFlush)
        return true;

    if ((res = (write(fFifo, &c, sizeof(c)) != sizeof(c)))) {
        jack_error("JackFifo::SignalAll name = %s err = %s", fName, strerror(errno));
    }
    return !res;
}

bool JackFifo::Wait()
{
    bool res;
    char c;
    assert(fFifo >= 0);

    if ((res = (read(fFifo, &c, sizeof(c)) != sizeof(c)))) {
        jack_error("JackFifo::Wait name = %s err = %s", fName, strerror(errno));
    }
    return !res;
}

#ifdef __APPLE__
#warning JackFifo::TimedWait not available : synchronous mode may not work correctly if FIFO are used
bool JackFifo::TimedWait(long usec)
{
    return Wait();
}
#else 
// Does not work on OSX ??
bool JackFifo::TimedWait(long usec)
{
    assert(fFifo >= 0);

    if ((poll(&fPoll, 1, usec / 1000) < 0) && (errno != EINTR)) {
        jack_error("JackFifo::TimedWait name = %s err = %s", fName, strerror(errno));
        return false;
    }

    if (fPoll.revents & POLLIN) {
        return Wait();
    } else {
        jack_error("JackFifo::TimedWait fails name = %s revents %ld ", fName, fPoll.revents);
        return false;
    }
}
#endif

// Server side
bool JackFifo::Allocate(const char* name, int value)
{
    struct stat statbuf;
    BuildName(name, fName);

    JackLog("JackFifo::Allocate name = %s\n", fName);

    if (stat(fName, &statbuf)) {
        if (errno == ENOENT) {
            if (mkfifo(fName, 0666) < 0) {
                jack_error("Cannot create inter-client FIFO [%s] (%s)\n", name, strerror(errno));
                return false;
            }
        } else {
            jack_error("Cannot check on FIFO %s\n", name);
            return false;
        }
    } else {
        if (!S_ISFIFO(statbuf.st_mode)) {
            jack_error("FIFO (%s) already exists, but is not a FIFO!\n", name);
            return false;
        }
    }

    if ((fFifo = open(fName, O_RDWR | O_CREAT, 0666)) < 0) {
        jack_error("Cannot open fifo [%s] (%s)", name, strerror(errno));
        return false;
    } else {
        fPoll.fd = fFifo;
        fPoll.events = POLLERR | POLLIN | POLLHUP | POLLNVAL;
        return true;
    }
}

// Client side
bool JackFifo::ConnectAux(const char* name, int access)
{
    BuildName(name, fName);
    JackLog("JackFifo::ConnectAux name = %s\n", fName);

    // Temporary...
    if (fFifo >= 0) {
        JackLog("Already connected name = %s\n", name);
        return true;
    }

    if ((fFifo = open(fName, access)) < 0) {
        jack_error("Connect: can't connect named fifo name = %s err = %s", fName, strerror(errno));
        return false;
    } else {
        fPoll.fd = fFifo;
        fPoll.events = POLLERR | POLLIN | POLLHUP | POLLNVAL;
        return true;
    }
}

bool JackFifo::Connect(const char* name)
{
    return ConnectAux(name, O_RDWR);
}

bool JackFifo::ConnectOutput(const char* name)
{
    return ConnectAux(name, O_WRONLY | O_NONBLOCK);
}

bool JackFifo::ConnectInput(const char* name)
{
    return ConnectAux(name, O_RDONLY);
}

bool JackFifo::Disconnect()
{
    if (fFifo >= 0) {
        JackLog("JackFifo::Disconnect %s\n", fName);
        if (close(fFifo) != 0) {
            jack_error("Disconnect: can't disconnect named fifo name = %s err = %s", fName, strerror(errno));
            return false;
        } else {
            fFifo = -1;
            return true;
        }
    } else {
        return true;
    }
}

// Server side : destroy the fifo
void JackFifo::Destroy()
{
    if (fFifo > 0) {
        JackLog("JackFifo::Destroy name = %s\n", fName);
        unlink(fName);
        if (close(fFifo) != 0) {
            jack_error("Destroy: can't destroy fifo name = %s err = %s", fName, strerror(errno));
        }
        fFifo = -1;
    } else {
        jack_error("JackFifo::Destroy fifo < 0");
    }
}

} // end of namespace