Skip to content

fluid_source

FluidSource

Bases: AbsoluteObjectState, LinkBasedStateMixin

Source code in object_states/fluid_source.py 
  9
 10
 11
 12
 13
 14
 15
 16
 17
 18
 19
 20
 21
 22
 23
 24
 25
 26
 27
 28
 29
 30
 31
 32
 33
 34
 35
 36
 37
 38
 39
 40
 41
 42
 43
 44
 45
 46
 47
 48
 49
 50
 51
 52
 53
 54
 55
 56
 57
 58
 59
 60
 61
 62
 63
 64
 65
 66
 67
 68
 69
 70
 71
 72
 73
 74
 75
 76
 77
 78
 79
 80
 81
 82
 83
 84
 85
 86
 87
 88
 89
 90
 91
 92
 93
 94
 95
 96
 97
 98
 99
100
class FluidSource(AbsoluteObjectState, LinkBasedStateMixin):
    def __init__(self, obj):
        super().__init__(obj)

        # Initialize variables that will be filled in at runtime
        self.fluid_groups = None
        self._step_counter = None

    @property
    def fluid_system(self):
        """
        Returns:
            FluidSystem: Fluid system to use to generate / handle fluid particles
        """
        raise NotImplementedError

    @property
    def n_particles_per_group(self):
        """
        Returns:
            int: How many fluid particles to generate per fluid group
        """
        raise NotImplementedError

    @property
    def n_steps_per_group(self):
        """
        Returns:
            int: How many update() steps to occur between fluid group generations
        """
        raise NotImplementedError

    @staticmethod
    def get_state_link_name():
        # Should be implemented by subclass
        raise NotImplementedError

    def _initialize(self):
        super()._initialize()
        self.initialize_link_mixin()
        fluid_source_position = self.get_link_position()
        if fluid_source_position is None:
            return

        # Further initialize internal variables
        self.fluid_groups = OrderedDict()
        self._step_counter = 0

    def _update(self):
        fluid_source_position = self.get_link_position()
        if fluid_source_position is None or not self._simulator.is_playing():
            # Terminate early, this is a "dead" fluid source or we're not stepping physics
            return

        # Synchronize our tracked fluid groups with the fluid system -- some might have been deleted from a fluid sink
        self.fluid_groups = OrderedDict([(name, inst) for name, inst in self.fluid_groups.items()
                                         if name in self.fluid_system.particle_instancers])

        # Possibly increment our fluid generation counter if we're either (a) not using any toggle state (i.e.:
        # fluid source is always on), or (b) toggledon is True
        self._step_counter += int(self.obj.states[ToggledOn].get_value()) if ToggledOn in self.obj.states else 1

        # If our counter reaches our threshold, we generate a new fluid group
        if self._step_counter == self.n_steps_per_group:
            # Create positions to generate particles at
            positions = np.ones((self.n_particles_per_group, 3)) * fluid_source_position.reshape(1, 3)
            # Modify the z direction procedurally, to simulated a "falling" stream of fluid
            particle_dist = self.fluid_system.particle_contact_offset * 2
            positions[:, -1] -= np.arange(0, particle_dist * self.n_particles_per_group, particle_dist)
            # Generate a new group, and store it internally
            particle_instancer = self.fluid_system.generate_particle_instancer(
                n_particles=self.n_particles_per_group,
                positions=positions,
            )
            self.fluid_groups[particle_instancer.name] = particle_instancer

            # Reset the counter
            self._step_counter = 0

    def _set_value(self, new_value):
        raise ValueError("set_value not supported for FluidSource.")

    def _get_value(self):
        pass

    @staticmethod
    def get_optional_dependencies():
        return [ToggledOn]

    @staticmethod
    def get_dependencies():
        return []

fluid_system property

Returns:

Name Type Description
FluidSystem

Fluid system to use to generate / handle fluid particles

n_particles_per_group property

Returns:

Name Type Description
int

How many fluid particles to generate per fluid group

n_steps_per_group property

Returns:

Name Type Description
int

How many update() steps to occur between fluid group generations