9a2f08733fbbbac28da5dba88cadbdcd021f412b,lazyflow/operator.py,Operator,handleInputBecameUnready,#Operator#Any#,486

Before Change

        // Keep track of the old ready statuses so we know if
        // something changed
        readyFlags = {}
        for k, oslot in self.outputs.items():
            readyFlags[k] = oslot.meta._ready

        // All unconnected outputs are no longer ready
        for oslot in self.outputs.values():
            oslot.meta._ready &= (oslot.partner is not None)

        // If the ready status changed, signal it.
        for k, oslot in self.outputs.items():
            if readyFlags[k] != oslot.meta._ready:
                oslot._sig_unready(self)
                oslot._changed()

    def setupOutputs(self):
        This method is called when all input slots of an operator
        are successfully connected, a successful connection is also
        established if the input slot is not connected to another

After Change

        if slot._optional:
            return

        newly_unready_slots = []
        def setunready(s):
            for ss in s._subSlots:
                setunready(ss)
            was_ready = s.meta._ready
            s.meta._ready &= (s.partner is not None)
            if was_ready and s.meta._ready:
                newly_unready_slots.append(s)

        // All unconnected outputs are no longer ready
        for oslot in self.outputs.values():
            setunready(oslot)

        // If the ready status changed, signal it.
        for s in newly_unready_slots:
            s._sig_unready(s)
            s._changed()

    def setupOutputs(self):
        This method is called when all input slots of an operator
        are successfully connected, a successful connection is also
        established if the input slot is not connected to another

Instances