/*  $NetBSD: perfuse_priv.h,v 1.38 2019/09/23 12:00:57 christos Exp $ */

/*-
 *  Copyright (c) 2010-2011 Emmanuel Dreyfus. All rights reserved.
 * 
 *  Redistribution and use in source and binary forms, with or without
 *  modification, are permitted provided that the following conditions
 *  are met:
 *  1. Redistributions of source code must retain the above copyright
 *     notice, this list of conditions and the following disclaimer.
 *  2. Redistributions in binary form must reproduce the above copyright
 *     notice, this list of conditions and the following disclaimer in the
 *     documentation and/or other materials provided with the distribution.
 * 
 *  THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
 *  ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
 *  TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
 *  PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
 *  BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
 *  CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
 *  SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
 *  INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
 *  CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
 *  ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
 *  POSSIBILITY OF SUCH DAMAGE.
 */ 

#ifndef _PERFUSE_PRIV_H_
#define _PERFUSE_PRIV_H_

#include <unistd.h>
#include <syslog.h>
#include <paths.h>
#include <err.h>
#include <sysexits.h>
#include <signal.h>
#include <puffs.h>

#include "perfuse_if.h"
#include "fuse.h"

/* From src/sys/fs/puffs/puffs_vfsops.c */
#ifndef PUFFS_PNODEBUCKETS
#define PUFFS_PNODEBUCKETS 256
#endif /* PUFFS_PNODEBUCKETS */

#define PERFUSE_TRACECOUNT_MAX 4096
#define PERFUSE_TRACEPATH_MAX 256
struct perfuse_trace {
        int pt_opcode;
        char pt_path[PERFUSE_TRACEPATH_MAX];
        char pt_extra[BUFSIZ];
        int pt_error;
        enum { inxchg, done } pt_status;
        struct timespec pt_start;
        struct timespec pt_end;
        TAILQ_ENTRY(perfuse_trace) pt_list;
};

LIST_HEAD(perfuse_node_hashlist, perfuse_node_data);
struct perfuse_state {
        void *ps_private;       /* Private field for libperfuse user */
        struct puffs_usermount *ps_pu;
        struct puffs_node *ps_root;
        uid_t ps_owner_uid;
        int ps_flags;
#define PS_NO_ACCESS    0x0001  /* access is unimplemented; */
#define PS_NO_CREAT     0x0004  /* create is unimplemented */
#define PS_INLOOP       0x0008  /* puffs mainloop started */
#define PS_NO_FALLOCATE 0x0010  /* fallocate is unimplemented */
        uint64_t ps_fsid;
        uint32_t ps_max_readahead;
        uint32_t ps_max_write;
        uint64_t ps_syncreads;
        uint64_t ps_syncwrites;
        uint64_t ps_asyncreads;
        uint64_t ps_asyncwrites;
        char *ps_source;
        char *ps_target;
        char *ps_filesystemtype;
        int ps_mountflags;
        uint64_t ps_unique;
        perfuse_new_msg_fn ps_new_msg;
        perfuse_xchg_msg_fn ps_xchg_msg;
        perfuse_destroy_msg_fn ps_destroy_msg;
        perfuse_get_inhdr_fn ps_get_inhdr;
        perfuse_get_inpayload_fn ps_get_inpayload;
        perfuse_get_outhdr_fn ps_get_outhdr;
        perfuse_get_outpayload_fn ps_get_outpayload;
        perfuse_umount_fn ps_umount;
        TAILQ_HEAD(,perfuse_trace) ps_trace;
        uint64_t ps_tracecount;
        struct perfuse_node_hashlist *ps_nidhash;
        int ps_nnidhash;
        int ps_nodecount;
        int ps_xchgcount;
};


enum perfuse_qtype { 
        PCQ_READDIR,    
        PCQ_READ,
        PCQ_WRITE,
        PCQ_AFTERWRITE,
        PCQ_OPEN,
        PCQ_AFTERXCHG,
        PCQ_RESIZE,
        PCQ_REF
};

#ifdef PERFUSE_DEBUG
extern const char * const perfuse_qtypestr[];
#endif

struct perfuse_cc_queue {
        enum perfuse_qtype pcq_type;
        struct puffs_cc *pcq_cc;
        TAILQ_ENTRY(perfuse_cc_queue) pcq_next;
        const char *pcq_func;
        int pcq_line;
};

