;ò
[†?c           @   s¢  d  Z  d k Z d k Z d k Z d k Z d k Z d k Z d k Z d k Z d k	 Z	 d k
 Z
 d k Z d k Z d k Z d k Z d k Z d k Z d k Z d k Z d k Z d k Z d k Z d k Z d k l Z d k l Z l Z d Z d „  Z d f  d „  ƒ  YZ d f  d	 „  ƒ  YZ d
 f  d „  ƒ  YZ d e f d „  ƒ  YZ  d e f d „  ƒ  YZ! d e f d „  ƒ  YZ" d e f d „  ƒ  YZ# d „  Z$ d „  Z% d S(   sH   A chain of responsibility class for stacking package sources for up2dateN(   s   rpclib(   s   _s   N_iœ  c         O   s   t  |  | | ƒ Sd  S(   N(   s   applys   aClasss   argss   kwargs(   s   aClasss   argss   kwargs(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys   factory/   s    s   HeaderCachec           B   sw   t  Z d „  Z d „  Z d „  Z d „  Z d „  Z d „  Z d „  Z d „  Z	 d	 „  Z
 e d
 „ Z d „  Z d „  Z RS(   Nc         C   sP   t  i ƒ  |  _ |  i d o |  i d |  _ n
 d |  _ h  |  _ h  |  _ d  S(   Ns   headerCacheSizei   (   s   configs   initUp2dateConfigs   selfs   cfgs
   cache_sizes   _HeaderCache__caches   _HeaderCache__cacheLite(   s   self(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys   __init__4   s    		c         C   s   | |  _ d  S(   N(   s   number_of_headerss   selfs
   cache_size(   s   selfs   number_of_headers(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys   set_cache_size>   s    c         C   sp   h  } | d | d <| d | d <| d | d <| d | d <| d | d <| d | d <| d | d <| Sd  S(   Ns   names   versions   releases   archs   summarys   descriptions   size(   s   tmps   header(   s   selfs   headers   tmp(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys
   __liteCopyA   s    c         C   s‹   t  |  i ƒ |  i j o' | |  i | <|  i | ƒ |  i | <nH |  i i ƒ  } |  i | |  i d =| |  i | <|  i | ƒ |  i | <d  S(   Ni   (
   s   lens   selfs   _HeaderCache__caches
   cache_sizes   values   items   _HeaderCache__liteCopys   _HeaderCache__cacheLites   keyss   bar(   s   selfs   items   values   bar(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys   __setitem__L   s    c         C   s   |  i | Sd  S(   N(   s   selfs   _HeaderCache__caches   item(   s   selfs   item(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys   __getitem__Z   s    c         C   s   |  i | Sd  S(   N(   s   selfs   _HeaderCache__cacheLites   item(   s   selfs   item(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys   getLite^   s    c         C   s   t  |  i ƒ Sd  S(   N(   s   lens   selfs   _HeaderCache__cache(   s   self(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys   __len__a   s    c         C   s   |  i i ƒ  Sd  S(   N(   s   selfs   _HeaderCache__caches   keys(   s   self(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys   keysd   s    c         C   s   |  i i ƒ  Sd  S(   N(   s   selfs   _HeaderCache__caches   keys(   s   self(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys   valuesg   s    c         C   s/   | o |  i i | ƒ Sn |  i i | ƒ Sd  S(   N(   s   lites   selfs   _HeaderCache__cacheLites   has_keys   items   _HeaderCache__cache(   s   selfs   items   lite(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys   has_keyj   s    c         C   s   |  i | =d  S(   N(   s   selfs   _HeaderCache__caches   item(   s   selfs   item(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys   __delitem__t   s    c         C   s   |  i GHd  S(   N(   s   selfs   _HeaderCache__cacheLite(   s   self(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys	   printLitew   s    (   s   __name__s
   __module__s   __init__s   set_cache_sizes   _HeaderCache__liteCopys   __setitem__s   __getitem__s   getLites   __len__s   keyss   valuess   Nones   has_keys   __delitem__s	   printLite(    (    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys   HeaderCache3   s   	
								
	s   PackageSourceChainc           B   s•   t  Z e e d „ Z d „  Z d „  Z d „  Z d „  Z e e d „ Z e e d „ Z	 e e d „ Z
 e e d	 „ Z e e d
 „ Z e e d „ Z RS(   Nc         C   s]   t  i ƒ  |  _ h  |  _ g  |  _ | t j o" x | D] } |  i	 | ƒ q5 Wn | |  _ d  S(   N(   s
   up2dateLogs   initLogs   selfs   logs   metainfos   source_lists   metainfolists   Nones   sources   addSourceClasss   headerCacheObjects   headerCache(   s   selfs   headerCacheObjects   metainfolists   source(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys   __init__   s    		 c         C   ss   | } | d } |  i i d | ƒ |  i i | ƒ t | d | d | d ƒ |  i  | <|  i  | i	 |  i
 ƒ d  S(   Ns   names   add source class names   classs   argss   kargs(   s   metainfos   sources   names   selfs   logs	   log_debugs   source_lists   appends   factorys   addHeaderCacheObjects   headerCache(   s   selfs   metainfos   sources   name(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys   addSourceClass   s    
%c         C   s   h  |  _ g  |  _ d  S(   N(   s   selfs   metainfos   source_list(   s   self(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys   clearSourceInstancesœ   s    	c         C   s,   |  i ƒ  x | D] } |  i | ƒ q Wd  S(   N(   s   selfs   clearSourceInstancess   metainfoLists   metainfos   addSourceInstance(   s   selfs   metainfoLists   metainfo(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys   setSourceInstances    s    
 c         C   sp   | } | d } |  i i d | ƒ |  i i | ƒ | d |  i  | <|  i  | i |  i	 ƒ | |  i  | d <d  S(   Ns   names   add instance class names   object(
   s   metainfos   sources   names   selfs   logs	   log_debugs   source_lists   appends   addHeaderCacheObjects   headerCache(   s   selfs   metainfos   sources   name(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys   addSourceInstance¥   s    
c         C   s„   |  i i d | ƒ xf |  i D][ } |  i | } | i | | | ƒ } | t j o& |  i i d | | d f ƒ | Sq q Wt Sd  S(   Ns
   getPackages   Package %s Fetched via: %ss   name(   s   selfs   logs	   log_debugs   pkgs   source_lists
   source_keys   metainfos   sources
   getPackages   MsgCallbacks   progressCallbacks   packages   None(   s   selfs   pkgs   MsgCallbacks   progressCallbacks   packages
   source_keys   source(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys
   getPackage²   s    
 c         C   sŠ   |  i i d | | ƒ xi |  i D]^ } |  i | } | i	 | | | | ƒ } | t j o& |  i i d | | d f ƒ | Sq  q  Wt Sd  S(   Ns   getPackageSources!   Source %s Package Fetched via: %ss   name(   s   selfs   logs	   log_debugs   channels   pkgs   source_lists
   source_keys   metainfos   sources   getPackageSources   MsgCallbacks   progressCallbacks   packages   None(   s   selfs   channels   pkgs   MsgCallbacks   progressCallbacks   packages
   source_keys   source(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys   getPackageSource¿   s    
 c         C   s{   xp |  i D]e } |  i | } | i | d | ƒ} | t	 j o0 |  i
 i d | | d f ƒ | | d f Sq
 q
 Wt	 Sd  S(   Ns   progressCallbacks   Header for %s Fetched via: %ss   name(   s   selfs   source_lists
   source_keys   metainfos   sources	   getHeaders   pkgs   progressCallbacks   headers   Nones   logs	   log_debug(   s   selfs   pkgs   msgCallbacks   progressCallbacks   headers
   source_keys   source(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys	   getHeaderÎ   s    
 c         C   st   xi |  i D]^ } |  i | } | i | | | ƒ } | t
 j o) |  i i d | d ƒ | | d f Sq
 q
 Wt
 Sd  S(   Ns   listPackages Fetched via:s   name(   s   selfs   source_lists
   source_keys   metainfos   sources   listPackagess   channels   msgCallbacks   progressCallbacks   packageLists   Nones   logs	   log_debug(   s   selfs   channels   msgCallbacks   progressCallbacks   packageLists
   source_keys   source(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys   listPackagesÜ   s    
 	c         C   st   xi |  i D]^ } |  i | } | i | | | ƒ } | t
 j o) |  i i d | d ƒ | | d f Sq
 q
 Wt
 Sd  S(   Ns   listAllPackages Fetched via:s   name(   s   selfs   source_lists
   source_keys   metainfos   sources   listAllPackagess   channels   msgCallbacks   progressCallbacks   packageLists   Nones   logs	   log_debug(   s   selfs   channels   msgCallbacks   progressCallbacks   packageLists
   source_keys   source(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys   listAllPackagesè   s    
 	c         C   st   xi |  i D]^ } |  i | } | i | | | ƒ } | t
 j o) |  i i d | d ƒ | | d f Sq
 q
 Wt
 Sd  S(   Ns   getObsoletes Fetched via:s   name(   s   selfs   source_lists
   source_keys   metainfos   sources   getObsoletess   channels   msgCallbacks   progressCallbacks   obsoletesLists   Nones   logs	   log_debug(   s   selfs   channels   msgCallbacks   progressCallbacks   obsoletesLists
   source_keys   source(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys   getObsoletesô   s    
 	(   s   __name__s
   __module__s   Nones   __init__s   addSourceClasss   clearSourceInstancess   setSourceInstancess   addSourceInstances
   getPackages   getPackageSources	   getHeaders   listPackagess   listAllPackagess   getObsoletes(    (    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys   PackageSourceChain€   s   				s   PackageSourcec           B   sA   t  Z e d „ Z d „  Z d „  Z d „  Z d „  Z d „  Z RS(   Nc         C   s   t  |  _ h  |  _ d  S(   N(   s   Nones   selfs   headerCaches   info(   s   selfs   cacheObject(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys   __init__  s    	c         C   s   d S(   s    N(    (   s   selfs   pkg(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys	   getHeader  s     c         C   s   d S(   s    N(    (   s   selfs   pkg(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys
   getPackage
  s     c         C   s   | |  _ d S(   s    N(   s   cacheObjects   selfs   headerCache(   s   selfs   cacheObject(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys   addHeaderCacheObject  s     c         C   s   | |  i | <d  S(   N(   s   values   selfs   infos   item(   s   selfs   items   value(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys   __setitem__  s    c         C   s   |  i | Sd  S(   N(   s   selfs   infos   item(   s   selfs   item(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys   __getitem__  s    (	   s   __name__s
   __module__s   Nones   __init__s	   getHeaders
   getPackages   addHeaderCacheObjects   __setitem__s   __getitem__(    (    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys   PackageSource  s   				s   HeaderMemoryCachec           B   s&   t  Z e d „ Z e e e d „ Z RS(   Nc         C   s   t  i |  | ƒ d  S(   N(   s   PackageSources   __init__s   selfs   cacheObject(   s   selfs   cacheObject(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys   __init__  s    c         C   s‚   | oC |  i i t i | ƒ d d ƒo |  i i t i | ƒ ƒ SqJ n |  i i t i | ƒ ƒ o |  i t i | ƒ Sn d  S(   Ns   litei   (   s   lites   selfs   headerCaches   has_keys   up2dateUtilss   pkgToStringArchs   pkgs   getLite(   s   selfs   pkgs   lites   msgCallbacks   progressCallback(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys	   getHeader  s
    "!(   s   __name__s
   __module__s   Nones   __init__s	   getHeader(    (    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys   HeaderMemoryCache  s   s	   LocalDiskc           B   sV   t  Z e e d „ Z d „  Z d „  Z e e d „ Z e e d „ Z e e d „ Z RS(   Nc         C   sn   t  i ƒ  |  _ t i ƒ  |  _ t i ƒ  |  _	 | o |  i	 | |  _	 n t i ƒ  |  _ t i |  d | ƒd  S(   Ns   cacheObject(   s   configs   initUp2dateConfigs   selfs   cfgs
   up2dateLogs   initLogs   logs   up2dateUtilss   getPackageSearchPaths   dir_lists   packagePaths   transactions   initReadOnlyTransactions   tss   PackageSources   __init__s   cacheObject(   s   selfs   cacheObjects   packagePath(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys   __init__'  s    c         C   s   |  i | |  _ d  S(   N(   s   selfs   dir_lists   packagePath(   s   selfs   packagePath(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys   addPackageDir1  s    c         C   s&   t  i | i ƒ  ƒ } t i | ƒ d  S(   N(   s   rpmUtilss   readHeaderBlobs   hdrs   unloads   tmps   rpmSourceUtilss
   saveHeader(   s   selfs   hdrs   tmp(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys   __saveHeader4  s    c         C   sï  d | d | d | d | d f } xA |  i D]6 }
 t i d |
 | f ƒ } d |  i d | f } q0 W| }	 t
 |	 ƒ o”t i |	 d t i ƒ ort i d |	 d ƒ o• t i |	 d ƒ d	 d j o t Sn t |	 d d
 ƒ } y t i | i ƒ  ƒ } Wn t Sn X| |  i t i | ƒ <| i ƒ  |  i | ƒ | Sqt i |	 d d ƒ } |  i i t i  t i! Bƒ y |  i i" | ƒ } Wn6 t i | ƒ |  i i# ƒ  t$ i% t& d ƒ ƒ ‚ n X|  i i# ƒ  t i | ƒ | |  i t i | ƒ <|  i | ƒ | Sqët SnÛx3 |  i D]( }
 t i d |
 t i' | ƒ f ƒ }	 qWt
 |	 ƒ o“t i |	 d t i ƒ oqt i d |	 d ƒ o  t i |	 d ƒ d	 d j o t Sn t |	 d d
 ƒ } y t i | i ƒ  ƒ } Wn# |  i( i) d |	 d ƒ t Sn X| i ƒ  | |  i t i | ƒ <| Sqãt i |	 d t i ƒ o— t i |	 d d ƒ } y |  i i" | ƒ } Wn) t i | ƒ t$ i% t& d ƒ ƒ ‚ n Xt i | ƒ |  i( i) d |	 ƒ | |  i t i | ƒ <| Sqãt Sqët Sn t Sd  S(   Ns   %s-%s-%s.%s.rpmi    i   i   i   s   %s/%ss
   storageDirs   rpm$i   s   rs   Error reading headers   %s/%s.noarch.*s3   Corrupt header %s, skipping, will download later...s   Reading header from: %s(*   s   pkgs   baseFileNames   selfs   dir_lists   dirs   globs   tmpFileNamess   cfgs   fileNames	   fileNamess   lens   oss   accesss   R_OKs   res   searchs   stats   Nones   opens   fds   rpmUtilss   readHeaderBlobs   reads   hdrs   headerCaches   up2dateUtilss   pkgToStringArchs   closes   _LocalDisk__saveHeaders   tss   pushVSFlagss   rpms   RPMVSF_NOMD5s   RPMVSF_NEEDPAYLOADs   hdrFromFdnos
   popVSFlagss   up2dateErrorss   RpmErrors   _s   pkgToStrings   logs   log_me(   s   selfs   pkgs   msgCallbacks   progressCallbacks   baseFileNames   fileNames   tmpFileNamess   fds   hdrs	   fileNamess   dir(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys	   getHeader9  s‚    &
 

 &
c         C   sÐ   d | d | d | d | d f } x£ |  i D]˜ } t i d | | f ƒ } d |  i d | f } t	 | ƒ o | |  i d j o@ y t
 i | ƒ Wn t j
 o n Xt
 i | d | ƒ Pq0 q0 Wd  S(   Ns   %s-%s-%s.%s.rpmi    i   i   i   s   %s/%ss
   storageDir(   s   pkgs   baseFileNames   selfs   dir_lists   dirs   globs   tmpFileNamess   cfgs   fileNames   lens   oss   removes   OSErrors   symlink(   s   selfs   pkgs   msgCallbacks   progressCallbacks   fileNames   tmpFileNamess   baseFileNames   dir(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys
   getPackage  s    &
 "c   	      C   sÉ   d | } x¸ |  i D]­ } t i d | | f ƒ } d |  i d | f } t	 | ƒ o | |  i d j oU y t
 i | ƒ Wn t j
 o n X| o | | ƒ n t
 i | d | ƒ Pq q Wd  S(   Ns   %ss   %s/%ss
   storageDiri    (   s   srcpkgs   baseFileNames   selfs   dir_lists   dirs   globs   tmpFileNamess   cfgs   fileNames   lens   oss   removes   OSErrors   msgCallbacks   symlink(	   s   selfs   channels   srcpkgs   msgCallbacks   progressCallbacks   fileNames   tmpFileNamess   baseFileNames   dir(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys   getPackageSource¢  s    

 "(	   s   __name__s
   __module__s   Nones   __init__s   addPackageDirs   _LocalDisk__saveHeaders	   getHeaders
   getPackages   getPackageSource(    (    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys	   LocalDisk&  s   
		Ws	   DiskCachec           B   s€   t  Z e d „ Z d „  Z d „  Z e e d „ Z e e d „ Z e e d „ Z e e d „ Z	 e e d „ Z
 e e d	 „ Z RS(
   Nc         C   sW   t  i ƒ  |  _ t i ƒ  |  _ |  i d g |  _ t i	 ƒ  |  _
 t i |  d | ƒd  S(   Ns
   storageDirs   cacheObject(   s   configs   initUp2dateConfigs   selfs   cfgs
   up2dateLogs   initLogs   logs   dir_lists   transactions   initReadOnlyTransactions   tss   PackageSources   __init__s   cacheObject(   s   selfs   cacheObject(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys   __init__¶  s
    c         C   sÌ   t  i | d d ƒ } |  i i t i t i	 Bƒ y |  i i
 | ƒ } Wn6 t  i | ƒ |  i i ƒ  t i t d ƒ ƒ ‚ n X|  i i ƒ  t  i | ƒ |  i i d | ƒ | |  i t i | ƒ <| Sd  S(   Ni    s   Error reading headers   Reading header from: %s(   s   oss   opens	   fileNamess   fds   selfs   tss   pushVSFlagss   rpms   RPMVSF_NOMD5s   RPMVSF_NEEDPAYLOADs   hdrFromFdnos   hdrs   closes
   popVSFlagss   up2dateErrorss   RpmErrors   _s   logs   log_mes   headerCaches   up2dateUtilss   pkgToStringArchs   pkg(   s   selfs	   fileNamess   pkgs   hdrs   fd(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys   __readHeaderFromRpm¾  s    c         C   s›   t  i | d t  i ƒ oy t  i | d ƒ d d j o d G| d GHt Sn t i | d ƒ } | t j o t Sn | |  i
 t i | ƒ <| Sn t Sd  S(   Ni    i   s   stat failed(   s   oss   accesss	   fileNamess   R_OKs   stats   Nones   rpmUtilss
   readHeaders   hdrs   selfs   headerCaches   up2dateUtilss   pkgToStringArchs   pkg(   s   selfs	   fileNamess   pkgs   hdr(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys   __readHeaderFromFileÐ  s    c         C   s  xL |  i D]A } t i d | t i | ƒ | d f ƒ } t | ƒ o Pq
 q
 Wt | ƒ o) |  i	 | | ƒ } | o | Sqt Sn x3 |  i D]( } t i d | t i | ƒ f ƒ } q Wt | ƒ o; |  i	 | | ƒ } | o | Sq|  i | | ƒ } | Sn d  S(   Ns   %s/%s.%s.hdri   s   %s/%s.noarch.hdr(   s   selfs   dir_lists   dirs   globs   up2dateUtilss   pkgToStrings   pkgs	   fileNamess   lens   _DiskCache__readHeaderFromFiles   hdrs   Nones   _DiskCache__readHeaderFromRpm(   s   selfs   pkgs   msgCallbacks   progressCallbacks   hdrs	   fileNamess   dir(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys	   getHeaderÝ  s&    
 )	
 &c         C   s¦   d | d | d | d | d f } d |  i d | f } t i | t i ƒ o t i	 | ƒ o; | o | | ƒ n | t j o | d d ƒ n d Sn t Sd  S(   Ns   %s-%s-%s.%s.rpmi    i   i   i   s   %s/%ss
   storageDir(   s   pkgs   baseFileNames   selfs   cfgs   fileNames   oss   accesss   R_OKs   rpmUtilss   checkRpmMd5s   msgCallbacks   progressCallbacks   None(   s   selfs   pkgs   msgCallbacks   progressCallbacks   fileNames   baseFileName(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys
   getPackageý  s    &&c         C   sz   d | } d |  i d | f } t i | t i ƒ o; | o | | ƒ n | t
 j o | d d ƒ n d Sn t
 Sd  S(   Ns   %ss   %s/%ss
   storageDiri   (   s   srcpkgs   baseFileNames   selfs   cfgs   fileNames   oss   accesss   R_OKs   msgCallbacks   progressCallbacks   None(   s   selfs   channels   srcpkgs   msgCallbacks   progressCallbacks   fileNames   baseFileName(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys   getPackageSource  s    
c   	      C   s§   d |  i d | d | d f } t i | t i ƒ o t Sn t | d ƒ } | i
 ƒ  } | o | d d ƒ n y t i | ƒ \ } } Wn t Sn X| d Sd  S(   Ns   %s/%s.%ss
   storageDirs   labels   versions   rid   i    (   s   selfs   cfgs   channels   localFilenames   oss   accesss   R_OKs   Nones   opens   fs   reads   filecontentss   progressCallbacks	   xmlrpclibs   loadss   tmp_argss
   tmp_method(	   s   selfs   channels   msgCallbacks   progressCallbacks   fs   filecontentss   localFilenames   tmp_argss
   tmp_method(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys   listPackages  s    "c   	      C   s§   d |  i d | d | d f } t i | t i ƒ o t Sn t | d ƒ } | i
 ƒ  } | o | d d ƒ n y t i | ƒ \ } } Wn t Sn X| d Sd  S(   Ns   %s/%s-all.%ss
   storageDirs   labels   versions   rid   i    (   s   selfs   cfgs   channels   localFilenames   oss   accesss   R_OKs   Nones   opens   fs   reads   filecontentss   progressCallbacks	   xmlrpclibs   loadss   tmp_argss
   tmp_method(	   s   selfs   channels   msgCallbacks   progressCallbacks   fs   filecontentss   localFilenames   tmp_argss
   tmp_method(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys   listAllPackages9  s    "c   
      C   s§   d |  i d | d | d f } t i | t i ƒ o t Sn t | d ƒ } | i
 ƒ  } | o | d d ƒ n y t i | ƒ \ } }	 Wn t Sn X| d Sd  S(   Ns   %s/%s-obsoletes.%ss
   storageDirs   labels   versions   rid   i    (   s   selfs   cfgs   channels   localFilenames   oss   accesss   R_OKs   Nones   opens   fs   reads   filecontentss   progressCallbacks	   xmlrpclibs   loadss   tmp_argss
   tmp_method(
   s   selfs   channels   versions   msgCallbacks   progressCallbacks   fs   filecontentss   localFilenames   tmp_argss
   tmp_method(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys   getObsoletesS  s    "(   s   __name__s
   __module__s   Nones   __init__s   _DiskCache__readHeaderFromRpms   _DiskCache__readHeaderFromFiles	   getHeaders
   getPackages   getPackageSources   listPackagess   listAllPackagess   getObsoletes(    (    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys	   DiskCacheµ  s   		 s   Up2datePackageSourcec           B   s&   t  Z e d „ Z e e e d „ Z RS(   Nc         C   s    | |  _ t i |  d | ƒd  S(   Ns   cacheObject(   s   servers   selfs   ss   PackageSources   __init__s   cacheObject(   s   selfs   servers	   proxyHosts   cacheObject(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys   __init__r  s    	c   
      C   s  t  } y" |  i i i t i ƒ  | ƒ } Wnt
 j
 o t i t d ƒ ƒ ‚ nÞ t i t i f j
 oO }	 t |	 i ƒ d j o t i |	 i d ƒ ‚ q/t i |	 i d ƒ ‚ nx t i j
 o }	 t i |	 i ƒ ‚ nO t i j
 o t i d ƒ ‚ n+ t i j
 o } t i | i ƒ ‚ n X| d } t i | i ƒ } t i  | ƒ | |  i! d | d | d | d | d	 f <| Sd  S(
   Ns   Connection aborted by the useri   i    s    Broken response from the server.s   %s-%s-%s.%ss   names   versions   releases   arch("   s   Nones   hdrs   selfs   ss   up2dates   headers   up2dateAuths   getSystemIds   pkgs   rets   KeyboardInterrupts   up2dateErrorss   CommunicationErrors   _s   sockets   errors   sslerrors   es   lens   argss   rpclibs   ProtocolErrors   errmsgs   ResponseErrors   Faults   fs   faultStrings   bins   rpmUtilss   readHeaderBlobs   datas   rpmSourceUtilss
   saveHeaders   headerCache(
   s   selfs   pkgs   lites   msgCallbacks   progressCallbacks   bins   hdrs   fs   rets   e(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys	   getHeaderx  s(    "
-(   s   __name__s
   __module__s   Nones   __init__s	   getHeader(    (    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys   Up2datePackageSourceq  s   c         C   s   d |  | f GHd  S(   Ns   -- %s bytes of %s(   s   totals   complete(   s   totals   complete(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys   callback˜  s    c         C   sN   t  t i | ƒ } t | t d | ƒ} |  i	 h  d d <d | <ƒ |  Sd  S(   Ns	   loginInfos   names   gets   object(
   s   getGETServers	   LoginInfos	   logininfos   serverSettingss
   httpServers   HttpGetSources   Nones   hdss   packageSourceChains   addSourceInstance(   s   packageSourceChains	   logininfos   serverSettingss
   httpServers   hds(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys   updateHttpServerœ  s    (&   s   __doc__s   up2dateUtilss
   up2dateLogs   up2dateErrorss   globs   sockets   res   oss   rpms   strings   times   structs   configs   rpmUtilss   up2dateAuths   transactions   urllibs   gzips
   rhnChannels   syss   rpmSourceUtilss	   xmlrpclibs   rhns   rpclibs   rhpl.translates   _s   N_s   BUFFER_SIZEs   factorys   HeaderCaches   PackageSourceChains   PackageSources   HeaderMemoryCaches	   LocalDisks	   DiskCaches   Up2datePackageSources   callbacks   updateHttpServer(#   s   up2dateErrorss   HeaderMemoryCaches   BUFFER_SIZEs   rpms   Up2datePackageSources	   LocalDisks   rpmSourceUtilss
   up2dateLogs   factorys   urllibs   res   updateHttpServers   N_s   rpclibs   configs
   rhnChannels   strings   globs   syss   up2dateUtilss	   DiskCaches   PackageSources   HeaderCaches   _s   structs   transactions   sockets	   xmlrpclibs   PackageSourceChains   callbacks   up2dateAuths   times   gzips   rpmUtilss   os(    (    s*   /usr/share/rhn/up2date_client/rpmSource.pys   ?	   sF   																							M¼'	