source3/modules/vfs_catia.c

   1 /*
   2  * Catia VFS module
   3  *
   4  * Implement a fixed mapping of forbidden NT characters in filenames that are
   5  * used a lot by the CAD package Catia.
   6  *
   7  * Catia V4 on AIX uses characters like "<*$ a *lot*, all forbidden under
   8  * Windows...
   9  *
  10  * Copyright (C) Volker Lendecke, 2005
  11  * Copyright (C) Aravind Srinivasan, 2009
  12  * Copyright (C) Guenter Kukkukk, 2013
  13  * Copyright (C) Ralph Boehme, 2017
  14  *
  15  * This program is free software; you can redistribute it and/or modify
  16  * it under the terms of the GNU General Public License as published by
  17  * the Free Software Foundation; either version 3 of the License, or
  18  * (at your option) any later version.
  19  *
  20  * This program is distributed in the hope that it will be useful,
  21  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  22  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  23  * GNU General Public License for more details.
  24  *
  25  * You should have received a copy of the GNU General Public License
  26  * along with this program; if not, see <http://www.gnu.org/licenses/>.
  27  */
  28
  29
  30 #include "includes.h"
  31 #include "smbd/smbd.h"
  32 #include "lib/util/tevent_unix.h"
  33 #include "lib/util/tevent_ntstatus.h"
  34
  35 static int vfs_catia_debug_level = DBGC_VFS;
  36
  37 #undef DBGC_CLASS
  38 #define DBGC_CLASS vfs_catia_debug_level
  39
  40 #define GLOBAL_SNUM     0xFFFFFFF
  41 #define MAP_SIZE        0xFF
  42 #define MAP_NUM         0x101 /* max unicode charval / MAP_SIZE */
  43 #define T_OFFSET(_v_)   ((_v_ % MAP_SIZE))
  44 #define T_START(_v_)    (((_v_ / MAP_SIZE) * MAP_SIZE))
  45 #define T_PICK(_v_)     ((_v_ / MAP_SIZE))
  46
  47 struct char_mappings {
  48         smb_ucs2_t entry[MAP_SIZE][2];
  49 };
  50
  51 struct share_mapping_entry {
  52         int snum;
  53         struct share_mapping_entry *next;
  54         struct char_mappings **mappings;
  55 };
  56
  57 struct catia_cache {
  58         bool is_fsp_ext;
  59         const struct catia_cache * const *busy;
  60         char *orig_fname;
  61         char *fname;
  62         char *orig_base_fname;
  63         char *base_fname;
  64 };
  65
  66 struct share_mapping_entry *srt_head = NULL;
  67
  68 static bool build_table(struct char_mappings **cmaps, int value)
  69 {
  70         int i;
  71         int start = T_START(value);
  72
  73         (*cmaps) = talloc_zero(NULL, struct char_mappings);
  74
  75         if (!*cmaps)
  76                 return False;
  77
  78         for (i = 0; i < MAP_SIZE;i++) {
  79                 (*cmaps)->entry[i][vfs_translate_to_unix] = start + i;
  80                 (*cmaps)->entry[i][vfs_translate_to_windows] = start + i;
  81         }
  82
  83         return True;
  84 }
  85
  86 static void set_tables(struct char_mappings **cmaps,
  87                        long unix_map,
  88                        long windows_map)
  89 {
  90         int i;
  91
  92         /* set unix -> windows */
  93         i = T_OFFSET(unix_map);
  94         cmaps[T_PICK(unix_map)]->entry[i][vfs_translate_to_windows] = windows_map;
  95
  96         /* set windows -> unix */
  97         i = T_OFFSET(windows_map);
  98         cmaps[T_PICK(windows_map)]->entry[i][vfs_translate_to_unix] = unix_map;
  99 }
 100
 101 static bool build_ranges(struct char_mappings **cmaps,
 102                          long unix_map,
 103                          long windows_map)
 104 {
 105
 106         if (!cmaps[T_PICK(unix_map)]) {
 107                 if (!build_table(&cmaps[T_PICK(unix_map)], unix_map))
 108                         return False;
 109         }
 110
 111         if (!cmaps[T_PICK(windows_map)]) {
 112                 if (!build_table(&cmaps[T_PICK(windows_map)], windows_map))
 113                         return False;
 114         }
 115
 116         set_tables(cmaps, unix_map, windows_map);
 117
 118         return True;
 119 }
 120
 121 static struct share_mapping_entry *get_srt(connection_struct *conn,
 122                                            struct share_mapping_entry **global)
 123 {
 124         struct share_mapping_entry *share;
 125
 126         for (share = srt_head; share != NULL; share = share->next) {
 127                 if (share->snum == GLOBAL_SNUM)
 128                         (*global) = share;
 129
 130                 if (share->snum == SNUM(conn))
 131                         return share;
 132         }
 133
 134         return share;
 135 }
 136
 137 static struct share_mapping_entry *add_srt(int snum, const char **mappings)
 138 {
 139
 140         char *tmp;
 141         fstring mapping;
 142         int i;
 143         long unix_map, windows_map;
 144         struct share_mapping_entry *ret = NULL;
 145
 146         ret = (struct share_mapping_entry *)
 147                 TALLOC_ZERO(NULL, sizeof(struct share_mapping_entry) +
 148                 (mappings ? (MAP_NUM * sizeof(struct char_mappings *)) : 0));
 149
 150         if (!ret)
 151                 return ret;
 152
 153         ret->snum = snum;
 154
 155         ret->next = srt_head;
 156         srt_head = ret;
 157
 158         if (mappings) {
 159                 ret->mappings = (struct char_mappings**) ((unsigned char*) ret +
 160                     sizeof(struct share_mapping_entry));
 161                 memset(ret->mappings, 0,
 162                     MAP_NUM * sizeof(struct char_mappings *));
 163         } else {
 164                 ret->mappings = NULL;
 165                 return ret;
 166         }
 167
 168         /*
 169          * catia mappings are of the form :
 170          * UNIX char (in 0xnn hex) : WINDOWS char (in 0xnn hex)
 171          *
 172          * multiple mappings are comma separated in smb.conf
 173          */
 174         for (i=0;mappings[i];i++) {
 175                 fstrcpy(mapping, mappings[i]);
 176                 unix_map = strtol(mapping, &tmp, 16);
 177                 if (unix_map == 0 && errno == EINVAL) {
 178                         DEBUG(0, ("INVALID CATIA MAPPINGS - %s\n", mapping));
 179                         continue;
 180                 }
 181                 windows_map = strtol(++tmp, NULL, 16);
 182                 if (windows_map == 0 && errno == EINVAL) {
 183                         DEBUG(0, ("INVALID CATIA MAPPINGS - %s\n", mapping));
 184                         continue;
 185                 }
 186
 187                 if (!build_ranges(ret->mappings, unix_map, windows_map)) {
 188                         DEBUG(0, ("TABLE ERROR - CATIA MAPPINGS - %s\n", mapping));
 189                         continue;
 190                 }
 191         }
 192
 193         return ret;
 194 }
 195
 196 static bool init_mappings(connection_struct *conn,
 197                           struct share_mapping_entry **selected_out)
 198 {
 199         const char **mappings = NULL;
 200         struct share_mapping_entry *share_level = NULL;
 201         struct share_mapping_entry *global = NULL;
 202
 203         /* check srt cache */
 204         share_level = get_srt(conn, &global);
 205         if (share_level) {
 206                 *selected_out = share_level;
 207                 return (share_level->mappings != NULL);
 208         }
 209
 210         /* see if we have a global setting */
 211         if (!global) {
 212                 /* global setting */
 213                 mappings = lp_parm_string_list(-1, "catia", "mappings", NULL);
 214                 global = add_srt(GLOBAL_SNUM, mappings);
 215         }
 216
 217         /* no global setting - what about share level ? */
 218         mappings = lp_parm_string_list(SNUM(conn), "catia", "mappings", NULL);
 219         share_level = add_srt(SNUM(conn), mappings);
 220
 221         if (share_level->mappings) {
 222                 (*selected_out) = share_level;
 223                 return True;
 224         }
 225         if (global->mappings) {
 226                 share_level->mappings = global->mappings;
 227                 (*selected_out) = share_level;
 228                 return True;
 229         }
 230
 231         return False;
 232 }
 233
 234 static NTSTATUS catia_string_replace_allocate(connection_struct *conn,
 235                                               const char *name_in,
 236                                               char **mapped_name,
 237                                         enum vfs_translate_direction direction)
 238 {
 239         static smb_ucs2_t *tmpbuf = NULL;
 240         smb_ucs2_t *ptr;
 241         struct share_mapping_entry *selected;
 242         struct char_mappings *map = NULL;
 243         size_t converted_size;
 244         TALLOC_CTX *ctx = talloc_tos();
 245
 246         if (!init_mappings(conn, &selected)) {
 247                 /* No mappings found. Just use the old name */
 248                 *mapped_name = talloc_strdup(NULL, name_in);
 249                 if (!*mapped_name) {
 250                         errno = ENOMEM;
 251                         return NT_STATUS_NO_MEMORY;
 252                 }
 253                 return NT_STATUS_OK;
 254         }
 255
 256         if ((push_ucs2_talloc(ctx, &tmpbuf, name_in,
 257                               &converted_size)) == false) {
 258                 return map_nt_error_from_unix(errno);
 259         }
 260         ptr = tmpbuf;
 261         for(;*ptr;ptr++) {
 262                 if (*ptr == 0)
 263                         break;
 264                 map = selected->mappings[T_PICK((*ptr))];
 265
 266                 /* nothing to do */
 267                 if (!map)
 268                         continue;
 269
 270                 *ptr = map->entry[T_OFFSET((*ptr))][direction];
 271         }
 272
 273         if ((pull_ucs2_talloc(ctx, mapped_name, tmpbuf,
 274                               &converted_size)) == false) {
 275                 TALLOC_FREE(tmpbuf);
 276                 return map_nt_error_from_unix(errno);
 277         }
 278         TALLOC_FREE(tmpbuf);
 279         return NT_STATUS_OK;
 280 }
 281
 282 static DIR *catia_opendir(vfs_handle_struct *handle,
 283                         const struct smb_filename *smb_fname,
 284                         const char *mask,
 285                         uint32_t attr)
 286 {
 287         char *name_mapped = NULL;
 288         NTSTATUS status;
 289         DIR *ret;
 290         struct smb_filename *mapped_smb_fname = NULL;
 291
 292         status = catia_string_replace_allocate(handle->conn,
 293                                 smb_fname->base_name,
 294                                 &name_mapped,
 295                                 vfs_translate_to_unix);
 296         if (!NT_STATUS_IS_OK(status)) {
 297                 errno = map_errno_from_nt_status(status);
 298                 return NULL;
 299         }
 300
 301         mapped_smb_fname = synthetic_smb_fname(talloc_tos(),
 302                                 name_mapped,
 303                                 NULL,
 304                                 NULL,
 305                                 smb_fname->flags);
 306         if (mapped_smb_fname == NULL) {
 307                 TALLOC_FREE(mapped_smb_fname);
 308                 errno = ENOMEM;
 309                 return NULL;
 310         }
 311
 312         ret = SMB_VFS_NEXT_OPENDIR(handle, mapped_smb_fname, mask, attr);
 313
 314         TALLOC_FREE(name_mapped);
 315         TALLOC_FREE(mapped_smb_fname);
 316
 317         return ret;
 318 }
 319
 320 /*
 321  * TRANSLATE_NAME call which converts the given name to
 322  * "WINDOWS displayable" name
 323  */
 324 static NTSTATUS catia_translate_name(struct vfs_handle_struct *handle,
 325                                      const char *orig_name,
 326                                      enum vfs_translate_direction direction,
 327                                      TALLOC_CTX *mem_ctx,
 328                                      char **pmapped_name)
 329 {
 330         char *name = NULL;
 331         char *mapped_name;
 332         NTSTATUS status, ret;
 333
 334         /*
 335          * Copy the supplied name and free the memory for mapped_name,
 336          * already allocated by the caller.
 337          * We will be allocating new memory for mapped_name in
 338          * catia_string_replace_allocate
 339          */
 340         name = talloc_strdup(talloc_tos(), orig_name);
 341         if (!name) {
 342                 errno = ENOMEM;
 343                 return NT_STATUS_NO_MEMORY;
 344         }
 345         status = catia_string_replace_allocate(handle->conn, name,
 346                         &mapped_name, direction);
 347
 348         TALLOC_FREE(name);
 349         if (!NT_STATUS_IS_OK(status)) {
 350                 return status;
 351         }
 352
 353         ret = SMB_VFS_NEXT_TRANSLATE_NAME(handle, mapped_name, direction,
 354                                           mem_ctx, pmapped_name);
 355
 356         if (NT_STATUS_EQUAL(ret, NT_STATUS_NONE_MAPPED)) {
 357                 *pmapped_name = talloc_move(mem_ctx, &mapped_name);
 358                 /* we need to return the former translation result here */
 359                 ret = status;
 360         } else {
 361                 TALLOC_FREE(mapped_name);
 362         }
 363
 364         return ret;
 365 }
 366
 367 #define CATIA_DEBUG_CC(lvl, cc, fsp) \
 368         catia_debug_cc((lvl), (cc), (fsp), __location__);
 369
 370 static void catia_debug_cc(int lvl,
 371                            struct catia_cache *cc,
 372                            files_struct *fsp,
 373                            const char *location)
 374 {
 375         DEBUG(lvl, ("%s: cc [0x%p] cc->busy [0x%p] "
 376                     "is_fsp_ext [%s] "
 377                     "fsp [0x%p] fsp name [%s] "
 378                     "orig_fname [%s] "
 379                     "fname [%s] "
 380                     "orig_base_fname [%s] "
 381                     "base_fname [%s]\n",
 382                     location,
 383                     cc, cc->busy,
 384                     cc->is_fsp_ext ? "yes" : "no",
 385                     fsp, fsp_str_dbg(fsp),
 386                     cc->orig_fname, cc->fname,
 387                     cc->orig_base_fname, cc->base_fname));
 388 }
 389
 390 static void catia_free_cc(struct catia_cache **_cc,
 391                           vfs_handle_struct *handle,
 392                           files_struct *fsp)
 393 {
 394         struct catia_cache *cc = *_cc;
 395
 396         if (cc->is_fsp_ext) {
 397                 VFS_REMOVE_FSP_EXTENSION(handle, fsp);
 398                 cc = NULL;
 399         } else {
 400                 TALLOC_FREE(cc);
 401         }
 402
 403         *_cc = NULL;
 404 }
 405
 406 static struct catia_cache *catia_validate_and_apply_cc(
 407                                        vfs_handle_struct *handle,
 408                                        files_struct *fsp,
 409                                        const struct catia_cache * const *busy,
 410                                        bool *make_tmp_cache)
 411 {
 412         struct catia_cache *cc = NULL;
 413
 414         *make_tmp_cache = false;
 415
 416         cc = (struct catia_cache *)VFS_FETCH_FSP_EXTENSION(handle, fsp);
 417         if (cc == NULL) {
 418                 return NULL;
 419         }
 420
 421         if (cc->busy != NULL) {
 422                 if (cc->busy == busy) {
 423                         /* This should never happen */
 424                         CATIA_DEBUG_CC(0, cc, fsp);
 425                         smb_panic(__location__);
 426                 }
 427
 428                 /*
 429                  * Recursion. Validate names, the names in the fsp's should be
 430                  * the translated names we had set.
 431                  */
 432
 433                 if ((cc->fname != fsp->fsp_name->base_name)
 434                     ||
 435                     ((fsp->base_fsp != NULL) &&
 436                      (cc->base_fname != fsp->base_fsp->fsp_name->base_name)))
 437                 {
 438                         CATIA_DEBUG_CC(10, cc, fsp);
 439
 440                         /*
 441                          * Names changed. Setting don't expose the cache on the
 442                          * fsp and ask the caller to create a temporary cache.
 443                          */
 444                         *make_tmp_cache = true;
 445                         return NULL;
 446                 }
 447
 448                 /*
 449                  * Ok, a validated cache while in a recursion, just let the
 450                  * caller detect that cc->busy is != busy and there's
 451                  * nothing else to do.
 452                  */
 453                 CATIA_DEBUG_CC(10, cc, fsp);
 454                 return cc;
 455         }
 456
 457         /* Not in a recursion */
 458
 459         if ((cc->orig_fname != fsp->fsp_name->base_name)
 460             ||
 461             ((fsp->base_fsp != NULL) &&
 462              (cc->orig_base_fname != fsp->base_fsp->fsp_name->base_name)))
 463         {
 464                 /*
 465                  * fsp names changed, this can happen in an rename op.
 466                  * Trigger recreation as a full fledged fsp extension.
 467                  */
 468
 469                 CATIA_DEBUG_CC(10, cc, fsp);
 470                 catia_free_cc(&cc, handle, fsp);
 471                 return NULL;
 472         }
 473
 474
 475         /*
 476          * Ok, we found a valid cache entry, no recursion. Just set translated
 477          * names from the cache and mark the cc as busy.
 478          */
 479         fsp->fsp_name->base_name = cc->fname;
 480         if (fsp->base_fsp != NULL) {
 481                 fsp->base_fsp->fsp_name->base_name = cc->base_fname;
 482         }
 483
 484         cc->busy = busy;
 485         CATIA_DEBUG_CC(10, cc, fsp);
 486         return cc;
 487 }
 488
 489 #define CATIA_FETCH_FSP_PRE_NEXT(mem_ctx, handle, fsp, _cc) \
 490         catia_fetch_fsp_pre_next((mem_ctx), (handle), (fsp), (_cc), __func__);
 491
 492 static int catia_fetch_fsp_pre_next(TALLOC_CTX *mem_ctx,
 493                                     vfs_handle_struct *handle,
 494                                     files_struct *fsp,
 495                                     struct catia_cache **_cc,
 496                                     const char *function)
 497 {
 498         const struct catia_cache * const *busy =
 499                 (const struct catia_cache * const *)_cc;
 500         struct catia_cache *cc = NULL;
 501         NTSTATUS status;
 502         bool make_tmp_cache = false;
 503
 504         *_cc = NULL;
 505
 506         DBG_DEBUG("Called from [%s]\n", function);
 507
 508         cc = catia_validate_and_apply_cc(handle,
 509                                          fsp,
 510                                          busy,
 511                                          &make_tmp_cache);
 512         if (cc != NULL) {
 513                 if (cc->busy != busy) {
 514                         return 0;
 515                 }
 516                 *_cc = cc;
 517                 return 0;
 518         }
 519
 520         if (!make_tmp_cache) {
 521                 cc = (struct catia_cache *)VFS_ADD_FSP_EXTENSION(
 522                         handle, fsp, struct catia_cache, NULL);
 523                 if (cc == NULL) {
 524                         return -1;
 525                 }
 526                 *cc = (struct catia_cache) {
 527                         .is_fsp_ext = true,
 528                 };
 529
 530                 mem_ctx = VFS_MEMCTX_FSP_EXTENSION(handle, fsp);
 531                 if (mem_ctx == NULL) {
 532                         DBG_ERR("VFS_MEMCTX_FSP_EXTENSION failed\n");
 533                         catia_free_cc(&cc, handle, fsp);
 534                         return -1;
 535                 }
 536         } else {
 537                 cc = talloc_zero(mem_ctx, struct catia_cache);
 538                 if (cc == NULL) {
 539                         return -1;
 540                 }
 541                 mem_ctx = cc;
 542         }
 543
 544
 545         status = catia_string_replace_allocate(handle->conn,
 546                                                fsp->fsp_name->base_name,
 547                                                &cc->fname,
 548                                                vfs_translate_to_unix);
 549         if (!NT_STATUS_IS_OK(status)) {
 550                 catia_free_cc(&cc, handle, fsp);
 551                 errno = map_errno_from_nt_status(status);
 552                 return -1;
 553         }
 554         talloc_steal(mem_ctx, cc->fname);
 555
 556         if (fsp->base_fsp != NULL) {
 557                 status = catia_string_replace_allocate(
 558                         handle->conn,
 559                         fsp->base_fsp->fsp_name->base_name,
 560                         &cc->base_fname,
 561                         vfs_translate_to_unix);
 562                 if (!NT_STATUS_IS_OK(status)) {
 563                         catia_free_cc(&cc, handle, fsp);
 564                         errno = map_errno_from_nt_status(status);
 565                         return -1;
 566                 }
 567                 talloc_steal(mem_ctx, cc->base_fname);
 568         }
 569
 570         cc->orig_fname = fsp->fsp_name->base_name;
 571         fsp->fsp_name->base_name = cc->fname;
 572
 573         if (fsp->base_fsp != NULL) {
 574                 cc->orig_base_fname = fsp->base_fsp->fsp_name->base_name;
 575                 fsp->base_fsp->fsp_name->base_name = cc->base_fname;
 576         }
 577
 578         cc->busy = busy;
 579         CATIA_DEBUG_CC(10, cc, fsp);
 580
 581         *_cc = cc;
 582
 583         return 0;
 584 }
 585
 586 #define CATIA_FETCH_FSP_POST_NEXT(_cc, fsp) do { \
 587         int saved_errno = errno; \
 588         catia_fetch_fsp_post_next((_cc), (fsp), __func__); \
 589         errno = saved_errno; \
 590 } while(0)
 591
 592 static void catia_fetch_fsp_post_next(struct catia_cache **_cc,
 593                                       files_struct *fsp,
 594                                       const char *function)
 595 {
 596         const struct catia_cache * const *busy =
 597                 (const struct catia_cache * const *)_cc;
 598         struct catia_cache *cc = *_cc;
 599
 600         DBG_DEBUG("Called from [%s]\n", function);
 601
 602         if (cc == NULL) {
 603                 /*
 604                  * This can happen when recursing in the VFS on the fsp when the
 605                  * pre_next func noticed the recursion and set out cc pointer to
 606                  * NULL.
 607                  */
 608                 return;
 609         }
 610
 611         if (cc->busy != busy) {
 612                 CATIA_DEBUG_CC(0, cc, fsp);
 613                 smb_panic(__location__);
 614                 return;
 615         }
 616
 617         cc->busy = NULL;
 618         *_cc = NULL;
 619
 620         fsp->fsp_name->base_name = cc->orig_fname;
 621         if (fsp->base_fsp != NULL) {
 622                 fsp->base_fsp->fsp_name->base_name = cc->orig_base_fname;
 623         }
 624
 625         CATIA_DEBUG_CC(10, cc, fsp);
 626
 627         if (!cc->is_fsp_ext) {
 628                 TALLOC_FREE(cc);
 629         }
 630
 631         return;
 632 }
 633
 634 static int catia_open(vfs_handle_struct *handle,
 635                       struct smb_filename *smb_fname,
 636                       files_struct *fsp,
 637                       int flags,
 638                       mode_t mode)
 639 {
 640         struct catia_cache *cc = NULL;
 641         char *orig_smb_fname = smb_fname->base_name;
 642         char *mapped_smb_fname = NULL;
 643         NTSTATUS status;
 644         int ret;
 645
 646         status = catia_string_replace_allocate(handle->conn,
 647                                                smb_fname->base_name,
 648                                                &mapped_smb_fname,
 649                                                vfs_translate_to_unix);
 650         if (!NT_STATUS_IS_OK(status)) {
 651                 return -1;
 652         }
 653
 654         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
 655         if (ret != 0) {
 656                 TALLOC_FREE(mapped_smb_fname);
 657                 return ret;
 658         }
 659
 660         smb_fname->base_name = mapped_smb_fname;
 661         ret = SMB_VFS_NEXT_OPEN(handle, smb_fname, fsp, flags, mode);
 662         smb_fname->base_name = orig_smb_fname;
 663
 664         TALLOC_FREE(mapped_smb_fname);
 665         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
 666
 667         return ret;
 668 }
 669
 670 static int catia_rename(vfs_handle_struct *handle,
 671                         const struct smb_filename *smb_fname_src,
 672                         const struct smb_filename *smb_fname_dst)
 673 {
 674         TALLOC_CTX *ctx = talloc_tos();
 675         struct smb_filename *smb_fname_src_tmp = NULL;
 676         struct smb_filename *smb_fname_dst_tmp = NULL;
 677         char *src_name_mapped = NULL;
 678         char *dst_name_mapped = NULL;
 679         NTSTATUS status;
 680         int ret = -1;
 681
 682         status = catia_string_replace_allocate(handle->conn,
 683                                 smb_fname_src->base_name,
 684                                 &src_name_mapped, vfs_translate_to_unix);
 685         if (!NT_STATUS_IS_OK(status)) {
 686                 errno = map_errno_from_nt_status(status);
 687                 return -1;
 688         }
 689
 690         status = catia_string_replace_allocate(handle->conn,
 691                                 smb_fname_dst->base_name,
 692                                 &dst_name_mapped, vfs_translate_to_unix);
 693         if (!NT_STATUS_IS_OK(status)) {
 694                 errno = map_errno_from_nt_status(status);
 695                 return -1;
 696         }
 697
 698         /* Setup temporary smb_filename structs. */
 699         smb_fname_src_tmp = cp_smb_filename(ctx, smb_fname_src);
 700         if (smb_fname_src_tmp == NULL) {
 701                 errno = ENOMEM;
 702                 goto out;
 703         }
 704
 705         smb_fname_dst_tmp = cp_smb_filename(ctx, smb_fname_dst);
 706         if (smb_fname_dst_tmp == NULL) {
 707                 errno = ENOMEM;
 708                 goto out;
 709         }
 710
 711         smb_fname_src_tmp->base_name = src_name_mapped;
 712         smb_fname_dst_tmp->base_name = dst_name_mapped;
 713         DEBUG(10, ("converted old name: %s\n",
 714                                 smb_fname_str_dbg(smb_fname_src_tmp)));
 715         DEBUG(10, ("converted new name: %s\n",
 716                                 smb_fname_str_dbg(smb_fname_dst_tmp)));
 717
 718         ret = SMB_VFS_NEXT_RENAME(handle, smb_fname_src_tmp,
 719                         smb_fname_dst_tmp);
 720 out:
 721         TALLOC_FREE(src_name_mapped);
 722         TALLOC_FREE(dst_name_mapped);
 723         TALLOC_FREE(smb_fname_src_tmp);
 724         TALLOC_FREE(smb_fname_dst_tmp);
 725         return ret;
 726 }
 727
 728 static int catia_stat(vfs_handle_struct *handle,
 729                       struct smb_filename *smb_fname)
 730 {
 731         char *name = NULL;
 732         char *tmp_base_name;
 733         int ret;
 734         NTSTATUS status;
 735
 736         status = catia_string_replace_allocate(handle->conn,
 737                                 smb_fname->base_name,
 738                                 &name, vfs_translate_to_unix);
 739         if (!NT_STATUS_IS_OK(status)) {
 740                 errno = map_errno_from_nt_status(status);
 741                 return -1;
 742         }
 743
 744         tmp_base_name = smb_fname->base_name;
 745         smb_fname->base_name = name;
 746
 747         ret = SMB_VFS_NEXT_STAT(handle, smb_fname);
 748         smb_fname->base_name = tmp_base_name;
 749
 750         TALLOC_FREE(name);
 751         return ret;
 752 }
 753
 754 static int catia_lstat(vfs_handle_struct *handle,
 755                        struct smb_filename *smb_fname)
 756 {
 757         char *name = NULL;
 758         char *tmp_base_name;
 759         int ret;
 760         NTSTATUS status;
 761
 762         status = catia_string_replace_allocate(handle->conn,
 763                                 smb_fname->base_name,
 764                                 &name, vfs_translate_to_unix);
 765         if (!NT_STATUS_IS_OK(status)) {
 766                 errno = map_errno_from_nt_status(status);
 767                 return -1;
 768         }
 769
 770         tmp_base_name = smb_fname->base_name;
 771         smb_fname->base_name = name;
 772
 773         ret = SMB_VFS_NEXT_LSTAT(handle, smb_fname);
 774         smb_fname->base_name = tmp_base_name;
 775         TALLOC_FREE(name);
 776
 777         return ret;
 778 }
 779
 780 static int catia_unlink(vfs_handle_struct *handle,
 781                         const struct smb_filename *smb_fname)
 782 {
 783         struct smb_filename *smb_fname_tmp = NULL;
 784         char *name = NULL;
 785         NTSTATUS status;
 786         int ret;
 787
 788         status = catia_string_replace_allocate(handle->conn,
 789                                         smb_fname->base_name,
 790                                         &name, vfs_translate_to_unix);
 791         if (!NT_STATUS_IS_OK(status)) {
 792                 errno = map_errno_from_nt_status(status);
 793                 return -1;
 794         }
 795
 796         /* Setup temporary smb_filename structs. */
 797         smb_fname_tmp = cp_smb_filename(talloc_tos(), smb_fname);
 798         if (smb_fname_tmp == NULL) {
 799                 errno = ENOMEM;
 800                 return -1;
 801         }
 802
 803         smb_fname_tmp->base_name = name;
 804         ret = SMB_VFS_NEXT_UNLINK(handle, smb_fname_tmp);
 805         TALLOC_FREE(smb_fname_tmp);
 806         TALLOC_FREE(name);
 807
 808         return ret;
 809 }
 810
 811 static int catia_chown(vfs_handle_struct *handle,
 812                        const struct smb_filename *smb_fname,
 813                        uid_t uid,
 814                        gid_t gid)
 815 {
 816         char *name = NULL;
 817         NTSTATUS status;
 818         int ret;
 819         int saved_errno;
 820         struct smb_filename *catia_smb_fname = NULL;
 821
 822         status = catia_string_replace_allocate(handle->conn,
 823                                         smb_fname->base_name,
 824                                         &name,
 825                                         vfs_translate_to_unix);
 826         if (!NT_STATUS_IS_OK(status)) {
 827                 errno = map_errno_from_nt_status(status);
 828                 return -1;
 829         }
 830         catia_smb_fname = synthetic_smb_fname(talloc_tos(),
 831                                         name,
 832                                         NULL,
 833                                         NULL,
 834                                         smb_fname->flags);
 835         if (catia_smb_fname == NULL) {
 836                 TALLOC_FREE(name);
 837                 errno = ENOMEM;
 838                 return -1;
 839         }
 840
 841         ret = SMB_VFS_NEXT_CHOWN(handle, catia_smb_fname, uid, gid);
 842         saved_errno = errno;
 843         TALLOC_FREE(name);
 844         TALLOC_FREE(catia_smb_fname);
 845         errno = saved_errno;
 846         return ret;
 847 }
 848
 849 static int catia_lchown(vfs_handle_struct *handle,
 850                         const struct smb_filename *smb_fname,
 851                         uid_t uid,
 852                         gid_t gid)
 853 {
 854         char *name = NULL;
 855         NTSTATUS status;
 856         int ret;
 857         int saved_errno;
 858         struct smb_filename *catia_smb_fname = NULL;
 859
 860         status = catia_string_replace_allocate(handle->conn,
 861                                         smb_fname->base_name,
 862                                         &name,
 863                                         vfs_translate_to_unix);
 864         if (!NT_STATUS_IS_OK(status)) {
 865                 errno = map_errno_from_nt_status(status);
 866                 return -1;
 867         }
 868         catia_smb_fname = synthetic_smb_fname(talloc_tos(),
 869                                         name,
 870                                         NULL,
 871                                         NULL,
 872                                         smb_fname->flags);
 873         if (catia_smb_fname == NULL) {
 874                 TALLOC_FREE(name);
 875                 errno = ENOMEM;
 876                 return -1;
 877         }
 878
 879         ret = SMB_VFS_NEXT_LCHOWN(handle, catia_smb_fname, uid, gid);
 880         saved_errno = errno;
 881         TALLOC_FREE(name);
 882         TALLOC_FREE(catia_smb_fname);
 883         errno = saved_errno;
 884         return ret;
 885 }
 886
 887 static int catia_chmod(vfs_handle_struct *handle,
 888                         const struct smb_filename *smb_fname,
 889                         mode_t mode)
 890 {
 891         char *name = NULL;
 892         NTSTATUS status;
 893         int ret;
 894         int saved_errno;
 895         struct smb_filename *catia_smb_fname = NULL;
 896
 897         status = catia_string_replace_allocate(handle->conn,
 898                                         smb_fname->base_name,
 899                                         &name,
 900                                         vfs_translate_to_unix);
 901         if (!NT_STATUS_IS_OK(status)) {
 902                 errno = map_errno_from_nt_status(status);
 903                 return -1;
 904         }
 905         catia_smb_fname = synthetic_smb_fname(talloc_tos(),
 906                                         name,
 907                                         NULL,
 908                                         NULL,
 909                                         smb_fname->flags);
 910         if (catia_smb_fname == NULL) {
 911                 TALLOC_FREE(name);
 912                 errno = ENOMEM;
 913                 return -1;
 914         }
 915
 916         ret = SMB_VFS_NEXT_CHMOD(handle, catia_smb_fname, mode);
 917         saved_errno = errno;
 918         TALLOC_FREE(name);
 919         TALLOC_FREE(catia_smb_fname);
 920         errno = saved_errno;
 921         return ret;
 922 }
 923
 924 static int catia_rmdir(vfs_handle_struct *handle,
 925                        const struct smb_filename *smb_fname)
 926 {
 927         char *name = NULL;
 928         NTSTATUS status;
 929         int ret;
 930         struct smb_filename *catia_smb_fname = NULL;
 931
 932         status = catia_string_replace_allocate(handle->conn,
 933                                 smb_fname->base_name,
 934                                 &name,
 935                                 vfs_translate_to_unix);
 936         if (!NT_STATUS_IS_OK(status)) {
 937                 errno = map_errno_from_nt_status(status);
 938                 return -1;
 939         }
 940         catia_smb_fname = synthetic_smb_fname(talloc_tos(),
 941                                         name,
 942                                         NULL,
 943                                         NULL,
 944                                         smb_fname->flags);
 945         if (catia_smb_fname == NULL) {
 946                 TALLOC_FREE(name);
 947                 errno = ENOMEM;
 948                 return -1;
 949         }
 950
 951         ret = SMB_VFS_NEXT_RMDIR(handle, catia_smb_fname);
 952         TALLOC_FREE(name);
 953         TALLOC_FREE(catia_smb_fname);
 954
 955         return ret;
 956 }
 957
 958 static int catia_mkdir(vfs_handle_struct *handle,
 959                        const struct smb_filename *smb_fname,
 960                        mode_t mode)
 961 {
 962         char *name = NULL;
 963         NTSTATUS status;
 964         int ret;
 965         struct smb_filename *catia_smb_fname = NULL;
 966
 967         status = catia_string_replace_allocate(handle->conn,
 968                                 smb_fname->base_name,
 969                                 &name,
 970                                 vfs_translate_to_unix);
 971         if (!NT_STATUS_IS_OK(status)) {
 972                 errno = map_errno_from_nt_status(status);
 973                 return -1;
 974         }
 975         catia_smb_fname = synthetic_smb_fname(talloc_tos(),
 976                                         name,
 977                                         NULL,
 978                                         NULL,
 979                                         smb_fname->flags);
 980         if (catia_smb_fname == NULL) {
 981                 TALLOC_FREE(name);
 982                 errno = ENOMEM;
 983                 return -1;
 984         }
 985
 986         ret = SMB_VFS_NEXT_MKDIR(handle, catia_smb_fname, mode);
 987         TALLOC_FREE(name);
 988         TALLOC_FREE(catia_smb_fname);
 989
 990         return ret;
 991 }
 992
 993 static int catia_chdir(vfs_handle_struct *handle,
 994                        const char *path)
 995 {
 996         char *name = NULL;
 997         NTSTATUS status;
 998         int ret;
 999
1000         status = catia_string_replace_allocate(handle->conn, path,
1001                                         &name, vfs_translate_to_unix);
1002         if (!NT_STATUS_IS_OK(status)) {
1003                 errno = map_errno_from_nt_status(status);
1004                 return -1;
1005         }
1006
1007         ret = SMB_VFS_NEXT_CHDIR(handle, name);
1008         TALLOC_FREE(name);
1009
1010         return ret;
1011 }
1012
1013 static int catia_ntimes(vfs_handle_struct *handle,
1014                         const struct smb_filename *smb_fname,
1015                         struct smb_file_time *ft)
1016 {
1017         struct smb_filename *smb_fname_tmp = NULL;
1018         char *name = NULL;
1019         NTSTATUS status;
1020         int ret;
1021
1022         status = catia_string_replace_allocate(handle->conn,
1023                                 smb_fname->base_name,
1024                                 &name, vfs_translate_to_unix);
1025         if (!NT_STATUS_IS_OK(status)) {
1026                 errno = map_errno_from_nt_status(status);
1027                 return -1;
1028         }
1029
1030         smb_fname_tmp = cp_smb_filename(talloc_tos(), smb_fname);
1031         if (smb_fname_tmp == NULL) {
1032                 errno = ENOMEM;
1033                 return -1;
1034         }
1035
1036         smb_fname_tmp->base_name = name;
1037         ret = SMB_VFS_NEXT_NTIMES(handle, smb_fname_tmp, ft);
1038         TALLOC_FREE(name);
1039         TALLOC_FREE(smb_fname_tmp);
1040
1041         return ret;
1042 }
1043
1044 static char *
1045 catia_realpath(vfs_handle_struct *handle, const char *path)
1046 {
1047         char *mapped_name = NULL;
1048         NTSTATUS status;
1049         char *ret = NULL;
1050
1051         status = catia_string_replace_allocate(handle->conn, path,
1052                                         &mapped_name, vfs_translate_to_unix);
1053         if (!NT_STATUS_IS_OK(status)) {
1054                 errno = map_errno_from_nt_status(status);
1055                 return NULL;
1056         }
1057
1058         ret = SMB_VFS_NEXT_REALPATH(handle, mapped_name);
1059         TALLOC_FREE(mapped_name);
1060
1061         return ret;
1062 }
1063
1064 static int catia_chflags(struct vfs_handle_struct *handle,
1065                          const char *path, unsigned int flags)
1066 {
1067         char *mapped_name = NULL;
1068         NTSTATUS status;
1069         int ret;
1070
1071         status = catia_string_replace_allocate(handle->conn, path,
1072                                         &mapped_name, vfs_translate_to_unix);
1073         if (!NT_STATUS_IS_OK(status)) {
1074                 errno = map_errno_from_nt_status(status);
1075                 return -1;
1076         }
1077
1078         ret = SMB_VFS_NEXT_CHFLAGS(handle, mapped_name, flags);
1079         TALLOC_FREE(mapped_name);
1080
1081         return ret;
1082 }
1083
1084 static NTSTATUS
1085 catia_streaminfo(struct vfs_handle_struct *handle,
1086                  struct files_struct *fsp,
1087                  const struct smb_filename *smb_fname,
1088                  TALLOC_CTX *mem_ctx,
1089                  unsigned int *_num_streams,
1090                  struct stream_struct **_streams)
1091 {
1092         char *mapped_name = NULL;
1093         NTSTATUS status;
1094         unsigned int i;
1095         struct smb_filename *catia_smb_fname = NULL;
1096         unsigned int num_streams = 0;
1097         struct stream_struct *streams = NULL;
1098
1099         *_num_streams = 0;
1100         *_streams = NULL;
1101
1102         status = catia_string_replace_allocate(handle->conn,
1103                                 smb_fname->base_name,
1104                                 &mapped_name,
1105                                 vfs_translate_to_unix);
1106         if (!NT_STATUS_IS_OK(status)) {
1107                 errno = map_errno_from_nt_status(status);
1108                 return status;
1109         }
1110
1111         catia_smb_fname = synthetic_smb_fname(talloc_tos(),
1112                                         mapped_name,
1113                                         NULL,
1114                                         NULL,
1115                                         smb_fname->flags);
1116         if (catia_smb_fname == NULL) {
1117                 TALLOC_FREE(mapped_name);
1118                 return NT_STATUS_NO_MEMORY;
1119         }
1120
1121         status = SMB_VFS_NEXT_STREAMINFO(handle, fsp, catia_smb_fname,
1122                                          mem_ctx, &num_streams, &streams);
1123         TALLOC_FREE(mapped_name);
1124         TALLOC_FREE(catia_smb_fname);
1125         if (!NT_STATUS_IS_OK(status)) {
1126                 return status;
1127         }
1128
1129         /*
1130          * Translate stream names just like the base names
1131          */
1132         for (i = 0; i < num_streams; i++) {
1133                 /*
1134                  * Strip ":" prefix and ":$DATA" suffix to get a
1135                  * "pure" stream name and only translate that.
1136                  */
1137                 void *old_ptr = streams[i].name;
1138                 char *stream_name = streams[i].name + 1;
1139                 char *stream_type = strrchr_m(stream_name, ':');
1140
1141                 if (stream_type != NULL) {
1142                         *stream_type = '\0';
1143                         stream_type += 1;
1144                 }
1145
1146                 status = catia_string_replace_allocate(handle->conn, stream_name,
1147                                                        &mapped_name, vfs_translate_to_windows);
1148                 if (!NT_STATUS_IS_OK(status)) {
1149                         TALLOC_FREE(streams);
1150                         return status;
1151                 }
1152
1153                 if (stream_type != NULL) {
1154                         streams[i].name = talloc_asprintf(streams, ":%s:%s",
1155                                                           mapped_name, stream_type);
1156                 } else {
1157                         streams[i].name = talloc_asprintf(streams, ":%s",
1158                                                           mapped_name);
1159                 }
1160                 TALLOC_FREE(mapped_name);
1161                 TALLOC_FREE(old_ptr);
1162                 if (streams[i].name == NULL) {
1163                         TALLOC_FREE(streams);
1164                         return NT_STATUS_NO_MEMORY;
1165                 }
1166         }
1167
1168         *_num_streams = num_streams;
1169         *_streams = streams;
1170         return NT_STATUS_OK;
1171 }
1172
1173 static NTSTATUS
1174 catia_get_nt_acl(struct vfs_handle_struct *handle,
1175                  const struct smb_filename *smb_fname,
1176                  uint32_t security_info,
1177                  TALLOC_CTX *mem_ctx,
1178                  struct security_descriptor **ppdesc)
1179 {
1180         char *mapped_name = NULL;
1181         const char *path = smb_fname->base_name;
1182         struct smb_filename *mapped_smb_fname = NULL;
1183         NTSTATUS status;
1184
1185         status = catia_string_replace_allocate(handle->conn,
1186                                 path, &mapped_name, vfs_translate_to_unix);
1187         if (!NT_STATUS_IS_OK(status)) {
1188                 errno = map_errno_from_nt_status(status);
1189                 return status;
1190         }
1191         mapped_smb_fname = synthetic_smb_fname(talloc_tos(),
1192                                         mapped_name,
1193                                         NULL,
1194                                         NULL,
1195                                         smb_fname->flags);
1196         if (mapped_smb_fname == NULL) {
1197                 TALLOC_FREE(mapped_name);
1198                 return NT_STATUS_NO_MEMORY;
1199         }
1200
1201         status = SMB_VFS_NEXT_GET_NT_ACL(handle, mapped_smb_fname,
1202                                          security_info, mem_ctx, ppdesc);
1203         TALLOC_FREE(mapped_name);
1204         TALLOC_FREE(mapped_smb_fname);
1205
1206         return status;
1207 }
1208
1209 static int
1210 catia_chmod_acl(vfs_handle_struct *handle,
1211                 const struct smb_filename *smb_fname,
1212                 mode_t mode)
1213 {
1214         char *mapped_name = NULL;
1215         struct smb_filename *mapped_smb_fname = NULL;
1216         NTSTATUS status;
1217         int ret;
1218         int saved_errno;
1219
1220         status = catia_string_replace_allocate(handle->conn,
1221                                 smb_fname->base_name,
1222                                 &mapped_name,
1223                                 vfs_translate_to_unix);
1224         if (!NT_STATUS_IS_OK(status)) {
1225                 errno = map_errno_from_nt_status(status);
1226                 return -1;
1227         }
1228
1229         mapped_smb_fname = synthetic_smb_fname(talloc_tos(),
1230                                         mapped_name,
1231                                         NULL,
1232                                         NULL,
1233                                         smb_fname->flags);
1234         if (mapped_smb_fname == NULL) {
1235                 TALLOC_FREE(mapped_name);
1236                 errno = ENOMEM;
1237                 return -1;
1238         }
1239         ret = SMB_VFS_NEXT_CHMOD_ACL(handle, mapped_smb_fname, mode);
1240         saved_errno = errno;
1241         TALLOC_FREE(mapped_name);
1242         TALLOC_FREE(mapped_smb_fname);
1243         errno = saved_errno;
1244         return ret;
1245 }
1246
1247 static SMB_ACL_T
1248 catia_sys_acl_get_file(vfs_handle_struct *handle,
1249                         const struct smb_filename *smb_fname,
1250                         SMB_ACL_TYPE_T type,
1251                         TALLOC_CTX *mem_ctx)
1252 {
1253         char *mapped_name = NULL;
1254         struct smb_filename *mapped_smb_fname = NULL;
1255         NTSTATUS status;
1256         SMB_ACL_T ret;
1257         int saved_errno = 0;
1258
1259         status = catia_string_replace_allocate(handle->conn,
1260                                 smb_fname->base_name,
1261                                 &mapped_name,
1262                                 vfs_translate_to_unix);
1263         if (!NT_STATUS_IS_OK(status)) {
1264                 errno = map_errno_from_nt_status(status);
1265                 return (SMB_ACL_T)NULL;
1266         }
1267
1268         mapped_smb_fname = synthetic_smb_fname(talloc_tos(),
1269                                         mapped_name,
1270                                         NULL,
1271                                         NULL,
1272                                         smb_fname->flags);
1273         if (mapped_smb_fname == NULL) {
1274                 TALLOC_FREE(mapped_name);
1275                 errno = ENOMEM;
1276                 return (SMB_ACL_T)NULL;
1277         }
1278
1279         ret = SMB_VFS_NEXT_SYS_ACL_GET_FILE(handle, mapped_smb_fname,
1280                         type, mem_ctx);
1281         if (ret == (SMB_ACL_T)NULL) {
1282                 saved_errno = errno;
1283         }
1284         TALLOC_FREE(mapped_smb_fname);
1285         TALLOC_FREE(mapped_name);
1286         if (saved_errno != 0) {
1287                 errno = saved_errno;
1288         }
1289         return ret;
1290 }
1291
1292 static int
1293 catia_sys_acl_set_file(vfs_handle_struct *handle,
1294                         const struct smb_filename *smb_fname,
1295                         SMB_ACL_TYPE_T type,
1296                         SMB_ACL_T theacl)
1297 {
1298         struct smb_filename *mapped_smb_fname = NULL;
1299         int saved_errno = 0;
1300         char *mapped_name = NULL;
1301         NTSTATUS status;
1302         int ret;
1303
1304         status = catia_string_replace_allocate(handle->conn,
1305                                 smb_fname->base_name,
1306                                 &mapped_name,
1307                                 vfs_translate_to_unix);
1308         if (!NT_STATUS_IS_OK(status)) {
1309                 errno = map_errno_from_nt_status(status);
1310                 return -1;
1311         }
1312
1313         mapped_smb_fname = synthetic_smb_fname(talloc_tos(),
1314                                         mapped_name,
1315                                         NULL,
1316                                         NULL,
1317                                         smb_fname->flags);
1318         if (mapped_smb_fname == NULL) {
1319                 TALLOC_FREE(mapped_name);
1320                 errno = ENOMEM;
1321                 return -1;
1322         }
1323
1324         ret = SMB_VFS_NEXT_SYS_ACL_SET_FILE(handle, mapped_smb_fname,
1325                         type, theacl);
1326         if (ret == -1) {
1327                 saved_errno = errno;
1328         }
1329         TALLOC_FREE(mapped_smb_fname);
1330         TALLOC_FREE(mapped_name);
1331         if (saved_errno != 0) {
1332                 errno = saved_errno;
1333         }
1334         return ret;
1335 }
1336
1337 static int
1338 catia_sys_acl_delete_def_file(vfs_handle_struct *handle,
1339                                 const struct smb_filename *smb_fname)
1340 {
1341         struct smb_filename *mapped_smb_fname = NULL;
1342         int saved_errno = 0;
1343         char *mapped_name = NULL;
1344         NTSTATUS status;
1345         int ret;
1346
1347         status = catia_string_replace_allocate(handle->conn,
1348                                 smb_fname->base_name,
1349                                 &mapped_name,
1350                                 vfs_translate_to_unix);
1351         if (!NT_STATUS_IS_OK(status)) {
1352                 errno = map_errno_from_nt_status(status);
1353                 return -1;
1354         }
1355
1356         mapped_smb_fname = synthetic_smb_fname(talloc_tos(),
1357                                         mapped_name,
1358                                         NULL,
1359                                         NULL,
1360                                         smb_fname->flags);
1361         if (mapped_smb_fname == NULL) {
1362                 TALLOC_FREE(mapped_name);
1363                 errno = ENOMEM;
1364                 return -1;
1365         }
1366         ret = SMB_VFS_NEXT_SYS_ACL_DELETE_DEF_FILE(handle, mapped_smb_fname);
1367         if (ret == -1) {
1368                 saved_errno = errno;
1369         }
1370         TALLOC_FREE(mapped_smb_fname);
1371         TALLOC_FREE(mapped_name);
1372         if (saved_errno != 0) {
1373                 errno = saved_errno;
1374         }
1375         return ret;
1376 }
1377
1378 static ssize_t
1379 catia_getxattr(vfs_handle_struct *handle, const char *path,
1380                const char *name, void *value, size_t size)
1381 {
1382         char *mapped_name = NULL;
1383         char *mapped_ea_name = NULL;
1384         NTSTATUS status;
1385         ssize_t ret;
1386
1387         status = catia_string_replace_allocate(handle->conn,
1388                                 path, &mapped_name, vfs_translate_to_unix);
1389         if (!NT_STATUS_IS_OK(status)) {
1390                 errno = map_errno_from_nt_status(status);
1391                 return -1;
1392         }
1393
1394         status = catia_string_replace_allocate(handle->conn,
1395                                 name, &mapped_ea_name, vfs_translate_to_unix);
1396         if (!NT_STATUS_IS_OK(status)) {
1397                 TALLOC_FREE(mapped_name);
1398                 errno = map_errno_from_nt_status(status);
1399                 return -1;
1400         }
1401
1402         ret = SMB_VFS_NEXT_GETXATTR(handle, mapped_name,
1403                                 mapped_ea_name, value, size);
1404         TALLOC_FREE(mapped_name);
1405         TALLOC_FREE(mapped_ea_name);
1406
1407         return ret;
1408 }
1409
1410 static ssize_t
1411 catia_listxattr(vfs_handle_struct *handle,
1412                 const struct smb_filename *smb_fname,
1413                 char *list, size_t size)
1414 {
1415         struct smb_filename *mapped_smb_fname = NULL;
1416         char *mapped_name = NULL;
1417         NTSTATUS status;
1418         ssize_t ret;
1419         int saved_errno = 0;
1420
1421         status = catia_string_replace_allocate(handle->conn,
1422                                 smb_fname->base_name,
1423                                 &mapped_name,
1424                                 vfs_translate_to_unix);
1425         if (!NT_STATUS_IS_OK(status)) {
1426                 errno = map_errno_from_nt_status(status);
1427                 return -1;
1428         }
1429
1430         mapped_smb_fname = synthetic_smb_fname(talloc_tos(),
1431                                         mapped_name,
1432                                         NULL,
1433                                         NULL,
1434                                         smb_fname->flags);
1435         if (mapped_smb_fname == NULL) {
1436                 TALLOC_FREE(mapped_name);
1437                 errno = ENOMEM;
1438                 return -1;
1439         }
1440
1441         ret = SMB_VFS_NEXT_LISTXATTR(handle, mapped_smb_fname, list, size);
1442         if (ret == -1) {
1443                 saved_errno = errno;
1444         }
1445         TALLOC_FREE(mapped_name);
1446         TALLOC_FREE(mapped_smb_fname);
1447         if (saved_errno != 0) {
1448                 errno = saved_errno;
1449         }
1450
1451         return ret;
1452 }
1453
1454 static int
1455 catia_removexattr(vfs_handle_struct *handle,
1456                         const struct smb_filename *smb_fname,
1457                         const char *name)
1458 {
1459         struct smb_filename *mapped_smb_fname = NULL;
1460         char *mapped_name = NULL;
1461         char *mapped_ea_name = NULL;
1462         NTSTATUS status;
1463         ssize_t ret;
1464         int saved_errno = 0;
1465
1466         status = catia_string_replace_allocate(handle->conn,
1467                                 smb_fname->base_name,
1468                                 &mapped_name,
1469                                 vfs_translate_to_unix);
1470         if (!NT_STATUS_IS_OK(status)) {
1471                 errno = map_errno_from_nt_status(status);
1472                 return -1;
1473         }
1474
1475         status = catia_string_replace_allocate(handle->conn,
1476                                 name, &mapped_ea_name, vfs_translate_to_unix);
1477         if (!NT_STATUS_IS_OK(status)) {
1478                 TALLOC_FREE(mapped_name);
1479                 errno = map_errno_from_nt_status(status);
1480                 return -1;
1481         }
1482
1483         mapped_smb_fname = synthetic_smb_fname(talloc_tos(),
1484                                         mapped_name,
1485                                         NULL,
1486                                         NULL,
1487                                         smb_fname->flags);
1488         if (mapped_smb_fname == NULL) {
1489                 TALLOC_FREE(mapped_name);
1490                 TALLOC_FREE(mapped_ea_name);
1491                 errno = ENOMEM;
1492                 return -1;
1493         }
1494
1495         ret = SMB_VFS_NEXT_REMOVEXATTR(handle, mapped_smb_fname,
1496                                 mapped_ea_name);
1497         if (ret == -1) {
1498                 saved_errno = errno;
1499         }
1500         TALLOC_FREE(mapped_name);
1501         TALLOC_FREE(mapped_ea_name);
1502         TALLOC_FREE(mapped_smb_fname);
1503         if (saved_errno != 0) {
1504                 errno = saved_errno;
1505         }
1506
1507         return ret;
1508 }
1509
1510 static int
1511 catia_setxattr(vfs_handle_struct *handle, const char *path,
1512                const char *name, const void *value, size_t size,
1513                int flags)
1514 {
1515         char *mapped_name = NULL;
1516         char *mapped_ea_name = NULL;
1517         NTSTATUS status;
1518         ssize_t ret;
1519
1520         status = catia_string_replace_allocate(handle->conn,
1521                                 path, &mapped_name, vfs_translate_to_unix);
1522         if (!NT_STATUS_IS_OK(status)) {
1523                 errno = map_errno_from_nt_status(status);
1524                 return -1;
1525         }
1526
1527         status = catia_string_replace_allocate(handle->conn,
1528                                 name, &mapped_ea_name, vfs_translate_to_unix);
1529         if (!NT_STATUS_IS_OK(status)) {
1530                 TALLOC_FREE(mapped_name);
1531                 errno = map_errno_from_nt_status(status);
1532                 return -1;
1533         }
1534
1535         ret = SMB_VFS_NEXT_SETXATTR(handle, mapped_name, mapped_ea_name,
1536                         value, size, flags);
1537         TALLOC_FREE(mapped_name);
1538         TALLOC_FREE(mapped_ea_name);
1539
1540         return ret;
1541 }
1542
1543 static int catia_fstat(vfs_handle_struct *handle,
1544                        files_struct *fsp,
1545                        SMB_STRUCT_STAT *sbuf)
1546 {
1547         struct catia_cache *cc = NULL;
1548         int ret;
1549
1550         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
1551         if (ret != 0) {
1552                 return ret;
1553         }
1554
1555         ret = SMB_VFS_NEXT_FSTAT(handle, fsp, sbuf);
1556
1557         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
1558
1559         return ret;
1560 }
1561
1562 static ssize_t catia_pread(vfs_handle_struct *handle,
1563                            files_struct *fsp, void *data,
1564                            size_t n, off_t offset)
1565 {
1566         struct catia_cache *cc = NULL;
1567         ssize_t result;
1568         int ret;
1569
1570         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
1571         if (ret != 0) {
1572                 return ret;
1573         }
1574
1575         result = SMB_VFS_NEXT_PREAD(handle, fsp, data, n, offset);
1576
1577         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
1578
1579         return result;
1580 }
1581
1582 static ssize_t catia_pwrite(vfs_handle_struct *handle,
1583                             files_struct *fsp, const void *data,
1584                             size_t n, off_t offset)
1585 {
1586         struct catia_cache *cc = NULL;
1587         ssize_t result;
1588         int ret;
1589
1590         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
1591         if (ret != 0) {
1592                 return ret;
1593         }
1594
1595         result = SMB_VFS_NEXT_PWRITE(handle, fsp, data, n, offset);
1596
1597         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
1598
1599         return result;
1600 }
1601
1602 static int catia_ftruncate(struct vfs_handle_struct *handle,
1603                            struct files_struct *fsp,
1604                            off_t offset)
1605 {
1606         struct catia_cache *cc = NULL;
1607         int ret;
1608
1609         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
1610         if (ret != 0) {
1611                 return ret;
1612         }
1613
1614         ret = SMB_VFS_NEXT_FTRUNCATE(handle, fsp, offset);
1615
1616         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
1617
1618         return ret;
1619 }
1620
1621 static int catia_fallocate(struct vfs_handle_struct *handle,
1622                            struct files_struct *fsp,
1623                            uint32_t mode,
1624                            off_t offset,
1625                            off_t len)
1626 {
1627         struct catia_cache *cc = NULL;
1628         int ret;
1629
1630         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
1631         if (ret != 0) {
1632                 return ret;
1633         }
1634
1635         ret = SMB_VFS_NEXT_FALLOCATE(handle, fsp, mode, offset, len);
1636
1637         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
1638
1639         return ret;
1640 }
1641
1642 static ssize_t catia_fgetxattr(struct vfs_handle_struct *handle,
1643                                struct files_struct *fsp,
1644                                const char *name,
1645                                void *value,
1646                                size_t size)
1647 {
1648         char *mapped_xattr_name = NULL;
1649         NTSTATUS status;
1650         ssize_t result;
1651
1652         status = catia_string_replace_allocate(handle->conn,
1653                                                name, &mapped_xattr_name,
1654                                                vfs_translate_to_unix);
1655         if (!NT_STATUS_IS_OK(status)) {
1656                 errno = map_errno_from_nt_status(status);
1657                 return -1;
1658         }
1659
1660         result = SMB_VFS_NEXT_FGETXATTR(handle, fsp, mapped_xattr_name,
1661                                         value, size);
1662
1663         TALLOC_FREE(mapped_xattr_name);
1664
1665         return result;
1666 }
1667
1668 static ssize_t catia_flistxattr(struct vfs_handle_struct *handle,
1669                                 struct files_struct *fsp,
1670                                 char *list,
1671                                 size_t size)
1672 {
1673         struct catia_cache *cc = NULL;
1674         ssize_t result;
1675         int ret;
1676
1677         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
1678         if (ret != 0) {
1679                 return ret;
1680         }
1681
1682         result = SMB_VFS_NEXT_FLISTXATTR(handle, fsp, list, size);
1683
1684         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
1685
1686         return result;
1687 }
1688
1689 static int catia_fremovexattr(struct vfs_handle_struct *handle,
1690                               struct files_struct *fsp,
1691                               const char *name)
1692 {
1693         char *mapped_name = NULL;
1694         NTSTATUS status;
1695         int ret;
1696
1697         status = catia_string_replace_allocate(handle->conn,
1698                                 name, &mapped_name, vfs_translate_to_unix);
1699         if (!NT_STATUS_IS_OK(status)) {
1700                 errno = map_errno_from_nt_status(status);
1701                 return -1;
1702         }
1703
1704         ret = SMB_VFS_NEXT_FREMOVEXATTR(handle, fsp, mapped_name);
1705
1706         TALLOC_FREE(mapped_name);
1707
1708         return ret;
1709 }
1710
1711 static int catia_fsetxattr(struct vfs_handle_struct *handle,
1712                            struct files_struct *fsp,
1713                            const char *name,
1714                            const void *value,
1715                            size_t size,
1716                            int flags)
1717 {
1718         char *mapped_xattr_name = NULL;
1719         NTSTATUS status;
1720         int ret;
1721
1722         status = catia_string_replace_allocate(
1723                 handle->conn, name, &mapped_xattr_name, vfs_translate_to_unix);
1724         if (!NT_STATUS_IS_OK(status)) {
1725                 errno = map_errno_from_nt_status(status);
1726                 return -1;
1727         }
1728
1729         ret = SMB_VFS_NEXT_FSETXATTR(handle, fsp, mapped_xattr_name,
1730                                      value, size, flags);
1731
1732         TALLOC_FREE(mapped_xattr_name);
1733
1734         return ret;
1735 }
1736
1737 static SMB_ACL_T catia_sys_acl_get_fd(vfs_handle_struct *handle,
1738                                       files_struct *fsp,
1739                                       TALLOC_CTX *mem_ctx)
1740 {
1741         struct catia_cache *cc = NULL;
1742         struct smb_acl_t *result = NULL;
1743         int ret;
1744
1745         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
1746         if (ret != 0) {
1747                 return NULL;
1748         }
1749
1750         result = SMB_VFS_NEXT_SYS_ACL_GET_FD(handle, fsp, mem_ctx);
1751
1752         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
1753
1754         return result;
1755 }
1756
1757 static int catia_sys_acl_blob_get_fd(vfs_handle_struct *handle,
1758                                      files_struct *fsp,
1759                                      TALLOC_CTX *mem_ctx,
1760                                      char **blob_description,
1761                                      DATA_BLOB *blob)
1762 {
1763         struct catia_cache *cc = NULL;
1764         int ret;
1765
1766         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
1767         if (ret != 0) {
1768                 return ret;
1769         }
1770
1771         ret = SMB_VFS_NEXT_SYS_ACL_BLOB_GET_FD(handle, fsp, mem_ctx,
1772                                                blob_description, blob);
1773
1774         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
1775
1776         return ret;
1777 }
1778
1779 static int catia_sys_acl_set_fd(vfs_handle_struct *handle,
1780                                 files_struct *fsp,
1781                                 SMB_ACL_T theacl)
1782 {
1783         struct catia_cache *cc = NULL;
1784         int ret;
1785
1786         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
1787         if (ret != 0) {
1788                 return ret;
1789         }
1790
1791         ret = SMB_VFS_NEXT_SYS_ACL_SET_FD(handle, fsp, theacl);
1792
1793         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
1794
1795         return ret;
1796 }
1797
1798 static int catia_fchmod_acl(vfs_handle_struct *handle,
1799                             files_struct *fsp,
1800                             mode_t mode)
1801 {
1802         struct catia_cache *cc = NULL;
1803         int ret;
1804
1805         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
1806         if (ret != 0) {
1807                 return ret;
1808         }
1809
1810         ret = SMB_VFS_NEXT_FCHMOD_ACL(handle, fsp, mode);
1811
1812         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
1813
1814         return ret;
1815 }
1816
1817 static NTSTATUS catia_fget_nt_acl(vfs_handle_struct *handle,
1818                                   files_struct *fsp,
1819                                   uint32_t security_info,
1820                                   TALLOC_CTX *mem_ctx,
1821                                   struct security_descriptor **ppdesc)
1822 {
1823         struct catia_cache *cc = NULL;
1824         NTSTATUS status;
1825         int ret;
1826
1827         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
1828         if (ret != 0) {
1829                 return map_nt_error_from_unix(errno);
1830         }
1831
1832         status = SMB_VFS_NEXT_FGET_NT_ACL(handle, fsp, security_info,
1833                                           mem_ctx, ppdesc);
1834
1835         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
1836
1837         return status;
1838 }
1839
1840 static NTSTATUS catia_fset_nt_acl(vfs_handle_struct *handle,
1841                                   files_struct *fsp,
1842                                   uint32_t security_info_sent,
1843                                   const struct security_descriptor *psd)
1844 {
1845         struct catia_cache *cc = NULL;
1846         NTSTATUS status;
1847         int ret;
1848
1849         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
1850         if (ret != 0) {
1851                 return map_nt_error_from_unix(errno);
1852         }
1853
1854         status = SMB_VFS_NEXT_FSET_NT_ACL(handle, fsp, security_info_sent, psd);
1855
1856         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
1857
1858         return status;
1859 }
1860
1861 static NTSTATUS catia_fset_dos_attributes(struct vfs_handle_struct *handle,
1862                                           struct files_struct *fsp,
1863                                           uint32_t dosmode)
1864 {
1865         struct catia_cache *cc = NULL;
1866         NTSTATUS status;
1867         int ret;
1868
1869         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
1870         if (ret != 0) {
1871                 return map_nt_error_from_unix(errno);
1872         }
1873
1874         status = SMB_VFS_NEXT_FSET_DOS_ATTRIBUTES(handle, fsp, dosmode);
1875
1876         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
1877
1878         return status;
1879 }
1880
1881 static NTSTATUS catia_fget_dos_attributes(struct vfs_handle_struct *handle,
1882                                           struct files_struct *fsp,
1883                                           uint32_t *dosmode)
1884 {
1885         struct catia_cache *cc = NULL;
1886         NTSTATUS status;
1887         int ret;
1888
1889         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
1890         if (ret != 0) {
1891                 return map_nt_error_from_unix(errno);
1892         }
1893
1894         status = SMB_VFS_NEXT_FGET_DOS_ATTRIBUTES(handle, fsp, dosmode);
1895
1896         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
1897
1898         return status;
1899 }
1900
1901 static int catia_fchown(vfs_handle_struct *handle,
1902                         files_struct *fsp,
1903                         uid_t uid,
1904                         gid_t gid)
1905 {
1906         struct catia_cache *cc = NULL;
1907         int ret;
1908
1909         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
1910         if (ret != 0) {
1911                 return ret;
1912         }
1913
1914         ret = SMB_VFS_NEXT_FCHOWN(handle, fsp, uid, gid);
1915
1916         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
1917
1918         return ret;
1919 }
1920
1921 static int catia_fchmod(vfs_handle_struct *handle,
1922                         files_struct *fsp,
1923                         mode_t mode)
1924 {
1925         struct catia_cache *cc = NULL;
1926         int ret;
1927
1928         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
1929         if (ret != 0) {
1930                 return ret;
1931         }
1932
1933         ret = SMB_VFS_NEXT_FCHMOD(handle, fsp, mode);
1934
1935         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
1936
1937         return ret;
1938 }
1939
1940 struct catia_pread_state {
1941         ssize_t ret;
1942         struct vfs_aio_state vfs_aio_state;
1943         struct files_struct *fsp;
1944         struct catia_cache *cc;
1945 };
1946
1947 static void catia_pread_done(struct tevent_req *subreq);
1948
1949 static struct tevent_req *catia_pread_send(struct vfs_handle_struct *handle,
1950                                            TALLOC_CTX *mem_ctx,
1951                                            struct tevent_context *ev,
1952                                            struct files_struct *fsp,
1953                                            void *data,
1954                                            size_t n,
1955                                            off_t offset)
1956 {
1957         struct tevent_req *req = NULL, *subreq = NULL;
1958         struct catia_pread_state *state = NULL;
1959         int ret;
1960
1961         req = tevent_req_create(mem_ctx, &state,
1962                                 struct catia_pread_state);
1963         if (req == NULL) {
1964                 return NULL;
1965         }
1966         state->fsp = fsp;
1967
1968         ret = CATIA_FETCH_FSP_PRE_NEXT(state, handle, fsp, &state->cc);
1969         if (ret != 0) {
1970                 tevent_req_error(req, errno);
1971                 return tevent_req_post(req, ev);
1972         }
1973
1974         subreq = SMB_VFS_NEXT_PREAD_SEND(state, ev, handle, fsp, data,
1975                                          n, offset);
1976         if (tevent_req_nomem(subreq, req)) {
1977                 return tevent_req_post(req, ev);
1978         }
1979         tevent_req_set_callback(subreq, catia_pread_done, req);
1980
1981         return req;
1982 }
1983
1984 static void catia_pread_done(struct tevent_req *subreq)
1985 {
1986         struct tevent_req *req = tevent_req_callback_data(
1987                 subreq, struct tevent_req);
1988         struct catia_pread_state *state = tevent_req_data(
1989                 req, struct catia_pread_state);
1990
1991         state->ret = SMB_VFS_PREAD_RECV(subreq, &state->vfs_aio_state);
1992         TALLOC_FREE(subreq);
1993
1994         CATIA_FETCH_FSP_POST_NEXT(&state->cc, state->fsp);
1995
1996         tevent_req_done(req);
1997 }
1998
1999 static ssize_t catia_pread_recv(struct tevent_req *req,
2000                                 struct vfs_aio_state *vfs_aio_state)
2001 {
2002         struct catia_pread_state *state = tevent_req_data(
2003                 req, struct catia_pread_state);
2004
2005         if (tevent_req_is_unix_error(req, &vfs_aio_state->error)) {
2006                 return -1;
2007         }
2008
2009         *vfs_aio_state = state->vfs_aio_state;
2010         return state->ret;
2011 }
2012
2013 struct catia_pwrite_state {
2014         ssize_t ret;
2015         struct vfs_aio_state vfs_aio_state;
2016         struct files_struct *fsp;
2017         struct catia_cache *cc;
2018 };
2019
2020 static void catia_pwrite_done(struct tevent_req *subreq);
2021
2022 static struct tevent_req *catia_pwrite_send(struct vfs_handle_struct *handle,
2023                                             TALLOC_CTX *mem_ctx,
2024                                             struct tevent_context *ev,
2025                                             struct files_struct *fsp,
2026                                             const void *data,
2027                                             size_t n,
2028                                             off_t offset)
2029 {
2030         struct tevent_req *req = NULL, *subreq = NULL;
2031         struct catia_pwrite_state *state = NULL;
2032         int ret;
2033
2034         req = tevent_req_create(mem_ctx, &state,
2035                                 struct catia_pwrite_state);
2036         if (req == NULL) {
2037                 return NULL;
2038         }
2039         state->fsp = fsp;
2040
2041         ret = CATIA_FETCH_FSP_PRE_NEXT(state, handle, fsp, &state->cc);
2042         if (ret != 0) {
2043                 tevent_req_error(req, errno);
2044                 return tevent_req_post(req, ev);
2045         }
2046
2047         subreq = SMB_VFS_NEXT_PWRITE_SEND(state, ev, handle, fsp, data,
2048                                           n, offset);
2049         if (tevent_req_nomem(subreq, req)) {
2050                 return tevent_req_post(req, ev);
2051         }
2052         tevent_req_set_callback(subreq, catia_pwrite_done, req);
2053
2054         return req;
2055 }
2056
2057 static void catia_pwrite_done(struct tevent_req *subreq)
2058 {
2059         struct tevent_req *req = tevent_req_callback_data(
2060                 subreq, struct tevent_req);
2061         struct catia_pwrite_state *state = tevent_req_data(
2062                 req, struct catia_pwrite_state);
2063
2064         state->ret = SMB_VFS_PWRITE_RECV(subreq, &state->vfs_aio_state);
2065         TALLOC_FREE(subreq);
2066
2067         CATIA_FETCH_FSP_POST_NEXT(&state->cc, state->fsp);
2068
2069         tevent_req_done(req);
2070 }
2071
2072 static ssize_t catia_pwrite_recv(struct tevent_req *req,
2073                                 struct vfs_aio_state *vfs_aio_state)
2074 {
2075         struct catia_pwrite_state *state = tevent_req_data(
2076                 req, struct catia_pwrite_state);
2077
2078         if (tevent_req_is_unix_error(req, &vfs_aio_state->error)) {
2079                 return -1;
2080         }
2081
2082         *vfs_aio_state = state->vfs_aio_state;
2083         return state->ret;
2084 }
2085
2086 static off_t catia_lseek(vfs_handle_struct *handle,
2087                          files_struct *fsp,
2088                          off_t offset,
2089                          int whence)
2090 {
2091         struct catia_cache *cc = NULL;
2092         ssize_t result;
2093         int ret;
2094
2095         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
2096         if (ret != 0) {
2097                 return -1;
2098         }
2099
2100         result = SMB_VFS_NEXT_LSEEK(handle, fsp, offset, whence);
2101
2102         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
2103
2104         return result;
2105 }
2106
2107 static int catia_fsync(vfs_handle_struct *handle, files_struct *fsp)
2108 {
2109         struct catia_cache *cc = NULL;
2110         int ret;
2111
2112         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
2113         if (ret != 0) {
2114                 return -1;
2115         }
2116
2117         ret = SMB_VFS_NEXT_FSYNC(handle, fsp);
2118
2119         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
2120
2121         return ret;
2122 }
2123
2124 struct catia_fsync_state {
2125         int ret;
2126         struct vfs_aio_state vfs_aio_state;
2127         struct files_struct *fsp;
2128         struct catia_cache *cc;
2129 };
2130
2131 static void catia_fsync_done(struct tevent_req *subreq);
2132
2133 static struct tevent_req *catia_fsync_send(struct vfs_handle_struct *handle,
2134                                            TALLOC_CTX *mem_ctx,
2135                                            struct tevent_context *ev,
2136                                            struct files_struct *fsp)
2137 {
2138         struct tevent_req *req = NULL, *subreq = NULL;
2139         struct catia_fsync_state *state = NULL;
2140         int ret;
2141
2142         req = tevent_req_create(mem_ctx, &state,
2143                                 struct catia_fsync_state);
2144         if (req == NULL) {
2145                 return NULL;
2146         }
2147         state->fsp = fsp;
2148
2149         ret = CATIA_FETCH_FSP_PRE_NEXT(state, handle, fsp, &state->cc);
2150         if (ret != 0) {
2151                 tevent_req_error(req, errno);
2152                 return tevent_req_post(req, ev);
2153         }
2154
2155         subreq = SMB_VFS_NEXT_FSYNC_SEND(state, ev, handle, fsp);
2156         if (tevent_req_nomem(subreq, req)) {
2157                 return tevent_req_post(req, ev);
2158         }
2159         tevent_req_set_callback(subreq, catia_fsync_done, req);
2160
2161         return req;
2162 }
2163
2164 static void catia_fsync_done(struct tevent_req *subreq)
2165 {
2166         struct tevent_req *req = tevent_req_callback_data(
2167                 subreq, struct tevent_req);
2168         struct catia_fsync_state *state = tevent_req_data(
2169                 req, struct catia_fsync_state);
2170
2171         state->ret = SMB_VFS_FSYNC_RECV(subreq, &state->vfs_aio_state);
2172         TALLOC_FREE(subreq);
2173
2174         CATIA_FETCH_FSP_POST_NEXT(&state->cc, state->fsp);
2175
2176         tevent_req_done(req);
2177 }
2178
2179 static int catia_fsync_recv(struct tevent_req *req,
2180                             struct vfs_aio_state *vfs_aio_state)
2181 {
2182         struct catia_fsync_state *state = tevent_req_data(
2183                 req, struct catia_fsync_state);
2184
2185         if (tevent_req_is_unix_error(req, &vfs_aio_state->error)) {
2186                 return -1;
2187         }
2188
2189         *vfs_aio_state = state->vfs_aio_state;
2190         return state->ret;
2191 }
2192
2193 static bool catia_lock(vfs_handle_struct *handle,
2194                        files_struct *fsp,
2195                        int op,
2196                        off_t offset,
2197                        off_t count,
2198                        int type)
2199 {
2200         struct catia_cache *cc = NULL;
2201         bool ok;
2202         int ret;
2203
2204         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
2205         if (ret != 0) {
2206                 return -1;
2207         }
2208
2209         ok = SMB_VFS_NEXT_LOCK(handle, fsp, op, offset, count, type);
2210
2211         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
2212
2213         return ok;
2214 }
2215
2216 static int catia_kernel_flock(struct vfs_handle_struct *handle,
2217                               struct files_struct *fsp,
2218                               uint32_t share_mode,
2219                               uint32_t access_mask)
2220 {
2221         struct catia_cache *cc = NULL;
2222         int ret;
2223
2224         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
2225         if (ret != 0) {
2226                 return -1;
2227         }
2228
2229         ret = SMB_VFS_NEXT_KERNEL_FLOCK(handle, fsp, share_mode, access_mask);
2230
2231         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
2232
2233         return ret;
2234 }
2235
2236 static int catia_linux_setlease(vfs_handle_struct *handle,
2237                                 files_struct *fsp,
2238                                 int leasetype)
2239 {
2240         struct catia_cache *cc = NULL;
2241         int ret;
2242
2243         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
2244         if (ret != 0) {
2245                 return -1;
2246         }
2247
2248         ret = SMB_VFS_NEXT_LINUX_SETLEASE(handle, fsp, leasetype);
2249
2250         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
2251
2252         return ret;
2253 }
2254
2255 static bool catia_getlock(vfs_handle_struct *handle,
2256                           files_struct *fsp,
2257                           off_t *poffset,
2258                           off_t *pcount,
2259                           int *ptype,
2260                           pid_t *ppid)
2261 {
2262         struct catia_cache *cc = NULL;
2263         int ret;
2264         bool ok;
2265
2266         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
2267         if (ret != 0) {
2268                 return -1;
2269         }
2270
2271         ok = SMB_VFS_NEXT_GETLOCK(handle, fsp, poffset, pcount, ptype, ppid);
2272
2273         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
2274
2275         return ok;
2276 }
2277
2278 static bool catia_strict_lock(struct vfs_handle_struct *handle,
2279                               struct files_struct *fsp,
2280                               struct lock_struct *plock)
2281 {
2282         struct catia_cache *cc = NULL;
2283         int ret;
2284         bool ok;
2285
2286         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
2287         if (ret != 0) {
2288                 return -1;
2289         }
2290
2291         ok = SMB_VFS_NEXT_STRICT_LOCK(handle, fsp, plock);
2292
2293         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
2294
2295         return ok;
2296 }
2297
2298 static void catia_strict_unlock(struct vfs_handle_struct *handle,
2299                                 struct files_struct *fsp,
2300                                 struct lock_struct *plock)
2301 {
2302         struct catia_cache *cc = NULL;
2303         int ret;
2304
2305         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
2306         if (ret != 0) {
2307                 smb_panic("CATIA_FETCH_FSP_PRE_NEXT failed\n");
2308         }
2309
2310         SMB_VFS_NEXT_STRICT_UNLOCK(handle, fsp, plock);
2311
2312         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
2313 }
2314
2315 static NTSTATUS catia_fsctl(struct vfs_handle_struct *handle,
2316                             struct files_struct *fsp,
2317                             TALLOC_CTX *ctx,
2318                             uint32_t function,
2319                             uint16_t req_flags,
2320                             const uint8_t *_in_data,
2321                             uint32_t in_len,
2322                             uint8_t **_out_data,
2323                             uint32_t max_out_len,
2324                             uint32_t *out_len)
2325 {
2326         NTSTATUS result;
2327         struct catia_cache *cc = NULL;
2328         int ret;
2329
2330         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
2331         if (ret != 0) {
2332                 return map_nt_error_from_unix(errno);
2333         }
2334
2335         result = SMB_VFS_NEXT_FSCTL(handle,
2336                                 fsp,
2337                                 ctx,
2338                                 function,
2339                                 req_flags,
2340                                 _in_data,
2341                                 in_len,
2342                                 _out_data,
2343                                 max_out_len,
2344                                 out_len);
2345
2346         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
2347
2348         return result;
2349 }
2350
2351 static NTSTATUS catia_get_compression(vfs_handle_struct *handle,
2352                                       TALLOC_CTX *mem_ctx,
2353                                       struct files_struct *fsp,
2354                                       struct smb_filename *smb_fname,
2355                                       uint16_t *_compression_fmt)
2356 {
2357         NTSTATUS result;
2358         struct catia_cache *cc = NULL;
2359         int ret;
2360
2361         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
2362         if (ret != 0) {
2363                 return map_nt_error_from_unix(errno);
2364         }
2365
2366         result = SMB_VFS_NEXT_GET_COMPRESSION(handle, mem_ctx, fsp, smb_fname,
2367                                               _compression_fmt);
2368
2369         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
2370
2371         return result;
2372 }
2373
2374 static NTSTATUS catia_set_compression(vfs_handle_struct *handle,
2375                                       TALLOC_CTX *mem_ctx,
2376                                       struct files_struct *fsp,
2377                                       uint16_t compression_fmt)
2378 {
2379         NTSTATUS result;
2380         struct catia_cache *cc = NULL;
2381         int ret;
2382
2383         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
2384         if (ret != 0) {
2385                 return map_nt_error_from_unix(errno);
2386         }
2387
2388         result = SMB_VFS_NEXT_SET_COMPRESSION(handle, mem_ctx, fsp,
2389                                               compression_fmt);
2390
2391         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
2392
2393         return result;
2394 }
2395
2396 static NTSTATUS catia_readdir_attr(struct vfs_handle_struct *handle,
2397                                    const struct smb_filename *smb_fname_in,
2398                                    TALLOC_CTX *mem_ctx,
2399                                    struct readdir_attr_data **pattr_data)
2400 {
2401         struct smb_filename *smb_fname;
2402         char *fname = NULL;
2403         NTSTATUS status;
2404
2405         status = catia_string_replace_allocate(handle->conn,
2406                                                smb_fname_in->base_name,
2407                                                &fname,
2408                                                vfs_translate_to_unix);
2409         if (!NT_STATUS_IS_OK(status)) {
2410                 errno = map_errno_from_nt_status(status);
2411                 return status;
2412         }
2413
2414         smb_fname = synthetic_smb_fname(talloc_tos(), fname, NULL,
2415                                         &smb_fname_in->st, 0);
2416
2417         status = SMB_VFS_NEXT_READDIR_ATTR(handle, smb_fname, mem_ctx, pattr_data);
2418
2419         TALLOC_FREE(smb_fname);
2420         return status;
2421 }
2422
2423 static NTSTATUS catia_get_dos_attributes(struct vfs_handle_struct *handle,
2424                                          struct smb_filename *smb_fname,
2425                                          uint32_t *dosmode)
2426 {
2427         char *mapped_name = NULL;
2428         const char *path = smb_fname->base_name;
2429         struct smb_filename *mapped_smb_fname = NULL;
2430         NTSTATUS status;
2431
2432         status = catia_string_replace_allocate(handle->conn,
2433                                 path, &mapped_name, vfs_translate_to_unix);
2434         if (!NT_STATUS_IS_OK(status)) {
2435                 errno = map_errno_from_nt_status(status);
2436                 return status;
2437         }
2438         mapped_smb_fname = synthetic_smb_fname(talloc_tos(),
2439                                         mapped_name,
2440                                         NULL,
2441                                         NULL,
2442                                         smb_fname->flags);
2443         if (mapped_smb_fname == NULL) {
2444                 TALLOC_FREE(mapped_name);
2445                 return NT_STATUS_NO_MEMORY;
2446         }
2447
2448         status = SMB_VFS_NEXT_GET_DOS_ATTRIBUTES(handle,
2449                                                  mapped_smb_fname,
2450                                                  dosmode);
2451         TALLOC_FREE(mapped_name);
2452         TALLOC_FREE(mapped_smb_fname);
2453
2454         return status;
2455 }
2456
2457 static NTSTATUS catia_set_dos_attributes(struct vfs_handle_struct *handle,
2458                                          const struct smb_filename *smb_fname,
2459                                          uint32_t dosmode)
2460 {
2461         char *mapped_name = NULL;
2462         const char *path = smb_fname->base_name;
2463         struct smb_filename *mapped_smb_fname = NULL;
2464         NTSTATUS status;
2465
2466         status = catia_string_replace_allocate(handle->conn,
2467                                 path, &mapped_name, vfs_translate_to_unix);
2468         if (!NT_STATUS_IS_OK(status)) {
2469                 errno = map_errno_from_nt_status(status);
2470                 return status;
2471         }
2472         mapped_smb_fname = synthetic_smb_fname(talloc_tos(),
2473                                         mapped_name,
2474                                         NULL,
2475                                         NULL,
2476                                         smb_fname->flags);
2477         if (mapped_smb_fname == NULL) {
2478                 TALLOC_FREE(mapped_name);
2479                 return NT_STATUS_NO_MEMORY;
2480         }
2481
2482         status = SMB_VFS_NEXT_SET_DOS_ATTRIBUTES(handle,
2483                                                  mapped_smb_fname,
2484                                                  dosmode);
2485         TALLOC_FREE(mapped_name);
2486         TALLOC_FREE(mapped_smb_fname);
2487
2488         return status;
2489 }
2490
2491 static struct vfs_fn_pointers vfs_catia_fns = {
2492         /* Directory operations */
2493         .mkdir_fn = catia_mkdir,
2494         .rmdir_fn = catia_rmdir,
2495         .opendir_fn = catia_opendir,
2496         .readdir_attr_fn = catia_readdir_attr,
2497
2498         /* File operations */
2499         .open_fn = catia_open,
2500         .pread_fn = catia_pread,
2501         .pread_send_fn = catia_pread_send,
2502         .pread_recv_fn = catia_pread_recv,
2503         .pwrite_fn = catia_pwrite,
2504         .pwrite_send_fn = catia_pwrite_send,
2505         .pwrite_recv_fn = catia_pwrite_recv,
2506         .lseek_fn = catia_lseek,
2507         .rename_fn = catia_rename,
2508         .fsync_fn = catia_fsync,
2509         .fsync_send_fn = catia_fsync_send,
2510         .fsync_recv_fn = catia_fsync_recv,
2511         .stat_fn = catia_stat,
2512         .fstat_fn = catia_fstat,
2513         .lstat_fn = catia_lstat,
2514         .unlink_fn = catia_unlink,
2515         .chmod_fn = catia_chmod,
2516         .fchmod_fn = catia_fchmod,
2517         .chown_fn = catia_chown,
2518         .fchown_fn = catia_fchown,
2519         .lchown_fn = catia_lchown,
2520         .chdir_fn = catia_chdir,
2521         .ntimes_fn = catia_ntimes,
2522         .ftruncate_fn = catia_ftruncate,
2523         .fallocate_fn = catia_fallocate,
2524         .lock_fn = catia_lock,
2525         .kernel_flock_fn = catia_kernel_flock,
2526         .linux_setlease_fn = catia_linux_setlease,
2527         .getlock_fn = catia_getlock,
2528         .realpath_fn = catia_realpath,
2529         .chflags_fn = catia_chflags,
2530         .streaminfo_fn = catia_streaminfo,
2531         .strict_lock_fn = catia_strict_lock,
2532         .strict_unlock_fn = catia_strict_unlock,
2533         .translate_name_fn = catia_translate_name,
2534         .fsctl_fn = catia_fsctl,
2535         .get_dos_attributes_fn = catia_get_dos_attributes,
2536         .set_dos_attributes_fn = catia_set_dos_attributes,
2537         .fset_dos_attributes_fn = catia_fset_dos_attributes,
2538         .fget_dos_attributes_fn = catia_fget_dos_attributes,
2539         .get_compression_fn = catia_get_compression,
2540         .set_compression_fn = catia_set_compression,
2541
2542         /* NT ACL operations. */
2543         .get_nt_acl_fn = catia_get_nt_acl,
2544         .fget_nt_acl_fn = catia_fget_nt_acl,
2545         .fset_nt_acl_fn = catia_fset_nt_acl,
2546
2547         /* POSIX ACL operations. */
2548         .chmod_acl_fn = catia_chmod_acl,
2549         .fchmod_acl_fn = catia_fchmod_acl,
2550
2551         .sys_acl_get_file_fn = catia_sys_acl_get_file,
2552         .sys_acl_get_fd_fn = catia_sys_acl_get_fd,
2553         .sys_acl_blob_get_fd_fn = catia_sys_acl_blob_get_fd,
2554         .sys_acl_set_file_fn = catia_sys_acl_set_file,
2555         .sys_acl_set_fd_fn = catia_sys_acl_set_fd,
2556         .sys_acl_delete_def_file_fn = catia_sys_acl_delete_def_file,
2557
2558         /* EA operations. */
2559         .getxattr_fn = catia_getxattr,
2560         .listxattr_fn = catia_listxattr,
2561         .removexattr_fn = catia_removexattr,
2562         .setxattr_fn = catia_setxattr,
2563         .fgetxattr_fn = catia_fgetxattr,
2564         .flistxattr_fn = catia_flistxattr,
2565         .fremovexattr_fn = catia_fremovexattr,
2566         .fsetxattr_fn = catia_fsetxattr,
2567 };
2568
2569 static_decl_vfs;
2570 NTSTATUS vfs_catia_init(TALLOC_CTX *ctx)
2571 {
2572         NTSTATUS ret;
2573
2574         ret = smb_register_vfs(SMB_VFS_INTERFACE_VERSION, "catia",
2575                                 &vfs_catia_fns);
2576         if (!NT_STATUS_IS_OK(ret))
2577                 return ret;
2578
2579         vfs_catia_debug_level = debug_add_class("catia");
2580         if (vfs_catia_debug_level == -1) {
2581                 vfs_catia_debug_level = DBGC_VFS;
2582                 DEBUG(0, ("vfs_catia: Couldn't register custom debugging "
2583                           "class!\n"));
2584         } else {
2585                 DEBUG(10, ("vfs_catia: Debug class number of "
2586                            "'catia': %d\n", vfs_catia_debug_level));
2587         }
2588
2589         return ret;
2590
2591 }