#include <sys/param.h>
#include <sys/systm.h>
#include <sys/vnode.h>
#include <sys/kernel.h>
#include <sys/malloc.h>
#include <sys/proc.h>
#include <sys/queue.h>
#include "hfs.h"
#include "hfs_cnode.h"
extern lck_attr_t * hfs_lock_attr;
extern lck_grp_t * hfs_mutex_group;
extern lck_grp_t * hfs_rwlock_group;
lck_grp_t * chash_lck_grp;
lck_grp_attr_t * chash_lck_grp_attr;
lck_attr_t * chash_lck_attr;
#define CNODEHASH(hfsmp, inum) (&hfsmp->hfs_cnodehashtbl[(inum) & hfsmp->hfs_cnodehash])
__private_extern__
void
hfs_chashinit()
{
chash_lck_grp_attr= lck_grp_attr_alloc_init();
chash_lck_grp = lck_grp_alloc_init("cnode_hash", chash_lck_grp_attr);
chash_lck_attr = lck_attr_alloc_init();
}
static void hfs_chash_lock(struct hfsmount *hfsmp)
{
lck_mtx_lock(&hfsmp->hfs_chash_mutex);
}
static void hfs_chash_lock_spin(struct hfsmount *hfsmp)
{
lck_mtx_lock_spin(&hfsmp->hfs_chash_mutex);
}
#ifdef i386
static void hfs_chash_lock_convert (struct hfsmount *hfsmp)
#else
static void hfs_chash_lock_convert (__unused struct hfsmount *hfsmp)
#endif
{
lck_mtx_convert_spin(&hfsmp->hfs_chash_mutex);
}
static void hfs_chash_unlock(struct hfsmount *hfsmp)
{
lck_mtx_unlock(&hfsmp->hfs_chash_mutex);
}
__private_extern__
void
hfs_chashinit_finish(struct hfsmount *hfsmp)
{
lck_mtx_init(&hfsmp->hfs_chash_mutex, chash_lck_grp, chash_lck_attr);
hfsmp->hfs_cnodehashtbl = hashinit(desiredvnodes / 4, M_HFSMNT, &hfsmp->hfs_cnodehash);
}
__private_extern__
void
hfs_delete_chash(struct hfsmount *hfsmp)
{
lck_mtx_destroy(&hfsmp->hfs_chash_mutex, chash_lck_grp);
FREE(hfsmp->hfs_cnodehashtbl, M_HFSMNT);
}
__private_extern__
struct vnode *
hfs_chash_getvnode(struct hfsmount *hfsmp, ino_t inum, int wantrsrc, int skiplock)
{
struct cnode *cp;
struct vnode *vp;
int error;
u_int32_t vid;
loop:
hfs_chash_lock_spin(hfsmp);
for (cp = CNODEHASH(hfsmp, inum)->lh_first; cp; cp = cp->c_hash.le_next) {
if (cp->c_fileid != inum)
continue;
if (ISSET(cp->c_hflag, H_ALLOC | H_TRANSIT | H_ATTACH)) {
SET(cp->c_hflag, H_WAITING);
(void) msleep(cp, &hfsmp->hfs_chash_mutex, PDROP | PINOD,
"hfs_chash_getvnode", 0);
goto loop;
}
vp = wantrsrc ? cp->c_rsrc_vp : cp->c_vp;
if (vp == NULLVP)
goto exit;
vid = vnode_vid(vp);
hfs_chash_unlock(hfsmp);
if ((error = vnode_getwithvid(vp, vid))) {
return (NULL);
}
if (!skiplock && hfs_lock(cp, HFS_EXCLUSIVE_LOCK) != 0) {
vnode_put(vp);
return (NULL);
}
if (cp->c_flag & (C_NOEXISTS | C_DELETED)) {
if (!skiplock)
hfs_unlock(cp);
vnode_put(vp);
return (NULL);
}
return (vp);
}
exit:
hfs_chash_unlock(hfsmp);
return (NULL);
}
__private_extern__
int
hfs_chash_snoop(struct hfsmount *hfsmp, ino_t inum, int (*callout)(const struct cat_desc *,
const struct cat_attr *, void *), void * arg)
{
struct cnode *cp;
int result = ENOENT;
hfs_chash_lock(hfsmp);
for (cp = CNODEHASH(hfsmp, inum)->lh_first; cp; cp = cp->c_hash.le_next) {
if (cp->c_fileid != inum)
continue;
if (!ISSET(cp->c_hflag, H_ALLOC | H_TRANSIT | H_ATTACH)) {
result = callout(&cp->c_desc, &cp->c_attr, arg);
}
break;
}
hfs_chash_unlock(hfsmp);
return (result);
}
__private_extern__
struct cnode *
hfs_chash_getcnode(struct hfsmount *hfsmp, ino_t inum, struct vnode **vpp, int wantrsrc, int skiplock)
{
struct cnode *cp;
struct cnode *ncp = NULL;
vnode_t vp;
u_int32_t vid;
loop:
hfs_chash_lock_spin(hfsmp);
loop_with_lock:
for (cp = CNODEHASH(hfsmp, inum)->lh_first; cp; cp = cp->c_hash.le_next) {
if (cp->c_fileid != inum)
continue;
if (ISSET(cp->c_hflag, H_ALLOC | H_ATTACH | H_TRANSIT)) {
SET(cp->c_hflag, H_WAITING);
(void) msleep(cp, &hfsmp->hfs_chash_mutex, PINOD,
"hfs_chash_getcnode", 0);
goto loop_with_lock;
}
vp = wantrsrc ? cp->c_rsrc_vp : cp->c_vp;
if (vp == NULL) {
SET(cp->c_hflag, H_ATTACH);
hfs_chash_unlock(hfsmp);
} else {
vid = vnode_vid(vp);
hfs_chash_unlock(hfsmp);
if (vnode_getwithvid(vp, vid))
goto loop;
}
if (ncp) {
FREE_ZONE(ncp, sizeof(struct cnode), M_HFSNODE);
ncp = NULL;
}
if (!skiplock) {
hfs_lock(cp, HFS_FORCE_LOCK);
}
if ((cp->c_flag & (C_NOEXISTS | C_DELETED)) && !wantrsrc) {
if (!skiplock)
hfs_unlock(cp);
if (vp != NULLVP) {
vnode_put(vp);
} else {
hfs_chash_lock_spin(hfsmp);
CLR(cp->c_hflag, H_ATTACH);
if (ISSET(cp->c_hflag, H_WAITING)) {
CLR(cp->c_hflag, H_WAITING);
wakeup((caddr_t)cp);
}
hfs_chash_unlock(hfsmp);
}
vp = NULL;
cp = NULL;
}
*vpp = vp;
return (cp);
}
if (skiplock && !wantrsrc)
panic("%s - should never get here when skiplock is set \n", __FUNCTION__);
if (ncp == NULL) {
hfs_chash_unlock(hfsmp);
MALLOC_ZONE(ncp, struct cnode *, sizeof(struct cnode), M_HFSNODE, M_WAITOK);
goto loop;
}
hfs_chash_lock_convert(hfsmp);
bzero(ncp, sizeof(struct cnode));
SET(ncp->c_hflag, H_ALLOC);
ncp->c_fileid = inum;
TAILQ_INIT(&ncp->c_hintlist);
TAILQ_INIT(&ncp->c_originlist);
lck_rw_init(&ncp->c_rwlock, hfs_rwlock_group, hfs_lock_attr);
if (!skiplock)
(void) hfs_lock(ncp, HFS_EXCLUSIVE_LOCK);
LIST_INSERT_HEAD(CNODEHASH(hfsmp, inum), ncp, c_hash);
hfs_chash_unlock(hfsmp);
*vpp = NULL;
return (ncp);
}
__private_extern__
void
hfs_chashwakeup(struct hfsmount *hfsmp, struct cnode *cp, int hflags)
{
hfs_chash_lock_spin(hfsmp);
CLR(cp->c_hflag, hflags);
if (ISSET(cp->c_hflag, H_WAITING)) {
CLR(cp->c_hflag, H_WAITING);
wakeup((caddr_t)cp);
}
hfs_chash_unlock(hfsmp);
}
__private_extern__
void
hfs_chash_rehash(struct hfsmount *hfsmp, struct cnode *cp1, struct cnode *cp2)
{
hfs_chash_lock_spin(hfsmp);
LIST_REMOVE(cp1, c_hash);
LIST_REMOVE(cp2, c_hash);
LIST_INSERT_HEAD(CNODEHASH(hfsmp, cp1->c_fileid), cp1, c_hash);
LIST_INSERT_HEAD(CNODEHASH(hfsmp, cp2->c_fileid), cp2, c_hash);
hfs_chash_unlock(hfsmp);
}
__private_extern__
int
hfs_chashremove(struct hfsmount *hfsmp, struct cnode *cp)
{
hfs_chash_lock_spin(hfsmp);
if (ISSET(cp->c_hflag, H_ATTACH)) {
hfs_chash_unlock(hfsmp);
return (EBUSY);
}
if (cp->c_hash.le_next || cp->c_hash.le_prev) {
LIST_REMOVE(cp, c_hash);
cp->c_hash.le_next = NULL;
cp->c_hash.le_prev = NULL;
}
hfs_chash_unlock(hfsmp);
return (0);
}
__private_extern__
void
hfs_chash_abort(struct hfsmount *hfsmp, struct cnode *cp)
{
hfs_chash_lock_spin(hfsmp);
LIST_REMOVE(cp, c_hash);
cp->c_hash.le_next = NULL;
cp->c_hash.le_prev = NULL;
CLR(cp->c_hflag, H_ATTACH | H_ALLOC);
if (ISSET(cp->c_hflag, H_WAITING)) {
CLR(cp->c_hflag, H_WAITING);
wakeup((caddr_t)cp);
}
hfs_chash_unlock(hfsmp);
}
__private_extern__
void
hfs_chash_mark_in_transit(struct hfsmount *hfsmp, struct cnode *cp)
{
hfs_chash_lock_spin(hfsmp);
SET(cp->c_hflag, H_TRANSIT);
hfs_chash_unlock(hfsmp);
}
static
struct cnode *
hfs_chash_search_cnid(struct hfsmount *hfsmp, cnid_t cnid)
{
struct cnode *cp;
for (cp = CNODEHASH(hfsmp, cnid)->lh_first; cp; cp = cp->c_hash.le_next) {
if (cp->c_fileid == cnid) {
break;
}
}
if (cp && ISSET(cp->c_hflag, H_ALLOC | H_TRANSIT | H_ATTACH)) {
cp = NULL;
}
return cp;
}
__private_extern__
int
hfs_chash_set_childlinkbit(struct hfsmount *hfsmp, cnid_t cnid)
{
int retval = -1;
struct cnode *cp;
hfs_chash_lock_spin(hfsmp);
cp = hfs_chash_search_cnid(hfsmp, cnid);
if (cp) {
if (cp->c_attr.ca_recflags & kHFSHasChildLinkMask) {
retval = 0;
} else {
cp->c_attr.ca_recflags |= kHFSHasChildLinkMask;
retval = 1;
}
}
hfs_chash_unlock(hfsmp);
return retval;
}