Web alhem.net

InjectSocket Class Reference

#include <InjectSocket.h>

List of all members.

Public Member Functions
	InjectSocket (ISocketHandler &h)
	~InjectSocket ()
void	OnConnect ()
void	OnAccept ()
void	SetFilename (const std::string &x)
void	OnFirst ()
void	OnHeader (const std::string &, const std::string &)
void	OnHeaderComplete ()
void	OnData (const char *, size_t)
Private Attributes
bool	m_is_server
std::string	m_filename
int	m_content_length
FILE *	m_file

---

Detailed Description

Definition at line 8 of file InjectSocket.h.

---

Constructor & Destructor Documentation

InjectSocket::InjectSocket

(

ISocketHandler &

h

)

Definition at line 14 of file InjectSocket.cpp.

:HTTPSocket(h)
,m_is_server(false)
,m_content_length(0)
,m_file(NULL)
{
}

InjectSocket::~InjectSocket

(

)

Definition at line 23 of file InjectSocket.cpp.

References m_file.

{
        if (m_file)
                fclose(m_file);
}

---

Member Function Documentation

void InjectSocket::OnConnect

(

)

Definition at line 30 of file InjectSocket.cpp.

References fil, and m_filename.

{
        struct stat st;
        if (stat(m_filename.c_str(),&st) == -1)
        {
                Handler().LogError(this, "stat", errno, strerror(errno), LOG_LEVEL_FATAL);
                SetCloseAndDelete();
                return;
        }
        std::string request;
        request += "PUT " + m_filename + " HTTP/1.0\n";
        request += "Content-type: text/xml\n";
        request += "Content-length: " + Utility::l2string(st.st_size) + "\n";
        request += "Connection: close\n";
        request += "\n";
        Send( request );
        FILE *fil;
        if ((fil = fopen(m_filename.c_str(),"rb")) != NULL)
        {
                char buf[1000];
                size_t n;
                while ((n = fread(buf,1,1000,fil)) > 0)
                {
                        SendBuf(buf, n);
                }
                fclose(fil);
        }
}

void InjectSocket::OnAccept

(

)

Definition at line 60 of file InjectSocket.cpp.

References m_is_server.

{
        m_is_server = true;
}

void InjectSocket::SetFilename

(

const std::string &

x

)

[inline]

Definition at line 17 of file InjectSocket.h.

References m_filename.

{ m_filename = x; }

void InjectSocket::OnFirst

(

)

Definition at line 66 of file InjectSocket.cpp.

{
}

void InjectSocket::OnHeader	(	const std::string &	,
		const std::string &
	)

Definition at line 71 of file InjectSocket.cpp.

References m_content_length, and m_filename.

{
//      printf("%s: %s\n",key.c_str(),value.c_str());
        if (!strcasecmp(key.c_str(),"content-type"))
        {
                if (strcasecmp(value.c_str(),"text/xml"))
                {
                        Handler().LogError(this, "OnHeader", 0, "content-type not text/xml", LOG_LEVEL_FATAL);
                        SetCloseAndDelete();
                }
                else
                        m_filename = GetUrl();
        }
        else
        if (!strcasecmp(key.c_str(),"content-length"))
        {
                m_content_length = atoi(value.c_str());
        }
}

void InjectSocket::OnHeaderComplete

(

)

Definition at line 92 of file InjectSocket.cpp.

References m_file, m_filename, and m_is_server.

{
//      printf("\n");
        if (m_filename.size() && m_is_server)
        {
                Uid random;
                m_filename = random.GetUid() + ".xml";
                m_file = fopen(m_filename.c_str(),"wb");
        }
}

void InjectSocket::OnData	(	const char *	,
		size_t
	)

Definition at line 104 of file InjectSocket.cpp.

References m_content_length, m_file, and m_filename.

{
//      printf("%s",static_cast<std::string>(buf).substr(0,sz).c_str());
        if (m_file)
                fwrite(buf,1,sz,m_file);
//printf("content length is still %d bytes, received %d bytes\n",m_content_length,sz);
        m_content_length -= sz;
        if (m_content_length <= 0)
        {
                fclose(m_file);
                m_file = NULL;
                SetCloseAndDelete();
                static_cast<RowoHandler&>(Handler()).InjectRobot(m_filename);
                unlink(m_filename.c_str());
        }
}

---

Member Data Documentation

bool InjectSocket::m_is_server [private]

Definition at line 25 of file InjectSocket.h.

Referenced by OnAccept(), and OnHeaderComplete().

std::string InjectSocket::m_filename [private]

Definition at line 26 of file InjectSocket.h.

Referenced by OnConnect(), OnData(), OnHeader(), OnHeaderComplete(), and SetFilename().

int InjectSocket::m_content_length [private]

Definition at line 27 of file InjectSocket.h.

Referenced by OnData(), and OnHeader().

FILE* InjectSocket::m_file [private]

Definition at line 28 of file InjectSocket.h.

Referenced by OnData(), OnHeaderComplete(), and ~InjectSocket().

---

The documentation for this class was generated from the following files:

• InjectSocket.h
• InjectSocket.cpp

---

Page, code, and content Copyright (C) 2004 by Anders Hedström