haiku-beta6/src/add-ons/kernel/file_systems/ntfs/fs_func.c

/*
 * Copyright (c) 2000-2004 Anton Altaparmakov
 * Copyright (c) 2002-2006 Szabolcs Szakacsits
 *
 * Copyright (c) 2006-2007 Troeglazov Gerasim (3dEyes**)
 *
 * This program/include file is free software; you can redistribute it and/or
 * modify it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or (at your
 * option) any later version.
 *
 * This program/include file is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General
 * Public License for more details.
 *
 * You should have received a copy of the GNU General Public License along with
 * this program (in the main directory of the Linux-NTFS distribution in the
 * file COPYING); if not, write to the Free Software Foundation,Inc., 59 Temple
 * Place, Suite 330, Boston, MA 02111-1307 USA
 */


#include "fs_func.h"

#include <ctype.h>
#include <dirent.h>
#include <errno.h>
#include <fcntl.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/stat.h>
#include <time.h>
#include <unistd.h>

#include <disk_device_manager.h>
#include <driver_settings.h>
#include <KernelExport.h>

#include <kernel.h>

#include "attributes.h"
#include "fake_attributes.h"
#include "lock.h"
#include "ntfs.h"
#include "volume_util.h"


extern int	mkntfs_main(const char *devpath, const char *label);

typedef struct identify_cookie {
	NTFS_BOOT_SECTOR boot;
	char label[MAX_PATH];
} identify_cookie;


static bool
is_device_read_only(const char *device)
{
	bool isReadOnly = false;
	device_geometry geometry;
	int fd = open(device, O_RDONLY | O_NOCACHE);
	if (fd < 0)
		return false;

	if (ioctl(fd, B_GET_GEOMETRY, &geometry) == 0)
		isReadOnly = geometry.read_only;

	close(fd);
	return isReadOnly;
}


static status_t
get_node_type(ntfs_inode* ni, int* _type)
{
	ntfs_attr* na;

	if (ni->mrec->flags & MFT_RECORD_IS_DIRECTORY) {
		// Directory
		*_type = S_IFDIR;
		return B_OK;
	} else {
		// Regular or Interix (INTX) file
		*_type = S_IFREG;

		if (ni->flags & FILE_ATTR_SYSTEM) {
			na = ntfs_attr_open(ni, AT_DATA, NULL, 0);
			if (!na)
				return ENOENT;

			// Check whether it's Interix symbolic link
			if (na->data_size <= sizeof(INTX_FILE_TYPES) +
				sizeof(ntfschar) * PATH_MAX &&
				na->data_size > sizeof(INTX_FILE_TYPES)) {
				INTX_FILE *intx_file;

				intx_file = ntfs_malloc(na->data_size);
				if (!intx_file) {
					ntfs_attr_close(na);
					return EINVAL;
				}
				if (ntfs_attr_pread(na, 0, na->data_size,
						intx_file) != na->data_size) {
					free(intx_file);
					ntfs_attr_close(na);
					return EINVAL;
				}
				if (intx_file->magic == INTX_SYMBOLIC_LINK)
					*_type = FS_SLNK_MODE;
				free(intx_file);
			}
			ntfs_attr_close(na);
		}
	}

	return B_OK;
}


static u64
ntfs_inode_lookup(fs_volume *_vol, ino_t parent, const char *name)
{
	nspace *ns = (nspace*)_vol->private_volume;
	ntfschar *uname = NULL;
	int uname_len;
	u64 ino = (u64)-1;
	u64 inum;
	ntfs_inode *dir_ni;

	/* Open target directory. */
	dir_ni = ntfs_inode_open(ns->ntvol, parent);
	if (dir_ni) {
		uname_len = ntfs_mbstoucs(name, &uname);
		if (uname_len < 0) {
			errno = EINVAL;
			return (ino);
		}
		/* Lookup file */
		inum = ntfs_inode_lookup_by_name(dir_ni, uname, uname_len);
			/* never return inodes 0 and 1 */
		if (MREF(inum) <= 1) {
			inum = (u64)-1;
			errno = ENOENT;
		}
		if (ntfs_inode_close(dir_ni)
		    || (inum == (u64)-1))
			ino = (u64)-1;
		else
			ino = MREF(inum);
	}
	free(uname);
	return (ino);
}


static int
ntfs_remove(fs_volume *_vol, ino_t parent, const char *name)
{
	nspace *ns = (nspace*)_vol->private_volume;

	ntfschar *uname = NULL;
	ntfs_inode *ni = NULL;
	ntfs_inode *dir_ni = NULL;
	int result = B_OK;
	int uname_len;
	u64 iref;

	/* Open parent directory. */
	dir_ni = ntfs_inode_open(ns->ntvol, parent);
	if (!dir_ni) {
		result = EINVAL;
		goto exit;
	}
	/* Generate unicode filename. */
	uname_len = ntfs_mbstoucs(name, &uname);
	if (uname_len < 0) {
		result = EINVAL;
		goto exit;
	}
	/* Open object for delete. */
	iref = ntfs_inode_lookup_by_name(dir_ni, uname, uname_len);
	if (iref == (u64)-1) {
		result = EINVAL;
		goto exit;
	}
	/* deny unlinking metadata files */
	if (MREF(iref) < FILE_first_user) {
		result = EINVAL;
		goto exit;
	}

	ni = ntfs_inode_open(ns->ntvol, MREF(iref));
	if (!ni) {
		result = EINVAL;
		goto exit;
	}

	if (ntfs_delete(ns->ntvol, (char*)NULL, ni, dir_ni, uname, uname_len))
			result = EINVAL;
		/* ntfs_delete() always closes ni and dir_ni */
	ni = dir_ni = NULL;
exit:
	if (ni != NULL)
		ntfs_inode_close(ni);
	if (dir_ni != NULL)
		ntfs_inode_close(dir_ni);

	free(uname);
	return result;
}


void
fs_ntfs_update_times(fs_volume *vol, ntfs_inode *ni,
	ntfs_time_update_flags mask)
{
	nspace *ns = (nspace*)vol->private_volume;

	if (ns->noatime)
		mask &= ~NTFS_UPDATE_ATIME;

	ntfs_inode_update_times(ni, mask);
}


float
fs_identify_partition(int fd, partition_data *partition, void **_cookie)
{
	NTFS_BOOT_SECTOR boot;
	char devpath[MAX_PATH];
	identify_cookie *cookie = NULL;
	ntfs_volume *ntVolume;
	uint8 *buf = (uint8*)&boot;

	// read in the boot sector
	TRACE("fs_identify_partition: read in the boot sector\n");
	if (read_pos(fd, 0, (void*)&boot, 512) != 512) {
		ERROR("fs_identify_partition: couldn't read boot sector\n");
		return -1;
	}

	// check boot signature
	if ((buf[0x1fe] != 0x55 || buf[0x1ff] != 0xaa) && buf[0x15] == 0xf8) {
		ERROR("fs_identify_partition: boot signature doesn't match\n");
		return -1;
	}

	// check boot signature NTFS
	if (memcmp(buf + 3, "NTFS    ", 8) != 0) {
		ERROR("fs_identify_partition: boot signature NTFS doesn't match\n");
		return -1;
	}

	// allocate identify_cookie
	cookie = (identify_cookie *)malloc(sizeof(identify_cookie));
	if (!cookie) {
		ERROR("fs_identify_partition: cookie allocation failed\n");
		return -1;
	}

	cookie->label[0]='\0';
	memcpy(&cookie->boot, &boot, 512);

	// get path for device
	if (ioctl(fd, B_GET_PATH_FOR_DEVICE, devpath) != 0) {
		// try mount
		ntVolume = utils_mount_volume(devpath, NTFS_MNT_RDONLY | NTFS_MNT_RECOVER);
		if (ntVolume != NULL) {
			if (ntVolume->vol_name && ntVolume->vol_name[0] != '\0')
				strcpy(cookie->label, ntVolume->vol_name);
			ntfs_umount(ntVolume, true);
		}
	}

	*_cookie = cookie;

	// Make sure we return a higher number than the intel partition check
	// as this one is more accurate.
	return 0.82f;
}


