tracing.py 40.9 KB
Newer Older
1 2 3 4 5 6 7 8
# -*- coding: utf-8 -*-
# MegEngine is Licensed under the Apache License, Version 2.0 (the "License")
#
# Copyright (c) 2014-2020 Megvii Inc. All rights reserved.
#
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT ARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
M
Megvii Engine Team 已提交
9
import collections
M
Megvii Engine Team 已提交
10 11
import contextlib
import functools
M
Megvii Engine Team 已提交
12
import itertools
13
import json
14
import os
M
Megvii Engine Team 已提交
15
import typing
M
Megvii Engine Team 已提交
16
import warnings
M
Megvii Engine Team 已提交
17 18
import weakref

M
Megvii Engine Team 已提交
19 20
import numpy as np

21
from ..core._imperative_rt import GraphProfiler, common
22 23
from ..core._imperative_rt.core2 import Tensor as RawTensor
from ..core._imperative_rt.core2 import (
24
    TensorWeakRef,
25 26 27 28 29 30 31
    apply,
    set_compiled,
    set_tracing,
    skip_tracing,
    unset_compiled,
    unset_tracing,
)
32
from ..core._imperative_rt.ops import CollectiveComm, RemoteRecv, RemoteSend
33
from ..core._trace_option import set_symbolic_shape
34
from ..core._wrap import device as as_device
35
from ..core.ops.builtin import BackwardGraph, OpDef
M
Megvii Engine Team 已提交
36 37
from ..core.ops.special import Const
from ..core.tensor import megbrain_graph as G
38
from ..core.tensor.utils import setscalar
39
from .sublinear_memory_config import SublinearMemoryConfig
M
Megvii Engine Team 已提交
40 41


42 43 44 45
def _input_node_use_static_shape():
    return os.environ.get("MEGENGINE_INPUT_NODE_USE_STATIC_SHAPE") is not None


M
Megvii Engine Team 已提交
46 47 48 49 50 51 52
class TraceMismatchError(RuntimeError):
    pass


active_trace = None


53 54 55 56 57 58 59
def is_tracing():
    if active_trace is None:
        return False
    else:
        return not skip_tracing


M
Megvii Engine Team 已提交
60 61 62 63 64 65 66 67
@contextlib.contextmanager
def exclude_from_trace():
    global skip_tracing
    if skip_tracing:
        yield
        return
    try:
        skip_tracing = True
68
        unset_tracing()
M
Megvii Engine Team 已提交
69 70 71 72 73
        if active_trace is not None:
            active_trace._begin_excluded_region()
        yield
    finally:
        skip_tracing = False
74
        set_tracing()
M
Megvii Engine Team 已提交
75 76 77 78 79 80


class TensorInfo:
    __slots__ = (
        # collected attributes
        "external",
81 82 83
        "data_read",
        "shape_read",
        "value_read",
M
Megvii Engine Team 已提交
84 85 86
        "exported",
        "device",
        "dtype",
87
        "shape",
88
        "is_const",
M
Megvii Engine Team 已提交
89 90 91 92 93 94 95 96 97 98 99
        "bound_data",
        # resources for execution
        "varnode",
        "data_setter",
        "shape_reader",
        "value_reader",
        "data_reader",
    )

    def __init__(self):
        self.exported = None
100 101 102
        self.data_read = None
        self.shape_read = None
        self.value_read = None
M
Megvii Engine Team 已提交
103 104 105 106 107 108 109 110
        self.bound_data = None

        self.data_setter = None
        self.shape_reader = None
        self.value_reader = None
        self.data_reader = None


111 112 113
_io_op_types = {CollectiveComm, RemoteSend, RemoteRecv}


M
Megvii Engine Team 已提交
114
class trace:
115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130
    """
    Wraps a callable and provide:

    * tracing via :meth:`.trace` and :meth:`.dump`
    * accelerated evalutaion via :meth:`.__call__`

    :param function: the function will be traced.
    :param symbolic: whether to apply symbolic execution for tracing. Default: False
    :param capture_as_const: capture global vars or closures as const value. Default: False
    :param sublinear_memory_config: configuration for sublinear memory optimization.
        If not None, it enables sublinear memory optimization with given setting.
    :param profiling: whether to profile compiled trace. Default: False
    :param opt_level: optimization level for compiling trace.
    :param symbolic_shape: whether to use symbolic shape for tracing. Default: True
    """

M
Megvii Engine Team 已提交
131 132 133
    def __new__(cls, *args, **kwargs):
        if not args:
            return functools.partial(cls, **kwargs)
134
        return super().__new__(cls)
M
Megvii Engine Team 已提交
135

136 137 138 139 140 141
    def __init__(
        self,
        function,
        symbolic=False,
        capture_as_const=False,
        sublinear_memory_config: SublinearMemoryConfig = None,
142
        profiling: bool = False,
143
        opt_level: int = None,
144
        symbolic_shape: bool = True,
145
    ):
M
Megvii Engine Team 已提交
146 147 148
        self.__wrapped__ = function
        self._symbolic = symbolic
        self._capture_as_const = capture_as_const
149
        self._sublinear_memory_config = sublinear_memory_config
150 151
        self._profiling = profiling
        self._profiler = None
152
        self._graph_opt_level = opt_level
153
        self._symbolic_shape = symbolic_shape
154
        self._output_handles = set()
M
Megvii Engine Team 已提交
155

156 157 158
        self._reset()

    def _reset(self):
M
Megvii Engine Team 已提交
159 160 161 162 163 164 165
        self._untraced = True
        self._tinfo = []  # handle -> TensorInfo
        self._seq = []
        self._pc = 0
        self._graph = None
        self._need_reset_nodes = None
        self._lazy_eval_graph = None
166
        self._lazy_eval_tensors = {}
