#ifndef CLUSTER_H
#define CLUSTER_H

/*
 *
 * Copyright (c) 2006 The Apache Software Foundation
 *
 * Licensed 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.
 *
 */

#include "qpid/cluster/Cluster.h"
#include "qpid/sys/ConcurrentQueue.h"
#include "qpid/framing/AMQFrame.h"

#include <boost/bind.hpp>
#include <boost/test/test_tools.hpp>

#include <iostream>
#include <functional>

/**
 * Definitions for the Cluster.cpp and Cluster_child.cpp child program.
 */

// using namespace in header file is bad manners, but this is strictly for
// the tests.
using namespace std;
using namespace qpid;
using namespace qpid::cluster;
using namespace qpid::framing;
using namespace qpid::sys;
using namespace boost;

void null_deleter(void*) {}

template <class T>
class TestHandler : public Handler<T&>, public ConcurrentQueue<T>
{
  public:
    void handle(T& frame) { push(frame); }
    bool waitPop(T& x) { return waitPop(x, TIME_SEC); }
    using ConcurrentQueue<T>::waitPop;
};

typedef TestHandler<AMQFrame> TestFrameHandler;

void nullDeleter(void*) {}

struct TestCluster : public Cluster
{
    TestCluster(string name, string url)
        : Cluster(name, url, make_shared_ptr(&received, nullDeleter)) {}

    /** Wait for cluster to be of size n. */
    bool waitFor(size_t n) {
        BOOST_CHECKPOINT("About to call Cluster::wait");
        return wait(boost::bind(
                        equal_to<size_t>(), bind(&Cluster::size,this), n));
    }

    TestFrameHandler received;
};



#endif  /*!CLUSTER_H*/