diff options
author | nobody <nobody@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2003-04-10 19:59:37 +0000 |
---|---|---|
committer | nobody <nobody@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2003-04-10 19:59:37 +0000 |
commit | 3df4acfa816441fc28a95dee6d0191a927145d95 (patch) | |
tree | b5ae7ca44662cfd8e5c95f1826e4406021a606f5 /examples/Web_Crawler/Command_Processor.cpp | |
parent | 60a5612b83d856fc0adc52b9f39fac9960ec9818 (diff) | |
download | ATCD-pre-subset.tar.gz |
This commit was manufactured by cvs2svn to create tag 'pre-subset'.pre-subset
Diffstat (limited to 'examples/Web_Crawler/Command_Processor.cpp')
-rw-r--r-- | examples/Web_Crawler/Command_Processor.cpp | 135 |
1 files changed, 0 insertions, 135 deletions
diff --git a/examples/Web_Crawler/Command_Processor.cpp b/examples/Web_Crawler/Command_Processor.cpp deleted file mode 100644 index 95b78b77a33..00000000000 --- a/examples/Web_Crawler/Command_Processor.cpp +++ /dev/null @@ -1,135 +0,0 @@ -// $Id$ - -#include "URL.h" -#include "HTTP_URL.h" -#include "Options.h" -#include "Command_Processor.h" -#include "URL_Visitor.h" - -ACE_RCSID(Web_Crawler, Command_Processor, "$Id$") - -Command::~Command (void) -{ -} - -URL_Command::URL_Command (URL *url) - : url_ (url) -{ -} - -int -URL_Command::execute (void) -{ - - ACE_CString check_string (this->url_->url_addr ().get_path_name ()); - if (check_string.find ("news:") >= 0) - return 0; - - if (check_string.find (".cgi") >= 0) - return 0; - - if (check_string.find ("mailto") >= 0) - return 0; - - if (check_string.find (".gif") >= 0) - return 0; - - if (check_string.find (".pdf") >= 0) - return 0; - - if (check_string.find (".map") >= 0) - return 0; - - if (check_string.find (".bmp") >= 0) - return 0; - - if (check_string.find (".jpg") >= 0) - return 0; - - if (this->url_->accept (OPTIONS::instance ()->visitor ()) !=0) - { - ACE_DEBUG ((LM_DEBUG, - "Coudnt accept url\n")); - return -1; - } - return 0; -} - -int -URL_Command::destroy (void) -{ - delete this; - return 0; -} -Command_Processor::Command_Processor (void) -{ -} - -Command_Processor::~Command_Processor (void) -{ -} - -int -Command_Processor::destroy (void) -{ - delete this; - return 0; -return 0; -} - -int -Command_Processor::execute (void) -{ - Command *command; - while (this->url_queue_.is_empty () != 1) - { - if (this->url_queue_.dequeue_head (command) != 0) - ACE_ERROR_RETURN ((LM_ERROR, - "%p\n", "dequeue_head"), - -1); - URL_Command *url_command = ACE_dynamic_cast (URL_Command *, - command); - Auto_Destroyer<URL_Command> url_command_ptr (url_command); - if (url_command_ptr->execute () != 0) - ACE_ERROR_RETURN ((LM_ERROR, - "%p\n", "Couldnt execute command"), - -1); - } - return 0; -} - -int -Command_Processor::insert (Command *command) -{ - // According to the order specified the commands are removed from the queue. - if (this->url_queue_.is_full() != 1) - { - if (ACE_OS::strcmp (OPTIONS::instance ()->order (),"FIFO") == 0) - { - if (this->url_queue_.enqueue_tail (command) !=0) - ACE_ERROR_RETURN ((LM_ERROR, - "%p\n", "enqueue_tail"), - - 1); - } - if (ACE_OS::strcmp (OPTIONS::instance ()->order (),"LIFO") == 0) - { - if (this->url_queue_.enqueue_head (command) !=0) - ACE_ERROR_RETURN ((LM_ERROR, - "%p\n", "enqueue_head"), - - 1); - } - } - return 0; -} - -#if defined (ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION) -template class ACE_Singleton<Options, ACE_Null_Mutex>; -template class ACE_Node<Command *>; -template class ACE_Unbounded_Queue_Iterator<Command *>; -template class ACE_Unbounded_Queue<Command *>; -#elif defined (ACE_HAS_TEMPLATE_INSTANTIATION_PRAGMA) -#pragma instantiate ACE_Singleton<Options, ACE_Null_Mutex> -#pragma instantiate ACE_Node<Command *> -#pragma instantiate ACE_Unbounded_Queue_Iterator<Command *> -#pragma instantiate ACE_Unbounded_Queue<Command *> -#endif /* ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION */ |