Set the Foreign Bus Level sendAllowed flag

@param sendAllowed
188391
public void setForeignBusSendAllowed(boolean sendAllowed)
  {
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
    {
      SibTr.entry(tc, "setForeignBusSendAllowed", Boolean.valueOf(sendAllowed));
    }
    
    // Set the flag on this handler
    _sendAllowedOnTargetForeignBus = Boolean.valueOf(sendAllowed);
    
    // Tell any destinations that target this destination to refresh their
    // sendAllowed setting
    if (aliasesThatTargetThisDest != null)
    {
      synchronized(aliasesThatTargetThisDest)
      {
        Iterator i = aliasesThatTargetThisDest.iterator();
        while (i.hasNext())
        {
          AbstractAliasDestinationHandler abstractAliasDestinationHandler = 
            (AbstractAliasDestinationHandler) i.next();
          abstractAliasDestinationHandler.setForeignBusSendAllowed(sendAllowed);
        }
      }
    }    
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
    {
      SibTr.exit(tc, "setForeignBusSendAllowed");
    }
  }
658019
private boolean checkReceiveAllowed() throws SISessionUnavailableException, SIResourceException
    {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(tc, "checkReceiveAllowed");

        boolean allowed = _destinationAttachedTo.isReceiveAllowed();

        if (!allowed)
        {
            // Register that LCP stopped for Receive Allowed
            _stoppedForReceiveAllowed = true;

            // Stop LCP for Receive Allowed
            if (!_stopped)
            {
                internalStop();
            }
        }
        else
        {
            // Register that LCP not stopped for Receive Allowed
            _stoppedForReceiveAllowed = false;

            // Start LCP if no reason to be stopped
            if ((_stopped)
                && (!_stoppedByRequest))
            {
                internalStart(false);
            }
        }

        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(tc, "checkReceiveAllowed", Boolean.valueOf(allowed));

        return allowed;
    }
406307
public void setImport(long now, SimpleOrderedMap<Object> status)
      throws IOException {
    if (action.equals(ComponentCollection.ACTION_IMPORT)) {
      this.now = now;
      this.status = status;
    } else {
      throw new IOException("not allowed with action '" + action + "'");
    }
  }
298779
func (s *AuthResult) SetAllowed(v *Allowed) *AuthResult {
	s.Allowed = v
	return s
}
766502
@GuardedBy("lock") protected void sendBundledMessages() {
        for(Map.Entry<Address,List<Message>> entry: msgs.entrySet()) {
            List<Message> list=entry.getValue();
            if(list.isEmpty())
                continue;

            output.position(0);
            if(list.size() == 1)
                sendSingleMessage(list.get(0));
            else {
                Address dst=entry.getKey();
                sendMessageList(dst, list.get(0).getSrc(), list);
                if(transport.statsEnabled())
                    transport.incrBatchesSent(1);
            }
        }
        clearMessages();
        count=0;
    }
505139
public void setExistingAllowedPrefixesToDirectConnectGateway(java.util.Collection<RouteFilterPrefix> existingAllowedPrefixesToDirectConnectGateway) {
        if (existingAllowedPrefixesToDirectConnectGateway == null) {
            this.existingAllowedPrefixesToDirectConnectGateway = null;
            return;
        }

        this.existingAllowedPrefixesToDirectConnectGateway = new com.amazonaws.internal.SdkInternalList<RouteFilterPrefix>(
                existingAllowedPrefixesToDirectConnectGateway);
    }
220254
public final void setGuaranteedCrossBusSourceBusUUID(SIBUuid8 value) {
    if (value != null)
      jmo.setField(ControlAccess.GUARANTEEDXBUS_SET_SOURCEBUSUUID, value.toByteArray());
    else
      jmo.setField(ControlAccess.GUARANTEEDXBUS_SET_SOURCEBUSUUID, null);
  }
1069883
public void setSendAllowed(boolean newIsSendAllowedValue)
    {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(tc, "setSendAllowed", new Boolean(newIsSendAllowedValue));

        this._isSendAllowed = newIsSendAllowedValue;
        updatePutRegistration(_isSendAllowed);

        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(tc, "setSendAllowed");
    }
1235898
@Override
    public void setIsolationLevel(IsolationLevel level) throws IllegalStateException {
        if(level != IsolationLevels.SNAPSHOT){
            throw new IllegalStateException("Only IsolationLevels.SNAPSHOT level supported.");
        }else{
            super.setIsolationLevel(level);
        }
    }
671007
public void setOverrideAllowedPrefixesToDirectConnectGateway(java.util.Collection<RouteFilterPrefix> overrideAllowedPrefixesToDirectConnectGateway) {
        if (overrideAllowedPrefixesToDirectConnectGateway == null) {
            this.overrideAllowedPrefixesToDirectConnectGateway = null;
            return;
        }

        this.overrideAllowedPrefixesToDirectConnectGateway = new com.amazonaws.internal.SdkInternalList<RouteFilterPrefix>(
                overrideAllowedPrefixesToDirectConnectGateway);
    }
