rom/filesys/fat/packet.c

   1 /*
   2  * fat-handler - FAT12/16/32 filesystem handler
   3  *
   4  * Copyright © 2006 Marek Szyprowski
   5  * Copyright © 2007-2015 The AROS Development Team
   6  *
   7  * This program is free software; you can redistribute it and/or modify it
   8  * under the same terms as AROS itself.
   9  *
  10  * $Id$
  11  */
  12
  13 #include <exec/types.h>
  14 #include <exec/execbase.h>
  15 #include <dos/dosextens.h>
  16 #include <dos/filehandler.h>
  17 #include <dos/notify.h>
  18 #include <devices/inputevent.h>
  19
  20 #include <proto/exec.h>
  21 #include <proto/dos.h>
  22
  23 #include <string.h>
  24
  25 #include "fat_fs.h"
  26 #include "fat_protos.h"
  27
  28 #define DEBUG DEBUG_PACKETS
  29 #include "debug.h"
  30
  31 void ProcessPackets(struct Globals *glob)
  32 {
  33     struct Message *msg;
  34     struct DosPacket *pkt;
  35
  36     while ((msg = GetMsg(glob->ourport)) != NULL)
  37     {
  38         IPTR res = DOSFALSE;
  39         LONG err = 0;
  40
  41         pkt = (struct DosPacket *)msg->mn_Node.ln_Name;
  42
  43         switch (pkt->dp_Type)
  44         {
  45         case ACTION_LOCATE_OBJECT:
  46             {
  47                 struct ExtFileLock *fl = BADDR(pkt->dp_Arg1), *lock;
  48                 LONG access = pkt->dp_Arg3;
  49
  50                 D(
  51                     bug("[fat] LOCATE_OBJECT: lock 0x%08x (dir %ld/%ld) name '",
  52                         pkt->dp_Arg1, fl != NULL ? fl->gl->dir_cluster : 0,
  53                         fl != NULL ? fl->gl->dir_entry : 0);
  54                     RawPutChars(AROS_BSTR_ADDR(pkt->dp_Arg2),
  55                         AROS_BSTR_strlen(pkt->dp_Arg2));
  56                     bug("' type %s\n", pkt->dp_Arg3 == EXCLUSIVE_LOCK ?
  57                         "EXCLUSIVE" : "SHARED");
  58                 )
  59
  60                 if ((err = TestLock(fl, glob)))
  61                     break;
  62
  63                 if ((err = OpLockFile(fl, AROS_BSTR_ADDR(pkt->dp_Arg2),
  64                     AROS_BSTR_strlen(pkt->dp_Arg2), access, &lock,
  65                     glob)) == 0)
  66                     res = (IPTR) MKBADDR(lock);
  67
  68                 break;
  69             }
  70
  71         case ACTION_FREE_LOCK:
  72             {
  73                 struct ExtFileLock *fl = BADDR(pkt->dp_Arg1);
  74
  75                 D(bug("[fat] FREE_LOCK: lock 0x%08x (dir %ld/%ld)\n",
  76                     pkt->dp_Arg1,
  77                     fl != NULL ? fl->gl->dir_cluster : 0,
  78                     fl != NULL ? fl->gl->dir_entry : 0));
  79
  80                 OpUnlockFile(fl, glob);
  81
  82                 res = DOSTRUE;
  83                 break;
  84             }
  85
  86         case ACTION_COPY_DIR:
  87         case ACTION_COPY_DIR_FH:
  88             {
  89                 struct ExtFileLock *fl = BADDR(pkt->dp_Arg1), *lock;
  90
  91                 D(bug("[fat] COPY_DIR: lock 0x%08x (dir %ld/%ld)\n",
  92                     pkt->dp_Arg1,
  93                     fl != NULL ? fl->gl->dir_cluster : 0,
  94                     fl != NULL ? fl->gl->dir_entry : 0));
  95
  96                 if ((err = TestLock(fl, glob)))
  97                     break;
  98
  99                 if ((err = OpCopyLock(fl, &lock, glob)) == 0)
 100                     res = (IPTR) MKBADDR(lock);
 101
 102                 break;
 103             }
 104
 105         case ACTION_PARENT:
 106         case ACTION_PARENT_FH:
 107             {
 108                 struct ExtFileLock *fl = BADDR(pkt->dp_Arg1), *lock;
 109
 110                 D(bug("[fat] ACTION_PARENT: lock 0x%08x (dir %ld/%ld)\n",
 111                     pkt->dp_Arg1,
 112                     fl != NULL ? fl->gl->dir_cluster : 0,
 113                     fl != NULL ? fl->gl->dir_entry : 0));
 114
 115                 if ((err = TestLock(fl, glob)))
 116                     break;
 117
 118                 if ((err = OpLockParent(fl, &lock, glob)) == 0)
 119                     res = (IPTR) MKBADDR(lock);
 120
 121                 break;
 122             }
 123
 124         case ACTION_SAME_LOCK:
 125             {
 126                 struct ExtFileLock *fl1 = BADDR(pkt->dp_Arg1);
 127                 struct ExtFileLock *fl2 = BADDR(pkt->dp_Arg2);
 128
 129                 D(bug("[fat] ACTION_SAME_LOCK: lock #1 0x%08x (dir %ld/%ld)"
 130                     " lock #2 0x%08x (dir %ld/%ld)\n",
 131                     pkt->dp_Arg1,
 132                     fl1 != NULL ? fl1->gl->dir_cluster : 0,
 133                     fl1 != NULL ? fl1->gl->dir_entry : 0, pkt->dp_Arg2,
 134                     fl2 != NULL ? fl2->gl->dir_cluster : 0,
 135                     fl2 != NULL ? fl2->gl->dir_entry : 0));
 136
 137                 err = 0;
 138
 139                 if (fl1 == fl2 || fl1->gl == fl2->gl)
 140                     res = DOSTRUE;
 141
 142                 break;
 143             }
 144
 145         case ACTION_EXAMINE_OBJECT:
 146         case ACTION_EXAMINE_FH:
 147             {
 148                 struct ExtFileLock *fl = BADDR(pkt->dp_Arg1);
 149                 struct FileInfoBlock *fib = BADDR(pkt->dp_Arg2);
 150
 151                 D(bug("[fat] EXAMINE_OBJECT: lock 0x%08x (dir %ld/%ld)\n",
 152                     pkt->dp_Arg1,
 153                     fl != NULL ? fl->gl->dir_cluster : 0,
 154                     fl != NULL ? fl->gl->dir_entry : 0));
 155
 156                 if ((err = TestLock(fl, glob)))
 157                     break;
 158
 159                 if ((err = FillFIB(fl, fib, glob)) == 0)
 160                     res = DOSTRUE;
 161
 162                 break;
 163             }
 164
 165         case ACTION_EXAMINE_NEXT:
 166             {
 167                 struct ExtFileLock *fl = BADDR(pkt->dp_Arg1), *lock;
 168                 struct FileInfoBlock *fib = BADDR(pkt->dp_Arg2);
 169                 struct DirHandle dh;
 170                 struct DirEntry de;
 171
 172                 D(bug("[fat] EXAMINE_NEXT: lock 0x%08x (dir %ld/%ld)\n",
 173                     pkt->dp_Arg1,
 174                     fl != NULL ? fl->gl->dir_cluster : 0,
 175                     fl != NULL ? fl->gl->dir_entry : 0));
 176
 177                 if ((err = TestLock(fl, glob)))
 178                     break;
 179
 180                 if ((err = InitDirHandle(glob->sb, fl->ioh.first_cluster, &dh,
 181                     FALSE, glob)) != 0)
 182                     break;
 183
 184                 dh.cur_index = fib->fib_DiskKey;
 185
 186                 if ((err = GetNextDirEntry(&dh, &de, glob)) != 0)
 187                 {
 188                     if (err == ERROR_OBJECT_NOT_FOUND)
 189                         err = ERROR_NO_MORE_ENTRIES;
 190                     ReleaseDirHandle(&dh, glob);
 191                     break;
 192                 }
 193
 194                 if ((err = LockFile(fl->ioh.first_cluster, dh.cur_index,
 195                     SHARED_LOCK, &lock, glob)) != 0)
 196                 {
 197                     ReleaseDirHandle(&dh, glob);
 198                     break;
 199                 }
 200
 201                 if (!(err = FillFIB(lock, fib, glob)))
 202                 {
 203                     fib->fib_DiskKey = dh.cur_index;
 204                     res = DOSTRUE;
 205                 }
 206
 207                 FreeLock(lock, glob);
 208                 ReleaseDirHandle(&dh, glob);
 209
 210                 break;
 211             }
 212
 213         case ACTION_FINDINPUT:
 214         case ACTION_FINDOUTPUT:
 215         case ACTION_FINDUPDATE:
 216             {
 217                 struct FileHandle *fh = BADDR(pkt->dp_Arg1);
 218                 struct ExtFileLock *fl = BADDR(pkt->dp_Arg2);
 219                 struct ExtFileLock *lock;
 220
 221                 D(
 222                     bug("[fat] %s: lock 0x%08x (dir %ld/%ld) path '",
 223                         pkt->dp_Type == ACTION_FINDINPUT ? "FINDINPUT" :
 224                         pkt->dp_Type == ACTION_FINDOUTPUT ? "FINDOUTPUT" :
 225                         "FINDUPDATE",
 226                         pkt->dp_Arg2,
 227                         fl != NULL ? fl->gl->dir_cluster : 0,
 228                         fl != NULL ? fl->gl->dir_entry : 0);
 229                     RawPutChars(AROS_BSTR_ADDR(pkt->dp_Arg3),
 230                         AROS_BSTR_strlen(pkt->dp_Arg3));
 231                     bug("'\n");
 232                 )
 233
 234                 if ((err = TestLock(fl, glob)))
 235                     break;
 236
 237                 if ((err = OpOpenFile(fl, AROS_BSTR_ADDR(pkt->dp_Arg3),
 238                     AROS_BSTR_strlen(pkt->dp_Arg3), pkt->dp_Type,
 239                     &lock, glob)) != 0)
 240                     break;
 241
 242                 fh->fh_Arg1 = (IPTR) MKBADDR(lock);
 243                 fh->fh_Port = DOSFALSE;
 244
 245                 res = DOSTRUE;
 246
 247                 break;
 248             }
 249
 250         case ACTION_READ:
 251             {
 252                 struct ExtFileLock *fl = BADDR(pkt->dp_Arg1);
 253                 APTR buffer = (APTR) pkt->dp_Arg2;
 254                 ULONG want = pkt->dp_Arg3, read;
 255
 256                 D(bug("[fat] READ: lock 0x%08x (dir %ld/%ld pos %ld)"
 257                     " want %ld\n",
 258                     pkt->dp_Arg1, fl != NULL ? fl->gl->dir_cluster : 0,
 259                     fl != NULL ? fl->gl->dir_entry : 0, fl->pos, want));
 260
 261                 if ((err = TestLock(fl, glob)))
 262                 {
 263                     res = -1;
 264                     break;
 265                 }
 266
 267                 if ((err = OpRead(fl, buffer, want, &read, glob)) != 0)
 268                     res = -1;
 269                 else
 270                     res = read;
 271
 272                 break;
 273             }
 274
 275         case ACTION_WRITE:
 276             {
 277                 struct ExtFileLock *fl = BADDR(pkt->dp_Arg1);
 278                 APTR buffer = (APTR) pkt->dp_Arg2;
 279                 ULONG want = pkt->dp_Arg3, written;
 280
 281                 D(bug("[fat] WRITE: lock 0x%08x (dir %ld/%ld pos %ld)"
 282                     " want %ld\n",
 283                     pkt->dp_Arg1, fl != NULL ? fl->gl->dir_cluster : 0,
 284                     fl != NULL ? fl->gl->dir_entry : 0, fl->pos, want));
 285
 286                 if ((err = TestLock(fl, glob)))
 287                 {
 288                     res = -1;
 289                     break;
 290                 }
 291
 292                 if ((err = OpWrite(fl, buffer, want, &written, glob)) != 0)
 293                     res = -1;
 294                 else
 295                     res = written;
 296
 297                 break;
 298             }
 299
 300         case ACTION_SEEK:
 301             {
 302                 struct ExtFileLock *fl = BADDR(pkt->dp_Arg1);
 303                 LONG offset = pkt->dp_Arg2;
 304                 ULONG whence = pkt->dp_Arg3;
 305
 306                 D(bug("[fat] SEEK: lock 0x%08x (dir %ld/%ld pos %ld)"
 307                     " offset %ld whence %s\n",
 308                     pkt->dp_Arg1, fl != NULL ? fl->gl->dir_cluster : 0,
 309                     fl != NULL ? fl->gl->dir_entry : 0, fl->pos, offset,
 310                     whence == OFFSET_BEGINNING ? "BEGINNING" :
 311                     whence == OFFSET_END ? "END" :
 312                     whence == OFFSET_CURRENT ? "CURRENT" :
 313                     "(unknown)"));
 314
 315                 if ((err = TestLock(fl, glob)))
 316                 {
 317                     res = -1;
 318                     break;
 319                 }
 320
 321                 res = fl->pos;
 322                 err = 0;
 323
 324                 if (whence == OFFSET_BEGINNING
 325                     && offset >= 0 && offset <= fl->gl->size)
 326                     fl->pos = offset;
 327                 else if (whence == OFFSET_CURRENT
 328                     && offset + fl->pos >= 0
 329                     && offset + fl->pos <= fl->gl->size)
 330                     fl->pos += offset;
 331                 else if (whence == OFFSET_END
 332                     && offset <= 0 && fl->gl->size + offset >= 0)
 333                     fl->pos = fl->gl->size + offset;
 334                 else
 335                 {
 336                     res = -1;
 337                     err = ERROR_SEEK_ERROR;
 338                 }
 339
 340                 break;
 341             }
 342
 343         case ACTION_SET_FILE_SIZE:
 344             {
 345                 struct ExtFileLock *fl = BADDR(pkt->dp_Arg1);
 346                 LONG offset = pkt->dp_Arg2;
 347                 LONG whence = pkt->dp_Arg3;
 348                 LONG newsize;
 349
 350                 D(bug("[fat] SET_FILE_SIZE: lock 0x%08x"
 351                     " (dir %ld/%ld pos %ld) offset %ld whence %s\n",
 352                     pkt->dp_Arg1, fl != NULL ? fl->gl->dir_cluster : 0,
 353                     fl != NULL ? fl->gl->dir_entry : 0, fl->pos, offset,
 354                     whence == OFFSET_BEGINNING ? "BEGINNING" :
 355                     whence == OFFSET_END ? "END" :
 356                     whence == OFFSET_CURRENT ? "CURRENT" :
 357                     "(unknown)"));
 358
 359                 if ((err = TestLock(fl, glob)))
 360                 {
 361                     res = -1;
 362                     break;
 363                 }
 364
 365                 if ((err = OpSetFileSize(fl, offset, whence, &newsize,
 366                     glob)) != 0)
 367                     res = -1;
 368                 else
 369                     res = newsize;
 370
 371                 break;
 372             }
 373
 374         case ACTION_END:
 375             {
 376                 struct ExtFileLock *fl = BADDR(pkt->dp_Arg1);
 377
 378                 D(bug("[fat] END: lock 0x%08x (dir %ld/%ld)\n",
 379                     pkt->dp_Arg1,
 380                     fl != NULL ? fl->gl->dir_cluster : 0,
 381                     fl != NULL ? fl->gl->dir_entry : 0));
 382
 383                 if ((err = TestLock(fl, glob)))
 384                     break;
 385
 386                 FreeLock(fl, glob);
 387
 388                 res = DOSTRUE;
 389                 break;
 390             }
 391
 392         case ACTION_IS_FILESYSTEM:
 393             D(bug("[fat] IS_FILESYSTEM\n"));
 394
 395             res = DOSTRUE;
 396             break;
 397
 398         case ACTION_CURRENT_VOLUME:
 399             {
 400                 struct ExtFileLock *fl = BADDR(pkt->dp_Arg1);
 401
 402                 D(bug("[fat] CURRENT_VOLUME: lock 0x%08x\n", pkt->dp_Arg1));
 403
 404                 res = (IPTR) ((fl) ? fl->fl_Volume : ((glob->sb != NULL) ?
 405                     MKBADDR(glob->sb->doslist) : BNULL));
 406                 break;
 407             }
 408
 409         case ACTION_INFO:
 410         case ACTION_DISK_INFO:
 411             {
 412                 struct InfoData *id;
 413
 414                 if (pkt->dp_Type == ACTION_INFO)
 415                 {
 416                     struct FileLock *fl = BADDR(pkt->dp_Arg1);
 417
 418                     D(bug("[fat] INFO: lock 0x%08x\n", pkt->dp_Arg1));
 419
 420                     if (fl && (glob->sb == NULL
 421                         || fl->fl_Volume != MKBADDR(glob->sb->doslist)))
 422                     {
 423                         err = ERROR_DEVICE_NOT_MOUNTED;
 424                         break;
 425                     }
 426
 427                     id = BADDR(pkt->dp_Arg2);
 428                 }
 429                 else
 430                 {
 431                     D(bug("[fat] DISK_INFO\n"));
 432
 433                     id = BADDR(pkt->dp_Arg1);
 434                 }
 435
 436                 FillDiskInfo(id, glob);
 437
 438                 res = DOSTRUE;
 439                 break;
 440             }
 441
 442         case ACTION_INHIBIT:
 443             {
 444                 LONG inhibit = pkt->dp_Arg1;
 445
 446                 D(bug("[fat] INHIBIT: %sinhibit\n",
 447                     inhibit == DOSTRUE ? "" : "un"));
 448
 449                 if (inhibit == DOSTRUE)
 450                 {
 451                     glob->disk_inhibited++;
 452                     if (glob->disk_inhibited == 1)
 453                         DoDiskRemove(glob);
 454                 }
 455                 else if (glob->disk_inhibited != 0)
 456                 {
 457                     glob->disk_inhibited--;
 458                     if (glob->disk_inhibited == 0)
 459                         ProcessDiskChange(glob);
 460                 }
 461
 462                 res = DOSTRUE;
 463                 break;
 464             }
 465
 466         case ACTION_DIE:
 467             {
 468                 struct FSSuper *sb;
 469                 struct NotifyNode *nn;
 470
 471                 D(bug("[fat] DIE\n"));
 472
 473                 /* Clear our message port from notification requests so DOS
 474                  * won't send notification-end packets to us after we're gone */
 475                 ForeachNode(&glob->sblist, sb)
 476                 {
 477                     ForeachNode(&sb->info->notifies, nn)
 478                     {
 479                         nn->nr->nr_Handler = NULL;
 480                     }
 481                 }
 482
 483                 if ((glob->sb != NULL
 484                     && !(IsListEmpty(&glob->sb->info->locks)
 485                     && IsListEmpty(&glob->sb->info->notifies))))
 486                 {
 487
 488                     D(bug("\tThere are remaining locks or notification "
 489                         "requests. Shutting down is not possible\n"));
 490
 491                     err = ERROR_OBJECT_IN_USE;
 492                     break;
 493                 }
 494
 495                 D(bug("\tNothing pending. Shutting down the handler\n"));
 496
 497                 /* Risky, because of async. volume remove, but works */
 498                 DoDiskRemove(glob);
 499
 500                 glob->quit = TRUE;
 501                 glob->death_packet = pkt;
 502                 glob->devnode->dol_Task = NULL;
 503
 504                 res = DOSTRUE;
 505                 break;
 506             }
 507
 508 #if 0
 509             /* XXX: AROS needs these ACTION_ headers defined in dos/dosextens.h */
 510
 511         case ACTION_GET_DISK_FSSM:
 512             {
 513                 D(bug("\nGot ACTION_GET_DISK_FSSM\n"));
 514
 515                 res = (ULONG) glob->fssm;
 516                 break;
 517             }
 518
 519         case ACTION_FREE_DISK_FSSM:
 520             {
 521                 D(bug("\nGot ACTION_FREE_DISK_FSSM\n"));
 522
 523                 res = DOSTRUE;
 524                 break;
 525
 526             }
 527 #endif
 528
 529         case ACTION_DISK_CHANGE:    /* Internal */
 530             {
 531                 struct DosList *vol = (struct DosList *)pkt->dp_Arg2;
 532                 struct VolumeInfo *vol_info =
 533                     BADDR(vol->dol_misc.dol_volume.dol_LockList);
 534                 ULONG type = pkt->dp_Arg3;
 535
 536                 D(bug("[fat] DISK_CHANGE [INTERNAL]\n"));
 537
 538                 if (pkt->dp_Arg1 == ID_FAT_DISK)    /* Security check */
 539                 {
 540                     if (AttemptLockDosList(LDF_VOLUMES | LDF_WRITE))
 541                     {
 542                         if (type == ACTION_VOLUME_ADD)
 543                         {
 544                             AddDosEntry(vol);
 545                             UnLockDosList(LDF_VOLUMES | LDF_WRITE);
 546
 547                             SendEvent(IECLASS_DISKINSERTED, glob);
 548
 549                             D(bug("\tVolume added\n"));
 550                         }
 551                         else if (type == ACTION_VOLUME_REMOVE)
 552                         {
 553                             RemDosEntry(vol);
 554                             DeletePool(vol_info->mem_pool);
 555                             UnLockDosList(LDF_VOLUMES | LDF_WRITE);
 556
 557                             SendEvent(IECLASS_DISKREMOVED, glob);
 558
 559                             D(bug("\tVolume removed\n"));
 560                         }
 561
 562                         FreeDosObject(DOS_STDPKT, pkt); /* Cleanup */
 563
 564                         pkt = NULL;
 565                         D(bug("Packet destroyed\n"));
 566                     }
 567
 568                     else
 569                     {
 570                         D(bug("\tDosList is locked\n"));
 571                         Delay(5);
 572                         PutMsg(glob->ourport, pkt->dp_Link);
 573                         pkt = NULL;
 574                         D(bug("Message moved to the end of the queue\n"));
 575                     }
 576                 }
 577                 else
 578                     err = ERROR_OBJECT_WRONG_TYPE;
 579
 580                 break;
 581             }
 582
 583         case ACTION_RENAME_DISK:
 584             {
 585
 586                 D(
 587                     bug("[fat] RENAME_DISK: name '");
 588                     RawPutChars(AROS_BSTR_ADDR(pkt->dp_Arg1),
 589                         AROS_BSTR_strlen(pkt->dp_Arg1));
 590                     bug("'\n");
 591                 )
 592
 593                 if (glob->sb->doslist == NULL)
 594                 {
 595                     err = glob->disk_inserted ?
 596                         ERROR_NOT_A_DOS_DISK : ERROR_NO_DISK;
 597                     break;
 598                 }
 599
 600                 while (!AttemptLockDosList(LDF_VOLUMES | LDF_WRITE))
 601                     ProcessPackets(glob);
 602
 603                 err = SetVolumeName(glob->sb, AROS_BSTR_ADDR(pkt->dp_Arg1),
 604                     AROS_BSTR_strlen(pkt->dp_Arg1));
 605                 UnLockDosList(LDF_VOLUMES | LDF_WRITE);
 606                 if (err != 0)
 607                     break;
 608
 609 #ifdef AROS_FAST_BPTR
 610                 /* ReadFATSuper() sets a null byte after the
 611                  * string, so this should be fine */
 612                 CopyMem(glob->sb->volume.name + 1,
 613                     glob->sb->doslist->dol_Name,
 614                     glob->sb->volume.name[0] + 1);
 615 #else
 616                 CopyMem(glob->sb->volume.name,
 617                     BADDR(glob->sb->doslist->dol_Name),
 618                     glob->sb->volume.name[0] + 2);
 619 #endif
 620
 621                 CopyMem(glob->sb->volume.name,
 622                     glob->sb->info->root_lock.name,
 623                     glob->sb->volume.name[0] + 1);
 624
 625                 res = DOSTRUE;
 626
 627                 break;
 628             }
 629
 630         case ACTION_FORMAT:
 631             {
 632                 D(
 633                     bug("[fat] FORMAT: name '");
 634                     RawPutChars(AROS_BSTR_ADDR(pkt->dp_Arg1),
 635                         AROS_BSTR_strlen(pkt->dp_Arg1));
 636                     bug("'\n");
 637                 )
 638
 639                 if (!glob->disk_inserted)
 640                 {
 641                     err = ERROR_NO_DISK;
 642                     break;
 643                 }
 644
 645                 err = FormatFATVolume(AROS_BSTR_ADDR(pkt->dp_Arg1),
 646                     AROS_BSTR_strlen(pkt->dp_Arg1), glob);
 647                 if (err != 0)
 648                     break;
 649
 650                 SendEvent(IECLASS_DISKINSERTED, glob);
 651
 652                 res = DOSTRUE;
 653
 654                 break;
 655             }
 656
 657         case ACTION_DELETE_OBJECT:
 658             {
 659                 struct ExtFileLock *fl = BADDR(pkt->dp_Arg1);
 660
 661                 D(
 662                     bug("[fat] DELETE_OBJECT:"
 663                         " lock 0x%08x (dir %ld/%ld) path '",
 664                         pkt->dp_Arg1, fl != NULL ? fl->gl->dir_cluster : 0,
 665                         fl != NULL ? fl->gl->dir_entry : 0);
 666                     RawPutChars(AROS_BSTR_ADDR(pkt->dp_Arg2),
 667                         AROS_BSTR_strlen(pkt->dp_Arg2));
 668                     bug("'\n");
 669                 )
 670
 671                 if ((err = TestLock(fl, glob)))
 672                     break;
 673
 674                 err = OpDeleteFile(fl, AROS_BSTR_ADDR(pkt->dp_Arg2),
 675                     AROS_BSTR_strlen(pkt->dp_Arg2), glob);
 676                 if (err == 0)
 677                     res = DOSTRUE;
 678
 679                 break;
 680             }
 681
 682         case ACTION_RENAME_OBJECT:
 683             {
 684                 struct ExtFileLock *sfl = BADDR(pkt->dp_Arg1), *dfl =
 685                     BADDR(pkt->dp_Arg3);
 686
 687                 D(
 688                     bug("[fat] RENAME_OBJECT:"
 689                     " srclock 0x%08x (dir %ld/%ld) name '",
 690                         pkt->dp_Arg1,
 691                         sfl != NULL ? sfl->gl->dir_cluster : 0,
 692                         sfl != NULL ? sfl->gl->dir_entry : 0);
 693                     RawPutChars(AROS_BSTR_ADDR(pkt->dp_Arg2),
 694                         AROS_BSTR_strlen(pkt->dp_Arg2));
 695                     bug("' destlock 0x%08x (dir %ld/%ld) name '",
 696                         pkt->dp_Arg3,
 697                         dfl != NULL ? dfl->gl->dir_cluster : 0,
 698                         dfl != NULL ? dfl->gl->dir_entry : 0);
 699                     RawPutChars(AROS_BSTR_ADDR(pkt->dp_Arg4),
 700                         AROS_BSTR_strlen(pkt->dp_Arg4));
 701                     bug("'\n");
 702                 )
 703
 704                 if ((err = TestLock(sfl, glob)) != 0
 705                     || (err = TestLock(dfl, glob)) != 0)
 706                     break;
 707
 708                 err = OpRenameFile(sfl, AROS_BSTR_ADDR(pkt->dp_Arg2),
 709                     AROS_BSTR_strlen(pkt->dp_Arg2), dfl,
 710                     AROS_BSTR_ADDR(pkt->dp_Arg4),
 711                     AROS_BSTR_strlen(pkt->dp_Arg4), glob);
 712                 if (err == 0)
 713                     res = DOSTRUE;
 714
 715                 break;
 716             }
 717
 718         case ACTION_CREATE_DIR:
 719             {
 720                 struct ExtFileLock *fl = BADDR(pkt->dp_Arg1), *new;
 721
 722                 D(
 723                     bug("[fat] CREATE_DIR: lock 0x%08x (dir %ld/%ld) name '",
 724                         pkt->dp_Arg1,
 725                         fl != NULL ? fl->gl->dir_cluster : 0,
 726                         fl != NULL ? fl->gl->dir_entry : 0);
 727                     RawPutChars(AROS_BSTR_ADDR(pkt->dp_Arg2),
 728                         AROS_BSTR_strlen(pkt->dp_Arg2));
 729                     bug("'\n");
 730                 )
 731
 732                 if ((err = TestLock(fl, glob)))
 733                     break;
 734
 735                 if ((err = OpCreateDir(fl, AROS_BSTR_ADDR(pkt->dp_Arg2),
 736                     AROS_BSTR_strlen(pkt->dp_Arg2), &new, glob)) == 0)
 737                     res = (IPTR) MKBADDR(new);
 738
 739                 break;
 740             }
 741
 742         case ACTION_SET_PROTECT:
 743             {
 744                 struct ExtFileLock *fl = BADDR(pkt->dp_Arg2);
 745                 ULONG prot = pkt->dp_Arg4;
 746
 747                 D(
 748                     bug("[fat] SET_PROTECT: lock 0x%08x (dir %ld/%ld) name '",
 749                         pkt->dp_Arg2, fl != NULL ? fl->gl->dir_cluster : 0,
 750                         fl != NULL ? fl->gl->dir_entry : 0);
 751                     RawPutChars(AROS_BSTR_ADDR(pkt->dp_Arg3),
 752                         AROS_BSTR_strlen(pkt->dp_Arg3));
 753                     bug("' prot 0x%08x\n", prot);
 754                 )
 755                 if ((err = TestLock(fl, glob)))
 756                     break;
 757
 758                 err = OpSetProtect(fl, AROS_BSTR_ADDR(pkt->dp_Arg3),
 759                     AROS_BSTR_strlen(pkt->dp_Arg3), prot, glob);
 760
 761                 break;
 762             }
 763
 764         case ACTION_SET_DATE:
 765             {
 766                 struct ExtFileLock *fl = BADDR(pkt->dp_Arg2);
 767                 struct DateStamp *ds = (struct DateStamp *)pkt->dp_Arg4;
 768
 769 #if defined(DEBUG) && DEBUG != 0
 770                 {
 771                     struct DateTime dt;
 772                     char datestr[LEN_DATSTRING];
 773
 774                     dt.dat_Stamp = *ds;
 775                     dt.dat_Format = FORMAT_DOS;
 776                     dt.dat_Flags = 0;
 777                     dt.dat_StrDay = NULL;
 778                     dt.dat_StrDate = datestr;
 779                     dt.dat_StrTime = NULL;
 780                     DateToStr(&dt);
 781
 782                     D(
 783                         bug("[fat] SET_DATE: lock 0x%08x (dir %ld/%ld) name '",
 784                             pkt->dp_Arg2,
 785                             fl != NULL ? fl->gl->dir_cluster : 0,
 786                             fl != NULL ? fl->gl->dir_entry : 0);
 787                         RawPutChars(AROS_BSTR_ADDR(pkt->dp_Arg3),
 788                             AROS_BSTR_strlen(pkt->dp_Arg3));
 789                         bug("' ds '%s'\n", datestr);
 790                     )
 791                 }
 792 #endif
 793
 794                 if ((err = TestLock(fl, glob)))
 795                     break;
 796
 797                 err = OpSetDate(fl, AROS_BSTR_ADDR(pkt->dp_Arg3),
 798                     AROS_BSTR_strlen(pkt->dp_Arg3), ds, glob);
 799
 800                 break;
 801             }
 802
 803         case ACTION_ADD_NOTIFY:
 804             {
 805                 struct NotifyRequest *nr =
 806                     (struct NotifyRequest *)pkt->dp_Arg1;
 807
 808                 D(bug("[fat] ADD_NOTIFY: nr 0x%08x name '%s'\n", nr,
 809                     nr->nr_FullName));
 810
 811                 err = OpAddNotify(nr, glob);
 812
 813                 break;
 814             }
 815
 816         case ACTION_REMOVE_NOTIFY:
 817             {
 818                 struct NotifyRequest *nr =
 819                     (struct NotifyRequest *)pkt->dp_Arg1;
 820
 821                 D(bug("[fat] REMOVE_NOTIFY: nr 0x%08x name '%s'\n", nr,
 822                     nr->nr_FullName));
 823
 824                 err = OpRemoveNotify(nr, glob);
 825
 826                 break;
 827             }
 828
 829         default:
 830             D(bug("[fat] got unknown packet type %ld\n", pkt->dp_Type));
 831
 832             err = ERROR_ACTION_NOT_KNOWN;
 833         }
 834
 835         if (pkt != NULL)
 836         {
 837             pkt->dp_Res1 = res;
 838             pkt->dp_Res2 = err;
 839             if (!glob->quit)
 840             {
 841                 D(bug("[fat] replying to packet: result 0x%lx, error %ld\n",
 842                     res, err));
 843                 ReplyPacket(pkt, SysBase);
 844             }
 845         }
 846
 847         RestartTimer(glob);
 848     }
 849 }
 850
 851 #undef SysBase
 852
 853 void ReplyPacket(struct DosPacket *dp, struct ExecBase *SysBase)
 854 {
 855     struct MsgPort *rp;
 856     struct Message *mn;
 857
 858     rp = dp->dp_Port;
 859     mn = dp->dp_Link;
 860     dp->dp_Port = &((struct Process *)FindTask(NULL))->pr_MsgPort;
 861     PutMsg(rp, mn);
 862 }