167
        self._lazy_eval_links = None
168
        self._active_tensors = {}
M
Megvii Engine Team 已提交
169 170
        self._tensor_remaps = None
        self._inputs_to_restore = None
171 172
        self._arg_bindings = None
        self._kwarg_bindings = None
M
Megvii Engine Team 已提交
173 174
        self._output_bindings = None
        self._output_names = None
M
Megvii Engine Team 已提交
175 176 177 178 179 180 181 182 183 184 185 186 187 188

    def _new_handle(self):
        handle = len(self._tinfo)
        info = TensorInfo()
        self._tinfo.append(info)
        return handle, info

    def _apply_op(self, op, args):
        assert not self._untraced
        # check against trace
        if self._pc >= len(self._seq):
            raise TraceMismatchError("trace should end here, but more op observed")
        record = self._seq[self._pc]
        op_, ihandles, ohandles = record
189
        if (isinstance(op_, str) and op_ == "Const") or (op != op_):
190
            raise TraceMismatchError("op different from last time")
M
Megvii Engine Team 已提交
191 192 193
        if len(ihandles) != len(args):
            raise TraceMismatchError("op input size different from last time")

194
        # check all inputs of crrent op
M
Megvii Engine Team 已提交
195 196 197 198
        for h, x in zip(ihandles, args):
            info = self._tinfo[h]
            if info.external:
                if (
199 200
                    x._compiled_info is not None
                    and not self._tinfo[x._mixin_handle].exported
M
Megvii Engine Team 已提交
201 202 203 204 205 206
                ):
                    raise TraceMismatchError(
                        "failed to capture: input was an external tensor "
                        "last time, got an internal tensor this time"
                    )
                if info.bound_data:
207
                    if x._compiled_info is not None:
M
Megvii Engine Team 已提交
208 209 210 211 212
                        raise TraceMismatchError(
                            "const capture violated: was an external tensor "
                            "last time, got an internal tensor this time"
                        )
                    if x._handle != info.bound_data._handle:
213
                        if not np.array_equal(x.numpy(), info.bound_data.numpy()):
M
Megvii Engine Team 已提交
214 215 216 217
                            raise TraceMismatchError(
                                "const capture violated: got "
                                "a different tensor this time"
                            )
M
Megvii Engine Team 已提交
218 219 220 221 222 223 224 225 226 227 228
                else:
                    if info.dtype != x.dtype:
                        raise TraceMismatchError(
                            "failed to capture: different dtype from last time"
                        )
                    if info.device != x.device:
                        raise TraceMismatchError(
                            "failed to capture: different device from last time"
                        )
                    info.data_setter.set_value(x._dev_tensor())
            else:
229
                if x._mixin_handle == -1:
230 231 232 233 234 235
                    if x._handle not in self._tensor_remaps:
                        raise TraceMismatchError(
                            "unexpected capture: trying to use an external tensor as "
                            "input, but that input was an internal tensor last time"
                        )
                    else:
236
                        x._mixin_handle = self._tensor_remaps[
237 238
                            x._handle
                        ]._CompiledTensorProxy__handle
239
                if x._mixin_handle != h:
240 241 242 243
                    raise TraceMismatchError(
                        "mis-wiring: input edge to an data flow "
                        "graph node is different from last time"
                    )
M
Megvii Engine Team 已提交
244 245

        self._pc += 1
246
        outputs = []
247
        for h in ohandles:
248
            info = self._tinfo[h]
249
            # generate output tensor and create compied info
250 251
            y = RawTensor(info.varnode)
            y._compiled_info = CompiledTensorProxy(h)
252
            y._mixin_handle = h
253
            outputs += [y]
254
            self._active_tensors[h] = TensorWeakRef(y)
255
        self._output_handles.update(ohandles)
M
Megvii Engine Team 已提交
256 257
        return outputs

258
    def _apply_const(self, value, dtype, device):
259 260 261 262 263 264
        assert not self._untraced
        # check against trace
        if self._pc >= len(self._seq):
            raise TraceMismatchError("trace should end here, but more op observed")
        record = self._seq[self._pc]
        op_, ihandles, ohandles = record
265
        # Const op is represented by a str
266 267
        assert isinstance(op_, str) and op_ == "Const"

268 269 270 271 272
        eq = np.all(np.atleast_1d(value) == self._tinfo[ohandles[0]].bound_data.numpy())
        if not eq:
            raise TraceMismatchError(
                "const tensor violated: got a different tensor this time"
            )
273 274 275

        self._pc += 1
        (h,) = ohandles
276
        outputs = [self._tinfo[h].bound_data]
277 278
        return outputs

279
    # run in first step, record information for trace
M
Megvii Engine Team 已提交
280 281 282
    def _record_op(self, op, inputs, outputs):
        if skip_tracing:
            for x in inputs:
283
                h = getattr(x, "_mixin_handle", -1)
284
                if h >= 0:
285
                    self._tinfo[h].data = True
M
Megvii Engine Team 已提交
286 287 288 289
            return

        ihandles = []
        for x in inputs:
290
            h = getattr(x, "_mixin_handle", -1)
291
            if h < 0 or (not self._capture_as_const and self._tinfo[h].exported):
M
Megvii Engine Team 已提交
292 293 294 295
                h, info = self._new_handle()
                info.external = True
                info.device = x.device
                info.dtype = x.dtype
296
                info.shape = x.shape
M
Megvii Engine Team 已提交
297
                if self._capture_as_const:
298
                    info.bound_data = RawTensor(x.numpy(), x.dtype, x.device, False)
M
Megvii Engine Team 已提交
299 300 301 302 303 304 305 306

            ihandles.append(h)

        ohandles = []
        for x in outputs:
            h, info = self._new_handle()
            ohandles.append(h)
            info.external = False
