~bzr-pqm/bzr/bzr.dev

# Copyright (C) 2008, 2009 Canonical Ltd

#

# 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 2 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

#

"""Pyrex extensions to btree node parsing."""

#python2.4 support

cdef extern from "python-compat.h":

    pass

cdef extern from "stdlib.h":

    ctypedef unsigned size_t

cdef extern from "Python.h":

    ctypedef int Py_ssize_t # Required for older pyrex versions

    ctypedef struct PyObject:

        pass

    int PyList_Append(object lst, object item) except -1

    char *PyString_AsString(object p) except NULL

    object PyString_FromStringAndSize(char *, Py_ssize_t)

    PyObject *PyString_FromStringAndSize_ptr "PyString_FromStringAndSize" (char *, Py_ssize_t)

    int PyString_CheckExact(object s)

    int PyString_CheckExact_ptr "PyString_CheckExact" (PyObject *)

    Py_ssize_t PyString_Size(object p)

    Py_ssize_t PyString_GET_SIZE_ptr "PyString_GET_SIZE" (PyObject *)

    char * PyString_AS_STRING_ptr "PyString_AS_STRING" (PyObject *)

    char * PyString_AS_STRING(object)

    Py_ssize_t PyString_GET_SIZE(object)

    int PyString_AsStringAndSize_ptr(PyObject *, char **buf, Py_ssize_t *len)

    void PyString_InternInPlace(PyObject **)

    int PyTuple_CheckExact(object t)

    object PyTuple_New(Py_ssize_t n_entries)

    void PyTuple_SET_ITEM(object, Py_ssize_t offset, object) # steals the ref

    Py_ssize_t PyTuple_GET_SIZE(object t)

    PyObject *PyTuple_GET_ITEM_ptr_object "PyTuple_GET_ITEM" (object tpl, int index)

    void Py_INCREF(object)

    void Py_DECREF_ptr "Py_DECREF" (PyObject *)

cdef extern from "string.h":

    void *memcpy(void *dest, void *src, size_t n)

    void *memchr(void *s, int c, size_t n)

    # GNU extension

    # void *memrchr(void *s, int c, size_t n)

    int strncmp(char *s1, char *s2, size_t n)

# It seems we need to import the definitions so that the pyrex compiler has

# local names to access them.

from _static_tuple_c cimport StaticTuple, \

    import_static_tuple_c, STATIC_TUPLE_ALL_STRING, StaticTuple_New, \

    StaticTuple_Intern, StaticTuple_SET_ITEM, StaticTuple_CheckExact

# TODO: Find some way to import this from _dirstate_helpers

cdef void* _my_memrchr(void *s, int c, size_t n):

    # memrchr seems to be a GNU extension, so we have to implement it ourselves

    # It is not present in any win32 standard library

    cdef char *pos

    cdef char *start

    start = <char*>s

    pos = start + n - 1

    while pos >= start:

        if pos[0] == c:

            return <void*>pos

        pos = pos - 1

    return NULL

# TODO: Import this from _dirstate_helpers when it is merged

cdef object safe_string_from_size(char *s, Py_ssize_t size):

    if size < 0:

        raise AssertionError(

            'tried to create a string with an invalid size: %d @0x%x'

            % (size, <int>s))

    return PyString_FromStringAndSize(s, size)

cdef object safe_interned_string_from_size(char *s, Py_ssize_t size):

    cdef PyObject *py_str

    if size < 0:

        raise AssertionError(

            'tried to create a string with an invalid size: %d @0x%x'

            % (size, <int>s))

    py_str = PyString_FromStringAndSize_ptr(s, size)

    PyString_InternInPlace(&py_str)

    result = <object>py_str

    # Casting a PyObject* to an <object> triggers an INCREF from Pyrex, so we

    # DECREF it to avoid geting immortal strings

    Py_DECREF_ptr(py_str)

    return result

from bzrlib import _static_tuple_c

