Commit aa6d5b20 authored by Arnd Bergmann's avatar Arnd Bergmann Committed by Arnd Bergmann

[CELL] cell: add per BE structure with info about its SPUs

Addition of a spufs-global "cbe_info" array. Each entry contains information
about one Cell/B.E. node, namelly:
* list of spus (both free and busy spus are in this list);
* list of free spus (replacing the static spu_list from spu_base.c)
* number of spus;
* number of reserved (non scheduleable) spus.

SPE affinity implementation actually requires only access to one spu per
BE node (since it implements its own pointer to walk through the other spus
of the ring) and the number of scheduleable spus (n_spus - non_sched_spus)
However having this more general structure can be useful for other
functionalities, concentrating per-cbe statistics / data.
Signed-off-by: default avatarAndre Detsch <adetsch@br.ibm.com>
Signed-off-by: default avatarArnd Bergmann <arnd.bergmann@de.ibm.com>
parent 7e90b749
...@@ -41,7 +41,6 @@ EXPORT_SYMBOL_GPL(spu_management_ops); ...@@ -41,7 +41,6 @@ EXPORT_SYMBOL_GPL(spu_management_ops);
const struct spu_priv1_ops *spu_priv1_ops; const struct spu_priv1_ops *spu_priv1_ops;
static struct list_head spu_list[MAX_NUMNODES];
static LIST_HEAD(spu_full_list); static LIST_HEAD(spu_full_list);
static DEFINE_MUTEX(spu_mutex); static DEFINE_MUTEX(spu_mutex);
static DEFINE_SPINLOCK(spu_list_lock); static DEFINE_SPINLOCK(spu_list_lock);
...@@ -429,8 +428,9 @@ struct spu *spu_alloc_node(int node) ...@@ -429,8 +428,9 @@ struct spu *spu_alloc_node(int node)
struct spu *spu = NULL; struct spu *spu = NULL;
mutex_lock(&spu_mutex); mutex_lock(&spu_mutex);
if (!list_empty(&spu_list[node])) { if (!list_empty(&cbe_spu_info[node].free_spus)) {
spu = list_entry(spu_list[node].next, struct spu, list); spu = list_entry(cbe_spu_info[node].free_spus.next, struct spu,
list);
list_del_init(&spu->list); list_del_init(&spu->list);
pr_debug("Got SPU %d %d\n", spu->number, spu->node); pr_debug("Got SPU %d %d\n", spu->number, spu->node);
} }
...@@ -459,7 +459,7 @@ struct spu *spu_alloc(void) ...@@ -459,7 +459,7 @@ struct spu *spu_alloc(void)
void spu_free(struct spu *spu) void spu_free(struct spu *spu)
{ {
mutex_lock(&spu_mutex); mutex_lock(&spu_mutex);
list_add_tail(&spu->list, &spu_list[spu->node]); list_add_tail(&spu->list, &cbe_spu_info[spu->node].free_spus);
mutex_unlock(&spu_mutex); mutex_unlock(&spu_mutex);
} }
EXPORT_SYMBOL_GPL(spu_free); EXPORT_SYMBOL_GPL(spu_free);
...@@ -582,7 +582,9 @@ static int __init create_spu(void *data) ...@@ -582,7 +582,9 @@ static int __init create_spu(void *data)
mutex_lock(&spu_mutex); mutex_lock(&spu_mutex);
spin_lock_irqsave(&spu_list_lock, flags); spin_lock_irqsave(&spu_list_lock, flags);
list_add(&spu->list, &spu_list[spu->node]); list_add(&spu->list, &cbe_spu_info[spu->node].free_spus);
list_add(&spu->cbe_list, &cbe_spu_info[spu->node].spus);
cbe_spu_info[spu->node].n_spus++;
list_add(&spu->full_list, &spu_full_list); list_add(&spu->full_list, &spu_full_list);
spin_unlock_irqrestore(&spu_list_lock, flags); spin_unlock_irqrestore(&spu_list_lock, flags);
mutex_unlock(&spu_mutex); mutex_unlock(&spu_mutex);
...@@ -650,12 +652,17 @@ static ssize_t spu_stat_show(struct sys_device *sysdev, char *buf) ...@@ -650,12 +652,17 @@ static ssize_t spu_stat_show(struct sys_device *sysdev, char *buf)
static SYSDEV_ATTR(stat, 0644, spu_stat_show, NULL); static SYSDEV_ATTR(stat, 0644, spu_stat_show, NULL);
struct cbe_spu_info cbe_spu_info[MAX_NUMNODES];
EXPORT_SYMBOL_GPL(cbe_spu_info);
static int __init init_spu_base(void) static int __init init_spu_base(void)
{ {
int i, ret = 0; int i, ret = 0;
for (i = 0; i < MAX_NUMNODES; i++) for (i = 0; i < MAX_NUMNODES; i++) {
INIT_LIST_HEAD(&spu_list[i]); INIT_LIST_HEAD(&cbe_spu_info[i].spus);
INIT_LIST_HEAD(&cbe_spu_info[i].free_spus);
}
if (!spu_management_ops) if (!spu_management_ops)
goto out; goto out;
......
...@@ -231,6 +231,9 @@ static void spu_bind_context(struct spu *spu, struct spu_context *ctx) ...@@ -231,6 +231,9 @@ static void spu_bind_context(struct spu *spu, struct spu_context *ctx)
spu->number, spu->node); spu->number, spu->node);
spuctx_switch_state(ctx, SPU_UTIL_SYSTEM); spuctx_switch_state(ctx, SPU_UTIL_SYSTEM);
if (ctx->flags & SPU_CREATE_NOSCHED)
atomic_inc(&cbe_spu_info[spu->node].reserved_spus);
ctx->stats.slb_flt_base = spu->stats.slb_flt; ctx->stats.slb_flt_base = spu->stats.slb_flt;
ctx->stats.class2_intr_base = spu->stats.class2_intr; ctx->stats.class2_intr_base = spu->stats.class2_intr;
...@@ -267,6 +270,8 @@ static void spu_unbind_context(struct spu *spu, struct spu_context *ctx) ...@@ -267,6 +270,8 @@ static void spu_unbind_context(struct spu *spu, struct spu_context *ctx)
spu->pid, spu->number, spu->node); spu->pid, spu->number, spu->node);
spuctx_switch_state(ctx, SPU_UTIL_SYSTEM); spuctx_switch_state(ctx, SPU_UTIL_SYSTEM);
if (spu->ctx->flags & SPU_CREATE_NOSCHED)
atomic_dec(&cbe_spu_info[spu->node].reserved_spus);
spu_switch_notify(spu, NULL); spu_switch_notify(spu, NULL);
spu_unmap_mappings(ctx); spu_unmap_mappings(ctx);
spu_save(&ctx->csa, spu); spu_save(&ctx->csa, spu);
......
...@@ -122,6 +122,7 @@ struct spu { ...@@ -122,6 +122,7 @@ struct spu {
struct spu_problem __iomem *problem; struct spu_problem __iomem *problem;
struct spu_priv2 __iomem *priv2; struct spu_priv2 __iomem *priv2;
struct list_head list; struct list_head list;
struct list_head cbe_list;
struct list_head sched_list; struct list_head sched_list;
struct list_head full_list; struct list_head full_list;
int number; int number;
...@@ -181,6 +182,15 @@ struct spu { ...@@ -181,6 +182,15 @@ struct spu {
} stats; } stats;
}; };
struct cbe_spu_info {
struct list_head spus;
struct list_head free_spus;
int n_spus;
atomic_t reserved_spus;
};
extern struct cbe_spu_info cbe_spu_info[];
struct spu *spu_alloc(void); struct spu *spu_alloc(void);
struct spu *spu_alloc_node(int node); struct spu *spu_alloc_node(int node);
void spu_free(struct spu *spu); void spu_free(struct spu *spu);
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment