The Flow properties on a ConsumerSet may be reset dynamically. This
method supports the resetting of cursors and filters.
336092
private void resetFlowProperties() 
  {
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
      SibTr.entry(tc, "resetFlowProperties");
 
    // Tidy up what we had before
    int numFilters = consumerKeyFilter.length;    
    for(int i=0;i<numFilters;i++)
    {
      // Discard the cursor
      consumerKeyFilter[i].discard();
    }    
    
    // Recreate the filters and cursors
    try
    {
      ItemStream itemStream = ((ConsumerDispatcher)consumerDispatcher).getItemStream();
      createNewFiltersAndCursors(itemStream);
    } 
    catch (Exception ex)
    {
      // TODO Appropriate messaging?
      // FFDC
      FFDCFilter.processException(
          ex,
        "com.ibm.ws.sib.processor.impl.LocalQPConsumerKey.resetFlowProperties",
        "1:1101:1.23",
        this);

      SIErrorException finalE =
        new SIErrorException(
          nls.getFormattedMessage(
            "INTERNAL_MESSAGING_ERROR_CWSIP0002",
            new Object[] { "com.ibm.ws.sib.processor.impl.LocalQPConsumerKey", "1:1108:1.23", ex },
            null),
            ex);

      SibTr.exception(tc, finalE);
      SibTr.error(tc, "INTERNAL_MESSAGING_ERROR_CWSIP0002",
        new Object[] { "com.ibm.ws.sib.processor.impl.LocalQPConsumerKey", "1:1114:1.23", SIMPUtils.getStackTrace(ex) });

      if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
        SibTr.exit(tc, "resetFlowProperties", finalE);

      throw finalE;        
    }
  
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
      SibTr.exit(tc, "resetFlowProperties"); 
  }
1307774
private final void reset() {
	backtrackStack.clear();
	actionStack.clear();
	stateStack.clear();
	parserErrors.clear();
	streamPosition = 0;
	stepCounter = 0;
	stateStack.push(0);
	maxPosition = 0;
	shiftIgnoredTokens();
    }
737826
@Override
    public void reset()
    {
        if (null != m_startPoints)
        {
            final IControlHandleList handles = m_connector.getPointHandles();

            final Point2DArray points = m_connector.getLine().getPoint2DArray();

            for (int i = 0, j = 0; i < handles.size(); i++, j += 2)
            {
                final double px = m_startPoints.get(j);

                final double py = m_startPoints.get(j + 1);

                final IControlHandle h = handles.getHandle(i);

                final IPrimitive<?> prim = h.getControl();

                prim.setX(px);

                prim.setY(py);

                final Point2D point = points.get(i);

                point.setX(px);

                point.setY(py);
            }
        }
        m_connector.getLine().refresh();

        m_wiresManager.getLayer().getLayer().batch();
    }
351639
void setFilters(Map<Object, Object> filters) {

        for (Object column : filters.keySet()) {
            Object filterValue = filters.get(column);
            if ((filterValue != null) && !filterValue.toString().isEmpty() && !m_table.isColumnCollapsed(column)) {
                m_table.setFilterFieldValue(column, filterValue);
            }
        }
    }
90256
@Override
	public final void setConsumer(StreamConsumer<T> consumer) {
		checkNotNull(consumer);
		checkState(this.consumer == null, "Consumer has already been set");

		checkState(getCapabilities().contains(LATE_BINDING) || eventloop.tick() == createTick,
				LATE_BINDING_ERROR_MESSAGE, this);
		this.consumer = consumer;
		onWired();
		consumer.getAcknowledgement()
				.whenException(this::close)
				.whenComplete(acknowledgement);
	}
494095
public void reinitializeClientDefaultSSLProperties() {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            Tr.entry(tc, "reinitializeClientDefaultSSLProperties");

        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            Tr.exit(tc, "reinitializeClientDefaultSSLProperties");
    }
1153180
@Override
    public void setConsumer(IDataSetConsumer consumer) {
        logger.debug("setConsumer(consumer) - start");

        if (this._columnSensing) {
            _consumer = new BufferedConsumer(consumer);
        } else {
            _consumer = consumer;
        }
    }
1035684
private function resetDynamicSettings()
    {
        // Ensure to reset services that need to be.
        foreach ($this->resettableServiceIds as $serviceId) {
            if (!$this->container->initialized($serviceId)) {
                continue;
            }

            $this->container->set($serviceId, null);
        }

        // Update services that can be updated.
        foreach ($this->updatableServices as $serviceId => $methodCalls) {
            if (!$this->container->initialized($serviceId)) {
                continue;
            }

            $service = $this->container->get($serviceId);
            foreach ($methodCalls as $callConfig) {
                list($method, $expression) = $callConfig;
                $argument = $this->expressionLanguage->evaluate($expression, ['container' => $this->container]);
                call_user_func_array([$service, $method], [$argument]);
            }
        }
    }
