summaryrefslogtreecommitdiff
path: root/lang/python/packing.py
blob: a642f70ba757ffa2ce738031258684ba95917471 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
#!/usr/bin/env python
#
# Copyright (c) 2008-2012 WiredTiger, Inc.
#	All rights reserved.
#
# See the file LICENSE for redistribution information.
#
# WiredTiger variable-length packing and unpacking functions

from intpacking import pack_int, unpack_int

def __get_type(fmt):
	if not fmt:
		return None, fmt
	# Variable-sized encoding is the default (and only supported format in v1)
	if fmt[0] in '.@<>':
		tfmt = fmt[0]
		fmt = fmt[1:]
	else:
		tfmt = '.'
	return tfmt, fmt

def unpack(fmt, s):
	tfmt, fmt = __get_type(fmt)
	if not fmt:
		return ()
	if tfmt != '.':
		raise ValueError('Only variable-length encoding is currently supported')
	result = []
	havesize = size = 0
	for offset, f in enumerate(fmt):
		if f.isdigit():
			size = (size * 10) + int(f)
			havesize = 1
			continue
		elif f == 'x':
			if not havesize:
				size = 1
			s = s[size:]
			# Note: no value, don't increment i
		elif f in 'Ssu':
			if not havesize:
				if f == 's':
					size = 1
				elif f == 'S':
					size = s.find('\0')
				elif f == 'u':
					if offset == len(fmt) - 1:
						size = len(s)
					else:
						size, s = unpack_int(s)
			result.append(s[:size])
			if f == 'S' and not havesize:
				size += 1
			s = s[size:]
		elif f in 't':
			# bit type, size is number of bits
			if not havesize:
				size = 1
			result.append(ord(s[0:1]))
			s = s[1:]
		else:
			# integral type
			if not havesize:
				size = 1
			for j in xrange(size):
				v, s = unpack_int(s)
				result.append(v)
		havesize = size = 0
	return result

def pack(fmt, *values):
	tfmt, fmt = __get_type(fmt)
	if not fmt:
		return ()
	if tfmt != '.':
		raise ValueError('Only variable-length encoding is currently supported')
	result = ''
	havesize = i = size = 0
	for offset, f in enumerate(fmt):
		if f.isdigit():
			size = (size * 10) + int(f)
			havesize = 1
			continue
		elif f == 'x':
			if not havesize:
				result += '\0'
			else:
				result += '\0' * size
			# Note: no value, don't increment i
		elif f in 'Ssu':
			if f == 'S' and '\0' in values[i]:
				l = values[i].find('\0')
			else:
				l = len(values[i])
			if havesize:
				if l > size:
					l = size
			elif f == 's':
				havesize = size = 1
			elif f == 'u' and offset != len(fmt) - 1:
				result += pack_int(l)
			result += values[i][:l]
			if f == 'S' and not havesize:
				result += '\0'
			elif size > l:
				result += '\0' * (size - l)
			i += 1
		elif f in 't':
			# bit type, size is number of bits
			if not havesize:
				size = 1
                        if size > 8:
				raise ValueError("bit count cannot be greater than 8 for 't' encoding")
			mask = (1 << size) - 1
			val = values[i]
                        if (mask & val) != val:
				raise ValueError("value out of range for 't' encoding")
			result += chr(val)
			i += 1
		else:
			# integral type
			if not havesize:
				size = 1
			for j in xrange(size):
				result += pack_int(values[i])
				i += 1
		havesize = size = 0
	return result