cdef object _ST

_ST = _static_tuple_c.StaticTuple

# This sets up the StaticTuple C_API functionality

import_static_tuple_c()

cdef class BTreeLeafParser:

    """Parse the leaf nodes of a BTree index.

    :ivar bytes: The PyString object containing the uncompressed text for the

        node.

    :ivar key_length: An integer describing how many pieces the keys have for

        this index.

    :ivar ref_list_length: An integer describing how many references this index

        contains.

    :ivar keys: A PyList of keys found in this node.

    :ivar _cur_str: A pointer to the start of the next line to parse

    :ivar _end_str: A pointer to the end of bytes

    :ivar _start: Pointer to the location within the current line while

        parsing.

    :ivar _header_found: True when we have parsed the header for this node

    """

    cdef object bytes

    cdef int key_length

    cdef int ref_list_length

    cdef object keys

    cdef char * _cur_str

    cdef char * _end_str

    # The current start point for parsing

    cdef char * _start

    cdef int _header_found

    def __init__(self, bytes, key_length, ref_list_length):

        self.bytes = bytes

        self.key_length = key_length

        self.ref_list_length = ref_list_length

        self.keys = []

        self._cur_str = NULL

        self._end_str = NULL

        self._header_found = 0

        # keys are tuples

    cdef extract_key(self, char * last):

        """Extract a key.

        :param last: points at the byte after the last byte permitted for the

            key.

        """

        cdef char *temp_ptr

        cdef int loop_counter

        cdef StaticTuple key

        key = StaticTuple_New(self.key_length)

        for loop_counter from 0 <= loop_counter < self.key_length:

            # grab a key segment

            temp_ptr = <char*>memchr(self._start, c'\0', last - self._start)

            if temp_ptr == NULL:

                if loop_counter + 1 == self.key_length:

                    # capture to last

                    temp_ptr = last

                else:

                    # Invalid line

                    failure_string = ("invalid key, wanted segment from " +

                        repr(safe_string_from_size(self._start,

                                                   last - self._start)))

                    raise AssertionError(failure_string)

            # capture the key string

            if (self.key_length == 1 

                and (temp_ptr - self._start) == 45

                and strncmp(self._start, 'sha1:', 5) == 0):

                key_element = safe_string_from_size(self._start,

                                                    temp_ptr - self._start)

            else:

                key_element = safe_interned_string_from_size(self._start,

                                                         temp_ptr - self._start)

            # advance our pointer

            self._start = temp_ptr + 1

            Py_INCREF(key_element)

            StaticTuple_SET_ITEM(key, loop_counter, key_element)

        # key->flags = key->flags | STATIC_TUPLE_ALL_STRING

        key = StaticTuple_Intern(key)

        return key

    cdef int process_line(self) except -1:

        """Process a line in the bytes."""

        cdef char *last

        cdef char *temp_ptr

        cdef char *ref_ptr

        cdef char *next_start

        cdef int loop_counter

        self._start = self._cur_str

        # Find the next newline

        last = <char*>memchr(self._start, c'\n', self._end_str - self._start)

        if last == NULL:

            # Process until the end of the file

            last = self._end_str

            self._cur_str = self._end_str

        else:

            # And the next string is right after it

            self._cur_str = last + 1

            # The last character is right before the '\n'

        if last == self._start:

            # parsed it all.

            return 0

        if last < self._start:

            # Unexpected error condition - fail

            raise AssertionError("last < self._start")

        if 0 == self._header_found:

            # The first line in a leaf node is the header "type=leaf\n"

            if strncmp("type=leaf", self._start, last - self._start) == 0:

                self._header_found = 1

                return 0

            else:

                raise AssertionError('Node did not start with "type=leaf": %r'

                    % (safe_string_from_size(self._start, last - self._start)))

        key = self.extract_key(last)

        # find the value area

        temp_ptr = <char*>_my_memrchr(self._start, c'\0', last - self._start)

        if temp_ptr == NULL:

            # Invalid line

            raise AssertionError("Failed to find the value area")

        else:

            # capture the value string

            value = safe_string_from_size(temp_ptr + 1, last - temp_ptr - 1)

            # shrink the references end point

            last = temp_ptr

        if self.ref_list_length:

            ref_lists = []

            loop_counter = 0

            while loop_counter < self.ref_list_length:

                ref_list = []

                # extract a reference list

                loop_counter = loop_counter + 1

                if last < self._start:

                    raise AssertionError("last < self._start")

                # find the next reference list end point:

                temp_ptr = <char*>memchr(self._start, c'\t', last - self._start)

                if temp_ptr == NULL:

                    # Only valid for the last list

                    if loop_counter != self.ref_list_length:

                        # Invalid line

                        raise AssertionError(

                            "invalid key, loop_counter != self.ref_list_length")

                    else:

                        # scan to the end of the ref list area

                        ref_ptr = last

                        next_start = last

                else:

                    # scan to the end of this ref list

                    ref_ptr = temp_ptr

                    next_start = temp_ptr + 1

                # Now, there may be multiple keys in the ref list.

                while self._start < ref_ptr:

                    # loop finding keys and extracting them

                    temp_ptr = <char*>memchr(self._start, c'\r',

                                             ref_ptr - self._start)

                    if temp_ptr == NULL:

                        # key runs to the end

                        temp_ptr = ref_ptr

                    PyList_Append(ref_list, self.extract_key(temp_ptr))

                ref_list = StaticTuple_Intern(StaticTuple(*ref_list))

                PyList_Append(ref_lists, ref_list)

                # prepare for the next reference list

                self._start = next_start

            ref_lists = StaticTuple(*ref_lists)

            node_value = StaticTuple(value, ref_lists)

        else:

            if last != self._start:

                # unexpected reference data present

                raise AssertionError("unexpected reference data present")

            node_value = StaticTuple(value, StaticTuple())

        PyList_Append(self.keys, StaticTuple(key, node_value))

        return 0

    def parse(self):

        cdef Py_ssize_t byte_count

        if not PyString_CheckExact(self.bytes):

            raise AssertionError('self.bytes is not a string.')

        byte_count = PyString_Size(self.bytes)

        self._cur_str = PyString_AsString(self.bytes)

        # This points to the last character in the string

        self._end_str = self._cur_str + byte_count

        while self._cur_str < self._end_str:

            self.process_line()

        return self.keys

