U 楡c>@sdZddlZddlZddlmZmZddlmZddddd d gZd dZd dZGd ddZ GdddZ Gdd d e Z dS)zlModule containing a memory memory manager which provides a sliding window on a number of memory mapped filesN)mmap ACCESS_READALLOCATIONGRANULARITY align_to_mmap is_64_bit MapWindow MapRegion MapRegionListrcCs$|tt}|r ||kr |t7}|S)a= Align the given integer number to the closest page offset, which usually is 4096 bytes. :param round_up: if True, the next higher multiple of page size is used, otherwise the lower page_size will be used (i.e. if True, 1 becomes 4096, otherwise it becomes 0) :return: num rounded to closest pager)numZround_upresr ./tmp/pip-unpacked-wheel-tps8jdza/smmap/util.pyrs  cCs tjdkS)zO:return: True if the system is 64 bit. Otherwise it can be assumed to be 32 bitl)sysmaxsizer r r rrsc@sPeZdZdZdZddZddZeddZd d Z d d Z d dZ ddZ dS)rzWUtility type which is used to snap windows towards each other, and to adjust their sizeofssizecCs||_||_dSNr)selfoffsetrr r r__init__-szMapWindow.__init__cCsd|j|jfS)NzMapWindow(%i, %i)rrr r r__repr__1szMapWindow.__repr__cCs||j|S)z!:return: new window from a region_br)clsZregionr r r from_region4szMapWindow.from_regioncCs |j|jSrrrr r rofs_end9szMapWindow.ofs_endcCs8t|jd}|j|j|7_||_t|jd|_dS)zrrr r rrszMapRegion.__repr__cCs|jS)z':return: a buffer containing the memoryr,rr r rbufferszMapRegion.buffercCs|jS)z+:return: a memory map containing the memoryrCrr r rmapsz MapRegion.mapcCs|jS)z>:return: absolute byte offset to the first byte of the mapping)rrr r r ofs_beginszMapRegion.ofs_begincCs|jS)z1:return: total size of the mapped region in bytes)r.rr r rrszMapRegion.sizecCs |j|jS)zE:return: Absolute offset to one byte beyond the mapping into the filerr.rr r rrszMapRegion.ofs_endcCs"|j|ko|j|jkSS)zB:return: True if the given offset can be read in our mapped regionrGrrr r r includes_ofsszMapRegion.includes_ofscCs|jS)z6:return: number of clients currently using this region)r-rr r r client_countszMapRegion.client_countrcCsF|j|7_|jdks&td|j|dkr>|dSdSdS)zAdjust the usage count by the given positive or negative offset. If usage count equals 0, we will auto-release our resources :return: True if we released resources, False otherwise. In the latter case, we can still be usedzs  z MapRegion.increment_client_countcCs|jdS)zbRelease all resources this instance might hold. Must only be called if there usage_count() is zeroN)r,r9rr r rrMszMapRegion.releaseN)r)r)r&r'r(r)r*rrrDrErFrrrIrJr>rMr r r rr Ss$ ' cs<eZdZdZdZfddZddZddZd d ZZ S) r zFList of MapRegion instances associating a path with a list of regions. _path_or_fd _file_sizecs t|Sr)super__new__)rpath __class__r rrRszMapRegionList.__new__cCs||_d|_dSrrN)rr?r r rrszMapRegionList.__init__cCs|jS)z3:return: path or file descriptor we are attached to)rOrr r rr?szMapRegionList.path_or_fdcCs>|jdkr8t|jtr(t|jj|_nt|jj|_|jS)z :return: size of file we managerN)rPr2rOr8r4statr<r;rr r r file_sizes   zMapRegionList.file_size) r&r'r(r)r*rRrr?rW __classcell__r r rTrr s  ) r)r4rrrr__all__rrrr listr r r r rs  .m