amiga.c

   1 const char amiga_rcs[] = "$Id: amiga.c,v 1.9 2002/03/26 22:29:54 swa Exp $";
   2 /*********************************************************************
   3  *
   4  * File        :  $Source: /cvsroot/ijbswa/current/Attic/amiga.c,v $
   5  *
   6  * Purpose     :  Amiga-specific declarations.
   7  *
   8  * Copyright   :  Written by and Copyright (C) 2001 the SourceForge
   9  *                Privoxy team. http://www.privoxy.org/
  10  *
  11  *                This program is free software; you can redistribute it
  12  *                and/or modify it under the terms of the GNU General
  13  *                Public License as published by the Free Software
  14  *                Foundation; either version 2 of the License, or (at
  15  *                your option) any later version.
  16  *
  17  *                This program is distributed in the hope that it will
  18  *                be useful, but WITHOUT ANY WARRANTY; without even the
  19  *                implied warranty of MERCHANTABILITY or FITNESS FOR A
  20  *                PARTICULAR PURPOSE.  See the GNU General Public
  21  *                License for more details.
  22  *
  23  *                The GNU General Public License should be included with
  24  *                this file.  If not, you can view it at
  25  *                http://www.gnu.org/copyleft/gpl.html
  26  *                or write to the Free Software Foundation, Inc., 59
  27  *                Temple Place - Suite 330, Boston, MA  02111-1307, USA.
  28  *
  29  * Revisions   :
  30  *    $Log: amiga.c,v $
  31  *    Revision 1.9  2002/03/26 22:29:54  swa
  32  *    we have a new homepage!
  33  *
  34  *    Revision 1.8  2002/03/25 19:32:15  joergs
  35  *    Name in version string changed from junkbuster to Privoxy.
  36  *
  37  *    Revision 1.7  2002/03/24 13:25:43  swa
  38  *    name change related issues
  39  *
  40  *    Revision 1.6  2002/03/09 20:03:52  jongfoster
  41  *    - Making various functions return int rather than size_t.
  42  *      (Undoing a recent change).  Since size_t is unsigned on
  43  *      Windows, functions like read_socket that return -1 on
  44  *      error cannot return a size_t.
  45  *
  46  *      THIS WAS A MAJOR BUG - it caused frequent, unpredictable
  47  *      crashes, and also frequently caused JB to jump to 100%
  48  *      CPU and stay there.  (Because it thought it had just
  49  *      read ((unsigned)-1) == 4Gb of data...)
  50  *
  51  *    - The signature of write_socket has changed, it now simply
  52  *      returns success=0/failure=nonzero.
  53  *
  54  *    - Trying to get rid of a few warnings --with-debug on
  55  *      Windows, I've introduced a new type "jb_socket".  This is
  56  *      used for the socket file descriptors.  On Windows, this
  57  *      is SOCKET (a typedef for unsigned).  Everywhere else, it's
  58  *      an int.  The error value can't be -1 any more, so it's
  59  *      now JB_INVALID_SOCKET (which is -1 on UNIX, and in
  60  *      Windows it maps to the #define INVALID_SOCKET.)
  61  *
  62  *    - The signature of bind_port has changed.
  63  *
  64  *    Revision 1.5  2002/03/03 09:18:03  joergs
  65  *    Made jumbjuster work on AmigaOS again.
  66  *
  67  *    Revision 1.4  2001/10/07 15:35:13  oes
  68  *    Replaced 6 boolean members of csp with one bitmap (csp->flags)
  69  *
  70  *    Revision 1.3  2001/09/12 22:54:51  joergs
  71  *    Stacksize of main thread increased.
  72  *
  73  *    Revision 1.2  2001/05/23 00:13:58  joergs
  74  *    AmigaOS support fixed.
  75  *
  76  *    Revision 1.1.1.1  2001/05/15 13:58:46  oes
  77  *    Initial import of version 2.9.3 source tree
  78  *
  79  *
  80  *********************************************************************/
  81 \f
  82
  83 #include "config.h"
  84
  85 #ifdef AMIGA
  86
  87 #include <stdio.h>
  88 #include <signal.h>
  89
  90 #include "project.h"
  91
  92 const char amiga_h_rcs[] = AMIGA_H_VERSION;
  93
  94 unsigned long __stack = 100*1024;
  95 static char ver[] = "$VER: Privoxy " __AMIGAVERSION__ " (" __AMIGADATE__ ")";
  96 struct Task *main_task = NULL;
  97 int childs = 0;
  98
  99 void serve(struct client_state *csp);
 100
 101 __saveds ULONG server_thread(void)
 102 {
 103    struct client_state *local_csp;
 104    struct UserData UserData;
 105    struct Task *me=FindTask(NULL);
 106
 107    Wait(SIGF_SINGLE);
 108    local_csp=(struct client_state *)(me->tc_UserData);
 109    me->tc_UserData=&UserData;
 110    SocketBase=(APTR)OpenLibrary("bsdsocket.library",3);
 111    if(SocketBase)
 112    {
 113       SetErrnoPtr(&(UserData.eno),sizeof(int));
 114       local_csp->cfd=ObtainSocket(local_csp->cfd, AF_INET, SOCK_STREAM, 0);
 115       if(JB_INVALID_SOCKET!=local_csp->cfd)
 116       {
 117          Signal(main_task,SIGF_SINGLE);
 118          serve((struct client_state *) local_csp);
 119       } else {
 120          local_csp->flags &= ~CSP_FLAG_ACTIVE;
 121          Signal(main_task,SIGF_SINGLE);
 122       }
 123       CloseLibrary(SocketBase);
 124    } else {
 125       local_csp->flags &= ~CSP_FLAG_ACTIVE;
 126       Signal(main_task,SIGF_SINGLE);
 127    }
 128    childs--;
 129    return 0;
 130 }
 131
 132 static BPTR olddir;
 133
 134 void amiga_exit(void)
 135 {
 136    if(SocketBase)
 137    {
 138       CloseLibrary(SocketBase);
 139    }
 140    CurrentDir(olddir);
 141 }
 142
 143 static struct SignalSemaphore memsem;
 144 static struct SignalSemaphore *memsemptr = NULL;
 145 static struct UserData GlobalUserData;
 146
 147 void InitAmiga(void)
 148 {
 149    main_task = FindTask(NULL);
 150    main_task->tc_UserData = &GlobalUserData;
 151
 152    if (((struct Library *)SysBase)->lib_Version < 39)
 153    {
 154       exit(RETURN_FAIL);
 155    }
 156
 157    signal(SIGINT,SIG_IGN);
 158    SocketBase = (APTR)OpenLibrary("bsdsocket.library",3);
 159    if (!SocketBase)
 160    {
 161       fprintf(stderr, "Can't open bsdsocket.library V3+\n");
 162       exit(RETURN_ERROR);
 163    }
 164    SetErrnoPtr(&(GlobalUserData.eno),sizeof(int));
 165    InitSemaphore(&memsem);
 166    memsemptr = &memsem;
 167
 168    olddir=CurrentDir(GetProgramDir());
 169    atexit(amiga_exit);
 170 }
 171
 172 #ifdef __GNUC__
 173 #ifdef libnix
 174 /* multithreadingsafe libnix replacements */
 175 static void *memPool=NULL;
 176
 177 void *malloc (size_t s)
 178 {
 179    ULONG *mem;
 180    LONG size = s;
 181
 182    if (size<=0)
 183    {
 184       return NULL;
 185    }
 186    if (!memPool)
 187    {
 188       if (!(memPool=CreatePool(MEMF_ANY,32*1024,8*1024)))
 189       {
 190          return NULL;
 191       }
 192    }
 193    size += sizeof(ULONG) + MEM_BLOCKMASK;
 194    size &= ~MEM_BLOCKMASK;
 195    if (memsemptr)
 196    {
 197       ObtainSemaphore(memsemptr);
 198    }
 199    if ((mem=AllocPooled(memPool,size)))
 200    {
 201       *mem++=size;
 202    }
 203    if (memsemptr)
 204    {
 205       ReleaseSemaphore(memsemptr);
 206    }
 207    return mem;
 208 }
 209
 210 void free (void *m)
 211 {
 212    ULONG *mem = m;
 213
 214    if(mem && memPool)
 215    {
 216       ULONG size=*--mem;
 217
 218       if (memsemptr)
 219       {
 220          ObtainSemaphore(memsemptr);
 221       }
 222       FreePooled(memPool,mem,size);
 223       if (memsemptr)
 224       {
 225          ReleaseSemaphore(memsemptr);
 226       }
 227    }
 228 }
 229
 230 void *realloc (void *old, size_t ns)
 231 {
 232    void *new;
 233    LONG osize, *o = old;
 234    LONG nsize = ns;
 235
 236    if (!old)
 237    {
 238       return malloc(nsize);
 239    }
 240    osize = (*(o-1)) - sizeof(ULONG);
 241    if (nsize <= osize)
 242    {
 243       return old;
 244    }
 245    if ((new = malloc(nsize)))
 246    {
 247       ULONG *n = new;
 248
 249       osize >>= 2;
 250       while(osize--)
 251       {
 252          *n++ = *o++;
 253       }
 254       free(old);
 255    }
 256    return new;
 257 }
 258
 259 void __memCleanUp (void)
 260 {
 261    if (memsemptr)
 262    {
 263       ObtainSemaphore(memsemptr);
 264    }
 265    if (memPool)
 266    {
 267       DeletePool(memPool);
 268    }
 269    if (memsemptr)
 270    {
 271       ReleaseSemaphore(memsemptr);
 272    }
 273 }
 274
 275 #define ADD2LIST(a,b,c) asm(".stabs \"_" #b "\"," #c ",0,0,_" #a )
 276 #define ADD2EXIT(a,pri) ADD2LIST(a,__EXIT_LIST__,22); \
 277                         asm(".stabs \"___EXIT_LIST__\",20,0,0," #pri "+128")
 278 ADD2EXIT(__memCleanUp,-50);
 279 #elif !defined(ixemul)
 280 #error No libnix and no ixemul!?
 281 #endif /* libnix */
 282 #else
 283 #error Only GCC is supported, multithreading safe malloc/free required.
 284 #endif /* __GNUC__ */
 285
 286 #endif /* def AMIGA */