# cython: profile=True from __future__ import unicode_literals import ctypes import os from ..structs cimport TokenC from .transition_system cimport do_func_t, get_cost_func_t from .transition_system cimport move_cost_func_t, label_cost_func_t from ..gold cimport GoldParse from ..gold cimport GoldParseC from libc.stdint cimport uint32_t from libc.string cimport memcpy from cymem.cymem cimport Pool from .stateclass cimport StateClass DEF NON_MONOTONIC = True DEF USE_BREAK = False DEF USE_ROOT_ARC_SEGMENT = True cdef weight_t MIN_SCORE = -90000 # Break transition from here # http://www.aclweb.org/anthology/P13-1074 cdef enum: SHIFT REDUCE LEFT RIGHT BREAK N_MOVES MOVE_NAMES = [None] * N_MOVES MOVE_NAMES[SHIFT] = 'S' MOVE_NAMES[REDUCE] = 'D' MOVE_NAMES[LEFT] = 'L' MOVE_NAMES[RIGHT] = 'R' MOVE_NAMES[BREAK] = 'B' # Helper functions for the arc-eager oracle cdef int push_cost(StateClass stcls, const GoldParseC* gold, int target) nogil: cdef int cost = 0 cdef int i, S_i for i in range(stcls.stack_depth()): S_i = stcls.S(i) if gold.heads[target] == S_i: cost += 1 if gold.heads[S_i] == target and (NON_MONOTONIC or not stcls.has_head(S_i)): cost += 1 cost += Break.is_valid(stcls, -1) and Break.move_cost(stcls, gold) == 0 return cost cdef int pop_cost(StateClass stcls, const GoldParseC* gold, int target) nogil: cdef int cost = 0 cdef int i, B_i for i in range(stcls.buffer_length()): B_i = stcls.B(i) cost += gold.heads[B_i] == target cost += gold.heads[target] == B_i if gold.heads[B_i] == B_i or gold.heads[B_i] < target: break cost += Break.is_valid(stcls, -1) and Break.move_cost(stcls, gold) == 0 return cost cdef int arc_cost(StateClass stcls, const GoldParseC* gold, int head, int child) nogil: if arc_is_gold(gold, head, child): return 0 elif stcls.H(child) == gold.heads[child]: return 1 # Head in buffer elif gold.heads[child] >= stcls.B(0) and stcls.B(1) != -1: return 1 else: return 0 cdef bint arc_is_gold(const GoldParseC* gold, int head, int child) nogil: if gold.labels[child] == -1: return True elif USE_ROOT_ARC_SEGMENT and _is_gold_root(gold, head) and _is_gold_root(gold, child): return True elif gold.heads[child] == head: return True else: return False cdef bint label_is_gold(const GoldParseC* gold, int head, int child, int label) nogil: if gold.labels[child] == -1: return True elif label == -1: return True elif gold.labels[child] == label: return True else: return False cdef bint _is_gold_root(const GoldParseC* gold, int word) nogil: return gold.labels[word] == -1 or gold.heads[word] == word cdef class Shift: @staticmethod cdef bint is_valid(StateClass st, int label) nogil: return st.buffer_length() >= 2 and not st.shifted[st.B(0)] and not st.B_(0).sent_end @staticmethod cdef int transition(StateClass st, int label) nogil: st.push() st.fast_forward() @staticmethod cdef int cost(StateClass st, const GoldParseC* gold, int label) nogil: return Shift.move_cost(st, gold) + Shift.label_cost(st, gold, label) @staticmethod cdef inline int move_cost(StateClass s, const GoldParseC* gold) nogil: return push_cost(s, gold, s.B(0)) @staticmethod cdef inline int label_cost(StateClass s, const GoldParseC* gold, int label) nogil: return 0 cdef class Reduce: @staticmethod cdef bint is_valid(StateClass st, int label) nogil: return st.stack_depth() >= 2 @staticmethod cdef int transition(StateClass st, int label) nogil: if st.has_head(st.S(0)): st.pop() else: st.unshift() st.fast_forward() @staticmethod cdef int cost(StateClass s, const GoldParseC* gold, int label) nogil: return Reduce.move_cost(s, gold) + Reduce.label_cost(s, gold, label) @staticmethod cdef inline int move_cost(StateClass st, const GoldParseC* gold) nogil: return pop_cost(st, gold, st.S(0)) @staticmethod cdef inline int label_cost(StateClass s, const GoldParseC* gold, int label) nogil: return 0 cdef class LeftArc: @staticmethod cdef bint is_valid(StateClass st, int label) nogil: return not st.B_(0).sent_end @staticmethod cdef int transition(StateClass st, int label) nogil: st.add_arc(st.B(0), st.S(0), label) st.pop() st.fast_forward() @staticmethod cdef int cost(StateClass s, const GoldParseC* gold, int label) nogil: return LeftArc.move_cost(s, gold) + LeftArc.label_cost(s, gold, label) @staticmethod cdef inline int move_cost(StateClass s, const GoldParseC* gold) nogil: cdef int cost = 0 if arc_is_gold(gold, s.B(0), s.S(0)): return 0 else: # Account for deps we might lose between S0 and stack if not s.has_head(s.S(0)): for i in range(1, s.stack_depth()): cost += gold.heads[s.S(i)] == s.S(0) cost += gold.heads[s.S(0)] == s.S(i) return pop_cost(s, gold, s.S(0)) + arc_cost(s, gold, s.B(0), s.S(0)) @staticmethod cdef inline int label_cost(StateClass s, const GoldParseC* gold, int label) nogil: return arc_is_gold(gold, s.B(0), s.S(0)) and not label_is_gold(gold, s.B(0), s.S(0), label) cdef class RightArc: @staticmethod cdef bint is_valid(StateClass st, int label) nogil: return not st.B_(0).sent_end @staticmethod cdef int transition(StateClass st, int label) nogil: st.add_arc(st.S(0), st.B(0), label) st.push() st.fast_forward() @staticmethod cdef inline int cost(StateClass s, const GoldParseC* gold, int label) nogil: return RightArc.move_cost(s, gold) + RightArc.label_cost(s, gold, label) @staticmethod cdef inline int move_cost(StateClass s, const GoldParseC* gold) nogil: if arc_is_gold(gold, s.S(0), s.B(0)): return 0 elif s.shifted[s.B(0)]: return push_cost(s, gold, s.B(0)) else: return push_cost(s, gold, s.B(0)) + arc_cost(s, gold, s.S(0), s.B(0)) @staticmethod cdef int label_cost(StateClass s, const GoldParseC* gold, int label) nogil: return arc_is_gold(gold, s.S(0), s.B(0)) and not label_is_gold(gold, s.S(0), s.B(0), label) cdef class Break: @staticmethod cdef bint is_valid(StateClass st, int label) nogil: cdef int i if not USE_BREAK: return False elif st.at_break(): return False elif st.B(0) == 0: return False elif st.stack_depth() < 1: return False elif (st.S(0) + 1) != st.B(0): # Must break at the token boundary return False else: return True @staticmethod cdef int transition(StateClass st, int label) nogil: st.set_break(st.B(0)) st.fast_forward() @staticmethod cdef int cost(StateClass s, const GoldParseC* gold, int label) nogil: return Break.move_cost(s, gold) + Break.label_cost(s, gold, label) @staticmethod cdef inline int move_cost(StateClass s, const GoldParseC* gold) nogil: cdef int cost = 0 cdef int S_i, B_i for i in range(s.stack_depth()): S_i = s.S(i) for j in range(s.buffer_length()): B_i = s.B(j) cost += gold.heads[S_i] == B_i cost += gold.heads[B_i] == S_i # Check for sentence boundary --- if it's here, we can't have any deps # between stack and buffer, so rest of action is irrelevant. s0_root = _get_root(s.S(0), gold) b0_root = _get_root(s.B(0), gold) if s0_root != b0_root or s0_root == -1 or b0_root == -1: return cost else: return cost + 1 @staticmethod cdef inline int label_cost(StateClass s, const GoldParseC* gold, int label) nogil: return 0 cdef int _get_root(int word, const GoldParseC* gold) nogil: while gold.heads[word] != word and gold.labels[word] != -1 and word >= 0: word = gold.heads[word] if gold.labels[word] == -1: return -1 else: return word cdef class ArcEager(TransitionSystem): @classmethod def get_labels(cls, gold_parses): move_labels = {SHIFT: {'': True}, REDUCE: {'': True}, RIGHT: {'root': True}, LEFT: {'root': True}, BREAK: {'root': True}} for raw_text, sents in gold_parses: for (ids, words, tags, heads, labels, iob), ctnts in sents: for child, head, label in zip(ids, heads, labels): if label != 'root': if head < child: move_labels[RIGHT][label] = True elif head > child: move_labels[LEFT][label] = True return move_labels cdef int preprocess_gold(self, GoldParse gold) except -1: for i in range(gold.length): if gold.heads[i] is None: # Missing values gold.c.heads[i] = i gold.c.labels[i] = -1 else: gold.c.heads[i] = gold.heads[i] gold.c.labels[i] = self.strings[gold.labels[i]] for end, brackets in gold.brackets.items(): for start, label_strs in brackets.items(): gold.c.brackets[start][end] = 1 for label_str in label_strs: # Add the encoded label to the set gold.brackets[end][start].add(self.strings[label_str]) cdef Transition lookup_transition(self, object name) except *: if '-' in name: move_str, label_str = name.split('-', 1) label = self.label_ids[label_str] else: label = 0 move = MOVE_NAMES.index(move_str) for i in range(self.n_moves): if self.c[i].move == move and self.c[i].label == label: return self.c[i] def move_name(self, int move, int label): label_str = self.strings[label] if label_str: return MOVE_NAMES[move] + '-' + label_str else: return MOVE_NAMES[move] cdef Transition init_transition(self, int clas, int move, int label) except *: # TODO: Apparent Cython bug here when we try to use the Transition() # constructor with the function pointers cdef Transition t t.score = 0 t.clas = clas t.move = move t.label = label if move == SHIFT: t.is_valid = Shift.is_valid t.do = Shift.transition t.get_cost = Shift.cost elif move == REDUCE: t.is_valid = Reduce.is_valid t.do = Reduce.transition t.get_cost = Reduce.cost elif move == LEFT: t.is_valid = LeftArc.is_valid t.do = LeftArc.transition t.get_cost = LeftArc.cost elif move == RIGHT: t.is_valid = RightArc.is_valid t.do = RightArc.transition t.get_cost = RightArc.cost elif move == BREAK: t.is_valid = Break.is_valid t.do = Break.transition t.get_cost = Break.cost else: raise Exception(move) return t cdef int initialize_state(self, StateClass st) except -1: # Ensure sent_end is set to 0 throughout for i in range(st.length): st._sent[i].sent_end = False st.fast_forward() cdef int finalize_state(self, StateClass st) except -1: cdef int root_label = self.strings['root'] for i in range(st.length): if st._sent[i].head == 0 and st._sent[i].dep == 0: st._sent[i].dep = root_label # If we're not using the Break transition, we segment via root-labelled # arcs between the root words. elif USE_ROOT_ARC_SEGMENT and st._sent[i].dep == root_label: st._sent[i].head = 0 cdef int set_valid(self, bint* output, StateClass stcls) except -1: cdef bint[N_MOVES] is_valid is_valid[SHIFT] = Shift.is_valid(stcls, -1) is_valid[REDUCE] = Reduce.is_valid(stcls, -1) is_valid[LEFT] = LeftArc.is_valid(stcls, -1) is_valid[RIGHT] = RightArc.is_valid(stcls, -1) is_valid[BREAK] = Break.is_valid(stcls, -1) cdef int i n_valid = 0 for i in range(self.n_moves): output[i] = is_valid[self.c[i].move] n_valid += output[i] assert n_valid >= 1 cdef int set_costs(self, int* output, StateClass stcls, GoldParse gold) except -1: cdef int i, move, label cdef label_cost_func_t[N_MOVES] label_cost_funcs cdef move_cost_func_t[N_MOVES] move_cost_funcs cdef int[N_MOVES] move_costs for i in range(N_MOVES): move_costs[i] = -1 move_cost_funcs[SHIFT] = Shift.move_cost move_cost_funcs[REDUCE] = Reduce.move_cost move_cost_funcs[LEFT] = LeftArc.move_cost move_cost_funcs[RIGHT] = RightArc.move_cost move_cost_funcs[BREAK] = Break.move_cost label_cost_funcs[SHIFT] = Shift.label_cost label_cost_funcs[REDUCE] = Reduce.label_cost label_cost_funcs[LEFT] = LeftArc.label_cost label_cost_funcs[RIGHT] = RightArc.label_cost label_cost_funcs[BREAK] = Break.label_cost cdef int* labels = gold.c.labels cdef int* heads = gold.c.heads n_gold = 0 for i in range(self.n_moves): if self.c[i].is_valid(stcls, self.c[i].label): move = self.c[i].move label = self.c[i].label if move_costs[move] == -1: move_costs[move] = move_cost_funcs[move](stcls, &gold.c) output[i] = move_costs[move] + label_cost_funcs[move](stcls, &gold.c, label) n_gold += output[i] == 0 else: output[i] = 9000 assert n_gold >= 1 cdef Transition best_valid(self, const weight_t* scores, StateClass stcls) except *: cdef bint[N_MOVES] is_valid is_valid[SHIFT] = Shift.is_valid(stcls, -1) is_valid[REDUCE] = Reduce.is_valid(stcls, -1) is_valid[LEFT] = LeftArc.is_valid(stcls, -1) is_valid[RIGHT] = RightArc.is_valid(stcls, -1) is_valid[BREAK] = Break.is_valid(stcls, -1) cdef Transition best cdef weight_t score = MIN_SCORE cdef int i for i in range(self.n_moves): if scores[i] > score and is_valid[self.c[i].move]: best = self.c[i] score = scores[i] assert best.clas < self.n_moves assert score > MIN_SCORE, (stcls.stack_depth(), stcls.buffer_length(), stcls.is_final(), stcls._b_i, stcls.length) return best