307 308
            x._mixin_handle = h
            x._recording = True
309
            x._trace_mixin_info = info
310 311 312
            self._active_tensors[h] = TensorWeakRef(x)
            if self._symbolic:
                self._lazy_eval_tensors[h] = TensorWeakRef(x)
M
Megvii Engine Team 已提交
313 314 315

        self._seq.append((op, tuple(ihandles), tuple(ohandles)))

316
    def _record_const(self, outputs):
317 318
        if skip_tracing:
            (x,) = outputs
319
            h = getattr(x, "_mixin_handle", -1)
320
            if h >= 0:
321
                self._tinfo[h].data_read = True
322 323 324 325 326 327 328 329 330 331 332
            return

        (x,) = outputs
        h, info = self._new_handle()
        ohandles = [h]
        info.external = True
        info.device = x.device
        info.dtype = x.dtype
        info.shape = x.shape
        info.bound_data = x
        info.is_const = True
333 334
        x._mixin_handle = h
        x._recording = True
335
        x._trace_mixin_info = info
336 337
        if self._symbolic:
            self._lazy_eval_tensors[h] = TensorWeakRef(x)
338
        self._seq.append(("Const", tuple(), tuple(ohandles)))
339

340
    def _set_active(self, active: bool):
M
Megvii Engine Team 已提交
341
        global active_trace
342 343 344 345
        if active:
            if active_trace:
                raise NotImplementedError("sorry, not implemented: nested trace")
            active_trace = self
M
Megvii Engine Team 已提交
346
        else:
347 348 349 350 351 352
            assert active_trace is self
            active_trace = None

    def _init_trace(self, symbolic: bool):
        if symbolic:
            self._lazy_eval_graph = G.Graph()
353
            self._apply_graph_options(self._lazy_eval_graph)
354
            self._lazy_eval_links = ()
355 356

    def _take_escaped_tensors(self):
357 358 359
        escaped_tensors = tuple(
            filter(lambda x: x() is not None, self._active_tensors.values())
        )
M
Megvii Engine Team 已提交
360
        self._active_tensors.clear()
361 362
        return escaped_tensors

363
    def _lazy_eval(self, lazy_eval_graph, lazy_eval_tensors, lazy_eval_links):
364 365 366
        lazy_eval_tensors = list(
            filter(lambda x: x() is not None, lazy_eval_tensors.values())
        )
367
        readers = [G.OutputNode(x()._varnode).outputs[0] for x in lazy_eval_tensors]
368
        self._apply_graph_options(lazy_eval_graph)
369 370 371 372 373
        # FIXME
        if self._graph_opt_level is not None:
            lazy_eval_graph.options.graph_opt_level = self._graph_opt_level
        else:
            lazy_eval_graph.options.graph_opt_level = 2
374
        lazy_eval_graph._set_priority_to_id([*lazy_eval_links, *readers])
375
        lazy_eval_graph.compile(*lazy_eval_links, *readers)
376
        lazy_eval_graph()
377
        for r, x in zip(readers, lazy_eval_tensors):
378
            # get values from lazy_eval_graph and assign to lazy_eval tensor
379
            x()._handle = RawTensor(r.op.get_value())._handle
380
            x()._reset_varnode()
381 382 383 384

    @contextlib.contextmanager
    def _setup(self):
        interrupted = False
M
Megvii Engine Team 已提交
385

386
        def do_enter():
387
            set_tracing()
388
            self._save_symbolic_shape = set_symbolic_shape(self._symbolic_shape)
389 390 391 392
            self._set_active(True)
            if self._untraced:
                self._init_trace(self._symbolic)
            else:
393
                set_compiled()
394 395 396 397 398 399 400 401
                if self._graph is None:
                    self._compile()
                self._graph.execute()

        def do_finalize():
            escaped_tensors = self._take_escaped_tensors()
            if self._untraced:
                for x in escaped_tensors:
402
                    if x():
403
                        info = self._tinfo[x()._mixin_handle]
404
                        info.data_read = True
405 406
                        x()._mixin_handle = -1
                        x()._recording = False
407 408
                if self._inputs_to_restore:
                    for x in self._inputs_to_restore:
409 410
                        x._mixin_handle = -1
                        x._recording = False
411 412 413
                if self._symbolic and (
                    self._lazy_eval_tensors or self._lazy_eval_links
                ):
414
                    # eval lazy eval tensors
415 416
                    self._lazy_eval(
                        self._lazy_eval_graph,
417
                        self._lazy_eval_tensors,
418 419
                        self._lazy_eval_links,
                    )
M
Megvii Engine Team 已提交
420 421
                    self._lazy_eval_graph = None
                    self._lazy_eval_tensors = None
422
                    self._lazy_eval_links = None
423 424 425 426 427 428
                self._untraced = False
            else:
                # compiled_tensor leaks
                if self._pc == len(self._seq):
                    for x in escaped_tensors:
                        try:
429
                            assign_raw_tensor(x(), RawTensor(x()._dev_tensor()))
430
                        except RuntimeError:
431 432 433 434 435 436
                            # TraceMismatchError thrown in do_exit
                            pass
                    self._graph.wait()
                    self._reset_exec_env()

            # reset status
M
Megvii Engine Team 已提交
437
            self._pc = 0
438 439
            self._tensor_remaps = None
            self._set_active(False)
440
            set_symbolic_shape(self._save_symbolic_shape)
441 442
            unset_compiled()
            unset_tracing()
443 444

        def do_exit():
445
            unset_tracing()
446 447 448
            if not self._untraced and self._pc != len(self._seq):
                raise TraceMismatchError("premature end")
            if not self._symbolic or not self._untraced:
449
                # reset output tensors
450
                for x in self._active_tensors.values():
451 452
                    if x() is not None:
                        x()._dev_tensor()