def _parse_leaf_lines(bytes, key_length, ref_list_length):

    parser = BTreeLeafParser(bytes, key_length, ref_list_length)

    return parser.parse()

def _flatten_node(node, reference_lists):

    """Convert a node into the serialized form.

    :param node: A tuple representing a node:

        (index, key_tuple, value, references)

    :param reference_lists: Does this index have reference lists?

    :return: (string_key, flattened)

        string_key  The serialized key for referencing this node

        flattened   A string with the serialized form for the contents

    """

    cdef int have_reference_lists

    cdef Py_ssize_t flat_len

    cdef Py_ssize_t key_len

    cdef Py_ssize_t node_len

    cdef char * value

    cdef Py_ssize_t value_len

    cdef char * out

    cdef Py_ssize_t refs_len

    cdef Py_ssize_t next_len

    cdef int first_ref_list

    cdef int first_reference

    cdef int i

    cdef Py_ssize_t ref_bit_len

    if not PyTuple_CheckExact(node) and not StaticTuple_CheckExact(node):

        raise TypeError('We expected a tuple() or StaticTuple() for node not: %s'

            % type(node))

    node_len = len(node)

    have_reference_lists = reference_lists

    if have_reference_lists:

        if node_len != 4:

            raise ValueError('With ref_lists, we expected 4 entries not: %s'

                % len(node))

    elif node_len < 3:

        raise ValueError('Without ref_lists, we need at least 3 entries not: %s'

            % len(node))

    # I don't expect that we can do faster than string.join()

    string_key = '\0'.join(node[1])# <object>PyTuple_GET_ITEM_ptr_object(node, 1))

    # TODO: instead of using string joins, precompute the final string length,

    #       and then malloc a single string and copy everything in.

    # TODO: We probably want to use PySequenceFast, because we have lists and

    #       tuples, but we aren't sure which we will get.

    # line := string_key NULL flat_refs NULL value LF

    # string_key := BYTES (NULL BYTES)*

    # flat_refs := ref_list (TAB ref_list)*

    # ref_list := ref (CR ref)*

    # ref := BYTES (NULL BYTES)*

    # value := BYTES

    refs_len = 0

    if have_reference_lists:

        # Figure out how many bytes it will take to store the references

        ref_lists = node[3]# <object>PyTuple_GET_ITEM_ptr_object(node, 3)

        next_len = len(ref_lists) # TODO: use a Py function

        if next_len > 0:

            # If there are no nodes, we don't need to do any work

            # Otherwise we will need (len - 1) '\t' characters to separate

            # the reference lists

            refs_len = refs_len + (next_len - 1)

            for ref_list in ref_lists:

                next_len = len(ref_list)

                if next_len > 0:

                    # We will need (len - 1) '\r' characters to separate the

                    # references

                    refs_len = refs_len + (next_len - 1)

                    for reference in ref_list:

                        if (not PyTuple_CheckExact(reference)

                            and not StaticTuple_CheckExact(reference)):

                            raise TypeError(

                                'We expect references to be tuples not: %s'

                                % type(reference))

                        next_len = len(reference)

                        if next_len > 0:

                            # We will need (len - 1) '\x00' characters to

                            # separate the reference key

                            refs_len = refs_len + (next_len - 1)

                            for i from 0 <= i < next_len:

                                ref_bit = reference[i]

                                if not PyString_CheckExact(ref_bit):

                                    raise TypeError('We expect reference bits'

                                        ' to be strings not: %s'

                                        % type(<object>ref_bit))

                                refs_len = refs_len + PyString_GET_SIZE(ref_bit)

    # So we have the (key NULL refs NULL value LF)

    key_len = PyString_Size(string_key)

    val = node[2] # PyTuple_GET_ITEM_ptr_object(node, 2)

    if not PyString_CheckExact(val):

        raise TypeError('Expected a plain str for value not: %s'

                        % type(val))

    value = PyString_AS_STRING(val)

    value_len = PyString_GET_SIZE(val)

    flat_len = (key_len + 1 + refs_len + 1 + value_len + 1)

    line = PyString_FromStringAndSize(NULL, flat_len)

    # Get a pointer to the new buffer

    out = PyString_AsString(line)

    memcpy(out, PyString_AsString(string_key), key_len)

    out = out + key_len

    out[0] = c'\0'

    out = out + 1

    if refs_len > 0:

        first_ref_list = 1

        for ref_list in ref_lists:

            if first_ref_list == 0:

                out[0] = c'\t'

                out = out + 1

            first_ref_list = 0

            first_reference = 1

            for reference in ref_list:

                if first_reference == 0:

                    out[0] = c'\r'

                    out = out + 1

                first_reference = 0

                next_len = len(reference)

                for i from 0 <= i < next_len:

                    if i != 0:

                        out[0] = c'\x00'

                        out = out + 1

                    ref_bit = reference[i] #PyTuple_GET_ITEM_ptr_object(reference, i)

                    ref_bit_len = PyString_GET_SIZE(ref_bit)

                    memcpy(out, PyString_AS_STRING(ref_bit), ref_bit_len)

                    out = out + ref_bit_len

    out[0] = c'\0'

    out = out  + 1

    memcpy(out, value, value_len)

    out = out + value_len

    out[0] = c'\n'

    return string_key, line