378 lines
9.9 KiB
C
378 lines
9.9 KiB
C
/* Created (MFS based):
|
|
* June 2011 (Evgeniy Ivanov)
|
|
*/
|
|
|
|
#include "fs.h"
|
|
#include <sys/stat.h>
|
|
#include <string.h>
|
|
#include <assert.h>
|
|
#include <minix/com.h>
|
|
#include <minix/vfsif.h>
|
|
|
|
#include "puffs.h"
|
|
#include "puffs_priv.h"
|
|
|
|
|
|
/*===========================================================================*
|
|
* fs_create *
|
|
*===========================================================================*/
|
|
int fs_create(void)
|
|
{
|
|
int r;
|
|
struct puffs_node *pn_dir;
|
|
struct puffs_node *pn;
|
|
mode_t omode;
|
|
struct puffs_newinfo pni;
|
|
struct puffs_kcn pkcnp;
|
|
PUFFS_MAKECRED(pcr, &global_kcred);
|
|
struct puffs_cn pcn = {&pkcnp, (struct puffs_cred *) __UNCONST(pcr), {0,0,0}};
|
|
struct vattr va;
|
|
struct timespec cur_time;
|
|
int len;
|
|
|
|
if (global_pu->pu_ops.puffs_node_create == NULL) {
|
|
lpuffs_debug("No puffs_node_create");
|
|
return(ENFILE);
|
|
}
|
|
|
|
/* Read request message */
|
|
omode = fs_m_in.m_vfs_fs_create.mode;
|
|
caller_uid = fs_m_in.m_vfs_fs_create.uid;
|
|
caller_gid = fs_m_in.m_vfs_fs_create.gid;
|
|
|
|
/* Copy the last component (i.e., file name) */
|
|
len = fs_m_in.m_vfs_fs_create.path_len;
|
|
pcn.pcn_namelen = len - 1;
|
|
if (pcn.pcn_namelen > NAME_MAX)
|
|
return(ENAMETOOLONG);
|
|
|
|
err_code = sys_safecopyfrom(VFS_PROC_NR, fs_m_in.m_vfs_fs_create.grant,
|
|
(vir_bytes) 0, (vir_bytes) pcn.pcn_name,
|
|
(size_t) len);
|
|
if (err_code != OK) return(err_code);
|
|
NUL(pcn.pcn_name, len, sizeof(pcn.pcn_name));
|
|
|
|
/* Get last directory pnode (i.e., directory that will hold the new pnode) */
|
|
if ((pn_dir = puffs_pn_nodewalk(global_pu, 0, &fs_m_in.m_vfs_fs_create.inode)) == NULL)
|
|
return(ENOENT);
|
|
|
|
memset(&pni, 0, sizeof(pni));
|
|
pni.pni_cookie = (void** )&pn;
|
|
|
|
cur_time = clock_timespec();
|
|
|
|
memset(&va, 0, sizeof(va));
|
|
va.va_type = VREG;
|
|
va.va_mode = omode;
|
|
va.va_uid = caller_uid;
|
|
va.va_gid = caller_gid;
|
|
va.va_atime = va.va_mtime = va.va_ctime = cur_time;
|
|
|
|
if (buildpath) {
|
|
r = puffs_path_pcnbuild(global_pu, &pcn, pn_dir);
|
|
if (r) {
|
|
lpuffs_debug("pathbuild error\n");
|
|
return(ENOENT);
|
|
}
|
|
}
|
|
|
|
r = global_pu->pu_ops.puffs_node_create(global_pu, pn_dir, &pni, &pcn, &va);
|
|
if (buildpath) {
|
|
if (r) {
|
|
global_pu->pu_pathfree(global_pu, &pcn.pcn_po_full);
|
|
} else {
|
|
struct puffs_node *_pn;
|
|
|
|
_pn = PU_CMAP(global_pu, pn);
|
|
_pn->pn_po = pcn.pcn_po_full;
|
|
}
|
|
}
|
|
|
|
if (r != OK) {
|
|
if (r > 0) r = -r;
|
|
return(r);
|
|
}
|
|
|
|
/* Open pnode */
|
|
pn->pn_count++;
|
|
|
|
update_timens(pn_dir, MTIME | CTIME, &cur_time);
|
|
|
|
/* Reply message */
|
|
fs_m_out.m_fs_vfs_create.inode = pn->pn_va.va_fileid;
|
|
fs_m_out.m_fs_vfs_create.mode = pn->pn_va.va_mode;
|
|
fs_m_out.m_fs_vfs_create.file_size = pn->pn_va.va_size;
|
|
|
|
/* This values are needed for the execution */
|
|
fs_m_out.m_fs_vfs_create.uid = pn->pn_va.va_uid;
|
|
fs_m_out.m_fs_vfs_create.gid = pn->pn_va.va_gid;
|
|
|
|
return(OK);
|
|
}
|
|
|
|
|
|
/*===========================================================================*
|
|
* fs_mknod *
|
|
*===========================================================================*/
|
|
int fs_mknod(void)
|
|
{
|
|
int r;
|
|
struct puffs_node *pn_dir;
|
|
struct puffs_node *pn;
|
|
struct puffs_newinfo pni;
|
|
struct puffs_kcn pkcnp;
|
|
PUFFS_MAKECRED(pcr, &global_kcred);
|
|
struct puffs_cn pcn = {&pkcnp, (struct puffs_cred *) __UNCONST(pcr), {0,0,0}};
|
|
struct vattr va;
|
|
struct timespec cur_time;
|
|
int len;
|
|
|
|
if (global_pu->pu_ops.puffs_node_mknod == NULL) {
|
|
lpuffs_debug("No puffs_node_mknod");
|
|
return(ENFILE);
|
|
}
|
|
|
|
/* Copy the last component and set up caller's user and group id */
|
|
len = fs_m_in.m_vfs_fs_mknod.path_len;
|
|
pcn.pcn_namelen = len - 1;
|
|
if (pcn.pcn_namelen > NAME_MAX)
|
|
return(ENAMETOOLONG);
|
|
|
|
err_code = sys_safecopyfrom(VFS_PROC_NR, fs_m_in.m_vfs_fs_mknod.grant,
|
|
(vir_bytes) 0, (vir_bytes) pcn.pcn_name,
|
|
(size_t) len);
|
|
if (err_code != OK) return(err_code);
|
|
NUL(pcn.pcn_name, len, sizeof(pcn.pcn_name));
|
|
|
|
caller_uid = fs_m_in.m_vfs_fs_mknod.uid;
|
|
caller_gid = fs_m_in.m_vfs_fs_mknod.gid;
|
|
|
|
/* Get last directory pnode */
|
|
if ((pn_dir = puffs_pn_nodewalk(global_pu, 0, &fs_m_in.m_vfs_fs_mknod.inode)) == NULL)
|
|
return(ENOENT);
|
|
|
|
memset(&pni, 0, sizeof(pni));
|
|
pni.pni_cookie = (void** )&pn;
|
|
|
|
cur_time = clock_timespec();
|
|
|
|
memset(&va, 0, sizeof(va));
|
|
va.va_type = VDIR;
|
|
va.va_mode = fs_m_in.m_vfs_fs_mknod.mode;
|
|
va.va_uid = caller_uid;
|
|
va.va_gid = caller_gid;
|
|
va.va_rdev = fs_m_in.m_vfs_fs_mknod.device;
|
|
va.va_atime = va.va_mtime = va.va_ctime = cur_time;
|
|
|
|
if (buildpath) {
|
|
if (puffs_path_pcnbuild(global_pu, &pcn, pn_dir) != 0) {
|
|
lpuffs_debug("pathbuild error\n");
|
|
return(ENOENT);
|
|
}
|
|
}
|
|
|
|
r = global_pu->pu_ops.puffs_node_mknod(global_pu, pn_dir, &pni, &pcn, &va);
|
|
if (buildpath) {
|
|
if (r) {
|
|
global_pu->pu_pathfree(global_pu, &pcn.pcn_po_full);
|
|
} else {
|
|
struct puffs_node *_pn;
|
|
|
|
_pn = PU_CMAP(global_pu, pn);
|
|
_pn->pn_po = pcn.pcn_po_full;
|
|
}
|
|
}
|
|
|
|
if (r != OK) {
|
|
if (r > 0) r = -r;
|
|
return(r);
|
|
}
|
|
|
|
update_timens(pn_dir, MTIME | CTIME, &cur_time);
|
|
|
|
return(OK);
|
|
}
|
|
|
|
|
|
/*===========================================================================*
|
|
* fs_mkdir *
|
|
*===========================================================================*/
|
|
int fs_mkdir(void)
|
|
{
|
|
int r;
|
|
struct puffs_node *pn_dir;
|
|
struct puffs_node *pn;
|
|
struct puffs_newinfo pni;
|
|
struct puffs_kcn pkcnp;
|
|
PUFFS_MAKECRED(pcr, &global_kcred);
|
|
struct puffs_cn pcn = {&pkcnp, (struct puffs_cred *) __UNCONST(pcr), {0,0,0}};
|
|
struct vattr va;
|
|
struct timespec cur_time;
|
|
int len;
|
|
|
|
if (global_pu->pu_ops.puffs_node_mkdir == NULL) {
|
|
lpuffs_debug("No puffs_node_mkdir");
|
|
return(ENFILE);
|
|
}
|
|
|
|
/* Copy the last component and set up caller's user and group id */
|
|
len = fs_m_in.m_vfs_fs_mkdir.path_len;
|
|
pcn.pcn_namelen = len - 1;
|
|
if (pcn.pcn_namelen > NAME_MAX)
|
|
return(ENAMETOOLONG);
|
|
|
|
err_code = sys_safecopyfrom(VFS_PROC_NR, fs_m_in.m_vfs_fs_mkdir.grant,
|
|
(vir_bytes) 0, (vir_bytes) pcn.pcn_name,
|
|
(phys_bytes) len);
|
|
if (err_code != OK) return(err_code);
|
|
NUL(pcn.pcn_name, len, sizeof(pcn.pcn_name));
|
|
|
|
caller_uid = fs_m_in.m_vfs_fs_mkdir.uid;
|
|
caller_gid = fs_m_in.m_vfs_fs_mkdir.gid;
|
|
|
|
/* Get last directory pnode */
|
|
if ((pn_dir = puffs_pn_nodewalk(global_pu, 0, &fs_m_in.m_vfs_fs_mkdir.inode)) == NULL)
|
|
return(ENOENT);
|
|
|
|
cur_time = clock_timespec();
|
|
|
|
memset(&pni, 0, sizeof(pni));
|
|
pni.pni_cookie = (void** )&pn;
|
|
|
|
memset(&va, 0, sizeof(va));
|
|
va.va_type = VDIR;
|
|
va.va_mode = fs_m_in.m_vfs_fs_mkdir.mode;
|
|
va.va_uid = caller_uid;
|
|
va.va_gid = caller_gid;
|
|
va.va_atime = va.va_mtime = va.va_ctime = cur_time;
|
|
|
|
if (buildpath) {
|
|
r = puffs_path_pcnbuild(global_pu, &pcn, pn_dir);
|
|
if (r) {
|
|
lpuffs_debug("pathbuild error\n");
|
|
return(ENOENT);
|
|
}
|
|
}
|
|
|
|
r = global_pu->pu_ops.puffs_node_mkdir(global_pu, pn_dir, &pni, &pcn, &va);
|
|
if (buildpath) {
|
|
if (r) {
|
|
global_pu->pu_pathfree(global_pu, &pcn.pcn_po_full);
|
|
} else {
|
|
struct puffs_node *_pn;
|
|
|
|
_pn = PU_CMAP(global_pu, pn);
|
|
_pn->pn_po = pcn.pcn_po_full;
|
|
}
|
|
}
|
|
|
|
if (r != OK) {
|
|
if (r > 0) r = -r;
|
|
return(r);
|
|
}
|
|
|
|
update_timens(pn_dir, MTIME | CTIME, &cur_time);
|
|
|
|
return(OK);
|
|
}
|
|
|
|
|
|
/*===========================================================================*
|
|
* fs_slink *
|
|
*===========================================================================*/
|
|
int fs_slink(void)
|
|
{
|
|
int r;
|
|
struct pnode *pn; /* pnode containing symbolic link */
|
|
struct pnode *pn_dir; /* directory containing link */
|
|
char target[PATH_MAX + 1]; /* target path */
|
|
struct puffs_newinfo pni;
|
|
struct puffs_kcn pkcnp;
|
|
PUFFS_MAKECRED(pcr, &global_kcred);
|
|
struct puffs_cn pcn = {&pkcnp, (struct puffs_cred *) __UNCONST(pcr), {0,0,0}};
|
|
struct vattr va;
|
|
int len;
|
|
|
|
caller_uid = fs_m_in.m_vfs_fs_slink.uid;
|
|
caller_gid = fs_m_in.m_vfs_fs_slink.gid;
|
|
|
|
/* Copy the link name's last component */
|
|
len = fs_m_in.m_vfs_fs_slink.path_len;
|
|
pcn.pcn_namelen = len - 1;
|
|
if (pcn.pcn_namelen > NAME_MAX)
|
|
return(ENAMETOOLONG);
|
|
|
|
if (fs_m_in.m_vfs_fs_slink.mem_size >= PATH_MAX)
|
|
return(ENAMETOOLONG);
|
|
|
|
r = sys_safecopyfrom(VFS_PROC_NR, fs_m_in.m_vfs_fs_slink.grant_path,
|
|
(vir_bytes) 0, (vir_bytes) pcn.pcn_name,
|
|
(size_t) len);
|
|
if (r != OK) return(r);
|
|
NUL(pcn.pcn_name, len, sizeof(pcn.pcn_name));
|
|
|
|
/* Copy the target path (note that it's not null terminated) */
|
|
r = sys_safecopyfrom(VFS_PROC_NR, fs_m_in.m_vfs_fs_slink.grant_target,
|
|
(vir_bytes) 0, (vir_bytes) target,
|
|
fs_m_in.m_vfs_fs_slink.mem_size);
|
|
if (r != OK) return(r);
|
|
target[fs_m_in.m_vfs_fs_slink.mem_size] = '\0';
|
|
|
|
if (strlen(target) != (size_t) fs_m_in.m_vfs_fs_slink.mem_size) {
|
|
/* This can happen if the user provides a buffer
|
|
* with a \0 in it. This can cause a lot of trouble
|
|
* when the symlink is used later. We could just use
|
|
* the strlen() value, but we want to let the user
|
|
* know he did something wrong. ENAMETOOLONG doesn't
|
|
* exactly describe the error, but there is no
|
|
* ENAMETOOWRONG.
|
|
*/
|
|
return(ENAMETOOLONG);
|
|
}
|
|
|
|
if ((pn_dir = puffs_pn_nodewalk(global_pu, 0, &fs_m_in.m_vfs_fs_slink.inode)) == NULL)
|
|
return(EINVAL);
|
|
|
|
memset(&pni, 0, sizeof(pni));
|
|
pni.pni_cookie = (void** )&pn;
|
|
|
|
memset(&va, 0, sizeof(va));
|
|
va.va_type = VLNK;
|
|
va.va_mode = (I_SYMBOLIC_LINK | RWX_MODES);
|
|
va.va_uid = caller_uid;
|
|
va.va_gid = caller_gid;
|
|
va.va_atime = va.va_mtime = va.va_ctime = clock_timespec();
|
|
|
|
if (buildpath) {
|
|
r = puffs_path_pcnbuild(global_pu, &pcn, pn_dir);
|
|
if (r) {
|
|
lpuffs_debug("pathbuild error\n");
|
|
return(ENOENT);
|
|
}
|
|
}
|
|
|
|
r = global_pu->pu_ops.puffs_node_symlink(global_pu, pn_dir, &pni, &pcn, &va, target);
|
|
if (buildpath) {
|
|
if (r) {
|
|
global_pu->pu_pathfree(global_pu, &pcn.pcn_po_full);
|
|
} else {
|
|
struct puffs_node *_pn;
|
|
|
|
_pn = PU_CMAP(global_pu, pn);
|
|
_pn->pn_po = pcn.pcn_po_full;
|
|
}
|
|
}
|
|
|
|
if (r > 0) r = -r;
|
|
|
|
return(r);
|
|
}
|
|
|
|
|
|
/*===========================================================================*
|
|
* fs_inhibread *
|
|
*===========================================================================*/
|
|
int fs_inhibread(void)
|
|
{
|
|
return(OK);
|
|
}
|