453
                        x()._reset_varnode()
454 455
                        x()._mixin_handle = -1
                        x()._recording = False
456
                        x()._trace_mixin_info = None
457 458 459 460 461 462 463 464 465 466 467 468

        try:
            do_enter()
            yield
            do_exit()
        except:
            interrupted = True
            raise
        finally:
            do_finalize()
            if interrupted:
                self._reset()
M
Megvii Engine Team 已提交
469 470

    def _begin_excluded_region(self):
M
Megvii Engine Team 已提交
471 472 473 474
        if self._capture_as_const:
            raise RuntimeError(
                "exclude_from_trace cannot be used with capture_as_const"
            )
M
Megvii Engine Team 已提交
475 476 477
        if self._untraced:
            # conditionally reading a compiled tensor in excluded region
            # is permitted, so we have to assume every tensor might be read
478
            for x in self._active_tensors.values():
479 480 481 482 483 484 485 486
                if x():
                    info = self._tinfo[x()._mixin_handle]
                    info.exported = True
                    info.data_read = True
        else:
            for x in self._active_tensors.values():
                if x():
                    x()._dev_tensor()
M
Megvii Engine Team 已提交
487

488 489
    def _apply_graph_options(self, graph):

490
        graph.options.no_force_inplace = True
491
        graph.options.seq_opt.enable_seq_comp_node_opt = False
492
        # graph opt level
493 494 495 496
        # if self._graph_opt_level is not None:
        #     graph.options.graph_opt_level = self._graph_opt_level
        # FIXME
        graph.options.graph_opt_level = 0
497 498 499 500 501 502 503 504 505 506 507 508 509
        # sublinear
        if self._sublinear_memory_config is not None:
            graph.options.enable_sublinear_memory_opt = True
            sublinear_config = graph.options.sublinear_mem_config
            sublinear_config.lb_memory = self._sublinear_memory_config.lb_memory
            sublinear_config.genetic_nr_iter = (
                self._sublinear_memory_config.genetic_nr_iter
            )
            sublinear_config.genetic_pool_size = (
                self._sublinear_memory_config.genetic_pool_size
            )
            sublinear_config.thresh_nr_try = self._sublinear_memory_config.thresh_nr_try
            sublinear_config.num_worker = self._sublinear_memory_config.num_worker
510
        # profile
511 512
        if self._profiling:
            self._profiler = GraphProfiler(graph)
513 514
        if int(os.getenv("MEGENGINE_INPLACE_UPDATE", "0")):
            graph.options.var_sanity_check_first_run = False
515

M
Megvii Engine Team 已提交
516 517
    def _compile(self):
        graph = self._graph = G.Graph()
518
        graph.options.async_exec_level = 0b100
519
        self._apply_graph_options(graph)
M
Megvii Engine Team 已提交
520 521 522
        # graph.options.graph_opt_level = 0
        need_reset_nodes = self._need_reset_nodes = []
        # links enforce ordering of I/O nodes
523 524
        in_out_links = ()
        io_links = ()
525
        readers = []
M
Megvii Engine Team 已提交
526 527

        if self._capture_as_const:
528
            for h in itertools.chain(self._arg_bindings, self._kwarg_bindings.values()):
M
Megvii Engine Team 已提交
529 530
                info = self._tinfo[h]
                opnode = info.data_setter = G.InputNode(
531 532
                    device=info.device,
                    dtype=info.dtype,
533
                    shape=info.shape or (1,),
534 535
                    graph=graph,
                    use_static_shape=_input_node_use_static_shape(),
M
Megvii Engine Team 已提交
536 537 538
                )
                need_reset_nodes.append(opnode)
                info.varnode = opnode.outputs[0]
539
                in_out_links += opnode.outputs[1:]
M
Megvii Engine Team 已提交
540

M
Megvii Engine Team 已提交
541
        for op, ihandles, ohandles in self._seq:
542
            if isinstance(op, str) and op == "Const":
543 544 545 546 547 548 549 550 551 552 553 554
                assert len(ihandles) == 0
                (h,) = ohandles
                info = self._tinfo[h]
                if not hasattr(info, "varnode"):
                    assert info.external
                    assert info.bound_data
                    info.varnode = graph.make_const(
                        info.bound_data.numpy(),
                        info.bound_data.dtype,
                        info.bound_data.device,
                    )
                continue
555

556
            require_links = type(op) in _io_op_types
M
Megvii Engine Team 已提交
557
            ivars = []
558
            for i, h in enumerate(ihandles):
M
Megvii Engine Team 已提交
559 560 561 562
                info = self._tinfo[h]
                if not hasattr(info, "varnode"):
                    assert info.external
                    if info.bound_data:
563 564 565 566 567 568 569 570 571 572 573
                        if hasattr(info, "is_const") and info.is_const:
                            info.varnode = graph.make_const(
                                info.bound_data.numpy(),
                                info.bound_data.dtype,
                                info.bound_data.device,
                            )
                        else:
                            info.varnode = graph.make_const(
                                info.bound_data._dev_tensor()
                                # info.bound_data.numpy()
                            )
M
Megvii Engine Team 已提交
574 575
                    else:
                        opnode = info.data_setter = G.InputNode(
576
                            *in_out_links,
577 578
                            device=info.device,
                            dtype=info.dtype,
579
                            shape=info.shape or (1,),
580
                            graph=graph,
581
                            use_static_shape=_input_node_use_static_shape(),
M
Megvii Engine Team 已提交
582 583
                        )
                        need_reset_nodes.append(opnode)
584 585
                        info.varnode, *in_out_links = opnode.outputs
                if require_links and i == 0 and len(io_links) > 0:
586 587 588 589
                    opnode = G.VirtualDepNode(
                        [info.varnode, *io_links], str(io_links[0].device)
                    )
                    info.varnode = opnode.outputs[0]
