2 * Unix SMB/CIFS implementation.
4 * Support for OneFS Alternate Data Streams
6 * Copyright (C) Tim Prouty, 2008
8 * This program is free software; you can redistribute it and/or modify
9 * it under the terms of the GNU General Public License as published by
10 * the Free Software Foundation; either version 3 of the License, or
11 * (at your option) any later version.
13 * This program is distributed in the hope that it will be useful,
14 * but WITHOUT ANY WARRANTY; without even the implied warranty of
15 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
16 * GNU General Public License for more details.
18 * You should have received a copy of the GNU General Public License
19 * along with this program; if not, see <http://www.gnu.org/licenses/>.
23 #include <sys/isi_enc.h>
26 * OneFS stores streams without the explicit :$DATA at the end, so this strips
27 * it off. All onefs_stream functions must call through this instead of
28 * split_ntfs_stream_name directly.
30 NTSTATUS onefs_split_ntfs_stream_name(TALLOC_CTX *mem_ctx, const char *fname,
31 char **pbase, char **pstream)
36 status = split_ntfs_stream_name(mem_ctx, fname, pbase, pstream);
37 if (!NT_STATUS_IS_OK(status)) {
41 /* Default $DATA stream. */
42 if (pstream == NULL || *pstream == NULL) {
46 /* Strip off the $DATA. */
47 stream = strrchr_m(*pstream, ':');
54 int onefs_is_stream(const char *path, char **pbase, char **pstream,
57 (*is_stream) = is_ntfs_stream_name(path);
63 if (!NT_STATUS_IS_OK(onefs_split_ntfs_stream_name(talloc_tos(), path,
65 DEBUG(10, ("onefs_split_ntfs_stream_name failed\n"));
73 int onefs_close(vfs_handle_struct *handle, struct files_struct *fsp)
78 ret = SMB_VFS_NEXT_CLOSE(handle, fsp->base_fsp);
80 ret2 = SMB_VFS_NEXT_CLOSE(handle, fsp);
82 return ret ? ret : ret2;
86 * Get the ADS directory fd for a file.
88 static int get_stream_dir_fd(connection_struct *conn, const char *base,
95 /* If a valid base_fdp was given, use it. */
96 if (base_fdp && *base_fdp >= 0) {
99 base_fd = onefs_sys_create_file(conn,
118 /* Open the ADS directory. */
119 dir_fd = onefs_sys_create_file(conn,
134 /* Close base_fd if it's not need or on error. */
135 if (!base_fdp || dir_fd < 0) {
141 /* Set the out base_fdp if successful and it was requested. */
142 if (base_fdp && dir_fd >= 0) {
149 int onefs_rename(vfs_handle_struct *handle, const char *oldname,
152 TALLOC_CTX *frame = NULL;
163 frame = talloc_stackframe();
165 ret = onefs_is_stream(oldname, &obase, &osname, &old_is_stream);
169 ret = onefs_is_stream(newname, &nbase, &nsname, &new_is_stream);
173 if (!old_is_stream && !new_is_stream) {
174 return SMB_VFS_NEXT_RENAME(handle, oldname, newname);
177 dir_fd = get_stream_dir_fd(handle->conn, obase, NULL);
182 DEBUG(8,("onefs_rename called for %s : %s => %s : %s\n",
183 obase, osname, nbase, nsname));
185 /* Handle rename of stream to default stream specially. */
186 if (nsname == NULL) {
187 ret = enc_renameat(dir_fd, osname, ENC_DEFAULT, AT_FDCWD,
190 ret = enc_renameat(dir_fd, osname, ENC_DEFAULT, dir_fd, nsname,
205 * Merge a base file's sbuf into the a streams's sbuf.
207 static void merge_stat(SMB_STRUCT_STAT *stream_sbuf,
208 const SMB_STRUCT_STAT *base_sbuf)
210 int dos_flags = (UF_DOS_NOINDEX | UF_DOS_ARCHIVE |
211 UF_DOS_HIDDEN | UF_DOS_RO | UF_DOS_SYSTEM);
212 stream_sbuf->st_mtime = base_sbuf->st_mtime;
213 stream_sbuf->st_ctime = base_sbuf->st_ctime;
214 stream_sbuf->st_atime = base_sbuf->st_atime;
215 stream_sbuf->st_flags &= ~dos_flags;
216 stream_sbuf->st_flags |= base_sbuf->st_flags & dos_flags;
219 /* fake timestamps */
220 static void onefs_adjust_stat_time(vfs_handle_struct *handle, const char *fname,
221 SMB_STRUCT_STAT *sbuf)
223 struct onefs_vfs_config cfg;
224 struct timeval tv_now = {0, 0};
225 bool static_mtime = False;
226 bool static_atime = False;
228 if (!onefs_get_config(SNUM(handle->conn),
229 ONEFS_VFS_CONFIG_FAKETIMESTAMPS, &cfg)) {
233 if (IS_MTIME_STATIC_PATH(handle->conn, &cfg, fname)) {
234 sbuf->st_mtime = sbuf->st_birthtime;
237 if (IS_ATIME_STATIC_PATH(handle->conn, &cfg, fname)) {
238 sbuf->st_atime = sbuf->st_birthtime;
242 if (IS_CTIME_NOW_PATH(handle->conn, &cfg, fname)) {
243 if (cfg.ctime_slop < 0) {
244 sbuf->st_birthtime = INT_MAX - 1;
246 GetTimeOfDay(&tv_now);
247 sbuf->st_birthtime = tv_now.tv_sec + cfg.ctime_slop;
251 if (!static_mtime && IS_MTIME_NOW_PATH(handle->conn,&cfg,fname)) {
252 if (cfg.mtime_slop < 0) {
253 sbuf->st_mtime = INT_MAX - 1;
255 if (tv_now.tv_sec == 0)
256 GetTimeOfDay(&tv_now);
257 sbuf->st_mtime = tv_now.tv_sec + cfg.mtime_slop;
260 if (!static_atime && IS_ATIME_NOW_PATH(handle->conn,&cfg,fname)) {
261 if (cfg.atime_slop < 0) {
262 sbuf->st_atime = INT_MAX - 1;
264 if (tv_now.tv_sec == 0)
265 GetTimeOfDay(&tv_now);
266 sbuf->st_atime = tv_now.tv_sec + cfg.atime_slop;
271 static int stat_stream(vfs_handle_struct *handle, const char *base,
272 const char *stream, SMB_STRUCT_STAT *sbuf, int flags)
274 SMB_STRUCT_STAT base_sbuf;
275 int base_fd = -1, dir_fd, ret, saved_errno;
277 dir_fd = get_stream_dir_fd(handle->conn, base, &base_fd);
282 /* Stat the stream. */
283 ret = enc_fstatat(dir_fd, stream, ENC_DEFAULT, sbuf, flags);
285 /* Now stat the base file and merge the results. */
286 ret = sys_fstat(base_fd, &base_sbuf);
288 merge_stat(sbuf, &base_sbuf);
299 int onefs_stat(vfs_handle_struct *handle, const char *path,
300 SMB_STRUCT_STAT *sbuf)
307 ret = onefs_is_stream(path, &base, &stream, &is_stream);
312 ret = SMB_VFS_NEXT_STAT(handle, path, sbuf);
313 } else if (!stream) {
314 /* If it's the ::$DATA stream just stat the base file name. */
315 ret = SMB_VFS_NEXT_STAT(handle, base, sbuf);
317 ret = stat_stream(handle, base, stream, sbuf, 0);
320 onefs_adjust_stat_time(handle, path, sbuf);
324 int onefs_fstat(vfs_handle_struct *handle, struct files_struct *fsp,
325 SMB_STRUCT_STAT *sbuf)
327 SMB_STRUCT_STAT base_sbuf;
330 /* Stat the stream, by calling next_fstat on the stream's fd. */
331 ret = SMB_VFS_NEXT_FSTAT(handle, fsp, sbuf);
336 /* Stat the base file and merge the results. */
337 if (fsp != NULL && fsp->base_fsp != NULL) {
338 ret = sys_fstat(fsp->base_fsp->fh->fd, &base_sbuf);
340 merge_stat(sbuf, &base_sbuf);
344 onefs_adjust_stat_time(handle, fsp->fsp_name, sbuf);
348 int onefs_lstat(vfs_handle_struct *handle, const char *path,
349 SMB_STRUCT_STAT *sbuf)
356 ret = onefs_is_stream(path, &base, &stream, &is_stream);
361 ret = SMB_VFS_NEXT_LSTAT(handle, path, sbuf);
362 } else if (!stream) {
363 /* If it's the ::$DATA stream just stat the base file name. */
364 ret = SMB_VFS_NEXT_LSTAT(handle, base, sbuf);
366 ret = stat_stream(handle, base, stream, sbuf,
367 AT_SYMLINK_NOFOLLOW);
370 onefs_adjust_stat_time(handle, path, sbuf);
374 int onefs_unlink(vfs_handle_struct *handle, const char *path)
380 int dir_fd, saved_errno;
382 ret = onefs_is_stream(path, &base, &stream, &is_stream);
388 return SMB_VFS_NEXT_UNLINK(handle, path);
391 /* If it's the ::$DATA stream just unlink the base file name. */
393 return SMB_VFS_NEXT_UNLINK(handle, base);
396 dir_fd = get_stream_dir_fd(handle->conn, base, NULL);
401 ret = enc_unlinkat(dir_fd, stream, ENC_DEFAULT, 0);
409 int onefs_vtimes_streams(vfs_handle_struct *handle, const char *fname,
410 int flags, struct timespec times[3])
419 START_PROFILE(syscall_ntimes);
421 ret = onefs_is_stream(fname, &base, &stream, &is_stream);
426 ret = vtimes(fname, times, flags);
430 dirfd = get_stream_dir_fd(handle->conn, base, NULL);
435 ret = enc_vtimesat(dirfd, stream, ENC_DEFAULT, times, flags);
437 END_PROFILE(syscall_ntimes);
445 int onefs_chflags(vfs_handle_struct *handle, const char *path,
451 if (!NT_STATUS_IS_OK(onefs_split_ntfs_stream_name(talloc_tos(), path,
453 DEBUG(10, ("onefs_split_ntfs_stream_name failed\n"));
459 * Only set the attributes on the base file. ifs_createfile handles
460 * file creation attribute semantics.
462 return SMB_VFS_NEXT_CHFLAGS(handle, base, flags);
466 * Streaminfo enumeration functionality
468 struct streaminfo_state {
470 vfs_handle_struct *handle;
471 unsigned int num_streams;
472 struct stream_struct *streams;
476 static bool add_one_stream(TALLOC_CTX *mem_ctx, unsigned int *num_streams,
477 struct stream_struct **streams,
478 const char *name, SMB_OFF_T size,
479 SMB_OFF_T alloc_size)
481 struct stream_struct *tmp;
483 tmp = TALLOC_REALLOC_ARRAY(mem_ctx, *streams, struct stream_struct,
489 tmp[*num_streams].name = talloc_asprintf(mem_ctx, ":%s:%s", name,
491 if (tmp[*num_streams].name == NULL) {
495 tmp[*num_streams].size = size;
496 tmp[*num_streams].alloc_size = alloc_size;
503 static NTSTATUS walk_onefs_streams(connection_struct *conn, files_struct *fsp,
505 struct streaminfo_state *state,
506 SMB_STRUCT_STAT *base_sbuf)
508 NTSTATUS status = NT_STATUS_OK;
509 bool opened_base_fd = false;
514 SMB_STRUCT_DIR *dirp = NULL;
515 SMB_STRUCT_DIRENT *dp = NULL;
516 files_struct fake_fs;
517 struct fd_handle fake_fh;
518 SMB_STRUCT_STAT stream_sbuf;
520 ZERO_STRUCT(fake_fh);
521 ZERO_STRUCT(fake_fs);
523 /* If the base file is already open, use its fd. */
524 if ((fsp != NULL) && (fsp->fh->fd != -1)) {
525 base_fd = fsp->fh->fd;
527 opened_base_fd = true;
530 dir_fd = get_stream_dir_fd(conn, fname, &base_fd);
532 return map_nt_error_from_unix(errno);
535 /* Open the ADS directory. */
536 if ((dirp = fdopendir(dir_fd)) == NULL) {
537 DEBUG(0, ("Error on opendir %s. errno=%d (%s)\n",
538 fname, errno, strerror(errno)));
539 status = map_nt_error_from_unix(errno);
544 fake_fs.fh = &fake_fh;
545 fake_fs.fsp_name = SMB_STRDUP(fname);
547 /* Iterate over the streams in the ADS directory. */
548 while ((dp = SMB_VFS_READDIR(conn, dirp, NULL)) != NULL) {
549 /* Skip the "." and ".." entries */
550 if ((strcmp(dp->d_name, ".") == 0) ||
551 (strcmp(dp->d_name, "..") == 0))
554 /* Open actual stream */
555 if ((stream_fd = onefs_sys_create_file(conn,
569 DEBUG(0, ("Error opening stream %s:%s. "
570 "errno=%d (%s)\n", fname, dp->d_name, errno,
575 /* Figure out the stat info. */
576 fake_fh.fd = stream_fd;
577 ret = SMB_VFS_FSTAT(&fake_fs, &stream_sbuf);
581 DEBUG(0, ("Error fstating stream %s:%s. "
582 "errno=%d (%s)\n", fname, dp->d_name, errno,
587 merge_stat(&stream_sbuf, base_sbuf);
589 if (!add_one_stream(state->mem_ctx,
590 &state->num_streams, &state->streams,
591 dp->d_name, stream_sbuf.st_size,
592 SMB_VFS_GET_ALLOC_SIZE(conn, NULL,
594 state->status = NT_STATUS_NO_MEMORY;
600 /* Cleanup everything that was opened. */
602 SMB_VFS_CLOSEDIR(conn, dirp);
607 if (opened_base_fd) {
608 SMB_ASSERT(base_fd >= 0);
612 SAFE_FREE(fake_fs.fsp_name);
616 NTSTATUS onefs_streaminfo(vfs_handle_struct *handle,
617 struct files_struct *fsp,
620 unsigned int *num_streams,
621 struct stream_struct **streams)
623 SMB_STRUCT_STAT sbuf;
626 struct streaminfo_state state;
628 /* Get a valid stat. */
629 if ((fsp != NULL) && (fsp->fh->fd != -1)) {
630 if (is_ntfs_stream_name(fsp->fsp_name)) {
631 return NT_STATUS_INVALID_PARAMETER;
633 ret = SMB_VFS_FSTAT(fsp, &sbuf);
635 if (is_ntfs_stream_name(fname)) {
636 return NT_STATUS_INVALID_PARAMETER;
638 ret = SMB_VFS_STAT(handle->conn, fname, &sbuf);
642 return map_nt_error_from_unix(errno);
645 state.streams = NULL;
646 state.num_streams = 0;
648 /* Add the default stream. */
649 if (S_ISREG(sbuf.st_mode)) {
650 if (!add_one_stream(mem_ctx,
651 &state.num_streams, &state.streams,
653 SMB_VFS_GET_ALLOC_SIZE(handle->conn, fsp,
655 return NT_STATUS_NO_MEMORY;
659 state.mem_ctx = mem_ctx;
660 state.handle = handle;
661 state.status = NT_STATUS_OK;
663 /* If there are more streams, add them too. */
664 if (sbuf.st_flags & UF_HASADS) {
666 status = walk_onefs_streams(handle->conn, fsp, fname,
669 if (!NT_STATUS_IS_OK(status)) {
670 TALLOC_FREE(state.streams);
674 if (!NT_STATUS_IS_OK(state.status)) {
675 TALLOC_FREE(state.streams);
680 *num_streams = state.num_streams;
681 *streams = state.streams;