status_t
fs_scan_partition(int fd, partition_data *partition, void *_cookie)
{
	identify_cookie *cookie = (identify_cookie *)_cookie;
	partition->status = B_PARTITION_VALID;
	partition->flags |= B_PARTITION_FILE_SYSTEM;
	partition->content_size = sle64_to_cpu(cookie->boot.number_of_sectors)
		* le16_to_cpu(cookie->boot.bpb.bytes_per_sector);
	partition->block_size = le16_to_cpu(cookie->boot.bpb.bytes_per_sector);
	partition->content_name = strdup(cookie->label);
	return B_OK;
}


void
fs_free_identify_partition_cookie(partition_data *partition, void *_cookie)
{
	identify_cookie *cookie = (identify_cookie *)_cookie;
	free(cookie);
}


uint32
fs_get_supported_operations(partition_data* partition, uint32 mask)
{
	return B_DISK_SYSTEM_SUPPORTS_INITIALIZING
		| B_DISK_SYSTEM_SUPPORTS_CONTENT_NAME
		| B_DISK_SYSTEM_SUPPORTS_WRITING;
}


status_t
fs_initialize(int fd, partition_id partitionID, const char* name,
	const char* parameterString, off_t partitionSize, disk_job_id job)
{
	char devpath[MAX_PATH];
	status_t result = B_OK;

	TRACE("fs_initialize - [%s] - [%s]\n",name, parameterString);

	update_disk_device_job_progress(job, 0);

	if (ioctl(fd, B_GET_PATH_FOR_DEVICE, devpath) != 0) {
		result = mkntfs_main(devpath, name);
		if (result != 0)
			return result;
	} else
		return B_BAD_VALUE;

	result = scan_partition(partitionID);
	if (result != B_OK)
		return result;

	update_disk_device_job_progress(job, 1);

	return result;
}


status_t
fs_mount(fs_volume *_vol, const char *device, uint32 flags, const char *args,
	ino_t *_rootID)
{
	nspace *ns;
	vnode *newNode = NULL;
	char lockname[32];
	void *handle;
	unsigned long mountFlags = 0;
	status_t result = B_NO_ERROR;

	TRACE("fs_mount - ENTER\n");

	ns = ntfs_malloc(sizeof(nspace));
	if (!ns) {
		result = ENOMEM;
		goto exit;
	}

	*ns = (nspace) {
		.state = NF_FreeClustersOutdate | NF_FreeMFTOutdate,
		.show_sys_files = false,
		.ro = false,
		.fake_attrib = false,
		.flags = 0
	};

	strlcpy(ns->devicePath, device, sizeof(ns->devicePath));

	sprintf(lockname, "ntfs_lock %" B_PRIx32, ns->id);
	recursive_lock_init_etc(&(ns->vlock), lockname, MUTEX_FLAG_CLONE_NAME);

	handle = load_driver_settings("ntfs");
	ns->show_sys_files = ! (strcasecmp(get_driver_parameter(handle,
		"hide_sys_files", "true", "true"), "true") == 0);
	ns->ro = strcasecmp(get_driver_parameter(handle, "read_only", "false",
		"false"), "false") != 0;
	ns->noatime = strcasecmp(get_driver_parameter(handle, "no_atime", "true",
		"true"), "true") == 0;
	ns->fake_attrib = strcasecmp(get_driver_parameter(handle, "fake_attributes",
		"true", "true"), "true") == 0;
	unload_driver_settings(handle);

	if (ns->ro || (flags & B_MOUNT_READ_ONLY) != 0
		|| is_device_read_only(device)) {
		mountFlags |= NTFS_MNT_RDONLY;
		ns->flags |= B_FS_IS_READONLY;
	}

	if (ns->fake_attrib) {
		gNTFSVnodeOps.open_attr_dir = fake_open_attrib_dir;
		gNTFSVnodeOps.close_attr_dir = fake_close_attrib_dir;
		gNTFSVnodeOps.free_attr_dir_cookie = fake_free_attrib_dir_cookie;
		gNTFSVnodeOps.read_attr_dir = fake_read_attrib_dir;
		gNTFSVnodeOps.rewind_attr_dir = fake_rewind_attrib_dir;
		gNTFSVnodeOps.create_attr = fake_create_attrib;
		gNTFSVnodeOps.open_attr = fake_open_attrib;
		gNTFSVnodeOps.close_attr = fake_close_attrib;
		gNTFSVnodeOps.free_attr_cookie = fake_free_attrib_cookie;
		gNTFSVnodeOps.read_attr = fake_read_attrib;
		gNTFSVnodeOps.read_attr_stat = fake_read_attrib_stat;
		gNTFSVnodeOps.write_attr = fake_write_attrib;
		gNTFSVnodeOps.remove_attr = NULL;
	} else {
		gNTFSVnodeOps.open_attr_dir = fs_open_attrib_dir;
		gNTFSVnodeOps.close_attr_dir = fs_close_attrib_dir;
		gNTFSVnodeOps.free_attr_dir_cookie = fs_free_attrib_dir_cookie;
		gNTFSVnodeOps.read_attr_dir = fs_read_attrib_dir;
		gNTFSVnodeOps.rewind_attr_dir = fs_rewind_attrib_dir;
		gNTFSVnodeOps.create_attr = fs_create_attrib;
		gNTFSVnodeOps.open_attr = fs_open_attrib;
		gNTFSVnodeOps.close_attr = fs_close_attrib;
		gNTFSVnodeOps.free_attr_cookie = fs_free_attrib_cookie;
		gNTFSVnodeOps.read_attr = fs_read_attrib;
		gNTFSVnodeOps.read_attr_stat = fs_read_attrib_stat;
		gNTFSVnodeOps.write_attr = fs_write_attrib;
		gNTFSVnodeOps.remove_attr = fs_remove_attrib;
	}

	ns->ntvol = utils_mount_volume(device, mountFlags | NTFS_MNT_RECOVER);
	if (ns->ntvol != NULL)
		result = B_NO_ERROR;
	else
		result = errno;

	if (result == B_NO_ERROR) {
		*_rootID = FILE_root;
		ns->id = _vol->id;
		_vol->private_volume = (void *)ns;
		_vol->ops = &gNTFSVolumeOps;

		newNode = (vnode*)ntfs_calloc(sizeof(vnode));
		if (newNode == NULL)
			result = ENOMEM;
		else {
			newNode->vnid = *_rootID;
			newNode->parent_vnid = -1;

			result = publish_vnode(_vol, *_rootID, (void*)newNode,
				&gNTFSVnodeOps, S_IFDIR, 0);
			if (result != B_NO_ERROR) {
				free(ns);
				result = EINVAL;
				goto exit;
			} else {
				result = B_NO_ERROR;
				ntfs_mark_free_space_outdated(ns);
				ntfs_calc_free_space(ns);
			}
		}
	} else
		free(ns);

	TRACE("fs_mount - EXIT\n");
	return B_OK;

exit:
	ERROR("fs_mount - EXIT, result code is %s\n", strerror(result));

	return result;
}


