staging: ramster: Add incremental accessory counters

Add incremental accessory counters that are going to be used for
debug fs entries.

Acked-by: Dan Magenheimer <dan.magenheimer@oracle.com>
Signed-off-by: Wanpeng Li <liwanp@linux.vnet.ibm.com>
Signed-off-by: Greg Kroah-Hartman <gregkh@linuxfoundation.org>
This commit is contained in:
Wanpeng Li 2013-04-13 21:01:29 +08:00 committed by Greg Kroah-Hartman
parent 1dbdd2fb47
commit f7d751ff1d
2 changed files with 83 additions and 16 deletions

View File

@ -62,6 +62,59 @@ extern ssize_t ramster_remote_page_flushes_failed;
int ramster_debugfs_init(void); int ramster_debugfs_init(void);
static inline void inc_ramster_eph_pages_remoted(void)
{
ramster_eph_pages_remoted++;
};
static inline void inc_ramster_pers_pages_remoted(void)
{
ramster_pers_pages_remoted++;
};
static inline void inc_ramster_eph_pages_remote_failed(void)
{
ramster_eph_pages_remote_failed++;
};
static inline void inc_ramster_pers_pages_remote_failed(void)
{
ramster_pers_pages_remote_failed++;
};
static inline void inc_ramster_remote_eph_pages_succ_get(void)
{
ramster_remote_eph_pages_succ_get++;
};
static inline void inc_ramster_remote_pers_pages_succ_get(void)
{
ramster_remote_pers_pages_succ_get++;
};
static inline void inc_ramster_remote_eph_pages_unsucc_get(void)
{
ramster_remote_eph_pages_unsucc_get++;
};
static inline void inc_ramster_remote_pers_pages_unsucc_get(void)
{
ramster_remote_pers_pages_unsucc_get++;
};
static inline void inc_ramster_pers_pages_remote_nomem(void)
{
ramster_pers_pages_remote_nomem++;
};
static inline void inc_ramster_remote_objects_flushed(void)
{
ramster_remote_objects_flushed++;
};
static inline void inc_ramster_remote_object_flushes_failed(void)
{
ramster_remote_object_flushes_failed++;
};
static inline void inc_ramster_remote_pages_flushed(void)
{
ramster_remote_pages_flushed++;
};
static inline void inc_ramster_remote_page_flushes_failed(void)
{
ramster_remote_page_flushes_failed++;
};
#else #else
static inline void inc_ramster_flnodes(void) { }; static inline void inc_ramster_flnodes(void) { };
@ -71,6 +124,20 @@ static inline void dec_ramster_foreign_eph_pages(void) { };
static inline void inc_ramster_foreign_pers_pages(void) { }; static inline void inc_ramster_foreign_pers_pages(void) { };
static inline void dec_ramster_foreign_pers_pages(void) { }; static inline void dec_ramster_foreign_pers_pages(void) { };
static inline void inc_ramster_eph_pages_remoted(void) { };
static inline void inc_ramster_pers_pages_remoted(void) { };
static inline void inc_ramster_eph_pages_remote_failed(void) { };
static inline void inc_ramster_pers_pages_remote_failed(void) { };
static inline void inc_ramster_remote_eph_pages_succ_get(void) { };
static inline void inc_ramster_remote_pers_pages_succ_get(void) { };
static inline void inc_ramster_remote_eph_pages_unsucc_get(void) { };
static inline void inc_ramster_remote_pers_pages_unsucc_get(void) { };
static inline void inc_ramster_pers_pages_remote_nomem(void) { };
static inline void inc_ramster_remote_objects_flushed(void) { };
static inline void inc_ramster_remote_object_flushes_failed(void) { };
static inline void inc_ramster_remote_pages_flushed(void) { };
static inline void inc_ramster_remote_page_flushes_failed(void) { };
static inline int ramster_debugfs_init(void) static inline int ramster_debugfs_init(void)
{ {
return 0; return 0;

View File

@ -156,9 +156,9 @@ int ramster_localify(int pool_id, struct tmem_oid *oidp, uint32_t index,
pr_err("UNTESTED pampd==NULL in ramster_localify\n"); pr_err("UNTESTED pampd==NULL in ramster_localify\n");
#endif #endif
if (eph) if (eph)
ramster_remote_eph_pages_unsucc_get++; inc_ramster_remote_eph_pages_unsucc_get();
else else
ramster_remote_pers_pages_unsucc_get++; inc_ramster_remote_pers_pages_unsucc_get();
obj = NULL; obj = NULL;
goto finish; goto finish;
} else if (unlikely(!pampd_is_remote(pampd))) { } else if (unlikely(!pampd_is_remote(pampd))) {
@ -167,9 +167,9 @@ int ramster_localify(int pool_id, struct tmem_oid *oidp, uint32_t index,
pr_err("UNTESTED dup while waiting in ramster_localify\n"); pr_err("UNTESTED dup while waiting in ramster_localify\n");
#endif #endif
if (eph) if (eph)
ramster_remote_eph_pages_unsucc_get++; inc_ramster_remote_eph_pages_unsucc_get();
else else
ramster_remote_pers_pages_unsucc_get++; inc_ramster_remote_pers_pages_unsucc_get();
obj = NULL; obj = NULL;
pampd = NULL; pampd = NULL;
ret = -EEXIST; ret = -EEXIST;
@ -178,7 +178,7 @@ int ramster_localify(int pool_id, struct tmem_oid *oidp, uint32_t index,
/* no remote data, delete the local is_remote pampd */ /* no remote data, delete the local is_remote pampd */
pampd = NULL; pampd = NULL;
if (eph) if (eph)
ramster_remote_eph_pages_unsucc_get++; inc_ramster_remote_eph_pages_unsucc_get();
else else
BUG(); BUG();
delete = true; delete = true;
@ -209,9 +209,9 @@ int ramster_localify(int pool_id, struct tmem_oid *oidp, uint32_t index,
BUG_ON(extra == NULL); BUG_ON(extra == NULL);
zcache_decompress_to_page(data, size, (struct page *)extra); zcache_decompress_to_page(data, size, (struct page *)extra);
if (eph) if (eph)
ramster_remote_eph_pages_succ_get++; inc_ramster_remote_eph_pages_succ_get();
else else
ramster_remote_pers_pages_succ_get++; inc_ramster_remote_pers_pages_succ_get();
ret = 0; ret = 0;
finish: finish:
tmem_localify_finish(obj, index, pampd, saved_hb, delete); tmem_localify_finish(obj, index, pampd, saved_hb, delete);
@ -296,7 +296,7 @@ void *ramster_pampd_repatriate_preload(void *pampd, struct tmem_pool *pool,
c = atomic_dec_return(&ramster_remote_pers_pages); c = atomic_dec_return(&ramster_remote_pers_pages);
WARN_ON_ONCE(c < 0); WARN_ON_ONCE(c < 0);
} else { } else {
ramster_pers_pages_remote_nomem++; inc_ramster_pers_pages_remote_nomem();
} }
local_irq_restore(flags); local_irq_restore(flags);
out: out:
@ -435,9 +435,9 @@ static void ramster_remote_flush_page(struct flushlist_node *flnode)
remotenode = flnode->xh.client_id; remotenode = flnode->xh.client_id;
ret = r2net_remote_flush(xh, remotenode); ret = r2net_remote_flush(xh, remotenode);
if (ret >= 0) if (ret >= 0)
ramster_remote_pages_flushed++; inc_ramster_remote_pages_flushed();
else else
ramster_remote_page_flushes_failed++; inc_ramster_remote_page_flushes_failed();
preempt_enable_no_resched(); preempt_enable_no_resched();
ramster_flnode_free(flnode, NULL); ramster_flnode_free(flnode, NULL);
} }
@ -452,9 +452,9 @@ static void ramster_remote_flush_object(struct flushlist_node *flnode)
remotenode = flnode->xh.client_id; remotenode = flnode->xh.client_id;
ret = r2net_remote_flush_object(xh, remotenode); ret = r2net_remote_flush_object(xh, remotenode);
if (ret >= 0) if (ret >= 0)
ramster_remote_objects_flushed++; inc_ramster_remote_objects_flushed();
else else
ramster_remote_object_flushes_failed++; inc_ramster_remote_object_flushes_failed();
preempt_enable_no_resched(); preempt_enable_no_resched();
ramster_flnode_free(flnode, NULL); ramster_flnode_free(flnode, NULL);
} }
@ -505,18 +505,18 @@ int ramster_remotify_pageframe(bool eph)
* But count them so we know if it becomes a problem. * But count them so we know if it becomes a problem.
*/ */
if (eph) if (eph)
ramster_eph_pages_remote_failed++; inc_ramster_eph_pages_remote_failed();
else else
ramster_pers_pages_remote_failed++; inc_ramster_pers_pages_remote_failed();
break; break;
} else { } else {
if (!eph) if (!eph)
atomic_inc(&ramster_remote_pers_pages); atomic_inc(&ramster_remote_pers_pages);
} }
if (eph) if (eph)
ramster_eph_pages_remoted++; inc_ramster_eph_pages_remoted();
else else
ramster_pers_pages_remoted++; inc_ramster_pers_pages_remoted();
/* /*
* data was successfully remoted so change the local version to * data was successfully remoted so change the local version to
* point to the remote node where it landed * point to the remote node where it landed