struct perfuse_node_data {
        uint64_t pnd_rfh;
        uint64_t pnd_wfh;
        uint64_t pnd_nodeid;                    /* nodeid, this is not inode */
        uint64_t pnd_parent_nodeid;             /* parent's nodeid */
        uint32_t pnd_hashidx;                   /* node hash index */
        uint64_t pnd_fuse_nlookup;              /* vnode refcount */
        int pnd_puffs_nlookup;                  /* vnode refcount */
        uint64_t pnd_lock_owner;
        struct dirent *pnd_dirent;              /* native buffer for readdir */
        off_t pnd_dirent_len;
        struct fuse_dirent *pnd_all_fd;         /* FUSE buffer for readdir */
        size_t pnd_all_fd_len;
        uint64_t pnd_fd_cookie;                 /* opaque readdir ref from fs */
        TAILQ_HEAD(,perfuse_cc_queue) pnd_pcq;  /* queued requests */
        int pnd_flags;
#define PND_RECLAIMED           0x001   /* reclaim pending */
#define PND_INREADDIR           0x002   /* readdir in progress */
#define PND_DIRTY               0x004   /* There is some data to sync */
#define PND_RFH                 0x008   /* Read FH allocated */
#define PND_WFH                 0x010   /* Write FH allocated */
#define PND_REMOVED             0x020   /* Node was removed */
#define PND_INWRITE             0x040   /* write in progress */
#define PND_INOPEN              0x100   /* open in progress */
#define PND_INVALID             0x400   /* node freed, usage is a bug */
#define PND_INRESIZE            0x800   /* resize in progress */

#define PND_OPEN                (PND_RFH|PND_WFH)       /* File is open */
#define PND_BUSY                (PND_INREADDIR|PND_INWRITE|PND_INOPEN)
        
        LIST_ENTRY(perfuse_node_data) pnd_nident;
        puffs_cookie_t pnd_pn;
        char pnd_name[MAXPATHLEN];      /* node name */
        struct timespec pnd_cn_expire;
        int pnd_inxchg;
        int pnd_ref;
};

#define PERFUSE_NODE_DATA(opc)  \
        ((struct perfuse_node_data *)puffs_pn_getpriv((struct puffs_node *)opc))


#define UNSPEC_REPLY_LEN PERFUSE_UNSPEC_REPLY_LEN /* shorter! */
#define NO_PAYLOAD_REPLY_LEN 0

#define GET_INHDR(ps, pm) ps->ps_get_inhdr(pm)
#define GET_INPAYLOAD(ps, pm, type) \
        (struct type *)(void *)ps->ps_get_inpayload(pm)
#define _GET_INPAYLOAD(ps, pm, type) (type)ps->ps_get_inpayload(pm)
#define GET_OUTHDR(ps, pm) ps->ps_get_outhdr(pm)
#define GET_OUTPAYLOAD(ps, pm, type) \
        (struct type *)(void *)ps->ps_get_outpayload(pm)
#define _GET_OUTPAYLOAD(ps, pm, type) (type)ps->ps_get_outpayload(pm)

__BEGIN_DECLS

struct puffs_node *perfuse_new_pn(struct puffs_usermount *, const char *,
    struct puffs_node *);
void perfuse_destroy_pn(struct puffs_usermount *, struct puffs_node *);
void perfuse_new_fh(puffs_cookie_t, uint64_t, int);
void perfuse_destroy_fh(puffs_cookie_t, uint64_t);
uint64_t perfuse_get_fh(puffs_cookie_t, int);
uint64_t perfuse_next_unique(struct puffs_usermount *);
char *perfuse_node_path(struct perfuse_state *, puffs_cookie_t);
int perfuse_node_close_common(struct puffs_usermount *, puffs_cookie_t, int);
int perfuse_ns_match(const int, const char *);
const char *perfuse_native_ns(const int, const char *, char *);

char *perfuse_fs_mount(int, ssize_t);


/*
 * ops.c - filesystem operations
 */
int perfuse_fs_unmount(struct puffs_usermount *, int);
int perfuse_fs_statvfs(struct puffs_usermount *, struct puffs_statvfs *);
int perfuse_fs_sync(struct puffs_usermount *, int,
    const struct puffs_cred *);
int perfuse_fs_fhtonode(struct puffs_usermount *, void *, size_t,
    struct puffs_newinfo *);
int perfuse_fs_nodetofh(struct puffs_usermount *, puffs_cookie_t,
    void *, size_t *);
void perfuse_fs_suspend(struct puffs_usermount *, int);
int perfuse_node_lookup(struct puffs_usermount *,
    puffs_cookie_t, struct puffs_newinfo *, const struct puffs_cn *);
int perfuse_node_create(struct puffs_usermount *,
    puffs_cookie_t, struct puffs_newinfo *, const struct puffs_cn *,
    const struct vattr *);
int perfuse_node_mknod(struct puffs_usermount *,
    puffs_cookie_t, struct puffs_newinfo *, const struct puffs_cn *,
    const struct vattr *);
int perfuse_node_open(struct puffs_usermount *,
    puffs_cookie_t, int, const struct puffs_cred *);
int perfuse_node_close(struct puffs_usermount *,
    puffs_cookie_t, int, const struct puffs_cred *);
int perfuse_node_access(struct puffs_usermount *,
    puffs_cookie_t, int, const struct puffs_cred *);