1009683
public void setSendAllowed(boolean newSendAllowedValue )
  {
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) 
      SibTr.entry(tc, "setSendAllowed", new Boolean(newSendAllowedValue));
    
    itemStream.setSendAllowed( newSendAllowedValue );
    
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) 
      SibTr.entry(tc, "setSendAllowed", new Boolean(newSendAllowedValue));
  }
920189
private synchronized ReceiveAllowedThread getReceiveAllowedThread(DestinationHandler destinationHandler)
    {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(tc, "getReceiveAllowedThread", destinationHandler);

        if (_receiveAllowedThread == null)
        {
            _receiveAllowedThread = new ReceiveAllowedThread(destinationHandler);
            if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
                SibTr.exit(tc, "getReceiveAllowedThread", _receiveAllowedThread);

            return _receiveAllowedThread;
        }

        _receiveAllowedThread.markForUpdate();
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(tc, "getReceiveAllowedThread", null);
        return null;
    }
695651
@Override
    public final void setReportPassMsgId(Boolean value) {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(this, tc, "setReportPassMsgId", value);
        if (value != null) {
            getApi().setField(JsApiAccess.REPORTPASSMSGID_VALUE, value);
        }
        else {
            getApi().setChoiceField(JsApiAccess.REPORTPASSMSGID, JsApiAccess.IS_REPORTPASSMSGID_UNSET);
        }
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(this, tc, "setReportPassMsgId");
    }
594180
private synchronized void setReceiveAllowed(DestinationAliasDefinition aliasDefinition)
    {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(tc, "setReceiveAllowed", aliasDefinition);

        ExtendedBoolean aliasIsReceiveAllowed = aliasDefinition.isReceiveAllowed();
        // A reliability of NONE signals use target value.
        if (aliasIsReceiveAllowed.equals(ExtendedBoolean.NONE))
            _isReceiveAllowed = getTarget().isReceiveAllowed();
        else if (aliasIsReceiveAllowed.equals(ExtendedBoolean.FALSE))
            _isReceiveAllowed = false;
        else
            _isReceiveAllowed = true;

        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(tc, "setReceiveAllowed", Boolean.valueOf(_isReceiveAllowed));
    }
119139
private void send(final TunnelingFeature tunnelingFeature)
		throws KNXConnectionClosedException, KNXAckTimeoutException, InterruptedException {
		if (layer == TunnelingLayer.BusMonitorLayer)
			throw new IllegalStateException("send not permitted in busmonitor mode");
		if (state < 0)
			throw new IllegalStateException("in error state, send aborted");
		if (state == CLOSED)
			throw new KNXConnectionClosedException("send attempt on closed connection");

//		sendWaitQueue.acquire(true);
		final byte[] buf = PacketHelper.toPacket(tunnelingFeature);
		try {
			int attempt = 0;
			for (; attempt < maxSendAttempts; ++attempt) {
				logger.trace("sending {}, attempt {}", tunnelingFeature, attempt + 1);
				updateState = false;

				send(buf, dataEndpt);
				internalState = ACK_PENDING;
				// always forward this state to user
				state = ACK_PENDING;
				waitForStateChange(ACK_PENDING, responseTimeout);
				if (internalState == ClientConnection.CEMI_CON_PENDING || internalState == OK)
					break;
			}
			if (attempt == maxSendAttempts) {
				final KNXAckTimeoutException e = new KNXAckTimeoutException("maximum send attempts, no service acknowledgment received");
				close(CloseEvent.INTERNAL, "maximum send attempts", LogLevel.ERROR, e);
				throw e;
			}
		}
		catch (final InterruptedIOException e) {
			throw new InterruptedException("interrupted I/O, " + e);
		}
		catch (final IOException e) {
			close(CloseEvent.INTERNAL, "communication failure", LogLevel.ERROR, e);
			throw new KNXConnectionClosedException("connection closed");
		}
		finally {
			updateState = true;
			setState(OK);
		}
	}
480655
@Override
    public synchronized void setCorrupt(boolean newCorrupt)
    {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(tc, "setCorrupt", Boolean.valueOf(newCorrupt));

        boolean oldCorrupt = _isCorruptOrIndoubt;
        _isCorruptOrIndoubt = newCorrupt;

        // PK54812 We need to pass this through to the destination manager to
        // actually change the state of the destination.
        if (newCorrupt && !oldCorrupt)
        {
            destinationManager.corruptDestination(this);

            // Log a message with details of the destination that is corrupt
            SibTr.info(tc_cwsik, "DELIVERY_ERROR_SIRC_27",
                       new Object[] { getName() + " " + getUuid().toString() });
        }

        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(tc, "setCorrupt");
    }
1039194
@Override
    public void notifyReceiveAllowedRCD(DestinationHandler destinationHandler)
    {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(tc, "notifyReceiveAllowedRCD", new Object[] { destinationHandler });

        _targetDestinationHandler.notifyReceiveAllowedRCD(destinationHandler);

        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(tc, "notifyReceiveAllowedRCD");
    }