rhodecode-vcsserver Files · vcsserver/lib/rc_cache/archive_cache/utils.py

feat(disk-cache): rewrite diskcache backend to be k8s and NFS safe....

feat(disk-cache): rewrite diskcache backend to be k8s and NFS safe. We no longer use diskcache lib, but instead a homebrew solution that uses redis lock and simple filesystem storage

super-admin - - Load All Authors

File last commit:

r1241:29c2a6b0 default


                r1241:29c2a6b0

default

Download file

             utils.py
        
                    29 lines
            
             | 1.0 KiB
            
                | text/x-python
            
             |
                PythonLexer
            
             / vcsserver / lib / rc_cache / archive_cache / utils.py
          
                    History
                
                 |
                  Annotation
                 | Raw
                 |Copy content
                 |Copy permalink

      # RhodeCode VCSServer provides access to different vcs backends via network.

      # Copyright (C) 2014-2024 RhodeCode GmbH

      #

      # This program is free software; you can redistribute it and/or modify

      # it under the terms of the GNU General Public License as published by

      # the Free Software Foundation; either version 3 of the License, or

      # (at your option) any later version.

      #

      # This program 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 General Public License for more details.

      #

      # You should have received a copy of the GNU General Public License

      # along with this program; if not, write to the Free Software Foundation,

      # Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301  USA

      class ArchiveCacheLock(Exception):

          pass

      def archive_iterator(_reader, block_size: int = 4096 * 512):

          # 4096 * 64 = 64KB

          while 1:

              data = _reader.read(block_size)

              if not data:

                  break

              yield data

	Site-wide shortcuts
/	Use quick search box
g h	Goto home page
g g	Goto my private gists page
g G	Goto my public gists page
g 0-9	Goto bookmarked items from 0-9
n r	New repository page
n g	New gist page

	Repositories
g s	Goto summary page
g c	Goto changelog page
g f	Goto files page
g F	Goto files page with file search activated
g p	Goto pull requests page
g o	Goto repository settings
g O	Goto repository access permissions settings
t s	Toggle sidebar on some pages

				# RhodeCode VCSServer provides access to different vcs backends via network.
				# Copyright (C) 2014-2024 RhodeCode GmbH
				#
				# This program is free software; you can redistribute it and/or modify
				# it under the terms of the GNU General Public License as published by
				# the Free Software Foundation; either version 3 of the License, or
				# (at your option) any later version.
				#
				# This program 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 General Public License for more details.
				#
				# You should have received a copy of the GNU General Public License
				# along with this program; if not, write to the Free Software Foundation,
				# Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA


				class ArchiveCacheLock(Exception):
				pass


				def archive_iterator(_reader, block_size: int = 4096 * 512):
				# 4096 * 64 = 64KB
				while 1:
				data = _reader.read(block_size)
				if not data:
				break
				yield data