int perfuse_node_getattr(struct puffs_usermount *,
    puffs_cookie_t, struct vattr *, const struct puffs_cred *);
int perfuse_node_setattr(struct puffs_usermount *,
    puffs_cookie_t, const struct vattr *, const struct puffs_cred *);
int perfuse_node_poll(struct puffs_usermount *, puffs_cookie_t, int *);
int perfuse_node_fsync(struct puffs_usermount *,
    puffs_cookie_t, const struct puffs_cred *, int, off_t, off_t);
int perfuse_node_remove(struct puffs_usermount *,
    puffs_cookie_t, puffs_cookie_t, const struct puffs_cn *);
int perfuse_node_link(struct puffs_usermount *,
    puffs_cookie_t, puffs_cookie_t, const struct puffs_cn *);
int perfuse_node_rename(struct puffs_usermount *,
    puffs_cookie_t, puffs_cookie_t, const struct puffs_cn *,
    puffs_cookie_t, puffs_cookie_t, const struct puffs_cn *);
int perfuse_node_mkdir(struct puffs_usermount *,
    puffs_cookie_t, struct puffs_newinfo *, const struct puffs_cn *,
    const struct vattr *);
int perfuse_node_rmdir(struct puffs_usermount *,
    puffs_cookie_t, puffs_cookie_t, const struct puffs_cn *);
int perfuse_node_symlink(struct puffs_usermount *,
    puffs_cookie_t, struct puffs_newinfo *, const struct puffs_cn *,
    const struct vattr *, const char *);
int perfuse_node_readdir(struct puffs_usermount *,
    puffs_cookie_t, struct dirent *, off_t *, size_t *,
    const struct puffs_cred *, int *, off_t *, size_t *);
int perfuse_node_readlink(struct puffs_usermount *,
    puffs_cookie_t, const struct puffs_cred *, char *, size_t *);
int perfuse_node_reclaim(struct puffs_usermount *, puffs_cookie_t);
int perfuse_node_reclaim2(struct puffs_usermount *, puffs_cookie_t, int);
int perfuse_node_inactive(struct puffs_usermount *, puffs_cookie_t);
int perfuse_node_print(struct puffs_usermount *, puffs_cookie_t);
int perfuse_node_pathconf(struct puffs_usermount *,
    puffs_cookie_t, int, register_t *);
int perfuse_node_advlock(struct puffs_usermount *,
    puffs_cookie_t, void *, int, struct flock *, int);
int perfuse_node_read(struct puffs_usermount *, puffs_cookie_t,
    uint8_t *, off_t, size_t *, const struct puffs_cred *, int);
int perfuse_node_write(struct puffs_usermount *, puffs_cookie_t,
    uint8_t *, off_t, size_t *, const struct puffs_cred *, int);
int perfuse_node_write2(struct puffs_usermount *, puffs_cookie_t,
    uint8_t *, off_t, size_t *, const struct puffs_cred *, int, int);
int perfuse_node_open2(struct puffs_usermount *,
    puffs_cookie_t, int, const struct puffs_cred *, int *);
void perfuse_cache_write(struct puffs_usermount *,
    puffs_cookie_t, size_t, struct puffs_cacherun *);
int perfuse_node_getextattr(struct puffs_usermount *, puffs_cookie_t,
    int, const char *, size_t *, uint8_t *, size_t *, 
    const struct puffs_cred *);
int perfuse_node_setextattr(struct puffs_usermount *, puffs_cookie_t,
    int, const char *, uint8_t *, size_t *, const struct puffs_cred *);
int perfuse_node_listextattr(struct puffs_usermount *, puffs_cookie_t,
    int, size_t *, uint8_t *, size_t *, int, const struct puffs_cred *);
int perfuse_node_deleteextattr(struct puffs_usermount *, puffs_cookie_t,
    int, const char *, const struct puffs_cred *);
int perfuse_node_getattr_ttl(struct puffs_usermount *,
    puffs_cookie_t, struct vattr *, const struct puffs_cred *,
    struct timespec *);
int perfuse_node_setattr_ttl(struct puffs_usermount *,
    puffs_cookie_t, struct vattr *, const struct puffs_cred *,
    struct timespec *, int);
int perfuse_node_fallocate(struct puffs_usermount *,
    puffs_cookie_t, off_t, off_t);

struct perfuse_trace *perfuse_trace_begin(struct perfuse_state *, 
    puffs_cookie_t, perfuse_msg_t *);
void perfuse_trace_end(struct perfuse_state *, struct perfuse_trace *, int);
char *perfuse_opdump_in(struct perfuse_state *, perfuse_msg_t *);
struct perfuse_node_data *perfuse_node_bynodeid(struct perfuse_state *,
    uint64_t);
void perfuse_node_cache(struct perfuse_state *, puffs_cookie_t);
void perfuse_cache_flush(puffs_cookie_t);

__END_DECLS

#endif /* _PERFUSE_PRIV_H_ */