#ifndef CREATE_FRIEND

#define CREATE_FRIEND

#include "../TwitterResponseParser.h"

#include "../libtwitcurl/twitcurl.h"

#include "transport/logging.h"

#include <string>

#include <boost/function.hpp>

#include <iostream>

#include <vector>

using namespace Transport;

class CreateFriendRequest : public Thread

{

#ifndef DESTROY_FRIEND

#define DESTROY_FRIEND

#include "../TwitterResponseParser.h"

#include "../libtwitcurl/twitcurl.h"

#include "transport/logging.h"

#include <string>

#include <boost/function.hpp>

#include <iostream>

#include <vector>

using namespace Transport;

class DestroyFriendRequest : public Thread

{

#ifndef DIRECT_MESSAGE

#define DIRECT_MESSAGE

#include "../TwitterResponseParser.h"

#include "../libtwitcurl/twitcurl.h"

#include "transport/logging.h"

#include <string>

#include <boost/function.hpp>

#include <iostream>

using namespace Transport;

class DirectMessageRequest : public Thread

{

	twitCurl *twitObj;

#ifndef FRIENDS_H

#define FRIENDS_H

#include "../libtwitcurl/twitcurl.h"

#include "../TwitterResponseParser.h"

#include "transport/logging.h"

#include <string>

#include <boost/signals.hpp>

#include <boost/function.hpp>

#include <boost/bind.hpp>

#include <iostream>

using namespace Transport;

class FetchFriends : public Thread

#ifndef HELPMESSAGE_H

#define HELPMESSAGE_H

#include "../libtwitcurl/twitcurl.h"

#include "transport/networkplugin.h"

#include "transport/logging.h"

#include <string>

#include <boost/function.hpp>

#include <iostream>

using namespace Transport;

class HelpMessageRequest : public Thread

{

	std::string user;

#ifndef OAUTH_FLOW

#define OAUTH_FLOW

#include "../libtwitcurl/twitcurl.h"

#include "../TwitterPlugin.h"

#include "transport/logging.h"

#include <string>

#include <iostream>

//class TwitterPlugin;

using namespace Transport;

class OAuthFlow : public Thread

{

	twitCurl *twitObj;

#ifndef PIN_EXCHANGE

#define PIN_EXCHANGE

#include "../libtwitcurl/twitcurl.h"

#include "../TwitterPlugin.h"

#include "transport/networkplugin.h"

#include "transport/logging.h"

#include <string>

#include <iostream>

//class TwitterPlugin;

using namespace Transport;

class PINExchangeProcess : public Thread

{

#ifndef PROFILEIMAGE_H

#define PROFILEIMAGE_H

#include "../TwitterResponseParser.h"

#include "transport/logging.h"

#include "transport/config.h"

#include <string>

#include <boost/signals.hpp>

#include <boost/function.hpp>

#include <boost/bind.hpp>

#include <iostream>

#include <sstream>

using namespace Transport;

using namespace boost::program_options;

#ifndef RETWEET_H

#define RETWEET_H

#include "../TwitterResponseParser.h"

#include "../libtwitcurl/twitcurl.h"

#include "transport/networkplugin.h"

#include "transport/logging.h"

#include <boost/function.hpp>

#include <string>

#include <iostream>

using namespace Transport;

class RetweetRequest : public Thread

{

	twitCurl *twitObj;

#ifndef STATUS_UPDATE

#define STATUS_UPDATE

#include "../libtwitcurl/twitcurl.h"

#include "transport/networkplugin.h"

#include "transport/logging.h"

#include <boost/function.hpp>

#include <string>

#include <iostream>

using namespace Transport;

class StatusUpdateRequest : public Thread

{

	twitCurl *twitObj;

	std::string data;

#ifndef TIMELINE_H

#define TIMELINE_H

#include "../libtwitcurl/twitcurl.h"

#include "../TwitterResponseParser.h"

#include "transport/logging.h"

#include <string>

#include <iostream>

#include <boost/function.hpp>

using namespace Transport;

class TimelineRequest : public Thread

{

	twitCurl *twitObj;

#ifndef TWITTER_PLUGIN

#define TWITTER_PLUGIN

#include "transport/config.h"

#include "transport/networkplugin.h"

#include "transport/logging.h"

#include "transport/sqlite3backend.h"

#include "transport/mysqlbackend.h"

#include "transport/pqxxbackend.h"

#include "transport/storagebackend.h"

#include "Swiften/Swiften.h"

#include "unistd.h"

#include "signal.h"

#include "sys/wait.h"

#include "sys/signal.h"

#include <boost/algorithm/string.hpp>

#include <boost/signal.hpp>

#include <boost/thread.hpp>

#include <boost/thread/mutex.hpp>

#include "twitcurl.h"

#include "TwitterResponseParser.h"

#include <iostream>

#include <sstream>

#include <map>

#include <vector>

#include <queue>

#include <set>

#include <cstdio>

#include "Swiften/StringCodecs/SHA1.h"

using namespace boost::filesystem;

using namespace boost::program_options;

using namespace Transport;

#define STR(x) (std::string("(") + x.from + ", " + x.to + ", " + x.message + ")")

class TwitterPlugin;

extern TwitterPlugin *np;

extern Swift::SimpleEventLoop *loop_; // Event Loop

DEFINE_LOGGER(logger, "ThreadPool")

boost::signals2::signal< void (Thread*, int) > onWorkCompleted;

static void Worker(Thread *t, int wid, Swift::EventLoop *loop)

{

	LOG4CXX_INFO(logger, "Starting thread " << wid)

	t->run();

	loop->postEvent(boost::bind(boost::ref(onWorkCompleted), t, wid), boost::shared_ptr<Swift::EventOwner>());

}

ThreadPool::ThreadPool(Swift::EventLoop *loop, int maxthreads) : MAX_THREADS(maxthreads)