TAO_HTTP_Reader Class Reference

#include <HTTP_Handler.h>

Inheritance diagram for TAO_HTTP_Reader:

[legend]Collaboration diagram for TAO_HTTP_Reader:

[legend]List of all members.

Public Member Functions
	TAO_HTTP_Reader (ACE_Message_Block *mb, ACE_TCHAR *filename, const char *request_prefix="GET", const char *request_suffix="HTTP/1.0\r\nAccept: HTTP/1.0\r\n\r\n")
Private Member Functions
int	send_request (void)
int	receive_reply (void)
Private Attributes
const char *	request_prefix_
const char *	request_suffix_

---

Detailed Description

Definition at line 80 of file HTTP_Handler.h.

---

Constructor & Destructor Documentation

TAO_HTTP_Reader::TAO_HTTP_Reader	(	ACE_Message_Block *	mb,
		ACE_TCHAR *	filename,
		const char *	request_prefix = "GET",
		const char *	request_suffix = "HTTP/1.0\r\nAccept: HTTP/1.0\r\n\r\n"
	)

Definition at line 72 of file HTTP_Handler.cpp.

                                                              :
  TAO_HTTP_Handler (mb, filename),
  request_prefix_ (request_prefix),
  request_suffix_ (request_suffix)
{
}

---

Member Function Documentation

int TAO_HTTP_Reader::receive_reply

(

void

)

[private, virtual]

Reimplemented from TAO_HTTP_Handler.

Definition at line 104 of file HTTP_Handler.cpp.

References ACE_ERROR_RETURN, ACE_NEW_RETURN, TAO_HTTP_Handler::bytecount_, ACE_Message_Block::cont(), ACE_Message_Block::copy(), LM_ERROR, TAO_HTTP_Handler::mb_, TAO_HTTP_Handler::MTU, ACE_Svc_Handler< ACE_SOCK_STREAM, ACE_NULL_SYNCH >::peer(), recv_n(), ACE_Message_Block::space(), ACE_OS::strstr(), and ACE_Message_Block::wr_ptr().

{
  size_t num_recvd = 0;
  char buf [MTU+1];
  char *buf_ptr = 0;
  size_t bytes_read = 0;

  // Receive the first MTU bytes and strip the header off.
  // Note that we assume that the header will fit into MTU bytes.
  if (peer ().recv_n (buf, MTU, 0, &num_recvd) >= 0)
    {
      //Make sure that response type is 200 OK
      if (ACE_OS::strstr (buf,"200 OK") == 0)
        ACE_ERROR_RETURN ((LM_ERROR,
                            "TAO (%P|%t) - HTTP_Reader::receive_reply, Response is not 200 OK\n" ), -1);

      // Search for the header termination string "\r\n\r\n", or "\n\n". If
      // found, move past it to get to the data portion.
      if ((buf_ptr = ACE_OS::strstr (buf,"\r\n\r\n")) != 0)
        buf_ptr += 4;
      else if ((buf_ptr = ACE_OS::strstr (buf, "\n\n")) != 0)     //for compatibility with JAWS
        buf_ptr += 2;
      else
        buf_ptr = buf;

      // Determine number of data bytes read. This is equal to the
      // total bytes read minus number of header bytes.
      bytes_read = num_recvd - (buf_ptr - buf);

    }
  else
    {
      ACE_ERROR_RETURN ((LM_ERROR,
                         "TAO (%P|%t) - HTTP_Reader::receive_reply, error while reading header\n"), -1);
    }

  // ***************************************************************
  // At this point, we have stripped off the header and are ready to
  // process data. buf_ptr points to the data

  ACE_Message_Block* temp = 0;
  ACE_Message_Block* curr = this->mb_;

  ACE_NEW_RETURN (temp,
                  ACE_Message_Block (bytes_read),
                  -1);
  curr->cont (temp);
  curr = curr->cont ();

  // Copy over all the data bytes into our message buffer.
  if (curr->copy (buf_ptr, bytes_read) == -1)
    {
      ACE_ERROR_RETURN ((LM_ERROR, "TAO (%P|%t) - HTTP_Reader::receive_reply, error copying data into Message_Block\n"), -1);
    }

  // read the rest of the data into a number of ACE_Message_Blocks and
  // chain them together in a link list fashion
  num_recvd = 0;

  do
  {
    if (curr->space () == 0)
    {
      ACE_NEW_RETURN (temp,
                      ACE_Message_Block (MTU),
                      -1);
      curr->cont (temp);
      curr = curr->cont ();
    }

  if (peer ().recv_n (curr->wr_ptr (), curr->space (), 0, &num_recvd) >= 0)
    {
      // Move the write pointer
      curr->wr_ptr (num_recvd);

      // Increment bytes_read
      bytes_read += num_recvd;

    }
  else
    {
      ACE_ERROR_RETURN ((LM_ERROR,
                         "TAO (%P|%t) - HTTP_Reader::receive_reply, Error while reading header\n"), -1);
    }
  } while (num_recvd != 0);

  // Set the byte count to number of bytes received
  this->bytecount_ = bytes_read;

  return 0;
}

int TAO_HTTP_Reader::send_request

(

void

)

[private, virtual]

Reimplemented from TAO_HTTP_Handler.

Definition at line 83 of file HTTP_Handler.cpp.

References ACE_ERROR_RETURN, TAO_HTTP_Handler::filename_, LM_ERROR, TAO_HTTP_Handler::MAX_HEADER_SIZE, ACE_Svc_Handler< ACE_SOCK_STREAM, ACE_NULL_SYNCH >::peer(), request_prefix_, request_suffix_, send_n(), ACE_OS::sprintf(), and ACE_OS::strlen().

{
  char mesg [MAX_HEADER_SIZE];

  // Check to see if the request is too big
  if (MAX_HEADER_SIZE < (ACE_OS::strlen (request_prefix_)
                         + ACE_OS::strlen (filename_)
                         + ACE_OS::strlen (request_suffix_) + 4))
    ACE_ERROR_RETURN((LM_ERROR,"TAO (%P|%t) - HTTP_Reader::send_request, request too large!"), -1);

  // Create a message to send to the server requesting retrieval of the file
  int const len = ACE_OS::sprintf (mesg, "%s %s %s", request_prefix_, filename_, request_suffix_);

  // Send the message to server
  if (peer ().send_n (mesg, len) != len)
    ACE_ERROR_RETURN((LM_ERROR,"TAO (%P|%t) - HTTP_Reader::send_request, error sending request\n"), -1);

  return 0;
}

---

Member Data Documentation

const char* TAO_HTTP_Reader::request_prefix_ [private]

Definition at line 92 of file HTTP_Handler.h.

Referenced by send_request().

const char* TAO_HTTP_Reader::request_suffix_ [private]

Definition at line 93 of file HTTP_Handler.h.

Referenced by send_request().

---

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

• HTTP_Handler.h
• HTTP_Handler.cpp

---