nvml 0.0.2

A mid-level wrapper around PMDK (the persistent memory development kit), formely NVML
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
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73

// This file is part of dpdk. It is subject to the license terms in the COPYRIGHT file found in the top-level directory of this distribution and at https://raw.githubusercontent.com/lemonrock/dpdk/master/COPYRIGHT. No part of dpdk, including this file, may be copied, modified, propagated, or distributed except according to the terms contained in the COPYRIGHT file.
// Copyright © 2017 The developers of dpdk. See the COPYRIGHT file in the top-level directory of this distribution and at https://raw.githubusercontent.com/lemonrock/dpdk/master/COPYRIGHT.


#[derive(Debug, Clone, PartialEq, Eq, PartialOrd, Ord, Hash)]
#[derive(Deserialize, Serialize)]
#[serde(default)]
pub struct ObjectPoolConfiguration
{
	poolSize: Option<usize>,
	permissions: mode_t,
	layoutName: Option<String>,
	skipExpensiveDebugChecks: bool,
	transactionCacheSize: u64,
	transactionCacheThreshold: u64,
}

impl Default for ObjectPoolConfiguration
{
	#[inline(always)]
	fn default() -> Self
	{
		Self
		{
			poolSize: None,
			permissions: Configuration::DefaultPermissionsForPoolSets,
			layoutName: None,
			skipExpensiveDebugChecks: false,
			transactionCacheSize: TX_DEFAULT_RANGE_CACHE_SIZE as u64,
			transactionCacheThreshold: TX_DEFAULT_RANGE_CACHE_THRESHOLD as u64,
		}
	}
}

impl ObjectPoolConfiguration
{
	pub fn openOrCreate(&self, objectPoolSetsFolderPath: &Path, fileName: &str) -> ObjectPool
	{
		let layoutName = match self.layoutName
		{
			None => fileName,
			Some(ref layoutName) => layoutName,
		};
		
		assert!(layoutName.len() + 1 <= PMEMOBJ_MAX_LAYOUT, "layoutName '{}' can not be larger than PMEMOBJ_MAX_LAYOUT '{}' - 1", layoutName, PMEMOBJ_MAX_LAYOUT);
		
		let poolSetFilePath = objectPoolSetsFolderPath.join(fileName);
		let layoutName = Some(layoutName);
		let objectPool = if likely(poolSetFilePath.exists())
		{
			assert!(poolSetFilePath.is_file(), "poolSetFilePath '{:?}' is not a file", poolSetFilePath);
			ObjectPool::open(&poolSetFilePath, layoutName).expect("Could not open ObjectPool")
		}
		else
		{
			let poolSize = match self.poolSize
			{
				None => 0,
				Some(poolSize) =>
				{
					assert!(poolSize >= PMEMOBJ_MIN_POOL, "poolSize '{}' is smaller than PMEMOBJ_MIN_POOL '{}'", poolSize, PMEMOBJ_MIN_POOL);
					poolSize
				},
			};
			ObjectPool::create(&poolSetFilePath, layoutName, poolSize, self.permissions).expect("Could not create ObjectPool")
		};
		
		objectPool.setTransactionDebugSkipExpensiveChecks(self.skipExpensiveDebugChecks);
		objectPool.setTransactionCacheSize(self.transactionCacheSize);
		objectPool.setTransactionCacheSize(self.transactionCacheThreshold);
		objectPool
	}
}