status_t
fs_unmount(fs_volume *_vol)
{
	nspace *ns = (nspace*)_vol->private_volume;
	status_t result = B_NO_ERROR;

	TRACE("fs_unmount - ENTER\n");

	ntfs_umount(ns->ntvol, true);

	recursive_lock_destroy(&(ns->vlock));

	free(ns);

	TRACE("fs_unmount - EXIT, result is %s\n", strerror(result));

	return result;
}


status_t
fs_rfsstat(fs_volume *_vol, struct fs_info *fss)
{
	nspace *ns = (nspace*)_vol->private_volume;
	int i;

	LOCK_VOL(ns);

	TRACE("fs_rfsstat - ENTER\n");

	ntfs_calc_free_space(ns);

	fss->dev = ns->id;
	fss->root = FILE_root;
	fss->flags = B_FS_IS_PERSISTENT | B_FS_HAS_MIME | B_FS_HAS_ATTR | ns->flags;

	fss->block_size = ns->ntvol->cluster_size;
	fss->io_size = 65536;
	fss->total_blocks = ns->ntvol->nr_clusters;
	fss->free_blocks = ns->free_clusters;
	strncpy(fss->device_name, ns->devicePath, sizeof(fss->device_name));
	strncpy(fss->volume_name, ns->ntvol->vol_name, sizeof(fss->volume_name));

	for (i = strlen(fss->volume_name) - 1; i >= 0 ; i--) {
		if (fss->volume_name[i] != ' ')
			break;
	}
	if (i < 0) {
		double size;
		off_t diskSize = ns->ntvol->nr_clusters	* ns->ntvol->cluster_size;
		off_t divisor = 1ULL << 40;
		char unit = 'T';
		if (diskSize < divisor) {
			divisor = 1UL << 30;
			unit = 'G';
			if (diskSize < divisor) {
				divisor = 1UL << 20;
				unit = 'M';
			}
		}

		size = (double)((10 * diskSize + divisor - 1) / divisor);
		snprintf(fss->volume_name, sizeof(fss->volume_name), "%g %cB NTFS Volume",
			size / 10, unit);
	} else
		fss->volume_name[i + 1] = 0;

	strcpy(fss->fsh_name, "NTFS");

	TRACE("fs_rfsstat - EXIT\n");

	UNLOCK_VOL(ns);

	return B_NO_ERROR;
}


status_t
fs_wfsstat(fs_volume *_vol, const struct fs_info *fss, uint32 mask)
{
	nspace* ns = (nspace*)_vol->private_volume;
	status_t result = B_NO_ERROR;

	if (ns->flags & B_FS_IS_READONLY) {
		ERROR("ntfs is read-only\n");
		return B_READ_ONLY_DEVICE;
	}

	LOCK_VOL(ns);

	if (mask & FS_WRITE_FSINFO_NAME) {
		result = ntfs_change_label(ns->ntvol, (char*)fss->volume_name);
		goto exit;
	}

exit:
	UNLOCK_VOL(ns);

	return result;
}


status_t
fs_walk(fs_volume *_vol, fs_vnode *_dir, const char *file, ino_t *_vnid)
{
	nspace *ns = (nspace*)_vol->private_volume;
	vnode *baseNode = (vnode*)_dir->private_node;
	vnode *newNode = NULL;
	status_t result = B_NO_ERROR;

	LOCK_VOL(ns);

	TRACE("fs_walk - ENTER : find for \"%s\"\n",file);

	if (ns == NULL || _dir == NULL || file == NULL || _vnid == NULL) {
		result = EINVAL;
		goto exit;
	}

	if (!strcmp(file, ".")) {
		*_vnid = baseNode->vnid;
		if (get_vnode(_vol, *_vnid, (void**)&newNode) != 0)
			result = ENOENT;
	} else if (!strcmp(file, "..") && baseNode->vnid != FILE_root) {
		*_vnid = baseNode->parent_vnid;
		if (get_vnode(_vol, *_vnid, (void**)&newNode) != 0)
			result = ENOENT;
	} else {
		ino_t vnid = ntfs_inode_lookup(_vol, baseNode->vnid, file);

		if (vnid == (u64)-1) {
			result = errno;
			goto exit;
		}

		if (get_vnode(_vol, vnid, (void**)&newNode) != 0)
			result = ENOENT;

		if (newNode!=NULL)
			newNode->parent_vnid = baseNode->vnid;

		*_vnid = vnid;
	}

exit:
	TRACE("fs_walk - EXIT, result is %s\n", strerror(result));

	UNLOCK_VOL(ns);

	return result;
}


status_t
fs_get_vnode_name(fs_volume *_vol, fs_vnode *_vnode, char *buffer,
	size_t bufferSize)
{
	nspace *ns = (nspace*)_vol->private_volume;
	vnode *node = (vnode*)_vnode->private_node;
	ntfs_inode *ni = NULL;
	status_t result = B_NO_ERROR;

	char path[MAX_PATH];
	char *name;

	LOCK_VOL(ns);

	ni = ntfs_inode_open(ns->ntvol, node->vnid);
	if (ni == NULL) {
		result = ENOENT;
		goto exit;
	}

	if (utils_inode_get_name(ni, path, MAX_PATH) == 0) {
		result = EINVAL;
		goto exit;
	}

	name = strrchr(path, '/');
	name++;

	strlcpy(buffer, name, bufferSize);

exit:
	if (ni != NULL)
		ntfs_inode_close(ni);

	UNLOCK_VOL(ns);

	return result;
}


status_t
fs_read_vnode(fs_volume *_vol, ino_t vnid, fs_vnode *_node, int *_type,
	uint32 *_flags, bool reenter)
{
	nspace *ns = (nspace*)_vol->private_volume;
	vnode *newNode = NULL;
	ntfs_inode *ni = NULL;
	status_t result = B_NO_ERROR;

	if (!reenter)
		LOCK_VOL(ns);

	TRACE("fs_read_vnode - ENTER\n");

	_node->private_node = NULL;
	_node->ops = &gNTFSVnodeOps;
	_flags = 0;

	newNode = (vnode*)ntfs_calloc(sizeof(vnode));
	if (newNode != NULL) {
		char *name = NULL;

		ni = ntfs_inode_open(ns->ntvol, vnid);
		if (ni == NULL) {
			result = ENOENT;
			goto exit;
		}

		// get the node type
		result = get_node_type(ni, _type);
		if (result != B_OK)
			goto exit;

		newNode->vnid = vnid;
		newNode->parent_vnid = ntfs_mft_get_parent_ref(ni);

		if (ns->fake_attrib) {
			if (ni->mrec->flags & MFT_RECORD_IS_DIRECTORY)
				set_mime_type(newNode, NULL);
			else {
				name = (char*)malloc(MAX_PATH);
				if (name != NULL) {
					if (utils_inode_get_name(ni, name, MAX_PATH) == 1)
						set_mime_type(newNode, name);
					free(name);
				}
			}
		}
		_node->private_node = newNode;
	} else
		result = ENOMEM;

exit:
	if (ni != NULL)
		ntfs_inode_close(ni);

	if (result != B_OK)
		free(newNode);

	TRACE("fs_read_vnode - EXIT, result is %s\n", strerror(result));

	if (!reenter)
		UNLOCK_VOL(ns);

	return result;
}


