summaryrefslogtreecommitdiff
path: root/httpd/tnt/worker.h
diff options
context:
space:
mode:
Diffstat (limited to 'httpd/tnt/worker.h')
-rw-r--r--httpd/tnt/worker.h91
1 files changed, 0 insertions, 91 deletions
diff --git a/httpd/tnt/worker.h b/httpd/tnt/worker.h
deleted file mode 100644
index be42841..0000000
--- a/httpd/tnt/worker.h
+++ /dev/null
@@ -1,91 +0,0 @@
-/* tnt/worker.h
- * Copyright (C) 2003-2005 Tommi Maekitalo
- *
- * 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
- * is provided AS IS, WITHOUT ANY WARRANTY; without even the implied
- * warranty of MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE, and
- * NON-INFRINGEMENT. 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., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
- *
- */
-
-#ifndef TNT_WORKER_H
-#define TNT_WORKER_H
-
-#include <string>
-#include <cxxtools/tcpstream.h>
-#include <cxxtools/thread.h>
-#include <cxxtools/pool.h>
-#include <tnt/comploader.h>
-#include <tnt/tntnet.h>
-#include <tnt/scope.h>
-
-namespace tnt
-{
- class HttpRequest;
- class HttpReply;
-
- class Worker : public cxxtools::DetachedThread
- {
- static cxxtools::Mutex mutex;
- static unsigned nextThreadNumber;
-
- Tntnet& application;
-
- typedef cxxtools::Pool<Comploader> ComploaderPoolType;
- static ComploaderPoolType comploaderPool;
-
- ComploaderPoolType::objectptr_type comploaderObject;
- Comploader& comploader;
-
- Scope threadScope;
-
- pthread_t threadId;
- const char* state;
- time_t lastWaitTime;
-
- typedef std::set<Worker*> workers_type;
- static workers_type workers;
-
- static unsigned maxRequestTime;
- static unsigned minThreads;
- static bool enableCompression;
-
- bool processRequest(HttpRequest& request, std::iostream& socket,
- unsigned keepAliveCount);
- void healthCheck(time_t currentTime);
-
- ~Worker();
-
- public:
- Worker(Tntnet& app);
-
- virtual void run();
-
- void dispatch(HttpRequest& request, HttpReply& reply);
-
- static void timer();
-
- /// Sets a hard limit for request-time.
- /// When the time is exceeded, this process exits.
- static void setMaxRequestTime(unsigned sec) { maxRequestTime = sec; }
- static unsigned getMaxRequestTime() { return maxRequestTime; }
-
- static workers_type::size_type getCountThreads();
- static void setMinThreads(unsigned n) { minThreads = n; }
-
- static void setEnableCompression(bool sw = true) { enableCompression = sw; }
- static unsigned getEnableCompression() { return enableCompression; }
- };
-}
-
-#endif // TNT_WORKER_H
-