lewi_mask.c File Reference

#include "LB_policies/lewi_mask.h"
#include "LB_core/spd.h"
#include "LB_comm/shmem_cpuinfo.h"
#include "LB_comm/shmem_async.h"
#include "apis/dlb_errors.h"
#include "support/debug.h"
#include "support/mask_utils.h"
#include "support/small_array.h"
#include "support/types.h"
#include <sched.h>
#include <stdlib.h>
#include <string.h>
#include <pthread.h>
#include "support/array_template.h"

Include dependency graph for lewi_mask.c:

Data Structures
struct	lewi_info_t

Macros
#define	ARRAY_T   cpuid_t
#define	ARRAY_T   cpuinfo_task_t
#define	ARRAY_KEY_T   pid_t

Functions
int	lewi_mask_Init (subprocess_descriptor_t *spd)
int	lewi_mask_Finalize (subprocess_descriptor_t *spd)
int	lewi_mask_EnableDLB (const subprocess_descriptor_t *spd)
int	lewi_mask_DisableDLB (const subprocess_descriptor_t *spd)
int	lewi_mask_SetMaxParallelism (const subprocess_descriptor_t *spd, int max)
int	lewi_mask_UnsetMaxParallelism (const subprocess_descriptor_t *spd)
int	lewi_mask_IntoBlockingCall (const subprocess_descriptor_t *spd)
int	lewi_mask_OutOfBlockingCall (const subprocess_descriptor_t *spd)
int	lewi_mask_Lend (const subprocess_descriptor_t *spd)
int	lewi_mask_LendCpu (const subprocess_descriptor_t *spd, int cpuid)
int	lewi_mask_LendCpuMask (const subprocess_descriptor_t *spd, const cpu_set_t *mask)
int	lewi_mask_Reclaim (const subprocess_descriptor_t *spd)
int	lewi_mask_ReclaimCpu (const subprocess_descriptor_t *spd, int cpuid)
int	lewi_mask_ReclaimCpus (const subprocess_descriptor_t *spd, int ncpus)
int	lewi_mask_ReclaimCpuMask (const subprocess_descriptor_t *spd, const cpu_set_t *mask)
int	lewi_mask_AcquireCpu (const subprocess_descriptor_t *spd, int cpuid)
int	lewi_mask_AcquireCpus (const subprocess_descriptor_t *spd, int ncpus)
int	lewi_mask_AcquireCpuMask (const subprocess_descriptor_t *spd, const cpu_set_t *mask)
int	lewi_mask_AcquireCpusInMask (const subprocess_descriptor_t *spd, int ncpus, const cpu_set_t *mask)
int	lewi_mask_Borrow (const subprocess_descriptor_t *spd)
int	lewi_mask_BorrowCpu (const subprocess_descriptor_t *spd, int cpuid)
int	lewi_mask_BorrowCpus (const subprocess_descriptor_t *spd, int ncpus)
int	lewi_mask_BorrowCpuMask (const subprocess_descriptor_t *spd, const cpu_set_t *mask)
int	lewi_mask_BorrowCpusInMask (const subprocess_descriptor_t *spd, int ncpus, const cpu_set_t *mask)
int	lewi_mask_Return (const subprocess_descriptor_t *spd)
int	lewi_mask_ReturnCpu (const subprocess_descriptor_t *spd, int cpuid)
int	lewi_mask_ReturnCpuMask (const subprocess_descriptor_t *spd, const cpu_set_t *mask)
int	lewi_mask_CheckCpuAvailability (const subprocess_descriptor_t *spd, int cpuid)
int	lewi_mask_UpdateOwnership (const subprocess_descriptor_t *spd, const cpu_set_t *process_mask)

Macro Definition Documentation

ARRAY_T [1/2]

#define ARRAY_T   cpuid_t

ARRAY_T [2/2]

#define ARRAY_T   cpuinfo_task_t

ARRAY_KEY_T

#define ARRAY_KEY_T   pid_t

Function Documentation

lewi_mask_Init()

int lewi_mask_Init

(

subprocess_descriptor_t *

spd

)

lewi_mask_Finalize()

int lewi_mask_Finalize

(

subprocess_descriptor_t *

spd

)

lewi_mask_EnableDLB()