status_t
fs_write_vnode(fs_volume *_vol, fs_vnode *_node, bool reenter)
{
	nspace *ns = (nspace*)_vol->private_volume;
	vnode *node = (vnode*)_node->private_node;
	status_t result = B_NO_ERROR;

	if (!reenter)
		LOCK_VOL(ns);

	TRACE("fs_write_vnode - ENTER (%Ld)\n", node->vnid);

	free(node);

	TRACE("fs_write_vnode - EXIT\n");

	if (!reenter)
		UNLOCK_VOL(ns);

	return result;
}


status_t
fs_remove_vnode(fs_volume *_vol, fs_vnode *_node, bool reenter)
{
	nspace *ns = (nspace*)_vol->private_volume;
	vnode *node = (vnode*)_node->private_node;
	status_t result = B_NO_ERROR;

	// TODO: this does not look right! The space if the node must be freed *here*
	if (!reenter)
		LOCK_VOL(ns);

	TRACE("fs_remove_vnode - ENTER (%Ld)\n", node->vnid);

	free(node);

	TRACE("fs_remove_vnode - EXIT, result is %s\n", strerror(result));

	if (!reenter)
	 	UNLOCK_VOL(ns);

	return result;
}


status_t
fs_rstat(fs_volume *_vol, fs_vnode *_node, struct stat *stbuf)
{
	nspace *ns = (nspace*)_vol->private_volume;
	vnode *node = (vnode*)_node->private_node;
	ntfs_inode *ni = NULL;
	ntfs_attr *na;
	status_t result = B_NO_ERROR;

	LOCK_VOL(ns);

	TRACE("fs_rstat - ENTER:\n");

	if (ns == NULL || node == NULL || stbuf == NULL) {
		result = ENOENT;
		goto exit;
	}

	ni = ntfs_inode_open(ns->ntvol, node->vnid);
	if (ni == NULL) {
		result = ENOENT;
		goto exit;
	}
	if (ni->mrec->flags & MFT_RECORD_IS_DIRECTORY) {
		// Directory
		stbuf->st_mode = FS_DIR_MODE;
		/* get index size, if not known */
		if (!test_nino_flag(ni, KnownSize)) {
			na = ntfs_attr_open(ni, AT_INDEX_ALLOCATION, NTFS_INDEX_I30, 4);
			if (na) {
				ni->data_size = na->data_size;
				ni->allocated_size = na->allocated_size;
				set_nino_flag(ni, KnownSize);
				ntfs_attr_close(na);
			}
		}
		stbuf->st_size = ni->data_size;
		stbuf->st_blocks = ni->allocated_size >> 9;
		stbuf->st_nlink = 1;	/* Make find(1) work */
	} else {
		// Regular or Interix (INTX) file
		stbuf->st_mode = FS_FILE_MODE;
		stbuf->st_size = ni->data_size;
		stbuf->st_blocks = (ni->allocated_size + 511) >> 9;
		stbuf->st_nlink = le16_to_cpu(ni->mrec->link_count);

		if (ni->flags & FILE_ATTR_SYSTEM) {
			na = ntfs_attr_open(ni, AT_DATA, NULL,0);
			if (!na) {
				result = ENOENT;
				goto exit;
			}
			stbuf->st_size = na->data_size;
			stbuf->st_blocks = na->allocated_size >> 9;
			// Check whether it's Interix symbolic link
			if (na->data_size <= sizeof(INTX_FILE_TYPES)
				+ sizeof(ntfschar) * PATH_MAX
				&& na->data_size > sizeof(INTX_FILE_TYPES)) {
				INTX_FILE *intx_file;

				intx_file = ntfs_malloc(na->data_size);
				if (!intx_file) {
					result = EINVAL;
					ntfs_attr_close(na);
					goto exit;
				}
				if (ntfs_attr_pread(na, 0, na->data_size,
						intx_file) != na->data_size) {
					result = EINVAL;
					free(intx_file);
					ntfs_attr_close(na);
					goto exit;
				}
				if (intx_file->magic == INTX_SYMBOLIC_LINK)
					stbuf->st_mode = FS_SLNK_MODE;
				free(intx_file);
			}
			ntfs_attr_close(na);
		}
		stbuf->st_mode |= 0666;
	}

	stbuf->st_uid = 0;
	stbuf->st_gid = 0;
	stbuf->st_ino = MREF(ni->mft_no);
	stbuf->st_atim = ntfs2timespec(ni->last_access_time);
	stbuf->st_ctim = ntfs2timespec(ni->last_mft_change_time);
	stbuf->st_mtim = ntfs2timespec(ni->last_data_change_time);

exit:
	if (ni != NULL)
		ntfs_inode_close(ni);

	TRACE("fs_rstat - EXIT, result is %s\n", strerror(result));

	UNLOCK_VOL(ns);

	return result;
}


status_t
fs_wstat(fs_volume *_vol, fs_vnode *_node, const struct stat *st, uint32 mask)
{
	nspace *ns = (nspace*)_vol->private_volume;
	vnode *node = (vnode*)_node->private_node;
	ntfs_inode *ni = NULL;
	status_t result = B_NO_ERROR;

	LOCK_VOL(ns);

	if ((ns->flags & B_FS_IS_READONLY) != 0) {
		UNLOCK_VOL(ns);
		return B_READ_ONLY_DEVICE;
	}

	TRACE("fs_wstat: ENTER\n");

	ni = ntfs_inode_open(ns->ntvol, node->vnid);
	if (ni == NULL) {
		result = ENOENT;
		goto exit;
	}

	if (mask & B_STAT_SIZE) {
		TRACE("fs_wstat: setting file size to %Lx\n", st->st_size);

		if (ni->mrec->flags & MFT_RECORD_IS_DIRECTORY)
			result = EISDIR;
		else {
			ntfs_attr *na = ntfs_attr_open(ni, AT_DATA, NULL, 0);
			if (!na) {
				result = EINVAL;
				goto exit;
			}

			ntfs_attr_truncate(na, st->st_size);
			ntfs_attr_close(na);

			ntfs_mark_free_space_outdated(ns);

			notify_stat_changed(ns->id, -1, MREF(ni->mft_no), mask);
		}
	}

	if (mask & B_STAT_MODIFICATION_TIME) {
		TRACE("fs_wstat: setting modification time\n");

		ni->last_access_time = timespec2ntfs(st->st_atim);
		ni->last_data_change_time = timespec2ntfs(st->st_mtim);
		ni->last_mft_change_time = timespec2ntfs(st->st_ctim);

		notify_stat_changed(ns->id, -1, MREF(ni->mft_no), mask);
	}

exit:
	if (ni != NULL)
		ntfs_inode_close(ni);

	TRACE("fs_wstat: EXIT with (%s)\n", strerror(result));

	UNLOCK_VOL(ns);

	return result;
}


status_t
fs_sync(fs_volume *_vol)
{
	nspace *ns = (nspace *)_vol->private_volume;

	LOCK_VOL(ns);

	TRACE("fs_sync - ENTER\n");

	TRACE("fs_sync - EXIT\n");

	UNLOCK_VOL(ns);

	return B_NO_ERROR;
}