590
                    io_links = (info.varnode,)
M
Megvii Engine Team 已提交
591 592

                ivars.append(info.varnode)
593

594 595 596 597 598
            if isinstance(op, BackwardGraph):
                ovars = G.apply_backward_varnode(op, *ivars)
            else:
                ovars = G.apply_normal_varnode(op, *ivars)

599
            if require_links and len(ovars) > 0:
600
                io_links = (ovars[0],)
M
Megvii Engine Team 已提交
601 602 603 604 605 606
            assert len(ovars) == len(ohandles)
            for h, v in zip(ohandles, ovars):
                info = self._tinfo[h]
                info.varnode = v

                def add_reader(opnode):
607
                    nonlocal in_out_links
M
Megvii Engine Team 已提交
608 609
                    need_reset_nodes.append(opnode)
                    readers.append(opnode.outputs[0])
610
                    in_out_links = opnode.outputs
M
Megvii Engine Team 已提交
611

612
                if info.data_read:
M
Megvii Engine Team 已提交
613 614 615 616
                    # Shape can be obtained from data so doesn't need its own
                    # output node. On the other hand, value is read separately
                    # to leverage eager h2d copy
                    info.shape_read = False
617
                    opnode = info.data_reader = G.OutputNode(v, *in_out_links)
M
Megvii Engine Team 已提交
618 619
                    add_reader(opnode)
                if info.value_read:
620
                    opnode = info.value_reader = G.ValueOutputNode(v, *in_out_links)
M
Megvii Engine Team 已提交
621 622
                    add_reader(opnode)
                if info.shape_read:
623
                    opnode = info.shape_reader = G.AttrOutputNode(v, *in_out_links)
M
Megvii Engine Team 已提交
624
                    add_reader(opnode)
625

626 627 628 629 630
        # FIXME
        if self._graph_opt_level is not None:
            graph.options.graph_opt_level = self._graph_opt_level
        else:
            graph.options.graph_opt_level = 2
631
        graph._set_priority_to_id([*readers, *in_out_links, *io_links])
632
        graph.compile(*readers, *in_out_links, *io_links)
M
Megvii Engine Team 已提交
633 634 635 636 637 638

    def _reset_exec_env(self):
        for opnode in self._need_reset_nodes:
            opnode.reset()

    def __call__(self, *args, **kwargs):
639 640
        if is_tracing():
            return self.__wrapped__(*args, **kwargs)
M
Megvii Engine Team 已提交
641
        with self._setup():
M
Megvii Engine Team 已提交
642 643 644
            if self._capture_as_const:
                self._process_inputs(*args, **kwargs)
            outputs = self.__wrapped__(*args, **kwargs)
645
            transform = False
646
            # outputs can be None
647 648 649 650 651
            if outputs is not None:
                if not isinstance(outputs, collections.abc.Sequence):
                    transform = True
                    outputs = (outputs,)
                for o in outputs:
652
                    # if outputs are copied, then use the newest info in trace data structure
653
                    if o._copied:
654
                        self._active_tensors[o._mixin_handle] = TensorWeakRef(o)
655
                        if self._untraced and self._symbolic:
656
                            self._lazy_eval_tensors[o._mixin_handle] = TensorWeakRef(o)
M
Megvii Engine Team 已提交
657 658
            if self._capture_as_const:
                self._process_outputs(outputs)
659 660
            if transform:
                outputs = outputs[0]
M
Megvii Engine Team 已提交
661 662
            return outputs

663 664 665 666 667 668 669 670 671 672
    def dump(
        self,
        file,
        *,
        arg_names=None,
        output_names=None,
        append=False,
        optimize_for_inference=True,
        **kwargs
    ):
673 674
        r"""
        Serializes trace to file system.
675 676 677 678 679 680 681

        :param file: output file, could be file object or filename.
        :param arg_names: names of the input tensors in the traced function.
        :param output_names: names of the output tensors in the traced function,
            use the default name if not specified.
        :param append: whether output is appended to ``file``.
            Only works when ``file`` is str.
682 683
        :param optimize_for_inference: enbale optmizations,
            will skip all optimize options if this is False. Default: True
684 685 686 687 688 689 690 691 692 693 694 695 696 697 698 699 700 701 702 703 704 705 706 707 708 709 710 711 712 713 714 715 716 717 718 719 720 721 722 723

        :Keyword Arguments:

            * enable_io16xc32 --
                whether to use float16 for I/O between oprs and use
                float32 as internal computation precision. Note the output var would be
                changed to float16.
            * enable_ioc16 --
                whether to use float16 for both I/O and computation
                precision.

            * enable_hwcd4 --
                whether to use NHWCD4 data layout. This is faster on some
                OpenCL backend.
            * enable_nchw88 --
                whether to use NCHW88 data layout, currently
                used in X86 AVX backend.
            * enable_nchw44 --
                whether to use NCHW44 data layout, currently
                used in arm backend.
            * enable_nchw44_dot --
                whether to use NCHW44_dot data layout, currently
                used in armv8.2+dotprod backend.
            * enable_nchw4 --
                whether to use NCHW4 data layout, currently
                used in nvidia backend(based on cudnn).
            * enable_nchw32 --
                whether to use NCHW32 data layout, currently
                used in nvidia backend with tensorcore(based on cudnn).
            * enable_chwn4 --
                whether to use CHWN4 data layout, currently
                used in nvidia backend with tensorcore.

            * enable_fuse_conv_bias_nonlinearity: whether to fuse conv+bias+nonlinearty
                into one opr.
            * enable_fuse_conv_bias_with_z: whether to fuse conv_bias with z
                input for inference on nvidia backend(this optimization pass will
                result in mismatch of the precision of output of training and
                inference)
        """