1123198
def reset(self):
    

    # Reset Union Temporal Pooler fields
    self._poolingActivation = numpy.zeros(self.getNumColumns(), dtype=REAL_DTYPE)
    self._unionSDR = numpy.array([], dtype=UINT_DTYPE)
    self._poolingTimer = numpy.ones(self.getNumColumns(), dtype=REAL_DTYPE) * 1000
    self._poolingActivationInitLevel = numpy.zeros(self.getNumColumns(), dtype=REAL_DTYPE)
    self._preActiveInput = numpy.zeros(self.getNumInputs(), dtype=REAL_DTYPE)
    self._prePredictedActiveInput = numpy.zeros((self.getNumInputs(), self._historyLength), dtype=REAL_DTYPE)

    # Reset Spatial Pooler fields
    self.setOverlapDutyCycles(numpy.zeros(self.getNumColumns(), dtype=REAL_DTYPE))
    self.setActiveDutyCycles(numpy.zeros(self.getNumColumns(), dtype=REAL_DTYPE))
    self.setMinOverlapDutyCycles(numpy.zeros(self.getNumColumns(), dtype=REAL_DTYPE))
    self.setBoostFactors(numpy.ones(self.getNumColumns(), dtype=REAL_DTYPE))
591738
def reset( self ):
        
        self.setValue('colorSet', XPaletteColorSet())
        self.setValue('font',     QApplication.font())
        self.setValue('fontSize', QApplication.font().pointSize())
539569
public void clear() {

        if (m_originalItems != null) {
            m_originalItems.clear();
        }
        m_filteredItems = null;
        synchronized (this) {
            if (m_visibleItems != null) {
                m_visibleItems.clear();
            }
        }
        setSearchFilter("");
        m_sortedColumn = null;
    }
1058035
synchronized void reset() {

        schemaMap.clear();
        sqlLookup.clear();
        csidMap.clear();
        sessionUseMap.clear();
        useMap.clear();

        next_cs_id = 0;
    }
595865
public void reset() {
        setDisplayName(null);
        setAbbreviatedDisplayName(null);
        setDescription(null);
        setInverseIsA(ArrayUtils.EMPTY_STRING_ARRAY);
        setTermIds(ArrayUtils.EMPTY_STRING_ARRAY);
        setPropertyDefinitions(new PropertyDefinition[]{});
        setReferenceDefinitions(new ReferenceDefinition[]{});
        setInDataSource(false);
        setAccessed(null);
        setCreated(null);
        setUpdated(null);
    }
1185623
private void createNewFiltersAndCursors(ItemStream itemStream) 
    throws SIResourceException, MessageStoreException
  {
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
      SibTr.entry(tc, "createNewFiltersAndCursors", itemStream);
    
    LockingCursor cursor = null;
 
    // Instantiate a new array of Filters and associated cursors. If there is
    // no message classification, then we'll instantiate a single filter and 
    // cursor pair.
    if(classifyingMessages)
    {
      // Classifying messages for XD.
      // this work should be done under the classifications readlock acquired higher
      // up in the stack
      JSConsumerClassifications classifications = consumerSet.getClassifications();
      int numClasses = classifications.getNumberOfClasses();
      consumerKeyFilter = new LocalQPConsumerKeyFilter[numClasses+1];
      for(int i=0;i<numClasses+1;i++)
      {
        String classificationName = null;
        // The zeroth filter belongs to the default classification, which has a 
        // null classification name
        if(i > 0)
          classificationName = classifications.getClassification(i);
        consumerKeyFilter[i] = new LocalQPConsumerKeyFilter(this, i, classificationName);
        cursor = itemStream.newLockingItemCursor(consumerKeyFilter[i], !forwardScanning);
        consumerKeyFilter[i].setLockingCursor(cursor);
      }
    }
    else
    {
      // No message classification
      consumerKeyFilter = new LocalQPConsumerKeyFilter[1];
      consumerKeyFilter[0] = new LocalQPConsumerKeyFilter(this, 0, null);
      cursor = itemStream.newLockingItemCursor(consumerKeyFilter[0], !forwardScanning);
      consumerKeyFilter[0].setLockingCursor(cursor);
    }
    
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
      SibTr.exit(tc, "createNewFiltersAndCursors");
  }
157821
@Override
    public final void clearProperties() {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(this, tc, "clearProperties");

        if (mayHaveJmsUserProperties()) {
            getJmsUserPropertyMap().clear();
        }
        if (mayHaveMappedJmsSystemProperties()) {
            getJmsSystemPropertyMap().clear();
        }
        clearSmokeAndMirrorsProperties();
        if (hasMQMDPropertiesSet()) {
            getMQMDSetPropertiesMap().clear();
        }

        // Clear the super-classes cached lengths, but NOT anything pertaining to the payload
        super.clearCachedLengths();
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(this, tc, "clearProperties");
    }
1003197
private void processProperties() {
        state = true;
        try {
            exporterServiceFilter = getFilter(exporterServiceFilterProperty);
        } catch (InvalidFilterException invalidFilterException) {
            LOG.debug("The value of the Property " + FILTER_EXPORTERSERVICE_PROPERTY + " is invalid,"
                    + " the recuperation of the Filter has failed. The instance gonna stop.", invalidFilterException);
            state = false;
            return;
        }

        try {
            exportDeclarationFilter = getFilter(exportDeclarationFilterProperty);
        } catch (InvalidFilterException invalidFilterException) {
            LOG.debug("The value of the Property " + FILTER_EXPORTDECLARATION_PROPERTY + " is invalid,"
                    + " the recuperation of the Filter has failed. The instance gonna stop.", invalidFilterException);
            state = false;
            return;
        }
    }
710157
def reset(self):
        
        for ents in self.__entity_set_map.values():
            for ent in ents:
                EntityState.release(ent, self)
        self.__entity_set_map.clear()