status_t
fs_fsync(fs_volume *_vol, fs_vnode *_node)
{
	nspace *ns = (nspace*)_vol->private_volume;
	vnode *node = (vnode*)_node->private_node;
	ntfs_inode *ni = NULL;
	status_t result = B_NO_ERROR;

	LOCK_VOL(ns);

	TRACE("fs_fsync: ENTER\n");

	if (ns == NULL || node == NULL) {
		result = ENOENT;
		goto exit;
	}

	ni = ntfs_inode_open(ns->ntvol, node->vnid);
	if (ni == NULL) {
		result = ENOENT;
		goto exit;
	}

	ntfs_inode_sync(ni);

exit:
	if (ni != NULL)
		ntfs_inode_close(ni);

	TRACE("fs_fsync: EXIT\n");

	UNLOCK_VOL(ns);

	return result;
}


status_t
fs_open(fs_volume *_vol, fs_vnode *_node, int omode, void **_cookie)
{
	nspace *ns = (nspace*)_vol->private_volume;
	vnode *node = (vnode*)_node->private_node;
	filecookie *cookie = NULL;
	ntfs_inode *ni = NULL;
	ntfs_attr *na = NULL;
	status_t result = B_NO_ERROR;

	TRACE("fs_open - ENTER\n");

	LOCK_VOL(ns);

	if (node == NULL) {
		result = EINVAL;
		goto exit;
	}

	ni = ntfs_inode_open(ns->ntvol, node->vnid);
	if (ni == NULL) {
		result = errno;
		goto exit;
	}

	if (omode & O_TRUNC) {
		na = ntfs_attr_open(ni, AT_DATA, NULL, 0);
		if (na) {
			if (ntfs_attr_truncate(na, 0))
				result = errno;
		} else
			result = errno;
	}

	cookie = (filecookie*)ntfs_calloc(sizeof(filecookie));

	if (cookie != NULL) {
		cookie->omode = omode;
		*_cookie = (void*)cookie;
	} else
		result = ENOMEM;

exit:
	if (na != NULL)
		ntfs_attr_close(na);

	if (ni != NULL)
		ntfs_inode_close(ni);

	TRACE("fs_open - EXIT\n");

	UNLOCK_VOL(ns);

	return result;
}


status_t
fs_create(fs_volume *_vol, fs_vnode *_dir, const char *name, int omode,
	int perms, void **_cookie, ino_t *_vnid)
{
	nspace *ns = (nspace*)_vol->private_volume;
	vnode *dir = (vnode*)_dir->private_node;
	filecookie *cookie = NULL;
	vnode *newNode = NULL;
	ntfs_attr *na = NULL;
	ntfs_inode *ni = NULL;
	ntfs_inode *dir_ni = NULL;
	ntfschar *uname = NULL;
	status_t result = B_NO_ERROR;
	int unameLength;

	if (ns->flags & B_FS_IS_READONLY) {
		return B_READ_ONLY_DEVICE;
	}

	LOCK_VOL(ns);

	TRACE("fs_create - ENTER: name=%s\n", name);

	if (_vol == NULL || _dir == NULL) {
		result = EINVAL;
		goto exit;
	}

	if (name == NULL || *name == '\0' || strchr(name, '/')
		|| strcmp(name, ".") == 0 || strcmp(name, "..") == 0) {
		result =  EINVAL;
		goto exit;
	}

	dir_ni = ntfs_inode_open(ns->ntvol, dir->vnid);
	if (dir_ni == NULL) {
		result = ENOENT;
		goto exit;
	}

	if (!(dir_ni->mrec->flags & MFT_RECORD_IS_DIRECTORY)) {
		result = EINVAL;
		goto exit;
	}

	unameLength = ntfs_mbstoucs(name, &uname);
	if (unameLength < 0) {
		result = EINVAL;
		goto exit;
	}

	cookie = (filecookie*)ntfs_calloc(sizeof(filecookie));

	if (cookie != NULL)
		cookie->omode = omode;
	else {
		result = ENOMEM;
		goto exit;
	}

	ni = ntfs_pathname_to_inode(ns->ntvol, dir_ni, name);
	if (ni != NULL) {
		// file exists
		*_vnid	= MREF(ni->mft_no);
		if (omode & O_TRUNC) {
			na = ntfs_attr_open(ni, AT_DATA, NULL, 0);
			if (na != NULL) {
				if (ntfs_attr_truncate(na, 0))
					result = errno;
				ntfs_attr_close(na);
			} else
				result = errno;
		}
		ntfs_inode_close(ni);
	} else {
		le32 securid = const_cpu_to_le32(0);
		ni = ntfs_create(dir_ni, securid, uname, unameLength, S_IFREG);
		if (ni != NULL)	{
			ino_t vnid = MREF(ni->mft_no);

			newNode = (vnode*)ntfs_calloc(sizeof(vnode));
			if (newNode == NULL) {
			 	result = ENOMEM;
			 	goto exit;
			}

			newNode->vnid = vnid;
			newNode->parent_vnid = dir->vnid;

			ni->flags |= FILE_ATTR_ARCHIVE;
			NInoSetDirty(ni);

			result = publish_vnode(_vol, vnid, (void*)newNode, &gNTFSVnodeOps,
				S_IFREG, 0);

			if (ntfs_inode_close_in_dir(ni, dir_ni)) {
				result = EINVAL;
				goto exit;
			}

			*_vnid = vnid;

			if (ns->fake_attrib) {
				if (ni->mrec->flags & MFT_RECORD_IS_DIRECTORY)
					set_mime_type(newNode, NULL);
				else
					set_mime_type(newNode, name);
			}

			ntfs_mark_free_space_outdated(ns);
			fs_ntfs_update_times(_vol, dir_ni, NTFS_UPDATE_MCTIME);
			notify_entry_created(ns->id, dir->vnid, name, vnid);
		} else
			result = errno;
	}

exit:
	if (result >= B_OK)
		*_cookie = cookie;
	else
		free(cookie);

	if (dir_ni != NULL)
		ntfs_inode_close(dir_ni);

	free(uname);

	TRACE("fs_create - EXIT, result is %s\n", strerror(result));

	UNLOCK_VOL(ns);

	return result;
}


