ꦫꦣꦺꦤ꧀ꦄꦤ꧀ꦠꦱꦺꦤ

PATH: usr / lib64 / python3.6

"""Internal classes used by the gzip, lzma and bz2 modules"""

import io

BUFFER_SIZE = io.DEFAULT_BUFFER_SIZE  # Compressed data read chunk size

class BaseStream(io.BufferedIOBase):
    """Mode-checking helper functions."""

def _check_not_closed(self):
        if self.closed:
            raise ValueError("I/O operation on closed file")

def _check_can_read(self):
        if not self.readable():
            raise io.UnsupportedOperation("File not open for reading")

def _check_can_write(self):
        if not self.writable():
            raise io.UnsupportedOperation("File not open for writing")

def _check_can_seek(self):
        if not self.readable():
            raise io.UnsupportedOperation("Seeking is only supported "
                                          "on files open for reading")
        if not self.seekable():
            raise io.UnsupportedOperation("The underlying file object "
                                          "does not support seeking")

class DecompressReader(io.RawIOBase):
    """Adapts the decompressor API to a RawIOBase reader API"""

def readable(self):
        return True

def __init__(self, fp, decomp_factory, trailing_error=(), **decomp_args):
        self._fp = fp
        self._eof = False
        self._pos = 0  # Current offset in decompressed stream

# Set to size of decompressed stream once it is known, for SEEK_END
        self._size = -1

# Save the decompressor factory and arguments.
        # If the file contains multiple compressed streams, each
        # stream will need a separate decompressor object. A new decompressor
        # object is also needed when implementing a backwards seek().
        self._decomp_factory = decomp_factory
        self._decomp_args = decomp_args
        self._decompressor = self._decomp_factory(**self._decomp_args)

# Exception class to catch from decompressor signifying invalid
        # trailing data to ignore
        self._trailing_error = trailing_error

def close(self):
        self._decompressor = None
        return super().close()

def seekable(self):
        return self._fp.seekable()

def readinto(self, b):
        with memoryview(b) as view, view.cast("B") as byte_view:
            data = self.read(len(byte_view))
            byte_view[:len(data)] = data
        return len(data)

def read(self, size=-1):
        if size < 0:
            return self.readall()

if not size or self._eof:
            return b""
        data = None  # Default if EOF is encountered
        # Depending on the input data, our call to the decompressor may not
        # return any data. In this case, try again after reading another block.
        while True:
            if self._decompressor.eof:
                rawblock = (self._decompressor.unused_data or
                            self._fp.read(BUFFER_SIZE))
                if not rawblock:
                    break
                # Continue to next stream.
                self._decompressor = self._decomp_factory(
                    **self._decomp_args)
                try:
                    data = self._decompressor.decompress(rawblock, size)
                except self._trailing_error:
                    # Trailing data isn't a valid compressed stream; ignore it.
                    break
            else:
                if self._decompressor.needs_input:
                    rawblock = self._fp.read(BUFFER_SIZE)
                    if not rawblock:
                        raise EOFError("Compressed file ended before the "
                                       "end-of-stream marker was reached")
                else:
                    rawblock = b""
                data = self._decompressor.decompress(rawblock, size)
            if data:
                break
        if not data:
            self._eof = True
            self._size = self._pos
            return b""
        self._pos += len(data)
        return data

# Rewind the file to the beginning of the data stream.
    def _rewind(self):
        self._fp.seek(0)
        self._eof = False
        self._pos = 0
        self._decompressor = self._decomp_factory(**self._decomp_args)

def seek(self, offset, whence=io.SEEK_SET):
        # Recalculate offset as an absolute file position.
        if whence == io.SEEK_SET:
            pass
        elif whence == io.SEEK_CUR:
            offset = self._pos + offset
        elif whence == io.SEEK_END:
            # Seeking relative to EOF - we need to know the file's size.
            if self._size < 0:
                while self.read(io.DEFAULT_BUFFER_SIZE):
                    pass
            offset = self._size + offset
        else:
            raise ValueError("Invalid value for whence: {}".format(whence))

# Make it so that offset is the number of bytes to skip forward.
        if offset < self._pos:
            self._rewind()
        else:
            offset -= self._pos

# Read and discard data until we reach the desired position.
        while offset > 0:
            data = self.read(min(io.DEFAULT_BUFFER_SIZE, offset))
            if not data:
                break
            offset -= len(data)

return self._pos

def tell(self):
        """Return the current file position."""
        return self._pos

