本文整理汇总了Python中up2dateLog.initLog函数的典型用法代码示例。如果您正苦于以下问题:Python initLog函数的具体用法?Python initLog怎么用?Python initLog使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了initLog函数的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Python代码示例。
示例1: __init__
def __init__(self, cacheObject = None):
# this is the cache, stuff here is only in storageDir
self.cfg = config.initUp2dateConfig()
self.log = up2dateLog.initLog()
self.dir_list = [self.cfg["storageDir"]]
self.ts = transaction.initReadOnlyTransaction()
PackageSource.__init__(self, cacheObject = cacheObject)
开发者ID:smgoller,项目名称:mrepo,代码行数:7,代码来源:rpmSource.py
示例2: readCachedLogin
def readCachedLogin():
"""
Read pickle info from a file
Caches authorization info for connecting to the server.
"""
log = up2dateLog.initLog()
log.log_debug("readCachedLogin invoked")
if not os.access(pcklAuthFileName, os.R_OK):
log.log_debug("Unable to read pickled loginInfo at: %s" % pcklAuthFileName)
return False
pcklAuth = open(pcklAuthFileName, 'rb')
try:
data = pickle.load(pcklAuth)
except EOFError:
log.log_debug("Unexpected EOF. Probably an empty file, \
regenerate auth file")
pcklAuth.close()
return False
pcklAuth.close()
createdTime = data['time']
li = data['loginInfo']
currentTime = time.time()
expireTime = createdTime + float(li['X-RHN-Auth-Expire-Offset'])
#Check if expired, offset is stored in "X-RHN-Auth-Expire-Offset"
log.log_debug("Checking pickled loginInfo, currentTime=", currentTime,
", createTime=", createdTime, ", expire-offset=",
float(li['X-RHN-Auth-Expire-Offset']))
if (currentTime > expireTime):
log.log_debug("Pickled loginInfo has expired, created = %s, expire = %s." \
%(createdTime, expireTime))
return False
_updateLoginInfo(li)
log.log_debug("readCachedLogin(): using pickled loginInfo set to expire at ", expireTime)
return True
开发者ID:renner,项目名称:spacewalk,代码行数:34,代码来源:up2dateAuth.py
示例3: _initialize_dmi_data
def _initialize_dmi_data():
""" Initialize _dmi_data unless it already exist and returns it """
global _dmi_data, _dmi_not_available
if _dmi_data is None:
if _dmi_not_available:
# do not try to initialize it again and again if not available
return None
else :
dmixml = dmidecode.dmidecodeXML()
dmixml.SetResultType(dmidecode.DMIXML_DOC)
# Get all the DMI data and prepare a XPath context
try:
data = dmixml.QuerySection('all')
dmi_warn = dmi_warnings()
if dmi_warn:
dmidecode.clear_warnings()
log = up2dateLog.initLog()
log.log_debug("dmidecode warnings: " % dmi_warn)
except:
# DMI decode FAIL, this can happend e.g in PV guest
_dmi_not_available = 1
dmi_warn = dmi_warnings()
if dmi_warn:
dmidecode.clear_warnings()
return None
_dmi_data = data.xpathNewContext()
return _dmi_data
开发者ID:aronparsons,项目名称:spacewalk,代码行数:27,代码来源:hardware.py
示例4: doCall
def doCall(method, *args, **kwargs):
log = up2dateLog.initLog()
cfg = config.initUp2dateConfig()
ret = None
attempt_count = 1
attempts = cfg["networkRetries"] or 5
while 1:
failure = 0
ret = None
try:
ret = apply(method, args, kwargs)
except KeyboardInterrupt:
raise up2dateErrors.CommunicationError(
"Connection aborted by the user")
# if we get a socket error, keep tryingx2
except (socket.error, socket.sslerror), e:
log.log_me("A socket error occurred: %s, attempt #%s" % (
e, attempt_count))
if attempt_count >= attempts:
if len(e.args) > 1:
raise up2dateErrors.CommunicationError(e.args[1])
else:
raise up2dateErrors.CommunicationError(e.args[0])
else:
failure = 1
except httplib.IncompleteRead:
print "httplib.IncompleteRead"
raise up2dateErrors.CommunicationError("httplib.IncompleteRead")
开发者ID:ChrisPortman,项目名称:mrepo,代码行数:30,代码来源:rpcServer.py
示例5: writeCachedLogin
def writeCachedLogin():
"""
Pickle loginInfo to a file
Returns:
True -- wrote loginInfo to a pickle file
False -- did _not_ write loginInfo to a pickle file
"""
log = up2dateLog.initLog()
log.log_debug("writeCachedLogin() invoked")
if not loginInfo:
log.log_debug("writeCachedLogin() loginInfo is None, so bailing.")
return False
data = {'time': time.time(),
'loginInfo': loginInfo}
pcklDir = os.path.dirname(pcklAuthFileName)
if not os.access(pcklDir, os.W_OK):
try:
os.mkdir(pcklDir)
os.chmod(pcklDir, 0700)
except:
log.log_me("Unable to write pickled loginInfo to %s" % pcklDir)
return False
pcklAuth = open(pcklAuthFileName, 'wb')
os.chmod(pcklAuthFileName, 0600)
pickle.dump(data, pcklAuth)
pcklAuth.close()
expireTime = data['time'] + float(loginInfo['X-RHN-Auth-Expire-Offset'])
log.log_debug("Wrote pickled loginInfo at ", data['time'], " with expiration of ",
expireTime, " seconds.")
return True
开发者ID:NehaRawat,项目名称:spacewalk,代码行数:31,代码来源:up2dateAuth.py
示例6: doCall
def doCall(method, *args, **kwargs):
log = up2dateLog.initLog()
log.log_debug("rpcServer: Calling XMLRPC %s" % method.__dict__["_Method__name"])
cfg = config.initUp2dateConfig()
ret = None
attempt_count = 1
try:
attempts = int(cfg["networkRetries"])
except ValueError:
attempts = 1
if attempts <= 0:
attempts = 1
while 1:
failure = 0
ret = None
try:
ret = method(*args, **kwargs)
except KeyboardInterrupt:
raise up2dateErrors.CommunicationError(_("Connection aborted by the user")), None, sys.exc_info()[2]
# if we get a socket error, keep tryingx2
except (socket.error, socket.sslerror), e:
log.log_me("A socket error occurred: %s, attempt #%s" % (e, attempt_count))
if attempt_count >= attempts:
if len(e.args) > 1:
raise up2dateErrors.CommunicationError(e.args[1]), None, sys.exc_info()[2]
else:
raise up2dateErrors.CommunicationError(e.args[0]), None, sys.exc_info()[2]
else:
failure = 1
except httplib.IncompleteRead:
print "httplib.IncompleteRead"
raise up2dateErrors.CommunicationError("httplib.IncompleteRead"), None, sys.exc_info()[2]
开发者ID:pombredanne,项目名称:spacewalk-2,代码行数:34,代码来源:rpcServer.py
示例7: login
def login(systemId=None):
server = rpcServer.getServer()
log = up2dateLog.initLog()
# send up the capabality info
headerlist = clientCaps.caps.headerFormat()
for (headerName, value) in headerlist:
server.add_header(headerName, value)
if systemId == None:
systemId = getSystemId()
if not systemId:
return None
maybeUpdateVersion()
log.log_me("logging into up2date server")
# the list of caps the client needs
caps = capabilities.Capabilities()
global loginInfo
try:
li = rpcServer.doCall(server.up2date.login, systemId)
except rpclib.Fault, f:
if abs(f.faultCode) == 49:
# print f.faultString
raise up2dateErrors.AbuseError(f.faultString)
else:
raise f
开发者ID:ChrisPortman,项目名称:mrepo,代码行数:30,代码来源:up2dateAuth.py
示例8: updateLoginInfo
def updateLoginInfo():
log = up2dateLog.initLog()
log.log_me("updating login info")
# NOTE: login() updates the loginInfo object
login()
if not loginInfo:
raise up2dateErrors.AuthenticationError("Unable to authenticate")
return loginInfo
开发者ID:ChrisPortman,项目名称:mrepo,代码行数:8,代码来源:up2dateAuth.py
示例9: updateLoginInfo
def updateLoginInfo(timeout=None):
log = up2dateLog.initLog()
log.log_me("updateLoginInfo() login info")
# NOTE: login() updates the loginInfo object
login(forceUpdate=True, timeout=timeout)
if not loginInfo:
raise up2dateErrors.AuthenticationError("Unable to authenticate")
return loginInfo
开发者ID:NehaRawat,项目名称:spacewalk,代码行数:8,代码来源:up2dateAuth.py
示例10: __init__
def __init__(self, filename = None):
self.repos = []
self.fileName = filename
self.log = up2dateLog.initLog()
self.cfg = config.initUp2dateConfig()
#just so we dont import repomd info more than onc
self.setupRepomd = None
if self.fileName:
self.load()
开发者ID:ChrisPortman,项目名称:mrepo,代码行数:9,代码来源:sourcesConfig.py
示例11: updatePackageProfile
def updatePackageProfile(timeout=None):
""" get a list of installed packages and send it to rhnServer """
log = up2dateLog.initLog()
log.log_me("Updating package profile")
packages = pkgUtils.getInstalledPackageList(getArch=1)
s = rhnserver.RhnServer(timeout=timeout)
if not s.capabilities.hasCapability('xmlrpc.packages.extended_profile', 2):
# for older satellites and hosted - convert to old format
packages = convertPackagesFromHashToList(packages)
s.registration.update_packages(up2dateAuth.getSystemId(), packages)
开发者ID:NehaRawat,项目名称:spacewalk,代码行数:10,代码来源:rhnPackageInfo.py
示例12: get_hal_system_and_smbios
def get_hal_system_and_smbios():
try:
if using_gudev:
props = get_computer_info()
else:
computer = get_hal_computer()
props = computer.GetAllProperties()
except Exception, e:
log = up2dateLog.initLog()
msg = "Error reading system and smbios information: %s\n" % (e)
log.log_debug(msg)
return {}
开发者ID:bjmingyang,项目名称:spacewalk,代码行数:12,代码来源:hardware.py
示例13: _request1
def _request1(self, methodname, params):
self.log = up2dateLog.initLog()
while 1:
try:
ret = self._request(methodname, params)
except rpclib.InvalidRedirectionError:
raise
except xmlrpclib.Fault:
raise
except httplib.BadStatusLine:
self.log.log_me("Error: Server Unavailable. Please try later.")
stdoutMsgCallback(_("Error: Server Unavailable. Please try later."))
sys.exit(-1)
except:
server = self.serverList.next()
if server == None:
# since just because we failed, the server list could
# change (aka, firstboot, they get an option to reset the
# the server configuration) so reset the serverList
self.serverList.resetServerIndex()
raise
msg = "An error occurred talking to %s:\n" % self._host
msg = msg + "%s\n%s\n" % (sys.exc_type, sys.exc_value)
msg = msg + "Trying the next serverURL: %s\n" % self.serverList.server()
self.log.log_me(msg)
# try a different url
# use the next serverURL
import urllib
typ, uri = urllib.splittype(self.serverList.server())
typ = typ.lower()
if typ not in ("http", "https"):
raise rpclib.InvalidRedirectionError(
"Redirected to unsupported protocol %s" % typ
), None, sys.exc_info()[2]
self._host, self._handler = urllib.splithost(uri)
self._orig_handler = self._handler
self._type = typ
self._uri = self.serverList.server()
if not self._handler:
self._handler = "/RPC2"
self._allow_redirect = 1
continue
# if we get this far, we succedded
break
return ret
开发者ID:pombredanne,项目名称:spacewalk-2,代码行数:49,代码来源:rpcServer.py
示例14: _request1
def _request1(self, methodname, params):
self.log = up2dateLog.initLog()
while 1:
try:
ret = self._request(methodname, params)
except rpclib.InvalidRedirectionError:
# print "GOT a InvalidRedirectionError"
raise
except rpclib.Fault:
raise
except:
server = self.serverList.next()
if server == None:
# since just because we failed, the server list could
# change (aka, firstboot, they get an option to reset the
# the server configuration) so reset the serverList
self.serverList.resetServerIndex()
raise
msg = "An error occured talking to %s:\n" % self._host
msg = msg + "%s\n%s\n" % (sys.exc_type, sys.exc_value)
msg = msg + "Trying the next serverURL: %s\n" % self.serverList.server()
self.log.log_me(msg)
# try a different url
# use the next serverURL
import urllib
typ, uri = urllib.splittype(self.serverList.server())
typ = string.lower(typ)
if typ not in ("http", "https"):
raise InvalidRedirectionError(
"Redirected to unsupported protocol %s" % typ)
# print "gha2"
self._host, self._handler = urllib.splithost(uri)
self._orig_handler = self._handler
self._type = typ
if not self._handler:
self._handler = "/RPC2"
self._allow_redirect = 1
continue
# if we get this far, we succedded
break
return ret
开发者ID:ChrisPortman,项目名称:mrepo,代码行数:44,代码来源:rpcServer.py
示例15: readCachedLogin
def readCachedLogin():
"""
Read pickle info from a file
Caches authorization info for connecting to the server.
"""
log = up2dateLog.initLog()
log.log_debug("readCachedLogin invoked")
if not os.access(pcklAuthFileName, os.R_OK):
log.log_debug("Unable to read pickled loginInfo at: %s" % pcklAuthFileName)
return False
pcklAuth = open(pcklAuthFileName, 'rb')
try:
data = pickle.load(pcklAuth)
except EOFError:
log.log_debug("Unexpected EOF. Probably an empty file, \
regenerate auth file")
pcklAuth.close()
return False
pcklAuth.close()
# Check if system_id has changed
try:
idVer = rpclib.xmlrpclib.loads(getSystemId())[0][0]['system_id']
cidVer = "ID-%s" % data['loginInfo']['X-RHN-Server-Id']
if idVer != cidVer:
log.log_debug("system id version changed: %s vs %s" % (idVer, cidVer))
return False
except:
pass
createdTime = data['time']
li = data['loginInfo']
currentTime = time.time()
expireTime = createdTime + float(li['X-RHN-Auth-Expire-Offset'])
#Check if expired, offset is stored in "X-RHN-Auth-Expire-Offset"
log.log_debug("Checking pickled loginInfo, currentTime=", currentTime,
", createTime=", createdTime, ", expire-offset=",
float(li['X-RHN-Auth-Expire-Offset']))
if (currentTime > expireTime):
log.log_debug("Pickled loginInfo has expired, created = %s, expire = %s." \
%(createdTime, expireTime))
return False
_updateLoginInfo(li)
log.log_debug("readCachedLogin(): using pickled loginInfo set to expire at ", expireTime)
return True
开发者ID:NehaRawat,项目名称:spacewalk,代码行数:43,代码来源:up2dateAuth.py
示例16: getChannels
def getChannels(force=None, label_whitelist=None):
cfg = config.initUp2dateConfig()
log = up2dateLog.initLog()
global selected_channels
# bz:210625 the selected_chs is never filled
# so it assumes there is no channel although
# channels are subscribed
selected_channels = label_whitelist
if not selected_channels and not force:
### mrepo: hardcode sources so we don't depend on /etc/sysconfig/rhn/sources
# sources = sourcesConfig.getSources()
sources = [{"url": "https://xmlrpc.rhn.redhat.com/XMLRPC", "type": "up2date"}]
useRhn = 1
if cfg.has_key("cmdlineChannel"):
sources.append({"type": "cmdline", "label": "cmdline"})
selected_channels = rhnChannelList()
cfg["useRhn"] = useRhn
li = up2dateAuth.getLoginInfo()
# login can fail...
if not li:
return []
tmp = li.get("X-RHN-Auth-Channels")
if tmp == None:
tmp = []
for i in tmp:
if label_whitelist and not label_whitelist.has_key(i[0]):
continue
channel = rhnChannel(label=i[0], version=i[1], type="up2date", url=cfg["serverURL"])
selected_channels.addChannel(channel)
if len(selected_channels.list) == 0:
raise up2dateErrors.NoChannelsError(
_("This system may not be updated until it is associated with a channel.")
)
return selected_channels
开发者ID:smgoller,项目名称:mrepo,代码行数:42,代码来源:rhnChannel.py
示例17: get_hal_system_and_smbios
def get_hal_system_and_smbios():
try:
if using_gudev:
props = get_computer_info()
else:
computer = get_hal_computer()
props = computer.GetAllProperties()
except Exception:
log = up2dateLog.initLog()
msg = "Error reading system and smbios information: %s\n" % (sys.exc_info()[1])
log.log_debug(msg)
return {}
system_and_smbios = {}
for key in props:
if key.startswith('system'):
system_and_smbios[unicode(key)] = unicode(props[key])
system_and_smbios.update(get_smbios())
return system_and_smbios
开发者ID:aronparsons,项目名称:spacewalk,代码行数:20,代码来源:hardware.py
示例18: getAdvisoryInfo
def getAdvisoryInfo(pkg, warningCallback=None):
log = up2dateLog.initLog()
cfg = config.initUp2dateConfig()
# no errata for non rhn use
if not cfg['useRhn']:
return None
s = rpcServer.getServer()
ts = transaction.initReadOnlyTransaction()
mi = ts.dbMatch('Providename', pkg[0])
if not mi:
return None
# odd,set h to last value in mi. mi has to be iterated
# to get values from it...
h = None
for h in mi:
break
info = None
# in case of package less errata that somehow apply
if h:
try:
pkgName = "%s-%s-%s" % (h['name'],
h['version'],
h['release'])
log.log_me("getAdvisoryInfo for %s" % pkgName)
info = rpcServer.doCall(s.errata.getPackageErratum,
up2dateAuth.getSystemId(),
pkg)
except rpclib.Fault, f:
if warningCallback:
warningCallback(f.faultString)
return None
开发者ID:ChrisPortman,项目名称:mrepo,代码行数:36,代码来源:rhnErrata.py
示例19: login
def login(systemId=None, forceUpdate=False, timeout=None):
log = up2dateLog.initLog()
log.log_debug("login(forceUpdate=%s) invoked" % (forceUpdate))
if not forceUpdate and not loginInfo:
if readCachedLogin():
return loginInfo
server = rhnserver.RhnServer(timeout=timeout)
# send up the capabality info
headerlist = clientCaps.caps.headerFormat()
for (headerName, value) in headerlist:
server.add_header(headerName, value)
if systemId == None:
systemId = getSystemId()
if not systemId:
return None
maybeUpdateVersion()
log.log_me("logging into up2date server")
li = server.up2date.login(systemId)
# figure out if were missing any needed caps
server.capabilities.validate()
_updateLoginInfo(li) #update global var, loginInfo
writeCachedLogin() #pickle global loginInfo
if loginInfo:
log.log_me("successfully retrieved authentication token "
"from up2date server")
log.log_debug("logininfo:", loginInfo)
return loginInfo
开发者ID:NehaRawat,项目名称:spacewalk,代码行数:36,代码来源:up2dateAuth.py
示例20: __repr__
def __repr__(self):
msg = "RPM dependency error. The message was:\n" + self.errmsg
log = up2dateLog.initLog()
log.log_me(msg)
return msg
开发者ID:ChrisPortman,项目名称:mrepo,代码行数:5,代码来源:up2dateErrors.py
注:本文中的up2dateLog.initLog函数示例由纯净天空整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论