M
Megvii Engine Team 已提交
724 725 726 727 728 729 730 731 732 733
        if not self._capture_as_const:
            raise ValueError(
                "you must specify capture_as_const=True at __init__ to use dump"
            )
        if self._untraced:
            raise RuntimeError("should run at least once before calling dump")
        if self._output_names and output_names:
            raise TypeError(
                "cannot specify output_names when output is already in dict format"
            )
M
Megvii Engine Team 已提交
734
        if output_names and not isinstance(output_names, collections.abc.Sequence):
M
Megvii Engine Team 已提交
735 736
            output_names = (output_names,)
        if output_names and len(output_names) != len(self._output_bindings):
737 738 739 740 741
            raise ValueError(
                "wrong number of output_names, should be {} values".format(
                    len(self._output_bindings)
                )
            )
742 743
        if arg_names is None:
            arg_names = ["arg_%d" % i for i in range(len(self._arg_bindings))]
M
Megvii Engine Team 已提交
744
        if arg_names and not isinstance(arg_names, collections.abc.Sequence):
M
Megvii Engine Team 已提交
745 746
            arg_names = (arg_names,)
        if arg_names and len(arg_names) != len(self._arg_bindings):
747 748 749 750 751
            raise ValueError(
                "wrong number of arg_names, should be {} values".format(
                    len(self._arg_bindings)
                )
            )
M
Megvii Engine Team 已提交
752 753
        output_names = output_names or self._output_names

754 755
        dumped_device = as_device("xpux")

M
Megvii Engine Team 已提交
756 757
        h2v = {}
        graph = G.Graph()
758 759
        # only graph_opt_level takes effect in dump
        self._apply_graph_options(graph)
M
Megvii Engine Team 已提交
760

761
        for i, h in enumerate(self._arg_bindings):
M
Megvii Engine Team 已提交
762
            info = self._tinfo[h]
763 764
            h2v[h] = graph.make_h2d(
                dtype=info.dtype,
765
                device=dumped_device,
766
                shape=info.shape or (1,),
767 768 769
                name=arg_names[i] if arg_names else None,
            )
        for k, h in self._kwarg_bindings.items():
M
Megvii Engine Team 已提交
770
            info = self._tinfo[h]
771
            h2v[h] = graph.make_h2d(
772
                dtype=info.dtype, device=dumped_device, shape=info.shape or (1,), name=k
773
            )
M
Megvii Engine Team 已提交
774 775

        for op, ihandles, ohandles in self._seq:
776
            if isinstance(op, str) and op == "Const":
777 778 779 780 781 782 783 784 785 786
                assert len(ihandles) == 0
                (h,) = ohandles
                info = self._tinfo[h]
                if h not in h2v:
                    assert info.external
                    assert info.bound_data
                    h2v[h] = graph.make_const(
                        info.bound_data.numpy(), dtype=info.dtype, device=info.device,
                    )
                continue
M
Megvii Engine Team 已提交
787 788 789 790 791 792
            ivars = []
            for h in ihandles:
                info = self._tinfo[h]
                if h not in h2v:
                    assert info.external
                    assert info.bound_data
793
                    h2v[h] = graph.make_const(
794
                        info.bound_data.numpy(), dtype=info.dtype, device=dumped_device
795
                    )
M
Megvii Engine Team 已提交
796
                ivars.append(h2v[h])
797
            ovars = G.apply_normal_varnode(op, *ivars)
M
Megvii Engine Team 已提交
798 799 800 801 802 803 804 805 806 807
            assert len(ovars) == len(ohandles)
            h2v.update(zip(ohandles, ovars))

        dest_vars = []
        for i, h in enumerate(self._output_bindings):
            v = h2v[h]
            if output_names:
                v.name = output_names[i]
            dest_vars.append(v)

808 809
        if optimize_for_inference:
            dest_vars = G.optimize_for_inference(dest_vars, **kwargs)
810

M
Megvii Engine Team 已提交
811
        if isinstance(file, str):
812 813
            permission = "wb" if append == False else "ab"
            file = open(file, permission)
814 815 816
        dump_content, dump_info = G.dump_graph(dest_vars)
        file.write(dump_content)
        return dump_info
M
Megvii Engine Team 已提交
817 818 819 820 821 822 823 824 825 826 827 828

    def _process_inputs(self, *args, **kwargs):
        if self._untraced:
            self._inputs_to_restore = []

            def record_input(x):
                if x is None:
                    return
                h, info = self._new_handle()
                info.external = False
                info.device = x.device
                info.dtype = x.dtype
829
                info.shape = x.numpy().shape
830 831
                x._mixin_handle = h
                x._recording = True
832
                x._trace_mixin_info = info
M
Megvii Engine Team 已提交
833 834 835
                self._inputs_to_restore.append(x)
                return h

836
            self._arg_bindings = []
M
Megvii Engine Team 已提交
837
            for i, x in enumerate(args):
838
                if not isinstance(x, RawTensor):
M
Megvii Engine Team 已提交
839 840 841 842
                    raise TypeError(
                        "positional arguments should all be tensor "
                        "but args[%d] cannot be recognized as one" % i
                    )
843
                self._arg_bindings.append(record_input(x))
M
Megvii Engine Team 已提交
844

845
            self._kwarg_bindings = {}
M
Megvii Engine Team 已提交
846
            for k, x in kwargs.items():
847
                if isinstance(x, RawTensor):
848
                    self._kwarg_bindings[k] = record_input(x)
M
Megvii Engine Team 已提交
849
        else:
850
            if len(args) != len(self._arg_bindings):
M
Megvii Engine Team 已提交
851 852 853 854
                raise TraceMismatchError("positional argument length mismatch")

            self._tensor_remaps = {}

855
            for i, (h, x) in enumerate(zip(self._arg_bindings, args)):
