Source Code for Package ganeti.confd

 1  # 
 2  # 
 3   
 4  # Copyright (C) 2009, 2012 Google Inc. 
 5  # All rights reserved. 
 6  # 
 7  # Redistribution and use in source and binary forms, with or without 
 8  # modification, are permitted provided that the following conditions are 
 9  # met: 
10  # 
11  # 1. Redistributions of source code must retain the above copyright notice, 
12  # this list of conditions and the following disclaimer. 
13  # 
14  # 2. Redistributions in binary form must reproduce the above copyright 
15  # notice, this list of conditions and the following disclaimer in the 
16  # documentation and/or other materials provided with the distribution. 
17  # 
18  # THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS 
19  # IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED 
20  # TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR 
21  # PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR 
22  # CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, 
23  # EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, 
24  # PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR 
25  # PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF 
26  # LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING 
27  # NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS 
28  # SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 
29   
30   
31  """Ganeti confd client/server library 
32   
33  """ 
34   
35  from ganeti import constants 
36  from ganeti import errors 
37  from ganeti import ht 
38   
39   
40  _FOURCC_LEN = 4 
41   
42   
43  #: Items in the individual rows of the NodeDrbd query 
44  _HTNodeDrbdItems = [ht.TString, ht.TInt, ht.TString, 
45                      ht.TString, ht.TString, ht.TString] 
46  #: Type for the (top-level) result of NodeDrbd query 
47  HTNodeDrbd = ht.TListOf(ht.TAnd(ht.TList, ht.TIsLength(len(_HTNodeDrbdItems)), 
48                                  ht.TItems(_HTNodeDrbdItems))) 
49   
50   
51 -def PackMagic(payload): 
52    """Prepend the confd magic fourcc to a payload. 
53   
54    """ 
55    return "".join([constants.CONFD_MAGIC_FOURCC, payload]) 
56   
57   
58 -def UnpackMagic(payload): 
59    """Unpack and check the confd magic fourcc from a payload. 
60   
61    """ 
62    if len(payload) < _FOURCC_LEN: 
63      raise errors.ConfdMagicError("UDP payload too short to contain the" 
64                                   " fourcc code") 
65   
66    magic_number = payload[:_FOURCC_LEN] 
67    if magic_number != constants.CONFD_MAGIC_FOURCC: 
68      raise errors.ConfdMagicError("UDP payload contains an unkown fourcc") 
69   
70    return payload[_FOURCC_LEN:] 
71