int lewi_mask_EnableDLB

(

const subprocess_descriptor_t *

spd

)

lewi_mask_DisableDLB()

int lewi_mask_DisableDLB

(

const subprocess_descriptor_t *

spd

)

lewi_mask_SetMaxParallelism()

int lewi_mask_SetMaxParallelism	(	const subprocess_descriptor_t *	spd,
		int	max
	)

lewi_mask_UnsetMaxParallelism()

int lewi_mask_UnsetMaxParallelism

(

const subprocess_descriptor_t *

spd

)

lewi_mask_IntoBlockingCall()

int lewi_mask_IntoBlockingCall

(

const subprocess_descriptor_t *

spd

)

lewi_mask_OutOfBlockingCall()

int lewi_mask_OutOfBlockingCall

(

const subprocess_descriptor_t *

spd

)

lewi_mask_Lend()

int lewi_mask_Lend

(

const subprocess_descriptor_t *

spd

)

lewi_mask_LendCpu()

int lewi_mask_LendCpu	(	const subprocess_descriptor_t *	spd,
		int	cpuid
	)

lewi_mask_LendCpuMask()

int lewi_mask_LendCpuMask	(	const subprocess_descriptor_t *	spd,
		const cpu_set_t *	mask
	)

lewi_mask_Reclaim()

int lewi_mask_Reclaim

(

const subprocess_descriptor_t *

spd

)

lewi_mask_ReclaimCpu()

int lewi_mask_ReclaimCpu	(	const subprocess_descriptor_t *	spd,
		int	cpuid
	)

lewi_mask_ReclaimCpus()

int lewi_mask_ReclaimCpus	(	const subprocess_descriptor_t *	spd,
		int	ncpus
	)

lewi_mask_ReclaimCpuMask()

int lewi_mask_ReclaimCpuMask	(	const subprocess_descriptor_t *	spd,
		const cpu_set_t *	mask
	)

lewi_mask_AcquireCpu()

int lewi_mask_AcquireCpu	(	const subprocess_descriptor_t *	spd,
		int	cpuid
	)

lewi_mask_AcquireCpus()

int lewi_mask_AcquireCpus	(	const subprocess_descriptor_t *	spd,
		int	ncpus
	)

lewi_mask_AcquireCpuMask()

int lewi_mask_AcquireCpuMask	(	const subprocess_descriptor_t *	spd,
		const cpu_set_t *	mask
	)

lewi_mask_AcquireCpusInMask()

int lewi_mask_AcquireCpusInMask	(	const subprocess_descriptor_t *	spd,
		int	ncpus,
		const cpu_set_t *	mask
	)

lewi_mask_Borrow()

int lewi_mask_Borrow

(

const subprocess_descriptor_t *

spd

)

lewi_mask_BorrowCpu()

int lewi_mask_BorrowCpu	(	const subprocess_descriptor_t *	spd,
		int	cpuid
	)

lewi_mask_BorrowCpus()

int lewi_mask_BorrowCpus	(	const subprocess_descriptor_t *	spd,
		int	ncpus
	)

lewi_mask_BorrowCpuMask()

int lewi_mask_BorrowCpuMask	(	const subprocess_descriptor_t *	spd,
		const cpu_set_t *	mask
	)

lewi_mask_BorrowCpusInMask()

int lewi_mask_BorrowCpusInMask	(	const subprocess_descriptor_t *	spd,
		int	ncpus,
		const cpu_set_t *	mask
	)

lewi_mask_Return()

int lewi_mask_Return

(

const subprocess_descriptor_t *

spd

)

lewi_mask_ReturnCpu()

int lewi_mask_ReturnCpu	(	const subprocess_descriptor_t *	spd,
		int	cpuid
	)

lewi_mask_ReturnCpuMask()

int lewi_mask_ReturnCpuMask	(	const subprocess_descriptor_t *	spd,
		const cpu_set_t *	mask
	)

lewi_mask_CheckCpuAvailability()

int lewi_mask_CheckCpuAvailability	(	const subprocess_descriptor_t *	spd,
		int	cpuid
	)

lewi_mask_UpdateOwnership()

int lewi_mask_UpdateOwnership	(	const subprocess_descriptor_t *	spd,
		const cpu_set_t *	process_mask
	)