856
                if not isinstance(x, RawTensor):
M
Megvii Engine Team 已提交
857 858 859 860 861 862 863 864 865 866
                    raise TypeError(
                        "positional arguments should all be tensor "
                        "but args[%d] cannot be recognized as one" % i
                    )
                info = self._tinfo[h]
                if x.dtype != info.dtype:
                    raise TypeError("args[%d].dtype different from last time" % i)
                if x.device != info.device:
                    raise TypeError("args[%d].device different from last time" % i)
                info.data_setter.set_value(x._dev_tensor())
867
                self._tensor_remaps[x._handle] = CompiledTensorProxy(h)
M
Megvii Engine Team 已提交
868 869 870

            kwargs_tensors = {}
            for k, x in kwargs.items():
871
                if isinstance(x, RawTensor):
M
Megvii Engine Team 已提交
872
                    kwargs_tensors[k] = x
873 874 875
            if set(kwargs_tensors) != set(self._kwarg_bindings):
                too_many = set(kwargs_tensors) - set(self._kwarg_bindings)
                too_few = set(self._kwarg_bindings) - set(kwargs_tensors)
M
Megvii Engine Team 已提交
876 877 878 879 880 881 882 883 884 885
                if too_many:
                    raise TraceMismatchError(
                        "keyword arguments found to be tensor this time "
                        "but were non-tensor previously: %s" % " ".join(too_many)
                    )
                if too_few:
                    raise TraceMismatchError(
                        "keyword arguments found to be non-tensor this time "
                        "but were tensor previously: %s" % " ".join(too_few)
                    )
886
            for k, h in self._kwarg_bindings.items():
M
Megvii Engine Team 已提交
887 888 889 890 891 892 893
                x = kwargs_tensors[k]
                info = self._tinfo[h]
                if x.dtype != info.dtype:
                    raise TypeError("kwargs[%s].dtype different from last time" % k)
                if x.device != info.device:
                    raise TypeError("kwargs[%s].device different from last time" % k)
                info.data_setter.set_value(x._dev_tensor())
894
                self._tensor_remaps[x._handle] = CompiledTensorProxy(h)
M
Megvii Engine Team 已提交
895 896 897

    def _process_outputs(self, outputs):
        output_names = None
M
Megvii Engine Team 已提交
898
        if isinstance(outputs, collections.abc.Mapping):
M
Megvii Engine Team 已提交
899
            output_names, outputs = zip(*sorted(outputs.items()))
M
Megvii Engine Team 已提交
900
        elif not isinstance(outputs, collections.abc.Sequence):
M
Megvii Engine Team 已提交
901 902 903 904 905 906 907 908 909 910 911 912 913 914 915 916 917 918 919 920 921
            outputs = (outputs,)

        if not self._untraced:
            if output_names != self._output_names:
                too_many = set(output_names) - set(self._output_names)
                too_few = set(self._output_names) - set(output_names)
                if too_many:
                    raise TraceMismatchError(
                        "output has more keys than last time: %s" % " ".join(too_many)
                    )
                if too_few:
                    raise TraceMismatchError(
                        "output has less keys than last time: %s" % " ".join(too_few)
                    )
            if len(outputs) != len(self._output_bindings):
                raise TraceMismatchError("output size differs from last time")
        else:
            self._output_names = output_names
            self._output_bindings = []

        for i, x in enumerate(outputs):
922
            if not isinstance(x, RawTensor):
M
Megvii Engine Team 已提交
923 924
                raise TypeError("every item of return value should be tensor")
            if self._untraced:
925
                h = x._mixin_handle
926
                if h < 0:
M
Megvii Engine Team 已提交
927 928 929
                    raise RuntimeError("output is not computed from inputs")
                self._output_bindings.append(h)
            else:
930
                h = x._mixin_handle
931
                if h not in self._output_handles:
M
Megvii Engine Team 已提交
932 933 934 935 936 937
                    raise RuntimeError("output is not computed from inputs")
                if h != self._output_bindings[i]:
                    raise TraceMismatchError(
                        "retval[%s] is a different tensor than last time"
                        % (output_names and output_names[i] or i)
                    )
M
Megvii Engine Team 已提交
938

939 940 941 942 943 944 945 946 947 948
    def get_profile(self):
        """
        Get profiling result for compiled trace.

        :return: a json compatible object.
        """
        if not self._profiler:
            raise RuntimeError("trace is not set with profiling=True")
        return json.loads(self._profiler.get())

949 950 951 952 953
    def __del__(self):
        for x in self._tinfo:
            if getattr(x, "bound_data", None):
                x.bound_data = None

954 955 956 957 958 959
    def trace(self, *args, **kwargs):
        raise NotImplementedError(
            "trace is deemed unbeneficial with the new "
            "tracing mechanism. You should alwasy use __call__."
        )

M
Megvii Engine Team 已提交
960

961
class CompiledTensorProxy:
M
Megvii Engine Team 已提交
962 963 964 965 966 967
    """
    Duck-typed RawTensor
    """

    def __init__(self, handle):
        self.__handle = handle
968
        self._isscalar = False
M
Megvii Engine Team 已提交
969 970 971 972 973 974 975 976 977 978 979 980 981 982 983
        self.__info = active_trace._tinfo[handle]
        self.__shape = None
        self.__data = None
        self.__value = None

    @property
    def dtype(self):
        return self.__info.varnode.dtype

    @property
    def device(self):
        return self.__info.varnode.device

    @property
    def shape(self):
984 985
        if self._isscalar:
            return ()
M
Megvii Engine Team 已提交
986
        if self.__shape is None:
987
            if self.__info.shape_read:
M
Megvii Engine Team 已提交
988
                self.__shape = self.__info.shape_reader.get_value().shape
989
            elif self.__info.data_read:
