ACE/apps/JAWS2/HTTP_10_Parse.cpp

   1 #include "HTTP_10.h"
   2
   3 #include "JAWS/JAWS.h"
   4 #include "JAWS/IO.h"
   5 #include "JAWS/IO_Handler.h"
   6 #include "JAWS/Policy.h"
   7
   8 #include "HTTP_10_Request.h"
   9
  10
  11 // --------------- PARSE TASK ----------------------
  12
  13 JAWS_HTTP_10_Parse_Task::JAWS_HTTP_10_Parse_Task ()
  14 {
  15 }
  16
  17 JAWS_HTTP_10_Parse_Task::~JAWS_HTTP_10_Parse_Task ()
  18 {
  19 }
  20
  21 int
  22 JAWS_HTTP_10_Parse_Task::handle_put (JAWS_Data_Block *data, ACE_Time_Value *)
  23 {
  24   JAWS_TRACE ("JAWS_HTTP_10_Parse_Task::handle_put");
  25
  26   JAWS_IO_Handler *handler = data->io_handler ();
  27   JAWS_Dispatch_Policy *policy = this->policy ();
  28   if (policy == 0) policy = data->policy ();
  29   JAWS_IO *io = policy->io ();
  30
  31   JAWS_HTTP_10_Request *info;
  32
  33   if (data->payload ())
  34     info = reinterpret_cast<JAWS_HTTP_10_Request *> (data->payload ());
  35   else
  36     {
  37       info = new JAWS_HTTP_10_Request;
  38       if (info == 0)
  39         {
  40           ACE_ERROR ((LM_ERROR, "%p\n", "JAWS_HTTP_10_Parse_Task::handle_put"));
  41           return -1;
  42         }
  43       data->payload (static_cast<void *> (info));
  44     }
  45
  46   while (info->receive (*(ACE_Message_Block *)data) == 0)
  47     {
  48       int next_read_size = data->space ();
  49
  50       if (next_read_size == 0)
  51         {
  52           // Set payload to reflect "request too long"
  53           break;
  54         }
  55
  56       io->read (handler, data, next_read_size);
  57       switch (handler->status ())
  58         {
  59         case JAWS_IO_Handler::READ_OK:
  60           // Behaved synchronously, reiterate
  61           continue;
  62         case JAWS_IO_Handler::READ_ERROR:
  63         case JAWS_IO_Handler::READ_ERROR_A:
  64           return -1;
  65         default:
  66           // This needs to be a value that tells the framework that
  67           // the call is asynchronous, but that we should remain in
  68           // the current task state.
  69           return 2;
  70         }
  71     }
  72
  73   // request completely parsed
  74   info->dump ();
  75
  76   return 0;
  77 }