[+] ..
[-] __phello__.foo.py [edit]
[-] zipfile.py [edit]
[-] _dummy_thread.py [edit]
[-] signal.py [edit]
[-] tabnanny.py [edit]
[-] cmd.py [edit]
[-] cProfile.py [edit]
[-] tempfile.py [edit]
[-] argparse.py [edit]
[-] platform.py [edit]
[-] binhex.py [edit]
[-] antigravity.py [edit]
[+] curses
[-] _compat_pickle.py [edit]
[-] statistics.py [edit]
[-] inspect.py [edit]
[-] ipaddress.py [edit]
[-] sunau.py [edit]
[-] imghdr.py [edit]
[-] random.py [edit]
[-] macpath.py [edit]
[-] hmac.py [edit]
[-] base64.py [edit]
[-] cgitb.py [edit]
[-] stringprep.py [edit]
[-] ast.py [edit]
[-] textwrap.py [edit]
[-] enum.py [edit]
[-] _compression.py [edit]
[-] dis.py [edit]
[+] venv
[-] chunk.py [edit]
[-] this.py [edit]
[-] py_compile.py [edit]
[-] fnmatch.py [edit]
[+] xml
[-] opcode.py [edit]
[+] site-packages
[-] sre_compile.py [edit]
[-] _pyio.py [edit]
[-] pty.py [edit]
[-] datetime.py [edit]
[-] macurl2path.py [edit]
[+] lib2to3
[+] wsgiref
[-] heapq.py [edit]
[-] keyword.py [edit]
[-] codecs.py [edit]
[+] ensurepip
[-] pickletools.py [edit]
[-] compileall.py [edit]
[-] nturl2path.py [edit]
[-] warnings.py [edit]
[-] shutil.py [edit]
[-] socket.py [edit]
[-] pdb.py [edit]
[-] zipapp.py [edit]
[-] formatter.py [edit]
[-] _sitebuiltins.py [edit]
[-] _markupbase.py [edit]
[-] types.py [edit]
[-] runpy.py [edit]
[-] uu.py [edit]
[-] typing.py [edit]
[-] pathlib.py [edit]
[-] _threading_local.py [edit]
[-] mailcap.py [edit]
[-] bisect.py [edit]
[-] linecache.py [edit]
[-] colorsys.py [edit]
[-] glob.py [edit]
[-] sndhdr.py [edit]
[-] ssl.py [edit]
[-] _strptime.py [edit]
[-] _sysconfigdata_m_linux_x86_64-linux-gnu.py [edit]
[-] imp.py [edit]
[-] contextlib.py [edit]
[-] copyreg.py [edit]
[-] filecmp.py [edit]
[+] logging
[-] operator.py [edit]
[-] token.py [edit]
[-] gzip.py [edit]
[-] string.py [edit]
[-] genericpath.py [edit]
[-] _osx_support.py [edit]
[-] stat.py [edit]
[-] lzma.py [edit]
[-] __future__.py [edit]
[+] distutils
[-] dummy_threading.py [edit]
[+] asyncio
[-] webbrowser.py [edit]
[-] symtable.py [edit]
[+] lib-dynload
[-] getopt.py [edit]
[-] wave.py [edit]
[-] codeop.py [edit]
[-] _sysconfigdata_dm_linux_x86_64-linux-gnu.py [edit]
[-] abc.py [edit]
[+] config-3.6m-x86_64-linux-gnu
[+] pydoc_data
[-] telnetlib.py [edit]
[+] unittest
[-] fileinput.py [edit]
[-] ftplib.py [edit]
[+] ctypes
[-] _bootlocale.py [edit]
[-] pipes.py [edit]
[-] aifc.py [edit]
[-] pprint.py [edit]
[-] queue.py [edit]
[-] difflib.py [edit]
[+] __pycache__
[-] uuid.py [edit]
[-] reprlib.py [edit]
[-] threading.py [edit]
[+] http
[-] sre_parse.py [edit]
[-] subprocess.py [edit]
[+] importlib
[-] selectors.py [edit]
[-] getpass.py [edit]
[-] trace.py [edit]
[-] struct.py [edit]
[-] tracemalloc.py [edit]
[-] plistlib.py [edit]
[-] asynchat.py [edit]
[-] fractions.py [edit]
[-] shlex.py [edit]
[-] bdb.py [edit]
[-] locale.py [edit]
[-] calendar.py [edit]
[-] poplib.py [edit]
[-] posixpath.py [edit]
[-] imaplib.py [edit]
[+] concurrent
[-] pickle.py [edit]
[-] timeit.py [edit]
[+] json
[-] traceback.py [edit]
[+] multiprocessing
[-] shelve.py [edit]
[-] csv.py [edit]
[-] tarfile.py [edit]
[-] numbers.py [edit]
[-] optparse.py [edit]
[-] cgi.py [edit]
[-] pstats.py [edit]
[-] crypt.py [edit]
[+] collections
[-] site.py [edit]
[-] pkgutil.py [edit]
[-] re.py [edit]
[-] pyclbr.py [edit]
[-] socketserver.py [edit]
[-] _pydecimal.py [edit]
[-] pydoc.py [edit]
[-] sre_constants.py [edit]
[-] xdrlib.py [edit]
[-] nntplib.py [edit]
[-] mimetypes.py [edit]
[+] email
[-] quopri.py [edit]
[-] doctest.py [edit]
[-] profile.py [edit]
[-] sched.py [edit]
[-] hashlib.py [edit]
[+] urllib
[-] secrets.py [edit]
[-] functools.py [edit]
[-] smtplib.py [edit]
[-] copy.py [edit]
[+] dbm
[-] tty.py [edit]
[-] os.py [edit]
[-] _collections_abc.py [edit]
[-] configparser.py [edit]
[-] _weakrefset.py [edit]
[-] netrc.py [edit]
[-] code.py [edit]
[-] asyncore.py [edit]
[-] tokenize.py [edit]
[+] encodings
[-] io.py [edit]
[-] smtpd.py [edit]
[-] sysconfig.py [edit]
[-] decimal.py [edit]
[+] sqlite3
[-] rlcompleter.py [edit]
[-] ntpath.py [edit]
[+] test
[-] weakref.py [edit]
[-] symbol.py [edit]
[-] modulefinder.py [edit]
[+] xmlrpc
[-] bz2.py [edit]
[-] gettext.py [edit]
[-] mailbox.py [edit]
[+] html