Statistics
| Branch: | Tag: | Revision:

root / lib / confd / __init__.py @ 178ad717

History | View | Annotate | Download (1.8 kB)

1
#
2
#
3

    
4
# Copyright (C) 2009, 2012 Google Inc.
5
#
6
# This program is free software; you can redistribute it and/or modify
7
# it under the terms of the GNU General Public License as published by
8
# the Free Software Foundation; either version 2 of the License, or
9
# (at your option) any later version.
10
#
11
# This program is distributed in the hope that it will be useful, but
12
# WITHOUT ANY WARRANTY; without even the implied warranty of
13
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
14
# General Public License for more details.
15
#
16
# You should have received a copy of the GNU General Public License
17
# along with this program; if not, write to the Free Software
18
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
19
# 02110-1301, USA.
20

    
21

    
22
"""Ganeti confd client/server library
23

24
"""
25

    
26
from ganeti import constants
27
from ganeti import errors
28
from ganeti import ht
29

    
30

    
31
_FOURCC_LEN = 4
32

    
33

    
34
#: Items in the individual rows of the NodeDrbd query
35
_HTNodeDrbdItems = [ht.TString, ht.TInt, ht.TString,
36
                    ht.TString, ht.TString, ht.TString]
37
#: Type for the (top-level) result of NodeDrbd query
38
HTNodeDrbd = ht.TListOf(ht.TAnd(ht.TList, ht.TIsLength(len(_HTNodeDrbdItems)),
39
                                ht.TItems(_HTNodeDrbdItems)))
40

    
41

    
42
def PackMagic(payload):
43
  """Prepend the confd magic fourcc to a payload.
44

45
  """
46
  return "".join([constants.CONFD_MAGIC_FOURCC, payload])
47

    
48

    
49
def UnpackMagic(payload):
50
  """Unpack and check the confd magic fourcc from a payload.
51

52
  """
53
  if len(payload) < _FOURCC_LEN:
54
    raise errors.ConfdMagicError("UDP payload too short to contain the"
55
                                 " fourcc code")
56

    
57
  magic_number = payload[:_FOURCC_LEN]
58
  if magic_number != constants.CONFD_MAGIC_FOURCC:
59
    raise errors.ConfdMagicError("UDP payload contains an unkown fourcc")
60

    
61
  return payload[_FOURCC_LEN:]