s3/vfs: rename SMB_VFS_STRICT_LOCK to SMB_VFS_STRICT_LOCK_CHECK
[samba.git] / 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 struct smb_filename *smb_fname)
995 {
996         char *name = NULL;
997         struct smb_filename *catia_smb_fname = NULL;
998         NTSTATUS status;
999         int ret;
1000
1001         status = catia_string_replace_allocate(handle->conn,
1002                                         smb_fname->base_name,
1003                                         &name,
1004                                         vfs_translate_to_unix);
1005         if (!NT_STATUS_IS_OK(status)) {
1006                 errno = map_errno_from_nt_status(status);
1007                 return -1;
1008         }
1009
1010         catia_smb_fname = synthetic_smb_fname(talloc_tos(),
1011                                         name,
1012                                         NULL,
1013                                         NULL,
1014                                         smb_fname->flags);
1015         if (catia_smb_fname == NULL) {
1016                 TALLOC_FREE(name);
1017                 errno = ENOMEM;
1018                 return -1;
1019         }
1020         ret = SMB_VFS_NEXT_CHDIR(handle, catia_smb_fname);
1021         TALLOC_FREE(name);
1022         TALLOC_FREE(catia_smb_fname);
1023
1024         return ret;
1025 }
1026
1027 static int catia_ntimes(vfs_handle_struct *handle,
1028                         const struct smb_filename *smb_fname,
1029                         struct smb_file_time *ft)
1030 {
1031         struct smb_filename *smb_fname_tmp = NULL;
1032         char *name = NULL;
1033         NTSTATUS status;
1034         int ret;
1035
1036         status = catia_string_replace_allocate(handle->conn,
1037                                 smb_fname->base_name,
1038                                 &name, vfs_translate_to_unix);
1039         if (!NT_STATUS_IS_OK(status)) {
1040                 errno = map_errno_from_nt_status(status);
1041                 return -1;
1042         }
1043
1044         smb_fname_tmp = cp_smb_filename(talloc_tos(), smb_fname);
1045         if (smb_fname_tmp == NULL) {
1046                 errno = ENOMEM;
1047                 return -1;
1048         }
1049
1050         smb_fname_tmp->base_name = name;
1051         ret = SMB_VFS_NEXT_NTIMES(handle, smb_fname_tmp, ft);
1052         TALLOC_FREE(name);
1053         TALLOC_FREE(smb_fname_tmp);
1054
1055         return ret;
1056 }
1057
1058 static struct smb_filename *
1059 catia_realpath(vfs_handle_struct *handle,
1060                 TALLOC_CTX *ctx,
1061                 const struct smb_filename *smb_fname)
1062 {
1063         char *mapped_name = NULL;
1064         struct smb_filename *catia_smb_fname = NULL;
1065         struct smb_filename *return_fname = NULL;
1066         NTSTATUS status;
1067
1068         status = catia_string_replace_allocate(handle->conn,
1069                                         smb_fname->base_name,
1070                                         &mapped_name, vfs_translate_to_unix);
1071         if (!NT_STATUS_IS_OK(status)) {
1072                 errno = map_errno_from_nt_status(status);
1073                 return NULL;
1074         }
1075
1076         catia_smb_fname = synthetic_smb_fname(talloc_tos(),
1077                                         mapped_name,
1078                                         NULL,
1079                                         NULL,
1080                                         smb_fname->flags);
1081         if (catia_smb_fname == NULL) {
1082                 TALLOC_FREE(mapped_name);
1083                 errno = ENOMEM;
1084                 return NULL;
1085         }
1086         return_fname = SMB_VFS_NEXT_REALPATH(handle, ctx, catia_smb_fname);
1087         TALLOC_FREE(mapped_name);
1088         TALLOC_FREE(catia_smb_fname);
1089         return return_fname;
1090 }
1091
1092 static int catia_chflags(struct vfs_handle_struct *handle,
1093                         const struct smb_filename *smb_fname,
1094                         unsigned int flags)
1095 {
1096         char *name = NULL;
1097         struct smb_filename *catia_smb_fname = NULL;
1098         NTSTATUS status;
1099         int ret;
1100
1101         status = catia_string_replace_allocate(handle->conn,
1102                                 smb_fname->base_name,
1103                                 &name,
1104                                 vfs_translate_to_unix);
1105         if (!NT_STATUS_IS_OK(status)) {
1106                 errno = map_errno_from_nt_status(status);
1107                 return -1;
1108         }
1109         catia_smb_fname = synthetic_smb_fname(talloc_tos(),
1110                                         name,
1111                                         NULL,
1112                                         NULL,
1113                                         smb_fname->flags);
1114         if (catia_smb_fname == NULL) {
1115                 TALLOC_FREE(name);
1116                 errno = ENOMEM;
1117                 return -1;
1118         }
1119
1120         ret = SMB_VFS_NEXT_CHFLAGS(handle, catia_smb_fname, flags);
1121         TALLOC_FREE(name);
1122         TALLOC_FREE(catia_smb_fname);
1123
1124         return ret;
1125 }
1126
1127 static NTSTATUS
1128 catia_streaminfo(struct vfs_handle_struct *handle,
1129                  struct files_struct *fsp,
1130                  const struct smb_filename *smb_fname,
1131                  TALLOC_CTX *mem_ctx,
1132                  unsigned int *_num_streams,
1133                  struct stream_struct **_streams)
1134 {
1135         char *mapped_name = NULL;
1136         NTSTATUS status;
1137         unsigned int i;
1138         struct smb_filename *catia_smb_fname = NULL;
1139         unsigned int num_streams = 0;
1140         struct stream_struct *streams = NULL;
1141
1142         *_num_streams = 0;
1143         *_streams = NULL;
1144
1145         status = catia_string_replace_allocate(handle->conn,
1146                                 smb_fname->base_name,
1147                                 &mapped_name,
1148                                 vfs_translate_to_unix);
1149         if (!NT_STATUS_IS_OK(status)) {
1150                 errno = map_errno_from_nt_status(status);
1151                 return status;
1152         }
1153
1154         catia_smb_fname = synthetic_smb_fname(talloc_tos(),
1155                                         mapped_name,
1156                                         NULL,
1157                                         NULL,
1158                                         smb_fname->flags);
1159         if (catia_smb_fname == NULL) {
1160                 TALLOC_FREE(mapped_name);
1161                 return NT_STATUS_NO_MEMORY;
1162         }
1163
1164         status = SMB_VFS_NEXT_STREAMINFO(handle, fsp, catia_smb_fname,
1165                                          mem_ctx, &num_streams, &streams);
1166         TALLOC_FREE(mapped_name);
1167         TALLOC_FREE(catia_smb_fname);
1168         if (!NT_STATUS_IS_OK(status)) {
1169                 return status;
1170         }
1171
1172         /*
1173          * Translate stream names just like the base names
1174          */
1175         for (i = 0; i < num_streams; i++) {
1176                 /*
1177                  * Strip ":" prefix and ":$DATA" suffix to get a
1178                  * "pure" stream name and only translate that.
1179                  */
1180                 void *old_ptr = streams[i].name;
1181                 char *stream_name = streams[i].name + 1;
1182                 char *stream_type = strrchr_m(stream_name, ':');
1183
1184                 if (stream_type != NULL) {
1185                         *stream_type = '\0';
1186                         stream_type += 1;
1187                 }
1188
1189                 status = catia_string_replace_allocate(handle->conn, stream_name,
1190                                                        &mapped_name, vfs_translate_to_windows);
1191                 if (!NT_STATUS_IS_OK(status)) {
1192                         TALLOC_FREE(streams);
1193                         return status;
1194                 }
1195
1196                 if (stream_type != NULL) {
1197                         streams[i].name = talloc_asprintf(streams, ":%s:%s",
1198                                                           mapped_name, stream_type);
1199                 } else {
1200                         streams[i].name = talloc_asprintf(streams, ":%s",
1201                                                           mapped_name);
1202                 }
1203                 TALLOC_FREE(mapped_name);
1204                 TALLOC_FREE(old_ptr);
1205                 if (streams[i].name == NULL) {
1206                         TALLOC_FREE(streams);
1207                         return NT_STATUS_NO_MEMORY;
1208                 }
1209         }
1210
1211         *_num_streams = num_streams;
1212         *_streams = streams;
1213         return NT_STATUS_OK;
1214 }
1215
1216 static NTSTATUS
1217 catia_get_nt_acl(struct vfs_handle_struct *handle,
1218                  const struct smb_filename *smb_fname,
1219                  uint32_t security_info,
1220                  TALLOC_CTX *mem_ctx,
1221                  struct security_descriptor **ppdesc)
1222 {
1223         char *mapped_name = NULL;
1224         const char *path = smb_fname->base_name;
1225         struct smb_filename *mapped_smb_fname = NULL;
1226         NTSTATUS status;
1227
1228         status = catia_string_replace_allocate(handle->conn,
1229                                 path, &mapped_name, vfs_translate_to_unix);
1230         if (!NT_STATUS_IS_OK(status)) {
1231                 errno = map_errno_from_nt_status(status);
1232                 return status;
1233         }
1234         mapped_smb_fname = synthetic_smb_fname(talloc_tos(),
1235                                         mapped_name,
1236                                         NULL,
1237                                         NULL,
1238                                         smb_fname->flags);
1239         if (mapped_smb_fname == NULL) {
1240                 TALLOC_FREE(mapped_name);
1241                 return NT_STATUS_NO_MEMORY;
1242         }
1243
1244         status = SMB_VFS_NEXT_GET_NT_ACL(handle, mapped_smb_fname,
1245                                          security_info, mem_ctx, ppdesc);
1246         TALLOC_FREE(mapped_name);
1247         TALLOC_FREE(mapped_smb_fname);
1248
1249         return status;
1250 }
1251
1252 static int
1253 catia_chmod_acl(vfs_handle_struct *handle,
1254                 const struct smb_filename *smb_fname,
1255                 mode_t mode)
1256 {
1257         char *mapped_name = NULL;
1258         struct smb_filename *mapped_smb_fname = NULL;
1259         NTSTATUS status;
1260         int ret;
1261         int saved_errno;
1262
1263         status = catia_string_replace_allocate(handle->conn,
1264                                 smb_fname->base_name,
1265                                 &mapped_name,
1266                                 vfs_translate_to_unix);
1267         if (!NT_STATUS_IS_OK(status)) {
1268                 errno = map_errno_from_nt_status(status);
1269                 return -1;
1270         }
1271
1272         mapped_smb_fname = synthetic_smb_fname(talloc_tos(),
1273                                         mapped_name,
1274                                         NULL,
1275                                         NULL,
1276                                         smb_fname->flags);
1277         if (mapped_smb_fname == NULL) {
1278                 TALLOC_FREE(mapped_name);
1279                 errno = ENOMEM;
1280                 return -1;
1281         }
1282         ret = SMB_VFS_NEXT_CHMOD_ACL(handle, mapped_smb_fname, mode);
1283         saved_errno = errno;
1284         TALLOC_FREE(mapped_name);
1285         TALLOC_FREE(mapped_smb_fname);
1286         errno = saved_errno;
1287         return ret;
1288 }
1289
1290 static SMB_ACL_T
1291 catia_sys_acl_get_file(vfs_handle_struct *handle,
1292                         const struct smb_filename *smb_fname,
1293                         SMB_ACL_TYPE_T type,
1294                         TALLOC_CTX *mem_ctx)
1295 {
1296         char *mapped_name = NULL;
1297         struct smb_filename *mapped_smb_fname = NULL;
1298         NTSTATUS status;
1299         SMB_ACL_T ret;
1300         int saved_errno = 0;
1301
1302         status = catia_string_replace_allocate(handle->conn,
1303                                 smb_fname->base_name,
1304                                 &mapped_name,
1305                                 vfs_translate_to_unix);
1306         if (!NT_STATUS_IS_OK(status)) {
1307                 errno = map_errno_from_nt_status(status);
1308                 return (SMB_ACL_T)NULL;
1309         }
1310
1311         mapped_smb_fname = synthetic_smb_fname(talloc_tos(),
1312                                         mapped_name,
1313                                         NULL,
1314                                         NULL,
1315                                         smb_fname->flags);
1316         if (mapped_smb_fname == NULL) {
1317                 TALLOC_FREE(mapped_name);
1318                 errno = ENOMEM;
1319                 return (SMB_ACL_T)NULL;
1320         }
1321
1322         ret = SMB_VFS_NEXT_SYS_ACL_GET_FILE(handle, mapped_smb_fname,
1323                         type, mem_ctx);
1324         if (ret == (SMB_ACL_T)NULL) {
1325                 saved_errno = errno;
1326         }
1327         TALLOC_FREE(mapped_smb_fname);
1328         TALLOC_FREE(mapped_name);
1329         if (saved_errno != 0) {
1330                 errno = saved_errno;
1331         }
1332         return ret;
1333 }
1334
1335 static int
1336 catia_sys_acl_set_file(vfs_handle_struct *handle,
1337                         const struct smb_filename *smb_fname,
1338                         SMB_ACL_TYPE_T type,
1339                         SMB_ACL_T theacl)
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
1367         ret = SMB_VFS_NEXT_SYS_ACL_SET_FILE(handle, mapped_smb_fname,
1368                         type, theacl);
1369         if (ret == -1) {
1370                 saved_errno = errno;
1371         }
1372         TALLOC_FREE(mapped_smb_fname);
1373         TALLOC_FREE(mapped_name);
1374         if (saved_errno != 0) {
1375                 errno = saved_errno;
1376         }
1377         return ret;
1378 }
1379
1380 static int
1381 catia_sys_acl_delete_def_file(vfs_handle_struct *handle,
1382                                 const struct smb_filename *smb_fname)
1383 {
1384         struct smb_filename *mapped_smb_fname = NULL;
1385         int saved_errno = 0;
1386         char *mapped_name = NULL;
1387         NTSTATUS status;
1388         int ret;
1389
1390         status = catia_string_replace_allocate(handle->conn,
1391                                 smb_fname->base_name,
1392                                 &mapped_name,
1393                                 vfs_translate_to_unix);
1394         if (!NT_STATUS_IS_OK(status)) {
1395                 errno = map_errno_from_nt_status(status);
1396                 return -1;
1397         }
1398
1399         mapped_smb_fname = synthetic_smb_fname(talloc_tos(),
1400                                         mapped_name,
1401                                         NULL,
1402                                         NULL,
1403                                         smb_fname->flags);
1404         if (mapped_smb_fname == NULL) {
1405                 TALLOC_FREE(mapped_name);
1406                 errno = ENOMEM;
1407                 return -1;
1408         }
1409         ret = SMB_VFS_NEXT_SYS_ACL_DELETE_DEF_FILE(handle, mapped_smb_fname);
1410         if (ret == -1) {
1411                 saved_errno = errno;
1412         }
1413         TALLOC_FREE(mapped_smb_fname);
1414         TALLOC_FREE(mapped_name);
1415         if (saved_errno != 0) {
1416                 errno = saved_errno;
1417         }
1418         return ret;
1419 }
1420
1421 static ssize_t
1422 catia_getxattr(vfs_handle_struct *handle,
1423                         const struct smb_filename *smb_fname,
1424                         const char *name,
1425                         void *value,
1426                         size_t size)
1427 {
1428         struct smb_filename *mapped_smb_fname = NULL;
1429         char *mapped_name = NULL;
1430         char *mapped_ea_name = NULL;
1431         NTSTATUS status;
1432         ssize_t ret;
1433         int saved_errno = 0;
1434
1435         status = catia_string_replace_allocate(handle->conn,
1436                                 smb_fname->base_name,
1437                                 &mapped_name,
1438                                 vfs_translate_to_unix);
1439         if (!NT_STATUS_IS_OK(status)) {
1440                 errno = map_errno_from_nt_status(status);
1441                 return -1;
1442         }
1443
1444         status = catia_string_replace_allocate(handle->conn,
1445                                 name, &mapped_ea_name, vfs_translate_to_unix);
1446         if (!NT_STATUS_IS_OK(status)) {
1447                 TALLOC_FREE(mapped_name);
1448                 errno = map_errno_from_nt_status(status);
1449                 return -1;
1450         }
1451
1452         mapped_smb_fname = synthetic_smb_fname(talloc_tos(),
1453                                         mapped_name,
1454                                         NULL,
1455                                         NULL,
1456                                         smb_fname->flags);
1457         if (mapped_smb_fname == NULL) {
1458                 TALLOC_FREE(mapped_name);
1459                 TALLOC_FREE(mapped_ea_name);
1460                 errno = ENOMEM;
1461                 return -1;
1462         }
1463
1464         ret = SMB_VFS_NEXT_GETXATTR(handle, mapped_smb_fname,
1465                                 mapped_ea_name, value, size);
1466         if (ret == -1) {
1467                 saved_errno = errno;
1468         }
1469         TALLOC_FREE(mapped_name);
1470         TALLOC_FREE(mapped_ea_name);
1471         TALLOC_FREE(mapped_smb_fname);
1472         if (saved_errno != 0) {
1473                 errno = saved_errno;
1474         }
1475
1476         return ret;
1477 }
1478
1479 static ssize_t
1480 catia_listxattr(vfs_handle_struct *handle,
1481                 const struct smb_filename *smb_fname,
1482                 char *list, size_t size)
1483 {
1484         struct smb_filename *mapped_smb_fname = NULL;
1485         char *mapped_name = NULL;
1486         NTSTATUS status;
1487         ssize_t ret;
1488         int saved_errno = 0;
1489
1490         status = catia_string_replace_allocate(handle->conn,
1491                                 smb_fname->base_name,
1492                                 &mapped_name,
1493                                 vfs_translate_to_unix);
1494         if (!NT_STATUS_IS_OK(status)) {
1495                 errno = map_errno_from_nt_status(status);
1496                 return -1;
1497         }
1498
1499         mapped_smb_fname = synthetic_smb_fname(talloc_tos(),
1500                                         mapped_name,
1501                                         NULL,
1502                                         NULL,
1503                                         smb_fname->flags);
1504         if (mapped_smb_fname == NULL) {
1505                 TALLOC_FREE(mapped_name);
1506                 errno = ENOMEM;
1507                 return -1;
1508         }
1509
1510         ret = SMB_VFS_NEXT_LISTXATTR(handle, mapped_smb_fname, list, size);
1511         if (ret == -1) {
1512                 saved_errno = errno;
1513         }
1514         TALLOC_FREE(mapped_name);
1515         TALLOC_FREE(mapped_smb_fname);
1516         if (saved_errno != 0) {
1517                 errno = saved_errno;
1518         }
1519
1520         return ret;
1521 }
1522
1523 static int
1524 catia_removexattr(vfs_handle_struct *handle,
1525                         const struct smb_filename *smb_fname,
1526                         const char *name)
1527 {
1528         struct smb_filename *mapped_smb_fname = NULL;
1529         char *mapped_name = NULL;
1530         char *mapped_ea_name = NULL;
1531         NTSTATUS status;
1532         ssize_t ret;
1533         int saved_errno = 0;
1534
1535         status = catia_string_replace_allocate(handle->conn,
1536                                 smb_fname->base_name,
1537                                 &mapped_name,
1538                                 vfs_translate_to_unix);
1539         if (!NT_STATUS_IS_OK(status)) {
1540                 errno = map_errno_from_nt_status(status);
1541                 return -1;
1542         }
1543
1544         status = catia_string_replace_allocate(handle->conn,
1545                                 name, &mapped_ea_name, vfs_translate_to_unix);
1546         if (!NT_STATUS_IS_OK(status)) {
1547                 TALLOC_FREE(mapped_name);
1548                 errno = map_errno_from_nt_status(status);
1549                 return -1;
1550         }
1551
1552         mapped_smb_fname = synthetic_smb_fname(talloc_tos(),
1553                                         mapped_name,
1554                                         NULL,
1555                                         NULL,
1556                                         smb_fname->flags);
1557         if (mapped_smb_fname == NULL) {
1558                 TALLOC_FREE(mapped_name);
1559                 TALLOC_FREE(mapped_ea_name);
1560                 errno = ENOMEM;
1561                 return -1;
1562         }
1563
1564         ret = SMB_VFS_NEXT_REMOVEXATTR(handle, mapped_smb_fname,
1565                                 mapped_ea_name);
1566         if (ret == -1) {
1567                 saved_errno = errno;
1568         }
1569         TALLOC_FREE(mapped_name);
1570         TALLOC_FREE(mapped_ea_name);
1571         TALLOC_FREE(mapped_smb_fname);
1572         if (saved_errno != 0) {
1573                 errno = saved_errno;
1574         }
1575
1576         return ret;
1577 }
1578
1579 static int
1580 catia_setxattr(vfs_handle_struct *handle,
1581                         const struct smb_filename *smb_fname,
1582                         const char *name,
1583                         const void *value,
1584                         size_t size,
1585                         int flags)
1586 {
1587         struct smb_filename *mapped_smb_fname = NULL;
1588         char *mapped_name = NULL;
1589         char *mapped_ea_name = NULL;
1590         NTSTATUS status;
1591         ssize_t ret;
1592         int saved_errno = 0;
1593
1594         status = catia_string_replace_allocate(handle->conn,
1595                                 smb_fname->base_name,
1596                                 &mapped_name,
1597                                 vfs_translate_to_unix);
1598         if (!NT_STATUS_IS_OK(status)) {
1599                 errno = map_errno_from_nt_status(status);
1600                 return -1;
1601         }
1602
1603         status = catia_string_replace_allocate(handle->conn,
1604                                 name, &mapped_ea_name, vfs_translate_to_unix);
1605         if (!NT_STATUS_IS_OK(status)) {
1606                 TALLOC_FREE(mapped_name);
1607                 errno = map_errno_from_nt_status(status);
1608                 return -1;
1609         }
1610
1611         mapped_smb_fname = synthetic_smb_fname(talloc_tos(),
1612                                         mapped_name,
1613                                         NULL,
1614                                         NULL,
1615                                         smb_fname->flags);
1616         if (mapped_smb_fname == NULL) {
1617                 TALLOC_FREE(mapped_name);
1618                 TALLOC_FREE(mapped_ea_name);
1619                 errno = ENOMEM;
1620                 return -1;
1621         }
1622
1623         ret = SMB_VFS_NEXT_SETXATTR(handle, mapped_smb_fname, mapped_ea_name,
1624                         value, size, flags);
1625         if (ret == -1) {
1626                 saved_errno = errno;
1627         }
1628         TALLOC_FREE(mapped_name);
1629         TALLOC_FREE(mapped_ea_name);
1630         TALLOC_FREE(mapped_smb_fname);
1631         if (saved_errno != 0) {
1632                 errno = saved_errno;
1633         }
1634
1635         return ret;
1636 }
1637
1638 static int catia_fstat(vfs_handle_struct *handle,
1639                        files_struct *fsp,
1640                        SMB_STRUCT_STAT *sbuf)
1641 {
1642         struct catia_cache *cc = NULL;
1643         int ret;
1644
1645         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
1646         if (ret != 0) {
1647                 return ret;
1648         }
1649
1650         ret = SMB_VFS_NEXT_FSTAT(handle, fsp, sbuf);
1651
1652         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
1653
1654         return ret;
1655 }
1656
1657 static ssize_t catia_pread(vfs_handle_struct *handle,
1658                            files_struct *fsp, void *data,
1659                            size_t n, off_t offset)
1660 {
1661         struct catia_cache *cc = NULL;
1662         ssize_t result;
1663         int ret;
1664
1665         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
1666         if (ret != 0) {
1667                 return ret;
1668         }
1669
1670         result = SMB_VFS_NEXT_PREAD(handle, fsp, data, n, offset);
1671
1672         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
1673
1674         return result;
1675 }
1676
1677 static ssize_t catia_pwrite(vfs_handle_struct *handle,
1678                             files_struct *fsp, const void *data,
1679                             size_t n, off_t offset)
1680 {
1681         struct catia_cache *cc = NULL;
1682         ssize_t result;
1683         int ret;
1684
1685         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
1686         if (ret != 0) {
1687                 return ret;
1688         }
1689
1690         result = SMB_VFS_NEXT_PWRITE(handle, fsp, data, n, offset);
1691
1692         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
1693
1694         return result;
1695 }
1696
1697 static int catia_ftruncate(struct vfs_handle_struct *handle,
1698                            struct files_struct *fsp,
1699                            off_t offset)
1700 {
1701         struct catia_cache *cc = NULL;
1702         int ret;
1703
1704         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
1705         if (ret != 0) {
1706                 return ret;
1707         }
1708
1709         ret = SMB_VFS_NEXT_FTRUNCATE(handle, fsp, offset);
1710
1711         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
1712
1713         return ret;
1714 }
1715
1716 static int catia_fallocate(struct vfs_handle_struct *handle,
1717                            struct files_struct *fsp,
1718                            uint32_t mode,
1719                            off_t offset,
1720                            off_t len)
1721 {
1722         struct catia_cache *cc = NULL;
1723         int ret;
1724
1725         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
1726         if (ret != 0) {
1727                 return ret;
1728         }
1729
1730         ret = SMB_VFS_NEXT_FALLOCATE(handle, fsp, mode, offset, len);
1731
1732         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
1733
1734         return ret;
1735 }
1736
1737 static ssize_t catia_fgetxattr(struct vfs_handle_struct *handle,
1738                                struct files_struct *fsp,
1739                                const char *name,
1740                                void *value,
1741                                size_t size)
1742 {
1743         char *mapped_xattr_name = NULL;
1744         NTSTATUS status;
1745         ssize_t result;
1746
1747         status = catia_string_replace_allocate(handle->conn,
1748                                                name, &mapped_xattr_name,
1749                                                vfs_translate_to_unix);
1750         if (!NT_STATUS_IS_OK(status)) {
1751                 errno = map_errno_from_nt_status(status);
1752                 return -1;
1753         }
1754
1755         result = SMB_VFS_NEXT_FGETXATTR(handle, fsp, mapped_xattr_name,
1756                                         value, size);
1757
1758         TALLOC_FREE(mapped_xattr_name);
1759
1760         return result;
1761 }
1762
1763 static ssize_t catia_flistxattr(struct vfs_handle_struct *handle,
1764                                 struct files_struct *fsp,
1765                                 char *list,
1766                                 size_t size)
1767 {
1768         struct catia_cache *cc = NULL;
1769         ssize_t result;
1770         int ret;
1771
1772         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
1773         if (ret != 0) {
1774                 return ret;
1775         }
1776
1777         result = SMB_VFS_NEXT_FLISTXATTR(handle, fsp, list, size);
1778
1779         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
1780
1781         return result;
1782 }
1783
1784 static int catia_fremovexattr(struct vfs_handle_struct *handle,
1785                               struct files_struct *fsp,
1786                               const char *name)
1787 {
1788         char *mapped_name = NULL;
1789         NTSTATUS status;
1790         int ret;
1791
1792         status = catia_string_replace_allocate(handle->conn,
1793                                 name, &mapped_name, vfs_translate_to_unix);
1794         if (!NT_STATUS_IS_OK(status)) {
1795                 errno = map_errno_from_nt_status(status);
1796                 return -1;
1797         }
1798
1799         ret = SMB_VFS_NEXT_FREMOVEXATTR(handle, fsp, mapped_name);
1800
1801         TALLOC_FREE(mapped_name);
1802
1803         return ret;
1804 }
1805
1806 static int catia_fsetxattr(struct vfs_handle_struct *handle,
1807                            struct files_struct *fsp,
1808                            const char *name,
1809                            const void *value,
1810                            size_t size,
1811                            int flags)
1812 {
1813         char *mapped_xattr_name = NULL;
1814         NTSTATUS status;
1815         int ret;
1816
1817         status = catia_string_replace_allocate(
1818                 handle->conn, name, &mapped_xattr_name, vfs_translate_to_unix);
1819         if (!NT_STATUS_IS_OK(status)) {
1820                 errno = map_errno_from_nt_status(status);
1821                 return -1;
1822         }
1823
1824         ret = SMB_VFS_NEXT_FSETXATTR(handle, fsp, mapped_xattr_name,
1825                                      value, size, flags);
1826
1827         TALLOC_FREE(mapped_xattr_name);
1828
1829         return ret;
1830 }
1831
1832 static SMB_ACL_T catia_sys_acl_get_fd(vfs_handle_struct *handle,
1833                                       files_struct *fsp,
1834                                       TALLOC_CTX *mem_ctx)
1835 {
1836         struct catia_cache *cc = NULL;
1837         struct smb_acl_t *result = NULL;
1838         int ret;
1839
1840         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
1841         if (ret != 0) {
1842                 return NULL;
1843         }
1844
1845         result = SMB_VFS_NEXT_SYS_ACL_GET_FD(handle, fsp, mem_ctx);
1846
1847         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
1848
1849         return result;
1850 }
1851
1852 static int catia_sys_acl_blob_get_fd(vfs_handle_struct *handle,
1853                                      files_struct *fsp,
1854                                      TALLOC_CTX *mem_ctx,
1855                                      char **blob_description,
1856                                      DATA_BLOB *blob)
1857 {
1858         struct catia_cache *cc = NULL;
1859         int ret;
1860
1861         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
1862         if (ret != 0) {
1863                 return ret;
1864         }
1865
1866         ret = SMB_VFS_NEXT_SYS_ACL_BLOB_GET_FD(handle, fsp, mem_ctx,
1867                                                blob_description, blob);
1868
1869         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
1870
1871         return ret;
1872 }
1873
1874 static int catia_sys_acl_set_fd(vfs_handle_struct *handle,
1875                                 files_struct *fsp,
1876                                 SMB_ACL_T theacl)
1877 {
1878         struct catia_cache *cc = NULL;
1879         int ret;
1880
1881         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
1882         if (ret != 0) {
1883                 return ret;
1884         }
1885
1886         ret = SMB_VFS_NEXT_SYS_ACL_SET_FD(handle, fsp, theacl);
1887
1888         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
1889
1890         return ret;
1891 }
1892
1893 static int catia_fchmod_acl(vfs_handle_struct *handle,
1894                             files_struct *fsp,
1895                             mode_t mode)
1896 {
1897         struct catia_cache *cc = NULL;
1898         int ret;
1899
1900         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
1901         if (ret != 0) {
1902                 return ret;
1903         }
1904
1905         ret = SMB_VFS_NEXT_FCHMOD_ACL(handle, fsp, mode);
1906
1907         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
1908
1909         return ret;
1910 }
1911
1912 static NTSTATUS catia_fget_nt_acl(vfs_handle_struct *handle,
1913                                   files_struct *fsp,
1914                                   uint32_t security_info,
1915                                   TALLOC_CTX *mem_ctx,
1916                                   struct security_descriptor **ppdesc)
1917 {
1918         struct catia_cache *cc = NULL;
1919         NTSTATUS status;
1920         int ret;
1921
1922         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
1923         if (ret != 0) {
1924                 return map_nt_error_from_unix(errno);
1925         }
1926
1927         status = SMB_VFS_NEXT_FGET_NT_ACL(handle, fsp, security_info,
1928                                           mem_ctx, ppdesc);
1929
1930         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
1931
1932         return status;
1933 }
1934
1935 static NTSTATUS catia_fset_nt_acl(vfs_handle_struct *handle,
1936                                   files_struct *fsp,
1937                                   uint32_t security_info_sent,
1938                                   const struct security_descriptor *psd)
1939 {
1940         struct catia_cache *cc = NULL;
1941         NTSTATUS status;
1942         int ret;
1943
1944         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
1945         if (ret != 0) {
1946                 return map_nt_error_from_unix(errno);
1947         }
1948
1949         status = SMB_VFS_NEXT_FSET_NT_ACL(handle, fsp, security_info_sent, psd);
1950
1951         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
1952
1953         return status;
1954 }
1955
1956 static NTSTATUS catia_fset_dos_attributes(struct vfs_handle_struct *handle,
1957                                           struct files_struct *fsp,
1958                                           uint32_t dosmode)
1959 {
1960         struct catia_cache *cc = NULL;
1961         NTSTATUS status;
1962         int ret;
1963
1964         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
1965         if (ret != 0) {
1966                 return map_nt_error_from_unix(errno);
1967         }
1968
1969         status = SMB_VFS_NEXT_FSET_DOS_ATTRIBUTES(handle, fsp, dosmode);
1970
1971         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
1972
1973         return status;
1974 }
1975
1976 static NTSTATUS catia_fget_dos_attributes(struct vfs_handle_struct *handle,
1977                                           struct files_struct *fsp,
1978                                           uint32_t *dosmode)
1979 {
1980         struct catia_cache *cc = NULL;
1981         NTSTATUS status;
1982         int ret;
1983
1984         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
1985         if (ret != 0) {
1986                 return map_nt_error_from_unix(errno);
1987         }
1988
1989         status = SMB_VFS_NEXT_FGET_DOS_ATTRIBUTES(handle, fsp, dosmode);
1990
1991         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
1992
1993         return status;
1994 }
1995
1996 static int catia_fchown(vfs_handle_struct *handle,
1997                         files_struct *fsp,
1998                         uid_t uid,
1999                         gid_t gid)
2000 {
2001         struct catia_cache *cc = NULL;
2002         int ret;
2003
2004         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
2005         if (ret != 0) {
2006                 return ret;
2007         }
2008
2009         ret = SMB_VFS_NEXT_FCHOWN(handle, fsp, uid, gid);
2010
2011         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
2012
2013         return ret;
2014 }
2015
2016 static int catia_fchmod(vfs_handle_struct *handle,
2017                         files_struct *fsp,
2018                         mode_t mode)
2019 {
2020         struct catia_cache *cc = NULL;
2021         int ret;
2022
2023         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
2024         if (ret != 0) {
2025                 return ret;
2026         }
2027
2028         ret = SMB_VFS_NEXT_FCHMOD(handle, fsp, mode);
2029
2030         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
2031
2032         return ret;
2033 }
2034
2035 struct catia_pread_state {
2036         ssize_t ret;
2037         struct vfs_aio_state vfs_aio_state;
2038         struct files_struct *fsp;
2039         struct catia_cache *cc;
2040 };
2041
2042 static void catia_pread_done(struct tevent_req *subreq);
2043
2044 static struct tevent_req *catia_pread_send(struct vfs_handle_struct *handle,
2045                                            TALLOC_CTX *mem_ctx,
2046                                            struct tevent_context *ev,
2047                                            struct files_struct *fsp,
2048                                            void *data,
2049                                            size_t n,
2050                                            off_t offset)
2051 {
2052         struct tevent_req *req = NULL, *subreq = NULL;
2053         struct catia_pread_state *state = NULL;
2054         int ret;
2055
2056         req = tevent_req_create(mem_ctx, &state,
2057                                 struct catia_pread_state);
2058         if (req == NULL) {
2059                 return NULL;
2060         }
2061         state->fsp = fsp;
2062
2063         ret = CATIA_FETCH_FSP_PRE_NEXT(state, handle, fsp, &state->cc);
2064         if (ret != 0) {
2065                 tevent_req_error(req, errno);
2066                 return tevent_req_post(req, ev);
2067         }
2068
2069         subreq = SMB_VFS_NEXT_PREAD_SEND(state, ev, handle, fsp, data,
2070                                          n, offset);
2071         if (tevent_req_nomem(subreq, req)) {
2072                 return tevent_req_post(req, ev);
2073         }
2074         tevent_req_set_callback(subreq, catia_pread_done, req);
2075
2076         return req;
2077 }
2078
2079 static void catia_pread_done(struct tevent_req *subreq)
2080 {
2081         struct tevent_req *req = tevent_req_callback_data(
2082                 subreq, struct tevent_req);
2083         struct catia_pread_state *state = tevent_req_data(
2084                 req, struct catia_pread_state);
2085
2086         state->ret = SMB_VFS_PREAD_RECV(subreq, &state->vfs_aio_state);
2087         TALLOC_FREE(subreq);
2088
2089         CATIA_FETCH_FSP_POST_NEXT(&state->cc, state->fsp);
2090
2091         tevent_req_done(req);
2092 }
2093
2094 static ssize_t catia_pread_recv(struct tevent_req *req,
2095                                 struct vfs_aio_state *vfs_aio_state)
2096 {
2097         struct catia_pread_state *state = tevent_req_data(
2098                 req, struct catia_pread_state);
2099
2100         if (tevent_req_is_unix_error(req, &vfs_aio_state->error)) {
2101                 return -1;
2102         }
2103
2104         *vfs_aio_state = state->vfs_aio_state;
2105         return state->ret;
2106 }
2107
2108 struct catia_pwrite_state {
2109         ssize_t ret;
2110         struct vfs_aio_state vfs_aio_state;
2111         struct files_struct *fsp;
2112         struct catia_cache *cc;
2113 };
2114
2115 static void catia_pwrite_done(struct tevent_req *subreq);
2116
2117 static struct tevent_req *catia_pwrite_send(struct vfs_handle_struct *handle,
2118                                             TALLOC_CTX *mem_ctx,
2119                                             struct tevent_context *ev,
2120                                             struct files_struct *fsp,
2121                                             const void *data,
2122                                             size_t n,
2123                                             off_t offset)
2124 {
2125         struct tevent_req *req = NULL, *subreq = NULL;
2126         struct catia_pwrite_state *state = NULL;
2127         int ret;
2128
2129         req = tevent_req_create(mem_ctx, &state,
2130                                 struct catia_pwrite_state);
2131         if (req == NULL) {
2132                 return NULL;
2133         }
2134         state->fsp = fsp;
2135
2136         ret = CATIA_FETCH_FSP_PRE_NEXT(state, handle, fsp, &state->cc);
2137         if (ret != 0) {
2138                 tevent_req_error(req, errno);
2139                 return tevent_req_post(req, ev);
2140         }
2141
2142         subreq = SMB_VFS_NEXT_PWRITE_SEND(state, ev, handle, fsp, data,
2143                                           n, offset);
2144         if (tevent_req_nomem(subreq, req)) {
2145                 return tevent_req_post(req, ev);
2146         }
2147         tevent_req_set_callback(subreq, catia_pwrite_done, req);
2148
2149         return req;
2150 }
2151
2152 static void catia_pwrite_done(struct tevent_req *subreq)
2153 {
2154         struct tevent_req *req = tevent_req_callback_data(
2155                 subreq, struct tevent_req);
2156         struct catia_pwrite_state *state = tevent_req_data(
2157                 req, struct catia_pwrite_state);
2158
2159         state->ret = SMB_VFS_PWRITE_RECV(subreq, &state->vfs_aio_state);
2160         TALLOC_FREE(subreq);
2161
2162         CATIA_FETCH_FSP_POST_NEXT(&state->cc, state->fsp);
2163
2164         tevent_req_done(req);
2165 }
2166
2167 static ssize_t catia_pwrite_recv(struct tevent_req *req,
2168                                 struct vfs_aio_state *vfs_aio_state)
2169 {
2170         struct catia_pwrite_state *state = tevent_req_data(
2171                 req, struct catia_pwrite_state);
2172
2173         if (tevent_req_is_unix_error(req, &vfs_aio_state->error)) {
2174                 return -1;
2175         }
2176
2177         *vfs_aio_state = state->vfs_aio_state;
2178         return state->ret;
2179 }
2180
2181 static off_t catia_lseek(vfs_handle_struct *handle,
2182                          files_struct *fsp,
2183                          off_t offset,
2184                          int whence)
2185 {
2186         struct catia_cache *cc = NULL;
2187         ssize_t result;
2188         int ret;
2189
2190         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
2191         if (ret != 0) {
2192                 return -1;
2193         }
2194
2195         result = SMB_VFS_NEXT_LSEEK(handle, fsp, offset, whence);
2196
2197         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
2198
2199         return result;
2200 }
2201
2202 static int catia_fsync(vfs_handle_struct *handle, files_struct *fsp)
2203 {
2204         struct catia_cache *cc = NULL;
2205         int ret;
2206
2207         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
2208         if (ret != 0) {
2209                 return -1;
2210         }
2211
2212         ret = SMB_VFS_NEXT_FSYNC(handle, fsp);
2213
2214         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
2215
2216         return ret;
2217 }
2218
2219 struct catia_fsync_state {
2220         int ret;
2221         struct vfs_aio_state vfs_aio_state;
2222         struct files_struct *fsp;
2223         struct catia_cache *cc;
2224 };
2225
2226 static void catia_fsync_done(struct tevent_req *subreq);
2227
2228 static struct tevent_req *catia_fsync_send(struct vfs_handle_struct *handle,
2229                                            TALLOC_CTX *mem_ctx,
2230                                            struct tevent_context *ev,
2231                                            struct files_struct *fsp)
2232 {
2233         struct tevent_req *req = NULL, *subreq = NULL;
2234         struct catia_fsync_state *state = NULL;
2235         int ret;
2236
2237         req = tevent_req_create(mem_ctx, &state,
2238                                 struct catia_fsync_state);
2239         if (req == NULL) {
2240                 return NULL;
2241         }
2242         state->fsp = fsp;
2243
2244         ret = CATIA_FETCH_FSP_PRE_NEXT(state, handle, fsp, &state->cc);
2245         if (ret != 0) {
2246                 tevent_req_error(req, errno);
2247                 return tevent_req_post(req, ev);
2248         }
2249
2250         subreq = SMB_VFS_NEXT_FSYNC_SEND(state, ev, handle, fsp);
2251         if (tevent_req_nomem(subreq, req)) {
2252                 return tevent_req_post(req, ev);
2253         }
2254         tevent_req_set_callback(subreq, catia_fsync_done, req);
2255
2256         return req;
2257 }
2258
2259 static void catia_fsync_done(struct tevent_req *subreq)
2260 {
2261         struct tevent_req *req = tevent_req_callback_data(
2262                 subreq, struct tevent_req);
2263         struct catia_fsync_state *state = tevent_req_data(
2264                 req, struct catia_fsync_state);
2265
2266         state->ret = SMB_VFS_FSYNC_RECV(subreq, &state->vfs_aio_state);
2267         TALLOC_FREE(subreq);
2268
2269         CATIA_FETCH_FSP_POST_NEXT(&state->cc, state->fsp);
2270
2271         tevent_req_done(req);
2272 }
2273
2274 static int catia_fsync_recv(struct tevent_req *req,
2275                             struct vfs_aio_state *vfs_aio_state)
2276 {
2277         struct catia_fsync_state *state = tevent_req_data(
2278                 req, struct catia_fsync_state);
2279
2280         if (tevent_req_is_unix_error(req, &vfs_aio_state->error)) {
2281                 return -1;
2282         }
2283
2284         *vfs_aio_state = state->vfs_aio_state;
2285         return state->ret;
2286 }
2287
2288 static bool catia_lock(vfs_handle_struct *handle,
2289                        files_struct *fsp,
2290                        int op,
2291                        off_t offset,
2292                        off_t count,
2293                        int type)
2294 {
2295         struct catia_cache *cc = NULL;
2296         bool ok;
2297         int ret;
2298
2299         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
2300         if (ret != 0) {
2301                 return -1;
2302         }
2303
2304         ok = SMB_VFS_NEXT_LOCK(handle, fsp, op, offset, count, type);
2305
2306         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
2307
2308         return ok;
2309 }
2310
2311 static int catia_kernel_flock(struct vfs_handle_struct *handle,
2312                               struct files_struct *fsp,
2313                               uint32_t share_mode,
2314                               uint32_t access_mask)
2315 {
2316         struct catia_cache *cc = NULL;
2317         int ret;
2318
2319         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
2320         if (ret != 0) {
2321                 return -1;
2322         }
2323
2324         ret = SMB_VFS_NEXT_KERNEL_FLOCK(handle, fsp, share_mode, access_mask);
2325
2326         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
2327
2328         return ret;
2329 }
2330
2331 static int catia_linux_setlease(vfs_handle_struct *handle,
2332                                 files_struct *fsp,
2333                                 int leasetype)
2334 {
2335         struct catia_cache *cc = NULL;
2336         int ret;
2337
2338         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
2339         if (ret != 0) {
2340                 return -1;
2341         }
2342
2343         ret = SMB_VFS_NEXT_LINUX_SETLEASE(handle, fsp, leasetype);
2344
2345         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
2346
2347         return ret;
2348 }
2349
2350 static bool catia_getlock(vfs_handle_struct *handle,
2351                           files_struct *fsp,
2352                           off_t *poffset,
2353                           off_t *pcount,
2354                           int *ptype,
2355                           pid_t *ppid)
2356 {
2357         struct catia_cache *cc = NULL;
2358         int ret;
2359         bool ok;
2360
2361         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
2362         if (ret != 0) {
2363                 return -1;
2364         }
2365
2366         ok = SMB_VFS_NEXT_GETLOCK(handle, fsp, poffset, pcount, ptype, ppid);
2367
2368         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
2369
2370         return ok;
2371 }
2372
2373 static bool catia_strict_lock_check(struct vfs_handle_struct *handle,
2374                                     struct files_struct *fsp,
2375                                     struct lock_struct *plock)
2376 {
2377         struct catia_cache *cc = NULL;
2378         int ret;
2379         bool ok;
2380
2381         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
2382         if (ret != 0) {
2383                 return -1;
2384         }
2385
2386         ok = SMB_VFS_NEXT_STRICT_LOCK_CHECK(handle, fsp, plock);
2387
2388         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
2389
2390         return ok;
2391 }
2392
2393 static NTSTATUS catia_fsctl(struct vfs_handle_struct *handle,
2394                             struct files_struct *fsp,
2395                             TALLOC_CTX *ctx,
2396                             uint32_t function,
2397                             uint16_t req_flags,
2398                             const uint8_t *_in_data,
2399                             uint32_t in_len,
2400                             uint8_t **_out_data,
2401                             uint32_t max_out_len,
2402                             uint32_t *out_len)
2403 {
2404         NTSTATUS result;
2405         struct catia_cache *cc = NULL;
2406         int ret;
2407
2408         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
2409         if (ret != 0) {
2410                 return map_nt_error_from_unix(errno);
2411         }
2412
2413         result = SMB_VFS_NEXT_FSCTL(handle,
2414                                 fsp,
2415                                 ctx,
2416                                 function,
2417                                 req_flags,
2418                                 _in_data,
2419                                 in_len,
2420                                 _out_data,
2421                                 max_out_len,
2422                                 out_len);
2423
2424         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
2425
2426         return result;
2427 }
2428
2429 static NTSTATUS catia_get_compression(vfs_handle_struct *handle,
2430                                       TALLOC_CTX *mem_ctx,
2431                                       struct files_struct *fsp,
2432                                       struct smb_filename *smb_fname,
2433                                       uint16_t *_compression_fmt)
2434 {
2435         NTSTATUS result;
2436         struct catia_cache *cc = NULL;
2437         int ret;
2438
2439         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
2440         if (ret != 0) {
2441                 return map_nt_error_from_unix(errno);
2442         }
2443
2444         result = SMB_VFS_NEXT_GET_COMPRESSION(handle, mem_ctx, fsp, smb_fname,
2445                                               _compression_fmt);
2446
2447         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
2448
2449         return result;
2450 }
2451
2452 static NTSTATUS catia_set_compression(vfs_handle_struct *handle,
2453                                       TALLOC_CTX *mem_ctx,
2454                                       struct files_struct *fsp,
2455                                       uint16_t compression_fmt)
2456 {
2457         NTSTATUS result;
2458         struct catia_cache *cc = NULL;
2459         int ret;
2460
2461         ret = CATIA_FETCH_FSP_PRE_NEXT(talloc_tos(), handle, fsp, &cc);
2462         if (ret != 0) {
2463                 return map_nt_error_from_unix(errno);
2464         }
2465
2466         result = SMB_VFS_NEXT_SET_COMPRESSION(handle, mem_ctx, fsp,
2467                                               compression_fmt);
2468
2469         CATIA_FETCH_FSP_POST_NEXT(&cc, fsp);
2470
2471         return result;
2472 }
2473
2474 static NTSTATUS catia_readdir_attr(struct vfs_handle_struct *handle,
2475                                    const struct smb_filename *smb_fname_in,
2476                                    TALLOC_CTX *mem_ctx,
2477                                    struct readdir_attr_data **pattr_data)
2478 {
2479         struct smb_filename *smb_fname;
2480         char *fname = NULL;
2481         NTSTATUS status;
2482
2483         status = catia_string_replace_allocate(handle->conn,
2484                                                smb_fname_in->base_name,
2485                                                &fname,
2486                                                vfs_translate_to_unix);
2487         if (!NT_STATUS_IS_OK(status)) {
2488                 errno = map_errno_from_nt_status(status);
2489                 return status;
2490         }
2491
2492         smb_fname = synthetic_smb_fname(talloc_tos(), fname, NULL,
2493                                         &smb_fname_in->st, 0);
2494
2495         status = SMB_VFS_NEXT_READDIR_ATTR(handle, smb_fname, mem_ctx, pattr_data);
2496
2497         TALLOC_FREE(smb_fname);
2498         return status;
2499 }
2500
2501 static NTSTATUS catia_get_dos_attributes(struct vfs_handle_struct *handle,
2502                                          struct smb_filename *smb_fname,
2503                                          uint32_t *dosmode)
2504 {
2505         char *mapped_name = NULL;
2506         const char *path = smb_fname->base_name;
2507         struct smb_filename *mapped_smb_fname = NULL;
2508         NTSTATUS status;
2509
2510         status = catia_string_replace_allocate(handle->conn,
2511                                 path, &mapped_name, vfs_translate_to_unix);
2512         if (!NT_STATUS_IS_OK(status)) {
2513                 errno = map_errno_from_nt_status(status);
2514                 return status;
2515         }
2516         mapped_smb_fname = synthetic_smb_fname(talloc_tos(),
2517                                         mapped_name,
2518                                         NULL,
2519                                         NULL,
2520                                         smb_fname->flags);
2521         if (mapped_smb_fname == NULL) {
2522                 TALLOC_FREE(mapped_name);
2523                 return NT_STATUS_NO_MEMORY;
2524         }
2525
2526         status = SMB_VFS_NEXT_GET_DOS_ATTRIBUTES(handle,
2527                                                  mapped_smb_fname,
2528                                                  dosmode);
2529         TALLOC_FREE(mapped_name);
2530         TALLOC_FREE(mapped_smb_fname);
2531
2532         return status;
2533 }
2534
2535 static NTSTATUS catia_set_dos_attributes(struct vfs_handle_struct *handle,
2536                                          const struct smb_filename *smb_fname,
2537                                          uint32_t dosmode)
2538 {
2539         char *mapped_name = NULL;
2540         const char *path = smb_fname->base_name;
2541         struct smb_filename *mapped_smb_fname = NULL;
2542         NTSTATUS status;
2543
2544         status = catia_string_replace_allocate(handle->conn,
2545                                 path, &mapped_name, vfs_translate_to_unix);
2546         if (!NT_STATUS_IS_OK(status)) {
2547                 errno = map_errno_from_nt_status(status);
2548                 return status;
2549         }
2550         mapped_smb_fname = synthetic_smb_fname(talloc_tos(),
2551                                         mapped_name,
2552                                         NULL,
2553                                         NULL,
2554                                         smb_fname->flags);
2555         if (mapped_smb_fname == NULL) {
2556                 TALLOC_FREE(mapped_name);
2557                 return NT_STATUS_NO_MEMORY;
2558         }
2559
2560         status = SMB_VFS_NEXT_SET_DOS_ATTRIBUTES(handle,
2561                                                  mapped_smb_fname,
2562                                                  dosmode);
2563         TALLOC_FREE(mapped_name);
2564         TALLOC_FREE(mapped_smb_fname);
2565
2566         return status;
2567 }
2568
2569 static struct vfs_fn_pointers vfs_catia_fns = {
2570         /* Directory operations */
2571         .mkdir_fn = catia_mkdir,
2572         .rmdir_fn = catia_rmdir,
2573         .opendir_fn = catia_opendir,
2574         .readdir_attr_fn = catia_readdir_attr,
2575
2576         /* File operations */
2577         .open_fn = catia_open,
2578         .pread_fn = catia_pread,
2579         .pread_send_fn = catia_pread_send,
2580         .pread_recv_fn = catia_pread_recv,
2581         .pwrite_fn = catia_pwrite,
2582         .pwrite_send_fn = catia_pwrite_send,
2583         .pwrite_recv_fn = catia_pwrite_recv,
2584         .lseek_fn = catia_lseek,
2585         .rename_fn = catia_rename,
2586         .fsync_fn = catia_fsync,
2587         .fsync_send_fn = catia_fsync_send,
2588         .fsync_recv_fn = catia_fsync_recv,
2589         .stat_fn = catia_stat,
2590         .fstat_fn = catia_fstat,
2591         .lstat_fn = catia_lstat,
2592         .unlink_fn = catia_unlink,
2593         .chmod_fn = catia_chmod,
2594         .fchmod_fn = catia_fchmod,
2595         .chown_fn = catia_chown,
2596         .fchown_fn = catia_fchown,
2597         .lchown_fn = catia_lchown,
2598         .chdir_fn = catia_chdir,
2599         .ntimes_fn = catia_ntimes,
2600         .ftruncate_fn = catia_ftruncate,
2601         .fallocate_fn = catia_fallocate,
2602         .lock_fn = catia_lock,
2603         .kernel_flock_fn = catia_kernel_flock,
2604         .linux_setlease_fn = catia_linux_setlease,
2605         .getlock_fn = catia_getlock,
2606         .realpath_fn = catia_realpath,
2607         .chflags_fn = catia_chflags,
2608         .streaminfo_fn = catia_streaminfo,
2609         .strict_lock_check_fn = catia_strict_lock_check,
2610         .translate_name_fn = catia_translate_name,
2611         .fsctl_fn = catia_fsctl,
2612         .get_dos_attributes_fn = catia_get_dos_attributes,
2613         .set_dos_attributes_fn = catia_set_dos_attributes,
2614         .fset_dos_attributes_fn = catia_fset_dos_attributes,
2615         .fget_dos_attributes_fn = catia_fget_dos_attributes,
2616         .get_compression_fn = catia_get_compression,
2617         .set_compression_fn = catia_set_compression,
2618
2619         /* NT ACL operations. */
2620         .get_nt_acl_fn = catia_get_nt_acl,
2621         .fget_nt_acl_fn = catia_fget_nt_acl,
2622         .fset_nt_acl_fn = catia_fset_nt_acl,
2623
2624         /* POSIX ACL operations. */
2625         .chmod_acl_fn = catia_chmod_acl,
2626         .fchmod_acl_fn = catia_fchmod_acl,
2627
2628         .sys_acl_get_file_fn = catia_sys_acl_get_file,
2629         .sys_acl_get_fd_fn = catia_sys_acl_get_fd,
2630         .sys_acl_blob_get_fd_fn = catia_sys_acl_blob_get_fd,
2631         .sys_acl_set_file_fn = catia_sys_acl_set_file,
2632         .sys_acl_set_fd_fn = catia_sys_acl_set_fd,
2633         .sys_acl_delete_def_file_fn = catia_sys_acl_delete_def_file,
2634
2635         /* EA operations. */
2636         .getxattr_fn = catia_getxattr,
2637         .listxattr_fn = catia_listxattr,
2638         .removexattr_fn = catia_removexattr,
2639         .setxattr_fn = catia_setxattr,
2640         .fgetxattr_fn = catia_fgetxattr,
2641         .flistxattr_fn = catia_flistxattr,
2642         .fremovexattr_fn = catia_fremovexattr,
2643         .fsetxattr_fn = catia_fsetxattr,
2644 };
2645
2646 static_decl_vfs;
2647 NTSTATUS vfs_catia_init(TALLOC_CTX *ctx)
2648 {
2649         NTSTATUS ret;
2650
2651         ret = smb_register_vfs(SMB_VFS_INTERFACE_VERSION, "catia",
2652                                 &vfs_catia_fns);
2653         if (!NT_STATUS_IS_OK(ret))
2654                 return ret;
2655
2656         vfs_catia_debug_level = debug_add_class("catia");
2657         if (vfs_catia_debug_level == -1) {
2658                 vfs_catia_debug_level = DBGC_VFS;
2659                 DEBUG(0, ("vfs_catia: Couldn't register custom debugging "
2660                           "class!\n"));
2661         } else {
2662                 DEBUG(10, ("vfs_catia: Debug class number of "
2663                            "'catia': %d\n", vfs_catia_debug_level));
2664         }
2665
2666         return ret;
2667
2668 }