input:b0011v0001p0001eAB41-e0,1,4,11,14,k71,72,73,74,75,76,77,79,7A,7B,7C,7D,7E,7F,80,8C,8E,8F,9B,9C,9D,9E,9F,A3,A4,A5,A6,AC,AD,B7,B8,B9,D9,E2,ram4,l0,1,2,sfw
# li~ h
nbѿ
L 8 # Copyright (C) 2011-2016 Red Hat, Inc.
# This library is free software; you can redistribute it and/or
# modify it under the terms of the GNU Lesser General Public
# License as published by the Free Software Foundation; either
# version 2.1 of the License, or any later version.
#
# This library is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
# Lesser General Public License for more details.
#
# You should have received a copy of the GNU Lesser General Public
# License along with this library; If not, see .
#
# Author: tasleson
# Gris Ge
from lsm import (uri_parse, VERSION, Capabilities, INfs,
IStorageAreaNetwork, search_property, Client, LsmError,
ErrorNumber)
from lsm.plugin.sim.simarray import SimArray
class SimPlugin(INfs, IStorageAreaNetwork):
"""
Simple class that implements enough to allow the framework to be exercised.
"""
def __init__(self):
self.uri = None
self.password = None
self.sim_array = None
def plugin_register(self, uri, password, timeout, flags=0):
self.uri = uri
self.password = password
# The caller may want to start clean, so we allow the caller to specify
# a file to store and retrieve individual state.
qp = uri_parse(uri)
if 'parameters' in qp and 'statefile' in qp['parameters'] \
and qp['parameters']['statefile'] is not None:
self.sim_array = SimArray(qp['parameters']['statefile'], timeout)
else:
self.sim_array = SimArray(None, timeout)
return None
def plugin_unregister(self, flags=0):
pass
def job_status(self, job_id, flags=0):
return self.sim_array.job_status(job_id, flags)
def job_free(self, job_id, flags=0):
return self.sim_array.job_free(job_id, flags)
@staticmethod
def _sim_data_2_lsm(sim_data):
"""
Fake converter. SimArray already do SimData to LSM data convert.
We move data convert to SimArray to make this sample plugin looks
clean.
But in real world, data converting is often handled by plugin itself
rather than array.
"""
return sim_data
def time_out_set(self, ms, flags=0):
self.sim_array.time_out_set(ms, flags)
return None
def time_out_get(self, flags=0):
return self.sim_array.time_out_get(flags)
def capabilities(self, system, flags=0):
rc = Capabilities()
rc.enable_all()
rc.set(Capabilities.POOLS_QUICK_SEARCH, Capabilities.UNSUPPORTED)
rc.set(Capabilities.VOLUMES_QUICK_SEARCH, Capabilities.UNSUPPORTED)
rc.set(Capabilities.DISKS_QUICK_SEARCH, Capabilities.UNSUPPORTED)
rc.set(Capabilities.FS_QUICK_SEARCH, Capabilities.UNSUPPORTED)
rc.set(Capabilities.ACCESS_GROUPS_QUICK_SEARCH,
Capabilities.UNSUPPORTED)
rc.set(Capabilities.NFS_EXPORTS_QUICK_SEARCH, Capabilities.UNSUPPORTED)
rc.set(Capabilities.TARGET_PORTS_QUICK_SEARCH,
Capabilities.UNSUPPORTED)
rc.set(Capabilities.VOLUME_PHYSICAL_DISK_CACHE_UPDATE_SYSTEM_LEVEL,
Capabilities.UNSUPPORTED)
rc.set(Capabilities.VOLUME_WRITE_CACHE_POLICY_UPDATE_IMPACT_READ,
Capabilities.UNSUPPORTED)
rc.set(Capabilities.VOLUME_WRITE_CACHE_POLICY_UPDATE_WB_IMPACT_OTHER,
Capabilities.UNSUPPORTED)
rc.set(Capabilities.VOLUME_READ_CACHE_POLICY_UPDATE_IMPACT_WRITE,
Capabilities.UNSUPPORTED)
return rc
def plugin_info(self, flags=0):
return "Storage simulator", VERSION
def systems(self, flags=0):
sim_syss = self.sim_