status_t
fs_read(fs_volume *_vol, fs_vnode *_node, void *_cookie, off_t offset, void *buf,
	size_t *len)
{
	nspace *ns = (nspace*)_vol->private_volume;
	vnode *node = (vnode*)_node->private_node;
	ntfs_inode *ni = NULL;
	ntfs_attr *na = NULL;
	size_t  size = *len;
	size_t total = 0;
	status_t result = B_OK;
	void *tempBuffer = NULL;
	addr_t buffer = (addr_t)buf;

	LOCK_VOL(ns);

	TRACE("fs_read - ENTER\n");

	ni = ntfs_inode_open(ns->ntvol, node->vnid);
	if (ni == NULL) {
		*len = 0;
		result = ENOENT;
		goto exit2;
	}

	if (ni->mrec->flags & MFT_RECORD_IS_DIRECTORY) {
		TRACE("ntfs_read called on directory.\n");
		*len = 0;
		result = EISDIR;
		goto exit2;
	}

	if (offset < 0) {
		*len = 0;
		result = EINVAL;
		goto exit2;
	}

	na = ntfs_attr_open(ni, AT_DATA, NULL, 0);
	if (na == NULL) {
		*len = 0;
		result = EINVAL;
		goto exit2;
	}
	if (offset + size > na->data_size)
		size = na->data_size - offset;

	if (IS_USER_ADDRESS(buf)) {
		tempBuffer = malloc(TEMP_BUFFER_SIZE);
		if (tempBuffer == NULL) {
			*len = 0;
			result = B_NO_MEMORY;
			goto exit;
		}
	}

	while (size > 0) {
		s64 bytesRead;
		s64 sizeToRead = size;
		if (tempBuffer != NULL && size > TEMP_BUFFER_SIZE)
			sizeToRead = TEMP_BUFFER_SIZE;
		bytesRead = ntfs_attr_pread(na, offset, sizeToRead,
			tempBuffer != NULL ? tempBuffer : (void*)buffer);
		if (bytesRead <= 0) {
			*len = 0;
			result = errno;
			goto exit;
		}
		if (tempBuffer != NULL
			&& user_memcpy((void*)buffer, tempBuffer, bytesRead) < B_OK) {
			result = B_BAD_ADDRESS;
			goto exit;
		}
		buffer += bytesRead;
		size -= bytesRead;
		offset += bytesRead;
		total += bytesRead;
		if (bytesRead < sizeToRead) {
			ntfs_log_error("ntfs_attr_pread returned less bytes than "
				"requested.\n");
			break;
		}
	}

	*len = total;
	fs_ntfs_update_times(_vol, ni, NTFS_UPDATE_ATIME);

exit:
	free(tempBuffer);
	if (na != NULL)
		ntfs_attr_close(na);

exit2:
	if (ni != NULL)
		ntfs_inode_close(ni);

	UNLOCK_VOL(ns);

	TRACE("fs_read - EXIT, result is %s\n", strerror(result));

	return result;
}


status_t
fs_write(fs_volume *_vol, fs_vnode *_node, void *_cookie, off_t offset,
	const void *buf, size_t *len)
{
	nspace *ns = (nspace*)_vol->private_volume;
	vnode *node = (vnode*)_node->private_node;
	filecookie *cookie = (filecookie*)_cookie;
	ntfs_inode *ni = NULL;
	ntfs_attr *na = NULL;
	size_t total = 0;
	size_t size = *len;
	status_t result = B_OK;
	void *tempBuffer = NULL;
	addr_t buffer = (addr_t)buf;

	if (ns->flags & B_FS_IS_READONLY) {
		ERROR("ntfs is read-only\n");
		return B_READ_ONLY_DEVICE;
	}

	LOCK_VOL(ns);

	TRACE("fs_write - ENTER, offset=%lld, len=%ld\n", offset, *len);

	ni = ntfs_inode_open(ns->ntvol, node->vnid);
	if (ni == NULL) {
		*len = 0;
		result = ENOENT;
		goto exit2;
	}

	if (ni->mrec->flags & MFT_RECORD_IS_DIRECTORY) {
		ERROR("fs_write - called on directory.\n");
		*len = 0;
		result = EISDIR;
		goto exit2;
	}

	if (offset < 0) {
		ERROR("fs_write - offset < 0.\n");
		*len = 0;
		result = EINVAL;
		goto exit2;
	}

	na = ntfs_attr_open(ni, AT_DATA, NULL, 0);
	if (na == NULL) {
		ERROR("fs_write - ntfs_attr_open()==NULL\n");
		*len = 0;
		result = EINVAL;
		goto exit2;
	}

	if (cookie->omode & O_APPEND)
		offset = na->data_size;

	if (offset + size > na->data_size) {
		ntfs_mark_free_space_outdated(ns);
		if (ntfs_attr_truncate(na, offset + size))
			size = na->data_size - offset;
		else
			notify_stat_changed(ns->id, -1, node->vnid, B_STAT_SIZE);
	}

	if (IS_USER_ADDRESS(buf)) {
		tempBuffer = malloc(TEMP_BUFFER_SIZE);
		if (tempBuffer == NULL) {
			*len = 0;
			result = B_NO_MEMORY;
			goto exit;
		}
	}

	while (size > 0) {
		s64 bytesWritten;
		s64 sizeToWrite = size;
		if (tempBuffer != NULL) {
			if (size > TEMP_BUFFER_SIZE)
				sizeToWrite = TEMP_BUFFER_SIZE;
			if (user_memcpy(tempBuffer, (void*)buffer, sizeToWrite) < B_OK) {
				result = B_BAD_ADDRESS;
				goto exit;
			}
		}
		bytesWritten = ntfs_attr_pwrite(na, offset, sizeToWrite,
			tempBuffer != NULL ? tempBuffer : (void*)buffer);
		if (bytesWritten <= 0) {
			ERROR("fs_write - ntfs_attr_pwrite()<=0\n");
			*len = 0;
			result = EINVAL;
			goto exit;
		}
		buffer += bytesWritten;
		size -= bytesWritten;
		offset += bytesWritten;
		total += bytesWritten;
		if (bytesWritten < sizeToWrite) {
			ERROR("fs_write - ntfs_attr_pwrite returned less bytes than "
				"requested.\n");
			break;
		}
	}

	*len = total;
	if (total > 0)
		fs_ntfs_update_times(_vol, ni, NTFS_UPDATE_MCTIME);

	TRACE("fs_write - OK\n");

exit:
	free(tempBuffer);
	if (na != NULL)
		ntfs_attr_close(na);
exit2:
	if (ni != NULL)
		ntfs_inode_close(ni);

	TRACE("fs_write - EXIT, result is %s, writed %d bytes\n",
		strerror(result), (int)(*len));

	UNLOCK_VOL(ns);

	return result;
}


status_t
fs_close(fs_volume *_vol, fs_vnode *_node, void *cookie)
{
	TRACE("fs_close - ENTER\n");

	TRACE("fs_close - EXIT\n");
	return B_NO_ERROR;
}


status_t
fs_free_cookie(fs_volume *_vol, fs_vnode *_node, void *cookie)
{
	TRACE("fs_free_cookie - ENTER\n");

	free(cookie);

	TRACE("fs_free_cookie - EXIT\n");
	return B_NO_ERROR;
}


status_t
fs_access(fs_volume *_vol, fs_vnode *_node, int mode)
{
	TRACE("fs_access - ENTER\n");

	TRACE("fs_access - EXIT\n");
	return B_NO_ERROR;
}


status_t
fs_readlink(fs_volume *_vol, fs_vnode *_node, char *buffer, size_t *bufferSize)
{
	nspace *ns = (nspace*)_vol->private_volume;
	vnode *node = (vnode*)_node->private_node;
	ntfs_attr *na = NULL;
	INTX_FILE *intxFile = NULL;
	ntfs_inode *ni = NULL;
	char *tempBuffer = NULL;
	status_t result = B_NO_ERROR;
	int l = 0;

	LOCK_VOL(ns);

	TRACE("fs_readlink - ENTER\n");

	if (ns == NULL || node == NULL || buffer == NULL || bufferSize == NULL) {
		result = EINVAL;
		goto exit;
	}

	ni = ntfs_inode_open(ns->ntvol, node->vnid);
	if (ni == NULL) {
		result = ENOENT;
		goto exit;
	}

	/* Sanity checks. */
	if (!(ni->flags & FILE_ATTR_SYSTEM)) {
		result = EINVAL;
		goto exit;
	}
	na = ntfs_attr_open(ni, AT_DATA, AT_UNNAMED, 0);
	if (!na) {
		result = errno;
		goto exit;
	}
	if (na->data_size <= sizeof(INTX_FILE_TYPES)) {
		result = EINVAL;
		goto exit;
	}
	if (na->data_size > sizeof(INTX_FILE_TYPES) + sizeof(ntfschar) * MAX_PATH) {
		result = ENAMETOOLONG;
		goto exit;
	}
	/* Receive file content. */
	intxFile = ntfs_malloc(na->data_size);
	if (!intxFile) {
		result = errno;
		goto exit;
	}
	if (ntfs_attr_pread(na, 0, na->data_size, intxFile) != na->data_size) {
		result = errno;
		goto exit;
	}
	/* Sanity check. */
	if (intxFile->magic != INTX_SYMBOLIC_LINK) {
		result = EINVAL;
		goto exit;
	}
	/* Convert link from unicode to local encoding. */
	l = ntfs_ucstombs(intxFile->target,
		(na->data_size - offsetof(INTX_FILE, target)) / sizeof(ntfschar),
		&tempBuffer, 0);

	if (l < 0) {
		result = errno;
		goto exit;
	}
	if (tempBuffer == NULL) {
		result = B_NO_MEMORY;
		goto exit;
	}

	strlcpy(buffer, tempBuffer, *bufferSize);

	*bufferSize = l + 1;

	TRACE("fs_readlink - LINK:[%s]\n", buffer);

	result = B_NO_ERROR;

exit:
	free(intxFile);
	if (na != NULL)
		ntfs_attr_close(na);
	if (ni != NULL)
		ntfs_inode_close(ni);

	free(tempBuffer);

	TRACE("fs_readlink - EXIT, result is %s\n", strerror(result));

	UNLOCK_VOL(ns);

	return result;
}


status_t
fs_create_symlink(fs_volume *_vol, fs_vnode *_dir, const char *name,
	const char *target, int mode)
{
	nspace *ns = (nspace*)_vol->private_volume;
	vnode *dir = (vnode*)_dir->private_node;
	ntfs_inode *ni = NULL;
	ntfs_inode *dir_ni = NULL;
	vnode *newNode = NULL;
	ntfschar *uname = NULL;
	ntfschar *utarget = NULL;
	int unameLength;
	int utargetLength;
	status_t result = B_NO_ERROR;
	le32 securid = const_cpu_to_le32(0);

	if (ns->flags & B_FS_IS_READONLY) {
		return B_READ_ONLY_DEVICE;
	}

	LOCK_VOL(ns);

	TRACE("fs_symlink - ENTER, name=%s, path=%s\n",name, target);

	if (ns == NULL || dir == NULL || name == NULL || target == NULL) {
		result = EINVAL;
		goto exit;
	}

	dir_ni = ntfs_inode_open(ns->ntvol, dir->vnid);
	if (dir_ni == NULL) {
		result = ENOENT;
		goto exit;
	}

	unameLength = ntfs_mbstoucs(name, &uname);
	if (unameLength < 0) {
		result = EINVAL;
		goto exit;
	}

	utargetLength = ntfs_mbstoucs(target, &utarget);
	if (utargetLength < 0) {
		result = EINVAL;
		goto exit;
	}

	ni = ntfs_create_symlink(dir_ni, securid, uname, unameLength, utarget,
		utargetLength);
	if (ni)	{
		ino_t vnid = MREF(ni->mft_no);
		newNode = (vnode*)ntfs_calloc(sizeof(vnode));
		if (newNode == NULL) {
		 	result = ENOMEM;
		 	goto exit;
		}

		newNode->vnid = vnid;
		newNode->parent_vnid = MREF(dir_ni->mft_no);

		ni->flags |= FILE_ATTR_ARCHIVE;
		NInoSetDirty(ni);

		result = B_NO_ERROR;
		result = publish_vnode(_vol, vnid, (void*)newNode, &gNTFSVnodeOps,
			S_IFREG, 0);
		put_vnode(_vol, vnid);

		if (ntfs_inode_close_in_dir(ni, dir_ni)) {
			result = EINVAL;
			goto exit;
		}

		ntfs_mark_free_space_outdated(ns);
		fs_ntfs_update_times(_vol, dir_ni, NTFS_UPDATE_MCTIME);
		notify_entry_created(ns->id, MREF(dir_ni->mft_no), name, vnid);
	} else
		result = errno;

exit:
	if (dir_ni != NULL)
		ntfs_inode_close(dir_ni);

	free(utarget);
	free(uname);

	TRACE("fs_symlink - EXIT, result is %s\n", strerror(result));

	UNLOCK_VOL(ns);

	return result;
}


status_t
fs_mkdir(fs_volume *_vol, fs_vnode *_dir, const char *name,	int perms)
{
	nspace *ns = (nspace*)_vol->private_volume;
	vnode *dir = (vnode*)_dir->private_node;
	vnode *newNode =NULL;
	ntfschar *uname = NULL;
	int unameLength;
	ntfs_inode *ni = NULL;
	ntfs_inode *dir_ni = NULL;
	status_t result = B_NO_ERROR;
	le32 securid = const_cpu_to_le32(0);

	if (ns->flags & B_FS_IS_READONLY) {
		ERROR("ntfs is read-only\n");
		return B_READ_ONLY_DEVICE;
	}

	LOCK_VOL(ns);

	TRACE("fs_mkdir - ENTER: name=%s\n", name);

	if (_vol == NULL || _dir == NULL || name == NULL) {
	 	result = EINVAL;
	 	goto exit;
	}

	dir_ni = ntfs_inode_open(ns->ntvol, dir->vnid);
	if (dir_ni == NULL) {
		result = ENOENT;
		goto exit;
	}

	if (!(dir_ni->mrec->flags & MFT_RECORD_IS_DIRECTORY)) {
		result = EINVAL;
		goto exit;
	}

	unameLength = ntfs_mbstoucs(name, &uname);
	if (unameLength < 0) {
		result = EINVAL;
		goto exit;
	}

	ni = ntfs_create(dir_ni, securid, uname, unameLength, S_IFDIR);
	if (ni != NULL)	{
		ino_t vnid = MREF(ni->mft_no);

		newNode = (vnode*)ntfs_calloc(sizeof(vnode));
		if (newNode == NULL) {
		 	result = ENOMEM;
		 	goto exit;
		}

		newNode->vnid = vnid;
		newNode->parent_vnid = MREF(dir_ni->mft_no);

		ni->flags |= FILE_ATTR_ARCHIVE;
		NInoSetDirty(ni);

		result = publish_vnode(_vol, vnid, (void*)newNode, &gNTFSVnodeOps,
			S_IFDIR, 0);

		put_vnode(_vol, vnid);

		if (ntfs_inode_close_in_dir(ni, dir_ni)) {
			result = EINVAL;
			goto exit;
		}

		ntfs_mark_free_space_outdated(ns);
		fs_ntfs_update_times(_vol, dir_ni, NTFS_UPDATE_MCTIME);
		notify_entry_created(ns->id, MREF(dir_ni->mft_no), name, vnid);
	} else
		result = errno;

exit:
	if (dir_ni != NULL)
		ntfs_inode_close(dir_ni);

	free(uname);

	TRACE("fs_mkdir - EXIT, result is %s\n", strerror(result));

	UNLOCK_VOL(ns);

	return result;
}


