summaryrefslogtreecommitdiffstats
path: root/kernel/include/linux/reset-controller.h
blob: ce6b962ffed43d892aa1bea3749e923f0032ea1f (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
#ifndef _LINUX_RESET_CONTROLLER_H_
#define _LINUX_RESET_CONTROLLER_H_

#include <linux/list.h>

struct reset_controller_dev;

/**
 * struct reset_control_ops
 *
 * @reset: for self-deasserting resets, does all necessary
 *         things to reset the device
 * @assert: manually assert the reset line, if supported
 * @deassert: manually deassert the reset line, if supported
 * @status: return the status of the reset line, if supported
 */
struct reset_control_ops {
	int (*reset)(struct reset_controller_dev *rcdev, unsigned long id);
	int (*assert)(struct reset_controller_dev *rcdev, unsigned long id);
	int (*deassert)(struct reset_controller_dev *rcdev, unsigned long id);
	int (*status)(struct reset_controller_dev *rcdev, unsigned long id);
};

struct module;
struct device_node;
struct of_phandle_args;

/**
 * struct reset_controller_dev - reset controller entity that might
 *                               provide multiple reset controls
 * @ops: a pointer to device specific struct reset_control_ops
 * @owner: kernel module of the reset controller driver
 * @list: internal list of reset controller devices
 * @of_node: corresponding device tree node as phandle target
 * @of_reset_n_cells: number of cells in reset line specifiers
 * @of_xlate: translation function to translate from specifier as found in the
 *            device tree to id as given to the reset control ops
 * @nr_resets: number of reset controls in this reset controller device
 */
struct reset_controller_dev {
	struct reset_control_ops *ops;
	struct module *owner;
	struct list_head list;
	struct device_node *of_node;
	int of_reset_n_cells;
	int (*of_xlate)(struct reset_controller_dev *rcdev,
			const struct of_phandle_args *reset_spec);
	unsigned int nr_resets;
};

int reset_controller_register(struct reset_controller_dev *rcdev);
void reset_controller_unregister(struct reset_controller_dev *rcdev);

#endif
# hugepage management # def get_hugepage_size(): """Return the size of the configured hugepages """ hugepage_size_re = re.compile(r'^Hugepagesize:\s+(?P<size_hp>\d+)\s+kB', re.IGNORECASE) with open('/proc/meminfo', 'r') as fh: data = fh.readlines() for line in data: match = hugepage_size_re.search(line) if match: _LOGGER.info('Hugepages size: %s', match.group('size_hp')) return int(match.group('size_hp')) else: _LOGGER.error('Could not parse for hugepage size') return 0 def allocate_hugepages(): """Allocate hugepages on the fly """ hp_size = get_hugepage_size() if hp_size > 0: nr_hp = int(math.ceil(settings.getValue('HUGEPAGE_RAM_ALLOCATION')/hp_size)) _LOGGER.info('Will allocate %s hugepages.', nr_hp) nr_hugepages = 'vm.nr_hugepages=' + str(nr_hp) try: tasks.run_task(['sudo', 'sysctl', nr_hugepages], _LOGGER, 'Trying to allocate hugepages..', True) except subprocess.CalledProcessError: _LOGGER.error('Unable to allocate hugepages.') return False global _allocated_hugepages _allocated_hugepages = True return True else: _LOGGER.error('Division by 0 will be supported in next release') return False def deallocate_hugepages(): """De-allocate hugepages that were allocated on the fly """ global _allocated_hugepages if _allocated_hugepages: nr_hugepages = 'vm.nr_hugepages= 0' try: tasks.run_task(['sudo', 'sysctl', nr_hugepages], _LOGGER, 'Trying to de-allocate hugepages..', True) except subprocess.CalledProcessError: _LOGGER.error('Unable to de-allocate hugepages.') return False _allocated_hugepages = False return True def get_free_hugepages(socket=None): """Get the free hugepage totals on the system. :param socket: optional socket param to get free hugepages on a socket. To be passed a string. :returns: hugepage amount as int """ hugepage_free_re = re.compile(r'HugePages_Free:\s+(?P<free_hp>\d+)$') if socket: if os.path.exists( '/sys/devices/system/node/node{}/meminfo'.format(socket)): meminfo_path = '/sys/devices/system/node/node{}/meminfo'.format( socket) else: _LOGGER.info('No hugepage info found for socket {}'.format(socket)) return 0 else: meminfo_path = '/proc/meminfo' with open(meminfo_path, 'r') as fh: data = fh.readlines() for line in data: match = hugepage_free_re.search(line) if match: _LOGGER.info('Hugepages free: %s %s', match.group('free_hp'), 'on socket {}'.format(socket) if socket else '') return int(match.group('free_hp')) else: _LOGGER.info('Could not parse for hugepage size') return 0 def is_hugepage_available(): """Check if hugepages are configured/available on the system. """ hugepage_size_re = re.compile(r'^Hugepagesize:\s+(?P<size_hp>\d+)\s+kB', re.IGNORECASE) # read in meminfo with open('/proc/meminfo') as mem_file: mem_info = mem_file.readlines() # see if the hugepage size is the recommended value for line in mem_info: match_size = hugepage_size_re.match(line) if match_size: if match_size.group('size_hp') != '1048576': _LOGGER.info( '%s%s%s kB', 'Hugepages not configured for recommend 1GB size. ', 'Currently set at ', match_size.group('size_hp')) num_huge = get_free_hugepages() if num_huge == 0: _LOGGER.info('No free hugepages.') if not allocate_hugepages(): return False else: _LOGGER.info('Found \'%s\' free hugepage(s).', num_huge) return True def is_hugepage_mounted(): """Check if hugepages are mounted. """ output = subprocess.check_output(['mount'], shell=True) my_encoding = locale.getdefaultlocale()[1] for line in output.decode(my_encoding).split('\n'): if 'hugetlbfs' in line: return True return False def mount_hugepages(): """Ensure hugepages are mounted. Raises RuntimeError if no configured hugepages are available. """ if not is_hugepage_available(): raise RuntimeError('No Hugepages configured.') if is_hugepage_mounted(): return if not os.path.exists(settings.getValue('HUGEPAGE_DIR')): tasks.run_task(['sudo', 'mkdir', settings.getValue('HUGEPAGE_DIR')], _LOGGER, 'Creating directory ' + settings.getValue('HUGEPAGE_DIR'), True) try: tasks.run_task(['sudo', 'mount', '-t', 'hugetlbfs', 'nodev', settings.getValue('HUGEPAGE_DIR')], _LOGGER, 'Mounting hugepages...', True) except subprocess.CalledProcessError: _LOGGER.error('Unable to mount hugepages.') def umount_hugepages(): """Ensure hugepages are unmounted. """ if not is_hugepage_mounted(): return try: tasks.run_task(['sudo', 'umount', settings.getValue('HUGEPAGE_DIR')], _LOGGER, 'Unmounting hugepages...', True) except subprocess.CalledProcessError: _LOGGER.error('Unable to umount hugepages.') if not deallocate_hugepages(): _LOGGER.error('Unable to deallocate previously allocated hugepages.')