src/common/protocol.cpp

   1 /////////////////////////////////////////////////////////////////////////////
   2 // Name:        protocol.cpp
   3 // Purpose:     Implement protocol base class
   4 // Author:      Guilhem Lavaux
   5 // Modified by:
   6 // Created:     07/07/1997
   7 // RCS-ID:      $Id$
   8 // Copyright:   (c) 1997, 1998 Guilhem Lavaux
   9 // Licence:     wxWindows license
  10 /////////////////////////////////////////////////////////////////////////////
  11
  12 #ifdef __GNUG__
  13 #pragma implementation "protocol.h"
  14 #endif
  15
  16 // For compilers that support precompilation, includes "wx.h".
  17 #include "wx/wxprec.h"
  18
  19 #ifdef __BORLANDC__
  20   #pragma hdrstop
  21 #endif
  22
  23 #include "wx/protocol/protocol.h"
  24 #include "wx/url.h"
  25 #include "wx/module.h"
  26
  27 #include <stdlib.h>
  28
  29 /////////////////////////////////////////////////////////////////
  30 // wxProtoInfo
  31 /////////////////////////////////////////////////////////////////
  32
  33 /*
  34  * --------------------------------------------------------------
  35  * --------- wxProtoInfo CONSTRUCTOR ----------------------------
  36  * --------------------------------------------------------------
  37  */
  38
  39 wxProtoInfo::wxProtoInfo(const wxChar *name, const wxChar *serv,
  40                          const bool need_host1, wxClassInfo *info)
  41 {
  42   m_protoname = name;
  43   m_servname = serv;
  44   m_cinfo = info;
  45   m_needhost = need_host1;
  46   next = wxURL::g_protocols;
  47   wxURL::g_protocols = this;
  48 }
  49
  50 /////////////////////////////////////////////////////////////////
  51 // wxProtocol ///////////////////////////////////////////////////
  52 /////////////////////////////////////////////////////////////////
  53
  54 #if wxUSE_SOCKETS
  55 IMPLEMENT_ABSTRACT_CLASS(wxProtocol, wxSocketClient)
  56 #else
  57 IMPLEMENT_ABSTRACT_CLASS(wxProtocol, wxObject)
  58 #endif
  59
  60 wxProtocol::wxProtocol()
  61 #if wxUSE_SOCKETS
  62  : wxSocketClient()
  63 #endif
  64 {
  65 }
  66
  67 #if wxUSE_SOCKETS
  68 bool wxProtocol::Reconnect()
  69 {
  70   wxIPV4address addr;
  71
  72   if (!GetPeer(addr)) {
  73     Close();
  74     return FALSE;
  75   }
  76   if (!Close())
  77     return FALSE;
  78   if (!Connect(addr))
  79     return FALSE;
  80   return TRUE;
  81 }
  82
  83 wxProtocolError GetLine(wxSocketBase *sock, wxString& result) {
  84 #define PROTO_BSIZE 2048
  85   size_t avail, size;
  86   char tmp_buf[PROTO_BSIZE], tmp_str[PROTO_BSIZE];
  87   char *ret;
  88   bool found;
  89
  90   avail = sock->Read(tmp_buf, PROTO_BSIZE).LastCount();
  91   if (sock->LastError() != 0 || avail == 0)
  92     return wxPROTO_NETERR;
  93
  94   memcpy(tmp_str, tmp_buf, avail);
  95
  96 // Not implemented on all systems
  97 // ret = (char *)memccpy(tmp_str, tmp_buf, '\n', avail);
  98   found = FALSE;
  99   for (ret=tmp_str;ret < (tmp_str+avail); ret++)
 100      if (*ret == '\n') {
 101        found = TRUE;
 102        break;
 103      }
 104
 105   if (!found)
 106     return wxPROTO_PROTERR;
 107   *ret = 0;
 108
 109   result = tmp_str;
 110   result = result.Left(result.Length()-1);
 111
 112   size = ret-tmp_str+1;
 113   sock->Unread(&tmp_buf[size], avail-size);
 114   return wxPROTO_NOERR;
 115 #undef PROTO_BSIZE
 116 }
 117 #endif
 118
 119 // ----------------------------------------------------------------------
 120 // Module
 121 // ----------------------------------------------------------------------
 122
 123 class wxProtocolModule: public wxModule {
 124   DECLARE_DYNAMIC_CLASS(wxProtocolModule)
 125 public:
 126   wxProtocolModule() {}
 127   bool OnInit();
 128   void OnExit();
 129 };
 130
 131 IMPLEMENT_DYNAMIC_CLASS(wxProtocolModule, wxModule)
 132
 133 bool wxProtocolModule::OnInit()
 134 {
 135 #if wxUSE_SOCKETS
 136   char *env_http_prox;
 137
 138   wxURL::g_proxy = NULL;
 139   // Initialize the proxy when HTTP_PROXY is defined
 140   env_http_prox = getenv("HTTP_PROXY");
 141   if (env_http_prox)
 142     wxURL::SetDefaultProxy(env_http_prox);
 143 #endif
 144
 145   return TRUE;
 146 }
 147
 148 void wxProtocolModule::OnExit()
 149 {
 150 #if wxUSE_SOCKETS
 151   if (wxURL::g_proxy)
 152     delete wxURL::g_proxy;
 153   wxURL::g_proxy = NULL;
 154 #endif
 155 }
 156