summaryrefslogtreecommitdiff
path: root/Sockets/AjpBaseSocket.cpp
diff options
context:
space:
mode:
authorOthmar Gsenger <otti@anytun.org>2008-04-12 11:38:42 +0000
committerOthmar Gsenger <otti@anytun.org>2008-04-12 11:38:42 +0000
commitfffd213c8cba2135afda493d797c41c10354770e (patch)
treebb5eea1b12871d8c3fed0e687d83be3e504d11b2 /Sockets/AjpBaseSocket.cpp
parentsvn cleanup (diff)
big svn cleanup
Diffstat (limited to 'Sockets/AjpBaseSocket.cpp')
-rw-r--r--Sockets/AjpBaseSocket.cpp258
1 files changed, 0 insertions, 258 deletions
diff --git a/Sockets/AjpBaseSocket.cpp b/Sockets/AjpBaseSocket.cpp
deleted file mode 100644
index 3b54dd0..0000000
--- a/Sockets/AjpBaseSocket.cpp
+++ /dev/null
@@ -1,258 +0,0 @@
-/**
- ** \file AjpBaseSocket.cpp
- ** \date 2007-10-05
- ** \author grymse@alhem.net
-**/
-/*
-Copyright (C) 2007 Anders Hedstrom
-
-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., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
-*/
-#ifdef _MSC_VER
-#pragma warning(disable:4786)
-#endif
-#include "AjpBaseSocket.h"
-#include "ajp13.h"
-
-#ifdef SOCKETS_NAMESPACE
-namespace SOCKETS_NAMESPACE {
-#endif
-
-#ifdef _DEBUG
-#define DEB(x) x
-#else
-#define DEB(x)
-#endif
-
-
-// ---------------------------------------------------------------------------
-AjpBaseSocket::Initializer AjpBaseSocket::Init;
-
-
-// ---------------------------------------------------------------------------
-AjpBaseSocket::Initializer::Initializer()
-{
-
- Header[HTTP_REQUEST_ACCEPT] = "accept";
- Header[HTTP_REQUEST_ACCEPT_CHARSET] = "accept-charset";
- Header[HTTP_REQUEST_ACCEPT_ENCODING] = "accept-encoding";
- Header[HTTP_REQUEST_ACCEPT_LANGUAGE] = "accept-language";
- Header[HTTP_REQUEST_AUTHORIZATION] = "authorization";
- Header[HTTP_REQUEST_CONNECTION] = "connection";
- Header[HTTP_REQUEST_CONTENT_TYPE] = "content-type";
- Header[HTTP_REQUEST_CONTENT_LENGTH] = "content-length";
- Header[HTTP_REQUEST_COOKIE] = "cookie";
- Header[HTTP_REQUEST_COOKIE2] = "cookie2";
- Header[HTTP_REQUEST_HOST] = "host";
- Header[HTTP_REQUEST_PRAGMA] = "pragma";
- Header[HTTP_REQUEST_REFERER] = "referer";
- Header[HTTP_REQUEST_USER_AGENT] = "user-agent";
-
- Method[HTTP_METHOD_OPTIONS] = "OPTIONS";
- Method[HTTP_METHOD_GET] = "GET";
- Method[HTTP_METHOD_HEAD] = "HEAD";
- Method[HTTP_METHOD_POST] = "POST";
- Method[HTTP_METHOD_PUT] = "PUT";
- Method[HTTP_METHOD_DELETE] = "DELETE";
- Method[HTTP_METHOD_TRACE] = "TRACE";
- Method[HTTP_METHOD_PROPFIND] = "PROPFIND";
- Method[HTTP_METHOD_PROPPATCH] = "PROPPATCH";
- Method[HTTP_METHOD_MKCOL] = "MKCOL";
- Method[HTTP_METHOD_COPY] = "COPY";
- Method[HTTP_METHOD_MOVE] = "MOVE";
- Method[HTTP_METHOD_LOCK] = "LOCK";
- Method[HTTP_METHOD_UNLOCK] = "UNLOCK";
- Method[HTTP_METHOD_ACL] = "ACL";
- Method[HTTP_METHOD_REPORT] = "REPORT";
- Method[HTTP_METHOD_VERSION_CONTROL] = "VERSION_CONTROL"; // with a dash "VERSION-CONTROL"
- Method[HTTP_METHOD_CHECKIN] = "CHECKIN";
- Method[HTTP_METHOD_CHECKOUT] = "CHECKOUT";
- Method[HTTP_METHOD_UNCHECKOUT] = "UNCHECKOUT";
- Method[HTTP_METHOD_SEARCH] = "SEARCH";
- Method[HTTP_METHOD_MKWORKSPACE] = "MKWORKSPACE";
- Method[HTTP_METHOD_UPDATE] = "UPDATE";
- Method[HTTP_METHOD_LABEL] = "LABEL";
- Method[HTTP_METHOD_MERGE] = "MERGE";
- Method[HTTP_METHOD_BASELINE_CONTROL] = "BASELINE_CONTROL";
- Method[HTTP_METHOD_MKACTIVITY] = "MKACTIVITY";
-
- Attribute[ATTR_CONTEXT] = "context";
- Attribute[ATTR_SERVLET_PATH] = "servlet_path";
- Attribute[ATTR_REMOTE_USER] = "remote_user";
- Attribute[ATTR_AUTH_TYPE] = "auth_type";
- Attribute[ATTR_QUERY_STRING] = "query_string";
- Attribute[ATTR_ROUTE] = "route";
- Attribute[ATTR_SSL_CERT] = "ssl_cert";
- Attribute[ATTR_SSL_CIPHER] = "ssl_cipher";
- Attribute[ATTR_SSL_SESSION] = "ssl_session";
- Attribute[ATTR_SSL_KEY_SIZE] = "ssl_key_size";
- Attribute[ATTR_SECRET] = "secret";
- Attribute[ATTR_STORED_METHOD] = "stored_method";
-
- ResponseHeader["content-type"] = 0xa001;
- ResponseHeader["content-language"] = 0xa002;
- ResponseHeader["content-length"] = 0xa003;
- ResponseHeader["date"] = 0xa004;
- ResponseHeader["last-modified"] = 0xa005;
- ResponseHeader["location"] = 0xa006;
- ResponseHeader["set-cookie"] = 0xa007;
- ResponseHeader["set-cookie2"] = 0xa008;
- ResponseHeader["servlet-engine"] = 0xa009;
- ResponseHeader["status"] = 0xa00a;
- ResponseHeader["www-authenticate"] = 0xa00b;
-}
-
-
-// ---------------------------------------------------------------------------
-AjpBaseSocket::AjpBaseSocket(ISocketHandler& h) : TcpSocket(h)
-, m_state(0)
-, m_length(4)
-, m_ptr(0)
-{
-}
-
-
-// ---------------------------------------------------------------------------
-void AjpBaseSocket::OnRawData(const char *buf, size_t sz)
-{
-DEB(fprintf(stderr, "OnRawData: %d bytes\n", sz);)
- size_t ptr = 0;
- while (true)
- {
- size_t left = sz - ptr;
-DEB(fprintf(stderr, " left: %d bytes\n", left);
-fprintf(stderr, " state: %d\n", m_state);)
- switch (m_state)
- {
- case 0:
- {
- size_t missing = m_length - m_ptr;
- short len = (short)(missing < left ? missing : left);
- memcpy(m_message + m_ptr, buf + ptr, len);
- m_ptr += len;
- ptr += len;
- if (m_ptr < m_length)
- {
- return; // read more
- }
- int p = 0;
- short id = get_integer(m_message, p);
- short length = get_integer(m_message, p);
- OnHeader(id, length);
- m_state = 1;
- m_length = length;
- m_ptr = 0; // bytes in m_message
- }
- break;
- case 1:
- {
- size_t missing = m_length - m_ptr;
- short len = (short)(missing < left ? missing : left);
- memcpy(m_message + m_ptr, buf + ptr, len);
- m_ptr += len;
- ptr += len;
- if (m_ptr < m_length)
- {
- return; // read more
- }
- OnPacket(m_message, m_ptr);
- m_state = 0;
- m_length = 4;
- m_ptr = 0;
- }
- break;
- }
- }
-}
-
-
-// ---------------------------------------------------------------------------
-unsigned char AjpBaseSocket::get_byte(const char *buf, int& ptr)
-{
- return (unsigned char)buf[ptr++];
-}
-
-
-// ---------------------------------------------------------------------------
-bool AjpBaseSocket::get_boolean(const char *buf, int& ptr)
-{
- return ( (unsigned char)buf[ptr++] & 1) == 1 ? true : false;
-}
-
-
-// ---------------------------------------------------------------------------
-short AjpBaseSocket::get_integer(const char *buf, int& ptr)
-{
- short n;
- memcpy(&n, buf + ptr, 2);
- ptr += 2;
- return ntohs(n);
-}
-
-
-// ---------------------------------------------------------------------------
-std::string AjpBaseSocket::get_string(const char *buf, int& ptr)
-{
- short len = get_integer(buf, ptr);
- if (len != -1)
- {
- std::string tmp = buf + ptr;
- ptr += len;
- ptr++; // skip trailing 0x0
- tmp.resize(len);
- return tmp;
- }
- return "";
-}
-
-
-// ---------------------------------------------------------------------------
-void AjpBaseSocket::put_byte(char *buf, int& ptr, unsigned char zz)
-{
- buf[ptr++] = zz;
-}
-
-
-// ---------------------------------------------------------------------------
-void AjpBaseSocket::put_boolean(char *buf, int& ptr, bool zz)
-{
- buf[ptr++] = zz ? 1 : 0;
-}
-
-
-// ---------------------------------------------------------------------------
-void AjpBaseSocket::put_integer(char *buf, int& ptr, short zz)
-{
- short tmp = htons(zz);
- memcpy(buf + ptr, &tmp, 2);
- ptr += 2;
-}
-
-
-// ---------------------------------------------------------------------------
-void AjpBaseSocket::put_string(char *buf, int& ptr, const std::string& zz)
-{
- put_integer(buf, ptr, (short)zz.size() );
- memcpy(buf + ptr, zz.c_str(), zz.size());
- ptr += (int)zz.size();
- put_byte(buf, ptr, 0);
-}
-
-
-#ifdef SOCKETS_NAMESPACE
-} // namespace SOCKETS_NAMESPACE {
-#endif
-
-