#include "socktest.h"
using namespace LCBTest;
using std::string;
using std::vector;

class SockReentrantTest : public SockTest
{
};

/**
 * This file tests various reentrant actions within the socket handlers.
 */
class ReadAgainAction : public IOActions
{
  public:
    ReadAgainAction()
    {
        callCount = 0;
        sf = NULL;
    }

    virtual ~ReadAgainAction() {}

    int callCount;
    SendFuture *sf;
    void onRead(ESocket *s, size_t nr)
    {
        if (callCount++) {
            s->parent->stop();
            return;
        }

        s->reqrd(nr * 2);
        sf = new SendFuture(string(nr, '$'));
        s->conn->setSend(sf);
        s->schedule();
    }
    void onError(ESocket *)
    {
        // do nothing
    }
};

class CallCountBreakCondition : public BreakCondition
{
  public:
    ReadAgainAction *raa;
    CallCountBreakCondition(ReadAgainAction *action)
    {
        raa = action;
    }

  protected:
    bool shouldBreakImpl()
    {
        return raa->callCount >= 2;
    }
};

TEST_F(SockReentrantTest, testReadAgain)
{
    ESocket sock;
    loop->connect(&sock);
    SendFuture sf1(string(100, '#'));
    sock.conn->setSend(&sf1);
    sock.reqrd(100);
    sock.schedule();

    ReadAgainAction raa;
    CallCountBreakCondition bc(&raa);
    sock.setActions(&raa);
    loop->setBreakCondition(&bc);
    loop->start();
    ASSERT_TRUE(raa.callCount == 2);
    ASSERT_TRUE(sock.getUnreadSize() >= 200);
    ASSERT_TRUE(raa.sf != NULL);
    raa.sf->wait();
    delete raa.sf;
}

class CloseReadAction : public IOActions
{
  public:
    CloseReadAction()
    {
        wasCalled = false;
    }
    virtual ~CloseReadAction() {}
    void onRead(ESocket *s, size_t)
    {
        EXPECT_FALSE(wasCalled);
        wasCalled = true;
        s->parent->stop();
        s->close();
    }
    void onError(ESocket *) {}
    bool wasCalled;
};

class CRABreakCondition : public BreakCondition
{
  public:
    CloseReadAction *cra;
    CRABreakCondition(CloseReadAction *action)
    {
        cra = action;
    }

  protected:
    bool shouldBreakImpl()
    {
        return cra->wasCalled;
    }
};

TEST_F(SockReentrantTest, testCloseOnRead)
{
    ESocket sock;
    loop->connect(&sock);
    SendFuture sf(string(100, '#'));
    sock.conn->setSend(&sf);
    sock.reqrd(1);
    sock.schedule();
    CloseReadAction cra;
    CRABreakCondition bc(&cra);
    sock.setActions(&cra);
    loop->setBreakCondition(&bc);
    loop->start();
    sf.wait();
    ASSERT_TRUE(cra.wasCalled);
}

class CloseWriteAction : public IOActions
{
  public:
    bool wasCalled;
    CloseWriteAction()
    {
        wasCalled = false;
    }
    virtual ~CloseWriteAction() {}
    void onRead(ESocket *s, size_t)
    {
        EXPECT_FALSE(wasCalled);
        wasCalled = true;
        for (int ii = 0; ii < 100; ii++) {
            s->put("Hello!");
            s->schedule();
        }
        s->close();
        s->parent->stop();
    }
    void onError(ESocket *) {}
};
TEST_F(SockReentrantTest, testCloseOnWrite)
{
    ESocket sock;
    loop->connect(&sock);
    SendFuture sf(string(100, '#'));
    sock.conn->setSend(&sf);
    sock.reqrd(1);
    sock.schedule();
    CloseWriteAction cwa;
    sock.setActions(&cwa);

    RecvFuture rf(1);
    FutureBreakCondition fbc(&rf);
    loop->setBreakCondition(&fbc);
    loop->start();
    sf.wait();
    ASSERT_TRUE(cwa.wasCalled);
}