990
                self.__shape = self._dev_tensor().shape
M
Megvii Engine Team 已提交
991
            else:
992 993
                # c++ will throw TraceReadError
                return None
M
Megvii Engine Team 已提交
994 995 996 997
        return self.__shape

    def numpy(self):
        if self.__value is None:
998
            if self.__info.value_read:
M
Megvii Engine Team 已提交
999
                self.__value = self.__info.value_reader.get_value()
1000
            elif self.__info.data_read:
M
Megvii Engine Team 已提交
1001 1002
                self.__value = self._dev_tensor().numpy()
            else:
1003 1004
                # c++ will throw TraceReadError
                return None
1005
        # c++ side will handle scalar case
M
Megvii Engine Team 已提交
1006 1007 1008 1009
        return self.__value

    def _dev_tensor(self):
        if self.__data is None:
1010
            if not self.__info.data_read:
1011 1012
                # c++ will throw TraceReadError
                return None
M
Megvii Engine Team 已提交
1013 1014 1015 1016
            self.__data = self.__info.data_reader.get_value()
        return self.__data

    def __del__(self):
1017
        if self.__info.shape_read and self.__shape is not None:
M
Megvii Engine Team 已提交
1018
            self.__info.shape_reader.drop_value()
1019
        if self.__info.value_read and self.__value is not None:
1020
            self.__info.value_reader.drop_value()
1021
        if self.__info.data_read and self.__data is not None:
M
Megvii Engine Team 已提交
1022 1023 1024 1025
            self.__info.data_reader.drop_value()


def assign_raw_tensor(lhs, rhs):
1026
    lhs.__init__(rhs)
M
Megvii Engine Team 已提交
1027 1028 1029 1030


def apply_symbolic_mode(op: OpDef, *args: RawTensor):
    graph = active_trace._lazy_eval_graph
1031 1032
    ivars = []
    for x in args:
1033
        var = getattr(x, "_varnode", None)
1034 1035 1036 1037 1038 1039
        if var:
            ivars.append(var)
        else:
            data_setter = G.InputNode(
                device=x.device,
                dtype=x.dtype,
1040
                shape=x.numpy().shape or (1,),
1041 1042 1043 1044 1045 1046
                graph=graph,
                use_static_shape=True,
            )
            var = data_setter.outputs[0]
            ivars.append(var)
            data_setter.set_value(x._dev_tensor())
1047 1048 1049 1050 1051

    require_links = type(op) in _io_op_types

    if require_links and active_trace._lazy_eval_links:
        assert len(ivars) > 0, "op should has at least one input"
1052 1053 1054 1055 1056
        opnode = G.VirtualDepNode(
            [ivars[0], *active_trace._lazy_eval_links],
            str(active_trace._lazy_eval_links[0].device),
        )
        ivars[0] = opnode.outputs[0]
1057 1058
        active_trace._lazy_eval_links = (ivars[0],)

1059 1060 1061 1062 1063
    if isinstance(op, BackwardGraph):
        ovars = G.apply_backward_varnode(op, *ivars)
    else:
        ovars = G.apply_normal_varnode(op, *ivars)
    outputs = [RawTensor(o) for o in ovars]
1064 1065

    if require_links:
1066
        active_trace._lazy_eval_links = (G.VarNode(outputs[0]._varnode),)
1067

M
Megvii Engine Team 已提交
1068 1069 1070
    return outputs


1071
def apply_const_symbolic_mode(value, dtype, device):
1072
    graph = active_trace._lazy_eval_graph
1073 1074 1075
    # don't need to unset tracing
    # because varnode construction will ignore tracing flag
    ret = RawTensor(graph.make_const(value, dtype=dtype, device=device))
1076 1077
    if np.array(value).ndim == 0:
        setscalar(ret)
1078 1079 1080
    return (ret,)


M
Megvii Engine Team 已提交
1081 1082 1083
def apply_compiled_mode(op: OpDef, *args: RawTensor):
    if skip_tracing:
        args = [
1084
            RawTensor(x._dev_tensor()) if x.__class__ is CompiledTensorProxy else x
M
Megvii Engine Team 已提交
1085 1086
            for x in args
        ]
1087 1088 1089 1090
        unset_tracing()
        ret = apply(op, *args)
        set_tracing()
        return ret
M
Megvii Engine Team 已提交
1091 1092 1093
    return active_trace._apply_op(op, args)


1094
def apply_const_compiled_mode(value, dtype, device, is_const, no_cache):
1095 1096
    if skip_tracing:
        args = [
1097
            RawTensor(x._dev_tensor()) if x.__class__ is CompiledTensorProxy else x
1098 1099
            for x in args
        ]
1100 1101 1102 1103 1104
        unset_tracing()
        ret = RawTensor(value, dtype, device, False)
        set_tracing()
        return ret
    return active_trace._apply_const(value, dtype, device)
1105 1106


M
Megvii Engine Team 已提交
1107
def apply_with_tracing(op: OpDef, *args: RawTensor):
1108 1109 1110 1111 1112 1113
    if active_trace._symbolic:
        outputs = apply_symbolic_mode(op, *args)
    else:
        unset_tracing()
        outputs = apply(op, *args)
        set_tracing()
M
Megvii Engine Team 已提交
1114

1115 1116
    active_trace._record_op(op, args, outputs)
    return list(outputs)
M
Megvii Engine Team 已提交
1117 1118


1119
def apply_const_with_tracing(value, dtype, device, is_const, no_cache):
1120 1121 1122 1123 1124 1125 1126 1127
    if active_trace._symbolic:
        outputs = apply_const_symbolic_mode(value, dtype, device)
    else:
        unset_tracing()
        outputs = (RawTensor(value, dtype, device, False),)
        set_tracing()
    active_trace._record_const(outputs)
    return list(outputs)