Skip to content
This repository has been archived by the owner on Jul 4, 2022. It is now read-only.

Commit

Permalink
EOS-13990: NFS ADDB: Tracepointsfor all ATTR operations (#22)
Browse files Browse the repository at this point in the history 
Signed-off-by: vimalraghwani20 <vimal.raghwani@seagate.com>
  • Loading branch information
@vimalraghwani20
vimalraghwani20 authored Oct 14, 2020
1 parent 7158949 commit acff4f4
Showing 1 changed file with 66 additions and 13 deletions.
79 changes: 66 additions & 13 deletions src/kvstore/kvstore_base.c
View file
Original file line number Diff line number Diff line change
Expand Up @@ -52,8 +52,8 @@ struct kvstore *kvstore_get(void)
return &g_kvstore;
}

int kvs_init(struct kvstore *kvstore, struct collection_item *cfg)

static inline int __kvs_init(struct kvstore *kvstore,
struct collection_item *cfg)
{
int rc = 0, i;
char *kvstore_type = NULL;
Expand Down Expand Up @@ -93,19 +93,46 @@ int kvs_init(struct kvstore *kvstore, struct collection_item *cfg)
return rc;
}

int kvs_fini(struct kvstore *kvstore)
int kvs_init(struct kvstore *kvstore, struct collection_item *cfg)
{
int rc;

perfc_trace_inii(PFT_KVS_INIT, PEM_KVS_TO_NFS);

rc = __kvs_init(kvstore, cfg);

perfc_trace_attr(PEA_KVS_RES_RC, rc);
perfc_trace_finii(PERFC_TLS_POP_DONT_VERIFY);

return rc;
}
static inline int __kvs_fini(struct kvstore *kvstore)
{
dassert(kvstore && kvstore->kvstore_ops && kvstore->kvstore_ops->fini);

return kvstore->kvstore_ops->fini();
}

int kvs_fini(struct kvstore *kvstore)
{
int rc;

perfc_trace_inii(PFT_KVS_FINI, PEM_KVS_TO_NFS);

rc = __kvs_fini(kvstore);

perfc_trace_attr(PEA_KVS_RES_RC, rc);
perfc_trace_finii(PERFC_TLS_POP_DONT_VERIFY);

return rc;
}

int kvs_fid_from_str(const char *fid_str, kvs_idx_fid_t *out_fid)
{
return cortx_kvs_fid_from_str(fid_str, out_fid);
}

static int __kvs_alloc(struct kvstore *kvstore, void **ptr, size_t size)
static inline int __kvs_alloc(struct kvstore *kvstore, void **ptr, size_t size)
{
dassert(kvstore);
return kvstore->kvstore_ops->alloc(ptr, size);
Expand All @@ -120,18 +147,27 @@ int kvs_alloc(struct kvstore *kvstore, void **ptr, size_t size)

rc = __kvs_alloc(kvstore, ptr, size);

perfc_trace_attr(PEA_KVS_ALLOC_RES_RC, rc);
perfc_trace_attr(PEA_KVS_RES_RC, rc);
perfc_trace_finii(PERFC_TLS_POP_DONT_VERIFY);

return rc;
}

void kvs_free(struct kvstore *kvstore, void *ptr)
static inline void __kvs_free(struct kvstore *kvstore, void *ptr)
{
dassert(kvstore);
return kvstore->kvstore_ops->free(ptr);
}

void kvs_free(struct kvstore *kvstore, void *ptr)
{
perfc_trace_inii(PFT_KVS_FREE, PEM_KVS_TO_NFS);

__kvs_free(kvstore, ptr);

perfc_trace_finii(PERFC_TLS_POP_DONT_VERIFY);
}

int kvs_begin_transaction(struct kvstore *kvstore, struct kvs_idx *index)
{
dassert(kvstore);
Expand Down Expand Up @@ -176,8 +212,8 @@ int kvs_index_close(struct kvstore *kvstore, struct kvs_idx *index)
return kvstore->kvstore_ops->index_close(index);
}

static int __kvs_get(struct kvstore *kvstore, struct kvs_idx *index, void *k,
const size_t klen, void **v, size_t *vlen)
static inline int __kvs_get(struct kvstore *kvstore, struct kvs_idx *index,
void *k, const size_t klen, void **v, size_t *vlen)
{
dassert(kvstore);
return kvstore->kvstore_ops->get_bin(index, k, klen, v, vlen);
Expand All @@ -189,24 +225,41 @@ int kvs_get(struct kvstore *kvstore, struct kvs_idx *index, void *k,
int rc;

perfc_trace_inii(PFT_KVS_GET, PEM_KVS_TO_NFS);
perfc_trace_attr(PEA_KVS_GET_KLEN, klen);
perfc_trace_attr(PEA_KVS_GET_VLEN, *vlen);
perfc_trace_attr(PEA_KVS_KLEN, klen);
perfc_trace_attr(PEA_KVS_VLEN, *vlen);

rc = __kvs_get(kvstore, index, k, klen, v, vlen);

perfc_trace_attr(PEA_KVS_GET_RES_RC, rc);
perfc_trace_attr(PEA_KVS_RES_RC, rc);
perfc_trace_finii(PERFC_TLS_POP_DONT_VERIFY);

return rc;
}

int kvs_set(struct kvstore *kvstore, struct kvs_idx *index, void *k, const size_t klen,
void *v, const size_t vlen)
static inline int __kvs_set(struct kvstore *kvstore, struct kvs_idx *index,
void *k, const size_t klen,void *v,
const size_t vlen)
{
dassert(kvstore);
return kvstore->kvstore_ops->set_bin(index, k, klen, v, vlen);
}

int kvs_set(struct kvstore *kvstore, struct kvs_idx *index, void *k,
const size_t klen, void *v, const size_t vlen)
{
int rc;

perfc_trace_inii(PFT_KVS_SET, PEM_KVS_TO_NFS);
perfc_trace_attr(PEA_KVS_KLEN, klen);
perfc_trace_attr(PEA_KVS_VLEN, vlen);

rc = __kvs_set(kvstore, index, k, klen, v, vlen);

perfc_trace_attr(PEA_KVS_RES_RC, rc);
perfc_trace_finii(PERFC_TLS_POP_DONT_VERIFY);

return rc;
}
int kvs_del(struct kvstore *kvstore, struct kvs_idx *index, const void *k,
size_t klen)
{
Expand Down

0 comments on commit acff4f4

Please sign in to comment.