cell/spufs/sched.c

254 static void aff_merge_remaining_ctxs(struct spu_gang *gang)
258 	list_for_each_entry(ctx, &gang->aff_list_head, aff_list) {
260 			list_add(&ctx->aff_list, &gang->aff_list_head);
262 	gang->aff_flags |= AFF_MERGED;
265 static void aff_set_offsets(struct spu_gang *gang)
271 	list_for_each_entry_reverse(ctx, &gang->aff_ref_ctx->aff_list,
273 		if (&ctx->aff_list == &gang->aff_list_head)
279 	list_for_each_entry(ctx, gang->aff_ref_ctx->aff_list.prev, aff_list) {
280 		if (&ctx->aff_list == &gang->aff_list_head)
285 	gang->aff_flags |= AFF_OFFSETS_SET;
318 			if (spu->ctx && spu->ctx->gang && !spu->ctx->aff_offset
319 					&& spu->ctx->gang->aff_ref_spu)
320 				available_spus -= spu->ctx->gang->contexts;
323 		if (available_spus < ctx->gang->contexts) {
340 static void aff_set_ref_point_location(struct spu_gang *gang)
345 	mem_aff = gang->aff_ref_ctx->flags & SPU_CREATE_AFFINITY_MEM;
349 	list_for_each_entry(tmp, &gang->aff_list_head, aff_list)
352 	list_for_each_entry_reverse(ctx, &gang->aff_ref_ctx->aff_list,
354 		if (&ctx->aff_list == &gang->aff_list_head)
359 	gang->aff_ref_spu = aff_ref_location(gang->aff_ref_ctx, mem_aff, gs,
395 	struct spu_gang *gang = ctx->gang;
400 	if (atomic_read(&ctx->gang->aff_sched_count) == 0)
401 		ctx->gang->aff_ref_spu = NULL;
403 	if (!gang->aff_ref_spu) {
404 		if (!(gang->aff_flags & AFF_MERGED))
405 			aff_merge_remaining_ctxs(gang);
406 		if (!(gang->aff_flags & AFF_OFFSETS_SET))
407 			aff_set_offsets(gang);
408 		aff_set_ref_point_location(gang);
411 	return gang->aff_ref_spu != NULL;
430 	if (ctx->gang)
432 		 * If ctx->gang->aff_sched_count is positive, SPU affinity is
433 		 * being considered in this gang. Using atomic_dec_if_positive
434 		 * allow us to skip an explicit check for affinity in this gang
436 		atomic_dec_if_positive(&ctx->gang->aff_sched_count);
560 	if (ctx->gang) {
561 		mutex_lock(&ctx->gang->aff_mutex);
563 			aff_ref_spu = ctx->gang->aff_ref_spu;
564 			atomic_inc(&ctx->gang->aff_sched_count);
565 			mutex_unlock(&ctx->gang->aff_mutex);
574 			atomic_dec(&ctx->gang->aff_sched_count);
577 		mutex_unlock(&ctx->gang->aff_mutex);