rom/dos/waitpkt.c

   1 /*
   2     Copyright © 1995-2007, The AROS Development Team. All rights reserved.
   3     $Id$
   4
   5     Desc:
   6     Lang: English
   7 */
   8
   9 #define  DEBUG 1
  10 #include <aros/debug.h>
  11
  12 #include "dos_intern.h"
  13 #include <dos/filesystem.h>
  14 #include <dos/notify.h>
  15 #include <proto/exec.h>
  16 #include <string.h>
  17
  18 /*****************************************************************************
  19
  20     NAME */
  21 #include <proto/dos.h>
  22
  23         AROS_LH0(struct DosPacket *, WaitPkt,
  24
  25 /*  SYNOPSIS */
  26         /* void */
  27
  28 /*  LOCATION */
  29         struct DosLibrary *, DOSBase, 42, Dos)
  30
  31 /*  FUNCTION
  32
  33     Wait for a packet to arrive at your process' pr_MsgPort. It will call
  34     pr_PktWait if such a function is installed.
  35
  36     INPUTS
  37
  38     RESULT
  39
  40     The packet we received.
  41
  42     NOTES
  43
  44     The packet will be released from the port.
  45
  46     This function should NOT be used. It's there only for AmigaOS
  47     compatibility.
  48
  49     EXAMPLE
  50
  51     BUGS
  52
  53     SEE ALSO
  54
  55     INTERNALS
  56
  57 *****************************************************************************/
  58 {
  59     AROS_LIBFUNC_INIT
  60
  61     struct Process   *me = (struct Process *)FindTask(NULL);
  62
  63     return internal_WaitPkt(&me->pr_MsgPort, DOSBase);
  64
  65     AROS_LIBFUNC_EXIT
  66 } /* WaitPkt */
  67
  68
  69 struct DosPacket *internal_WaitPkt(struct MsgPort *msgPort,
  70                                    struct DosLibrary *DOSBase)
  71 {
  72     struct Message   *msg;
  73     struct DosPacket *packet;
  74     struct Process   *me = (struct Process *)FindTask(NULL);
  75     struct IOFileSys *iofs;
  76
  77     if (__is_process(me))
  78     {
  79         /* Call the packet wait function if the user has one installed.
  80            Unfortunately, the user gets something completely different than
  81            a packet, but we cannot do anything about that... */
  82 #if 0
  83         if (me->pr_PktWait != NULL)
  84         {
  85             me->pr_PktWait();
  86         }
  87 #endif
  88     }
  89
  90     /* Make sure we have a packet -- we may be woken up even if there is
  91        not a packet for us as SIGF_DOS may be used and we may have another
  92        message port that waits for packets, too. */
  93     while ((msg = GetMsg(msgPort)) == NULL)
  94     {
  95         Wait(1 << msgPort->mp_SigBit);
  96     }
  97
  98     iofs = (struct IOFileSys *)msg;
  99     packet = iofs->io_PacketEmulation;
 100
 101     /* Convert AROS IOFileSys results back to DosPacket results */
 102
 103     switch (iofs->IOFS.io_Command)
 104     {
 105     case FSA_SEEK:
 106         packet->dp_Res1 = (IPTR)iofs->io_Union.io_SEEK.io_Offset;
 107         packet->dp_Res2 = iofs->io_DosError;
 108         break;
 109
 110         /* This FSA corrsponds to ACTION_LOCATE_OBJECT, ACTION_COPY_DIR and
 111            ACTION_COPY_DIR_FH */
 112     case FSA_OPEN:
 113         {
 114             struct FileHandle *fh = (struct FileHandle *)packet->dp_Arg6;
 115
 116             packet->dp_Res1 = (IPTR)MKBADDR(fh);
 117             packet->dp_Res2 = iofs->io_DosError;
 118
 119             if (iofs->io_DosError != 0)
 120             {
 121                 FreeDosObject(DOS_FILEHANDLE, fh);
 122             }
 123
 124             fh->fh_Device = iofs->IOFS.io_Device;
 125             fh->fh_Unit   = iofs->IOFS.io_Unit;
 126             break;
 127         }
 128
 129         /* This corresponds to ACTION_FINDINPUT, ACTION_FINDOUTPUT,
 130            ACTION_FINDUPDATE which fortunately have the same return values */
 131     case FSA_OPEN_FILE:
 132         {
 133             struct FileHandle *fh = (struct FileHandle *)BADDR(packet->dp_Arg1);
 134
 135             fh->fh_Device = iofs->IOFS.io_Device;
 136             fh->fh_Unit   = iofs->IOFS.io_Unit;
 137
 138             packet->dp_Res1 = iofs->io_DosError == 0;
 139             packet->dp_Res2 = iofs->io_DosError;
 140             break;
 141         }
 142
 143     case FSA_READ:
 144     case FSA_WRITE:
 145         packet->dp_Res1 = (IPTR)iofs->io_Union.io_READ_WRITE.io_Length;
 146         kprintf("Packet (%p) length = %u", packet, packet->dp_Res1);
 147         packet->dp_Res2 = iofs->io_DosError;
 148         break;
 149
 150     case FSA_CLOSE:
 151         packet->dp_Res1 = iofs->io_DosError == 0;
 152         FreeDosObject(DOS_FILEHANDLE, (APTR)packet->dp_Arg1);
 153         break;
 154
 155
 156     case FSA_EXAMINE:
 157         {
 158             /* Get supplied FileInfoBlock */
 159             struct FileInfoBlock *fib = (struct FileInfoBlock *)BADDR(packet->dp_Arg2);
 160             struct ExAllData     *ead = iofs->io_Union.io_EXAMINE.io_ead;
 161
 162             packet->dp_Res1 = iofs->io_DosError == 0;
 163             packet->dp_Res2 = iofs->io_DosError;
 164
 165             /* in fib_DiskKey the result from telldir is being stored which
 166                gives us important info for a call to ExNext() */
 167             fib->fib_DiskKey      = iofs->io_DirPos;
 168             fib->fib_DirEntryType = ead->ed_Type;
 169
 170             strncpy(fib->fib_FileName, ead->ed_Name, MAXFILENAMELENGTH);
 171
 172             fib->fib_Protection = ead->ed_Prot;
 173             fib->fib_EntryType = ead->ed_Type;
 174             fib->fib_Size = ead->ed_Size;
 175             fib->fib_Date.ds_Days = ead->ed_Days;
 176             fib->fib_Date.ds_Minute = ead->ed_Mins;
 177             fib->fib_Date.ds_Tick = ead->ed_Ticks;
 178
 179             if (ead->ed_Comment != NULL)
 180             {
 181                 strncpy(fib->fib_Comment, ead->ed_Comment, MAXCOMMENTLENGTH);
 182             }
 183
 184             fib->fib_OwnerUID = ead->ed_OwnerUID;
 185             fib->fib_OwnerGID = ead->ed_OwnerGID;
 186
 187             /* Release temporary buffer memory */
 188             FreeVec(ead);
 189             break;
 190         }
 191
 192     case FSA_EXAMINE_NEXT:
 193     case FSA_SET_FILE_SIZE:
 194     case FSA_DELETE_OBJECT:
 195     case FSA_RENAME:
 196     case FSA_SET_PROTECT:
 197     case FSA_SET_COMMENT:
 198     case FSA_SET_DATE:
 199     case FSA_FORMAT:
 200     case FSA_IS_FILESYSTEM:
 201     case FSA_LOCK_RECORD:
 202     case FSA_UNLOCK_RECORD:
 203     case FSA_ADD_NOTIFY:
 204     case FSA_CREATE_HARDLINK:
 205     case FSA_CREATE_SOFTLINK:
 206         packet->dp_Res1 = iofs->io_DosError == 0;
 207         packet->dp_Res2 = iofs->io_DosError;
 208         break;
 209
 210     case FSA_REMOVE_NOTIFY:
 211         {
 212             struct NotifyRequest *notify = iofs->io_Union.io_NOTIFY.io_NotificationRequest;
 213
 214             if (notify->nr_Flags & NRF_SEND_MESSAGE)
 215             {
 216                 struct Node          *tempNode;
 217                 struct NotifyMessage *nm;
 218
 219                 Disable();
 220
 221                 ForeachNodeSafe(&notify->nr_stuff.nr_Msg.nr_Port->mp_MsgList,
 222                                 nm, tempNode)
 223                 {
 224                     if (notify->nr_MsgCount == 0)
 225                     {
 226                         break;
 227                     }
 228
 229                     if (nm->nm_NReq == notify)
 230                     {
 231                         notify->nr_MsgCount--;
 232                         Remove((struct Node *)nm);
 233                         ReplyMsg((struct Message *)nm);
 234                     }
 235                 }
 236
 237                 Enable();
 238             }
 239         }
 240
 241         break;
 242
 243     case FSA_CREATE_DIR:
 244         {
 245             struct FileHandle *fh = AllocDosObject(DOS_FILEHANDLE, NULL);
 246
 247             /* If the allocation operation failed, we are in trouble as we
 248                have to UnLock() the created directory -- this should be moved
 249                to SendPkt()! */
 250
 251             if (fh == NULL)
 252             {
 253                 /* Crash... well, we keep the lock for now */
 254
 255                 packet->dp_Res1 = DOSFALSE;
 256                 packet->dp_Res2 = ERROR_NO_FREE_STORE;
 257                 break;
 258             }
 259
 260             fh->fh_Unit   = iofs->IOFS.io_Unit;
 261             fh->fh_Device = iofs->IOFS.io_Device;
 262             packet->dp_Res1 = (IPTR)MKBADDR(fh);
 263             break;
 264         }
 265
 266     case FSA_SAME_LOCK:
 267         packet->dp_Res1 = (IPTR)(iofs->io_Union.io_SAME_LOCK.io_Same == LOCK_SAME);
 268         packet->dp_Res2 = iofs->io_DosError;
 269         break;
 270
 271     case FSA_EXAMINE_ALL:
 272         /* TODO */
 273         /* ExAll() seems to be flawed(?)... have to investigate this. */
 274         break;
 275
 276     case FSA_DISK_INFO:
 277     case FSA_INHIBIT:
 278         packet->dp_Res1 = iofs->io_DosError == 0;
 279         break;
 280
 281     case FSA_RELABEL:
 282         packet->dp_Res1 = iofs->io_Union.io_RELABEL.io_Result;
 283         break;
 284
 285     case FSA_MORE_CACHE:
 286         packet->dp_Res1 = iofs->io_DosError == 0;
 287         packet->dp_Res2 = iofs->io_Union.io_MORE_CACHE.io_NumBuffers;
 288         break;
 289
 290
 291         /* TODO */
 292     case FSA_READ_SOFTLINK:
 293     case FSA_FILE_MODE:
 294     default:
 295         kprintf("Filesystem action %i not handled yet in WaitPkt()\n",
 296                 iofs->IOFS.io_Command);
 297         break;
 298     }
 299
 300     return packet;
 301 }