/*
  Copyright (c) 2018 Red Hat, Inc. <http://www.redhat.com>
  This file is part of GlusterFS.

  This file is licensed to you under your choice of the GNU Lesser
  General Public License, version 3 or any later version (LGPLv3 or
  later), or the GNU General Public License, version 2 (GPLv2), in all
  cases as published by the Free Software Foundation.
*/
#ifndef _CLOUDSYNC_COMMON_H
#define _CLOUDSYNC_COMMON_H

#include "glusterfs.h"
#include "call-stub.h"
#include "xlator.h"
#include "syncop.h"
#include "cloudsync-mem-types.h"
#include "cloudsync-messages.h"

typedef struct cs_local {
        loc_t           loc;
        fd_t            *fd;
        call_stub_t     *stub;
        call_frame_t    *main_frame;
        int              op_errno;
        int              op_ret;
        fd_t            *dlfd;
        off_t            dloffset;
        struct iatt      stbuf;
        dict_t          *xattr_rsp;
        dict_t          *xattr_req;
        glusterfs_fop_t  fop;
        gf_boolean_t     locked;
        int              call_cnt;
        inode_t         *inode;
        char            *remotepath;
} cs_local_t;

typedef int (*fop_download_t) (call_frame_t *frame, void *config);

typedef void *(*store_init) (xlator_t *this);

typedef int (*store_reconfigure) (xlator_t *this, dict_t *options);

typedef void (*store_fini) (void *config);

struct cs_remote_stores {
        char            *name; /* store name */
        void            *config; /* store related information */
        fop_download_t   dlfop; /* store specific download function */
        store_init       init; /* store init to initialize store config */
        store_reconfigure reconfigure; /* reconfigure store config */
        store_fini       fini;
        void            *handle; /* shared library handle*/
};

typedef struct cs_private {
        xlator_t *this;
        struct cs_remote_stores *stores;
        gf_boolean_t abortdl;
        pthread_spinlock_t  lock;
} cs_private_t;

void
cs_local_wipe (xlator_t *this, cs_local_t *local);

#define CS_STACK_UNWIND(fop, frame, params ...) do {    \
        cs_local_t *__local  = NULL;                    \
        xlator_t    *__xl    = NULL;                    \
        if (frame) {                                    \
                __xl         = frame->this;             \
                __local      = frame->local;            \
                frame->local = NULL;                    \
        }                                               \
        STACK_UNWIND_STRICT (fop, frame, params);       \
        cs_local_wipe (__xl, __local);                 \
} while (0)

#define CS_STACK_DESTROY(frame) do {                   \
        cs_local_t *__local  = NULL;            \
        xlator_t    *__xl    = NULL;            \
        __xl                 = frame->this;     \
        __local              = frame->local;    \
        frame->local         = NULL;            \
        STACK_DESTROY (frame->root);            \
        cs_local_wipe (__xl, __local);         \
} while (0)

typedef struct store_methods {
        int (*fop_download) (call_frame_t *frame, void *config);
        /* return type should be the store config */
        void *(*fop_init) (xlator_t *this);
        int (*fop_reconfigure) (xlator_t *this, dict_t *options);
        void (*fop_fini) (void *config);
} store_methods_t;

#endif /* _CLOUDSYNC_COMMON_H */