U 9%e`%@sXddlmZmZmZmZmZmZmZddlZddl m Z ddl Z ddl Z ddl mZddlmZdddd d gZeee jee jfZee jefZee jjZee jjZeeZd d d hZeddddZeddeee jjfe jjedddZedde jje dddZ!eddGdd d Z"edde jj#e jj#ddd Z$dS))ListTupleUnionDictAnySetMappingN) dataclass)_get_qualified_name) compatibilityget_acc_ops_nameget_node_targetis_node_output_tensorFxNetAccFusionsFinderlegalize_graph call_module call_functionZ call_methodF)Zis_backward_compatiblecCsTt|tr|S|jr*d|jkr*d|jS|jdd}|r@|ndd|jSdS)Nacc_opsacc_ops.z torch._opsz torch.ops.) isinstancestr __module____name__replace)kmoduler[/var/www/html/Darija-Ai-API/env/lib/python3.8/site-packages/torch/fx/passes/tools_common.pyr s   ) submodulesnodereturncCs|jtks(tddtd|j|jdkrdt|jtsBt||j}t|dt|}t |S|jdkr|j}|j dk rd|j krd |j St |St|jtst|jSdS) a, Given a `node` returns its target typename. For "call_method" node, return node.target which is the name of that method being called. This could potential lead to conflict but should be okay because normally it's on a tensor. For "call_function" node, return typename of node.target. For "call_module" node, return typename of the module that node.target point to. If seeing "_VariableFunctionsClass" in the target name string, it will be replaced by "torch". e.g. _VariableFunctionsClass.relu would become torch.relu. zExpect op types of z, z , but found rZ_base_class_originrNrr) opCALLABLE_NODE_OPSAssertionErrorjoinrtargetrgetattrtyper rrr )r r!ZsubmodZ submod_typer'rrrr s$    )r!r"cCs"|jdd}|dk o t|tjS)aChecks if the node output produces a Tensor or not. NOTE: This requires to run `ShapeProp` on the containing fx graph before calling this function. This is because it works by checking the `type` metadata on the node. This metadata is produced by the `ShapeProp`. r)N)metaget issubclasstorchTensor)r!type_rrrrCsc@sheZdZdZejjedddZe GdddZ de ee fdd d Z eejjefd d d ZdS)rz Finds groups of connected ACC nodes that pass non-tensor data between each other. Such groups are called fusion groups. )r acc_nodescCs||_t|jj|_||_dSN)rlistgraphnodesr0)selfrr0rrr__init__UszFxNetAccFusionsFinder.__init__c@s6eZdZUeed<eed<eed<eed<ddZdS)!FxNetAccFusionsFinder.FusionGroup top_node_idxr4inputsnodes_need_processcsR|jkrdSj|j|j|jfdd|jDdS)z5 Add a node to fusion group. Ncs$h|]}|jtkr|jkr|qSr)r#r$r4).0nr5rr ss z=FxNetAccFusionsFinder.FusionGroup.add_node..)r4r:addr9discardupdateall_input_nodes)r5r!rr=radd_nodehs     z*FxNetAccFusionsFinder.FusionGroup.add_nodeN)rr __qualname__int__annotations__NodeSetrCrrrr FusionGroupZs rHr7) fusion_groupr9cCs\|D]R}|jtkrq|j||jkr(q||jkr8dS|||jr||dSqdS)z Start from inputs and going reverse topological order. If any upstream node is in the fusion group, add all the nodes in this path to fusion group. TF)r#r$r4indexr8recursive_add_noderBrC)r5rIr9argrrrrKzs    z(FxNetAccFusionsFinder.recursive_add_node)r"cCsri}t|j}|D]X}||kr"q|jtkr.qd|jkr:q||jkrFq|j|j||ht|j |hd}|j r0|j }| ||j d|jkr|jD]4}|jtkrq||jkrq||| ||j q|j D]V}|jtkrqd|jkrq||jkrq||t|j|j||_| ||j qqjt|j|jksT|j|j8_q|jD]}|j||<qZq|S)NZ tensor_meta)r8r4r9r:)r2r0r#r$r*rHr4rJsetrBr:poprKr9usersrCminr8)r5resultr0r!rIuserrLr<rrr__call__s\                   zFxNetAccFusionsFinder.__call__N)rrrD__doc__r-fx GraphModulerGr6r rHrNodeListrKrNoderSrrrrrNs! )gmr"csdd|jjDtj}|jjD] }|jD]}|d7<q.q$t}|jjD]}|dkrV||qVit |dkr| }| |fdd|<|jD]*}|d8<|dkr||qqvt |jt |jjkr t dfdd D|jj |_ ||_|S) a Replace the graph of the given GraphModule with one that contains the same nodes as the original, but in topologically sorted order. This is used by the merge_matmul transformation below, which disturbs the topologically sorted order of its input GraphModule, so that this order is restored before further transformation. Arguments: gm: The graph module to topologically sort. It is modified in-place. Returns: The graph module in-place sorted cSsi|] }|dqSrrr;r!rrr sz"legalize_graph..rcs|Sr1r)x)envrrz legalize_graph..z&Input graph has cycles, unable to add csg|]}|dkr|qSrZrr[)indegrr s z"legalize_graph..)r3r4r-rUZGraphrO collectionsdequeappendlenpopleftZ node_copy RuntimeErrorZ_codegen)rYZ new_graphr!rRqueuecurr)r_rbrrs,          )%typingrrrrrrrrd dataclassesr r-Ztorch.fxZ torch.fx.noder Ztorch.fx._compatibilityr __all__r.ZTensorsZTensorOrTensorsrUrXrWrGrZNamesr$r nnModuler boolrrrVrrrrrs0$       $#