Revision 41ddb860 pithos/lib/hashfiler/mapper.py

b/pithos/lib/hashfiler/mapper.py
1 
# Copyright 2011 GRNET S.A. All rights reserved.
2 
#
3 
# Redistribution and use in source and binary forms, with or
4 
# without modification, are permitted provided that the following
5 
# conditions are met:
6 
#
7 
#   1. Redistributions of source code must retain the above
8 
#      copyright notice, this list of conditions and the following
9 
#      disclaimer.
10 
#
11 
#   2. Redistributions in binary form must reproduce the above
12 
#      copyright notice, this list of conditions and the following
13 
#      disclaimer in the documentation and/or other materials
14 
#      provided with the distribution.
15 
#
16 
# THIS SOFTWARE IS PROVIDED BY GRNET S.A. ``AS IS'' AND ANY EXPRESS
17 
# OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
18 
# WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
19 
# PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL GRNET S.A OR
20 
# CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
21 
# SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
22 
# LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
23 
# USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
24 
# AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
25 
# LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN
26 
# ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
27 
# POSSIBILITY OF SUCH DAMAGE.
28 
#
29 
# The views and conclusions contained in the software and
30 
# documentation are those of the authors and should not be
31 
# interpreted as representing official policies, either expressed
32 
# or implied, of GRNET S.A.
33 

  		





  1
  34
  
    
from os.path import realpath, join, exists, isdir


  		





  2
  35
  
    
from os import makedirs, unlink


  		





  3
  36
  
    
from errno import ENOENT


  		





  
  37
  
    

  		





  4
  38
  
    
from pithos.lib.hashfiler.context_file import ContextFile


  		





  5
  39
  
    

  		





  
  40
  
    

  		





  6
  41
  
    
class Mapper(object):


  		





  
  42
  
    
    """Mapper.


  		





  
  43
  
    
       Required contstructor parameters: mappath, namelen.


  		





  
  44
  
    
    """


  		





  
  45
  
    
    


  		





  7
  46
  
    
    mappath = None


  		





  8
  47
  
    
    namelen = None


  		





  9
  48
  
    

  		





  ......




  15
  54
  
    
            if not exists(mappath):


  		





  16
  55
  
    
                makedirs(mappath)


  		





  17
  56
  
    
            else:


  		





  18
  
  
    
                raise ValueError("blockpath '%s' is not a directory" % (blockpath,))


  		





  
  57
  
    
                raise ValueError("Variable mappath '%s' is not a directory" % (mappath,))


  		





  19
  58
  
    
        self.mappath = mappath


  		





  20
  59
  
    

  		





  21
  60
  
    
    def get_rear_map(self, name, create=0):


  		





  ......




  43
  82
  
    
        with self.get_rear_map(name, 0) as rmap:


  		





  44
  83
  
    
            if rmap:


  		





  45
  84
  
    
                hashes = list(rmap.sync_read_chunks(namelen, nr, blkoff))


  		





  46
  
  
    

  		





  47
  
  
    
        if hashes and not hashes[-1]:


  		





  48
  
  
    
            print "AIEEEEE", repr(name), repr(hashes)


  		





  49
  85
  
    
        return hashes


  		





  50
  86
  
    

  		





  51
  87
  
    
    def map_stor(self, name, hashes=(), blkoff=0, create=1):


  		





  ......




  54
  90
  
    
        with self.get_rear_map(name, 1) as rmap:


  		





  55
  91
  
    
            rmap.sync_write_chunks(namelen, blkoff, hashes, None)


  		





  56
  92
  
    

  		





  57
  
  
    
    def map_copy(self, src, dst):


  		





  58
  
  
    
        """Copy a hashes map to another one, replacing it."""


  		





  59
  
  
    
        with self.get_rear_map(src, 0) as rmap:


  		





  60
  
  
    
            if rmap:


  		





  61
  
  
    
                rmap.copy_to(dst)


  		





  
  93
  
    
#     def map_copy(self, src, dst):


  		





  
  94
  
    
#         """Copy a hashes map to another one, replacing it."""


  		





  
  95
  
    
#         with self.get_rear_map(src, 0) as rmap:


  		





  
  96
  
    
#             if rmap:


  		





  
  97
  
    
#                 rmap.copy_to(dst)


  		





  62
  98
  
    

  		





  63
  99
  
    
    def map_remv(self, name):


  		





  64
  100
  
    
        """Remove a hashes map. Returns true if the map was found and removed."""


  		












Also available in:
  Unified diff