status_t
fs_rename(fs_volume *_vol, fs_vnode *_odir, const char *name,
	fs_vnode *_ndir, const char *newname)
{
	nspace *ns = (nspace*)_vol->private_volume;
	vnode *parent_vnode = (vnode*)_odir->private_node;
	vnode *newparent_vnode = (vnode*)_ndir->private_node;
	vnode *file = NULL;

	ino_t parent_vnid = parent_vnode->vnid;
	ino_t newparent_vnid = newparent_vnode->vnid;

	ino_t inode;
	ino_t target_inode;

	ntfs_inode *ni = NULL;
	ntfs_inode *dir_ni = NULL;

	status_t result = B_NO_ERROR;

	if (ns->flags & B_FS_IS_READONLY) {
		ERROR("ntfs is read-only\n");
		return B_READ_ONLY_DEVICE;
	}

	LOCK_VOL(ns);

	TRACE("NTFS:fs_rename - oldname:%s newname:%s\n", name, newname);

	inode = ntfs_inode_lookup(_vol, parent_vnid, name);
	if (inode == (u64)-1) {
		result = EINVAL;
		goto exit;
	}

	/* Check whether target is present */
	target_inode = ntfs_inode_lookup(_vol, newparent_vnid, newname);

	if (target_inode == (u64)-1) {
		ntfschar *uname = NULL;
		int uname_len;

		result = get_vnode(_vol, inode, (void**)&file);
		if (result != B_NO_ERROR)
			goto exit;


		ni = ntfs_inode_open(ns->ntvol, inode);
		if (!ni) {
			result = EINVAL;
			goto exit;
		}

		uname_len = ntfs_mbstoucs(newname, &uname);
		if (uname_len < 0) {
			result = EINVAL;
			goto exit;
		}

		dir_ni = ntfs_inode_open(ns->ntvol, newparent_vnid);
		if (!dir_ni) {
			result = EINVAL;
			goto exit;
		}

		if (ntfs_link(ni, dir_ni, uname, uname_len)) {
			result = EINVAL;
			goto exit;
		}

		ni->flags |= FILE_ATTR_ARCHIVE;

		fs_ntfs_update_times(_vol, ni, NTFS_UPDATE_CTIME);
		fs_ntfs_update_times(_vol, dir_ni, NTFS_UPDATE_MCTIME);

		if (ns->fake_attrib) {
			if (ni->mrec->flags & MFT_RECORD_IS_DIRECTORY)
				set_mime_type(file, NULL);
			else
				set_mime_type(file, newname);
			notify_attribute_changed(ns->id, -1, file->vnid, "BEOS:TYPE",
				B_ATTR_CHANGED);
		}

		ntfs_inode_close(dir_ni);
		ntfs_inode_close(ni);

        free(uname);

		ntfs_remove(_vol, parent_vnid, name);

		file->parent_vnid = newparent_vnid;

		put_vnode(_vol, file->vnid);

		notify_entry_moved(ns->id, parent_vnid, name, newparent_vnid,
			newname, inode);
	} else
		result = EINVAL;
exit:
	TRACE("fs_rename - EXIT, result is %s\n", strerror(result));

	UNLOCK_VOL(ns);

	return result;
}


status_t
fs_rmdir(fs_volume *_vol, fs_vnode *_dir, const char *name)
{
	nspace *ns = (nspace*)_vol->private_volume;
	vnode *dir = (vnode*)_dir->private_node;
	vnode *file = NULL;
	ntfs_inode *ni = NULL;
	ntfs_inode *dir_ni = NULL;
	status_t result = B_NO_ERROR;
	ino_t ino;

	if (ns->flags & B_FS_IS_READONLY) {
		ERROR("ntfs is read-only\n");
		return B_READ_ONLY_DEVICE;
	}

	LOCK_VOL(ns);

	TRACE("fs_rmdir  - ENTER:  name %s\n", name == NULL ? "NULL" : name);

	if (ns == NULL || dir == NULL || name == NULL) {
		result = EINVAL;
		goto exit;
	}

	if (strcmp(name, ".") == 0 || strcmp(name, "..") == 0) {
		result = EPERM;
		goto exit;
	}

	ino = ntfs_inode_lookup(_vol, dir->vnid, name);
	if (ino == (u64)-1) {
		result = EINVAL;
		goto exit;
	}

	result = get_vnode(_vol, ino, (void**)&file);
	if (result != B_NO_ERROR)
		goto exit;

	ni = ntfs_inode_open(ns->ntvol, file->vnid);
	if (ni != NULL) {
		if (!(ni->mrec->flags & MFT_RECORD_IS_DIRECTORY)) {
			result = ENOTDIR;
			goto exit;
		}
		if (ntfs_check_empty_dir(ni)<0)	{
			result = ENOTEMPTY;
			goto exit;
		}
		ntfs_inode_close(ni);
	} else {
		result = EINVAL;
		goto exit;
	}


	result = ntfs_remove(_vol, dir->vnid, name);
	if(result != B_NO_ERROR) {
		goto exit;
	}

	notify_entry_removed(ns->id, dir->vnid, name, file->vnid);

	remove_vnode(_vol, file->vnid);

	put_vnode(_vol, ino);

	dir_ni = ntfs_inode_open(ns->ntvol, dir->vnid);
	if (dir_ni != NULL) {
		fs_ntfs_update_times(_vol, dir_ni, NTFS_UPDATE_MCTIME);
		ntfs_inode_close(dir_ni);
	}

	ntfs_mark_free_space_outdated(ns);

exit:
	if (ni != NULL)
		ntfs_inode_close(ni);

	TRACE("fs_rmdir - EXIT, result is %s\n", strerror(result));

	UNLOCK_VOL(ns);

	return result;
}


status_t
fs_unlink(fs_volume *_vol, fs_vnode *_dir, const char *name)
{
	nspace *ns = (nspace*)_vol->private_volume;
	vnode *dir = (vnode*)_dir->private_node;
	vnode *file = NULL;
	ntfs_inode *dir_ni = NULL;
	status_t result = B_NO_ERROR;
	ino_t inode;

	if (ns->flags & B_FS_IS_READONLY) {
		ERROR("ntfs is read-only\n");
		return B_READ_ONLY_DEVICE;
	}

	LOCK_VOL(ns);

	TRACE("fs_unlink  - ENTER:  name %s\n", name == NULL ? "NULL" : name);

	if (ns == NULL || dir == NULL || name == NULL) {
		result = EINVAL;
		goto exit;
	}

	if (strcmp(name, ".") == 0 || strcmp(name, "..") == 0) {
		result = EPERM;
		goto exit;
	}

	inode = ntfs_inode_lookup(_vol, dir->vnid, name);
	if (inode == (u64)-1) {
		result = EINVAL;
		goto exit;
	}

	result = get_vnode(_vol, inode, (void**)&file);
	if (result != B_NO_ERROR)
		goto exit;

	result = ntfs_remove(_vol, dir->vnid, name);
	if(result != B_NO_ERROR) {
		goto exit;
	}

	notify_entry_removed(ns->id, dir->vnid, name, file->vnid);

	remove_vnode(_vol, file->vnid);

	put_vnode(_vol, inode);

	dir_ni = ntfs_inode_open(ns->ntvol, dir->vnid);
	if (dir_ni != NULL) {
		fs_ntfs_update_times(_vol, dir_ni, NTFS_UPDATE_MCTIME);
		ntfs_inode_close(dir_ni);
	}

	ntfs_mark_free_space_outdated(ns);

exit:
	TRACE("fs_unlink - EXIT, result is %s\n", strerror(result));

	UNLOCK_VOL(ns);

	return result;
}