Temporarily removed free space check on tape library frontend. We assume to have enough space. (c84a0f15) · Commits · VOSpace INAF / vospace-transfer-service

transfer_service/store_executor.py

+7 −6

Original line number	Original line	Diff line number	Diff line
	@@ -86,21 +86,22 @@ class StoreExecutor(TaskExecutor):
	if self.storageType == "hot":		if self.storageType == "hot":
	[ total, used, free ] = self.systemUtils.getFileSystemSize(storageBasePath)		[ total, used, free ] = self.systemUtils.getFileSystemSize(storageBasePath)
	storageFreeSpace = free - self.TOL		storageFreeSpace = free - self.TOL
	self.logger.debug(f"storageFreeSpace (hot): {storageFreeSpace}")		self.logger.debug(f"storageFreeSpace (hot): {storageFreeSpace} B")
	if storageFreeSpace < self.dataSize:		if storageFreeSpace < self.dataSize:
	return False		return False
	else:		else:
	[ total, used, free ] = self.systemUtils.getFileSystemSize(storageBasePath)		#[ total, used, free ] = self.systemUtils.getFileSystemSize(storageBasePath)
	tapeFrontendFreeSpace = free - self.maxBlockSize - self.TOL		#tapeFrontendFreeSpace = free - self.maxBlockSize - self.TOL
	self.tapeClient.connect()		self.tapeClient.connect()
	tapePoolList = self.tapeClient.getPoolList()		tapePoolList = self.tapeClient.getPoolList()
	for el in tapePoolList:		for el in tapePoolList:
	if el.getName() == self.tapePool:		if el.getName() == self.tapePool:
	storageFreeSpace = el.getFreeSpace() - self.TOL		storageFreeSpace = el.getFreeSpace() - self.TOL
	self.tapeClient.disconnect()		self.tapeClient.disconnect()
	self.logger.debug(f"tapeFrontendFreeSpace (cold): {tapeFrontendFreeSpace}")		#self.logger.debug(f"tapeFrontendFreeSpace (cold): {tapeFrontendFreeSpace}")
	self.logger.debug(f"storageFreeSpace (cold): {storageFreeSpace}")		self.logger.debug(f"storageFreeSpace (cold): {storageFreeSpace} B")
	if tapeFrontendFreeSpace < self.dataSize or storageFreeSpace < self.dataSize:		#if tapeFrontendFreeSpace < self.dataSize or storageFreeSpace < self.dataSize:
			if storageFreeSpace < self.dataSize:
	return False		return False
	destPathPrefix = storageBasePath + '/' + self.username		destPathPrefix = storageBasePath + '/' + self.username
	sp = subprocess.run(["rsync", "-av", srcPathPrefix + '/', destPathPrefix + '/'], capture_output = True)		sp = subprocess.run(["rsync", "-av", srcPathPrefix + '/', destPathPrefix + '/'], capture_output = True)