Called by interceptor when an outgoing request is sent.
This updates the server association counts for this context.
775764
public synchronized void suspendAssociation(boolean notify) {
        final boolean traceOn = TraceComponent.isAnyTracingEnabled();

        if (traceOn && tc.isEntryEnabled())
            Tr.entry(tc, "suspendAssociation", notify);

        _suspendedAssociations++;

        if (notify)
            notifyAll();

        if (traceOn && tc.isEntryEnabled())
            Tr.exit(tc, "suspendAssociation");
    }
1332059
private void notifyListenersAfterRequest(ModbusRequest req) {
        synchronized (listeners) {
            for (AbstractSerialTransportListener listener : listeners) {
                listener.afterRequestRead(commPort, req);
            }
        }
    }
64988
public <T> void notifyObserversOfRequestSuccess(CachedSpiceRequest<T> request) {
        RequestProcessingContext requestProcessingContext = new RequestProcessingContext();
        requestProcessingContext.setExecutionThread(Thread.currentThread());
        post(new RequestSucceededNotifier<T>(request, spiceServiceListenerList, requestProcessingContext));
    }
1137251
@Override
    public void isLeader() {
        LOG.warn("Server instance with server id {} is elected as leader", serverId);
        serviceState.becomingActive();
        try {
            for (ActiveStateChangeHandler handler : activeStateChangeHandlers) {
                handler.instanceIsActive();
            }
            activeInstanceState.update(serverId);
            serviceState.setActive();
        } catch (Exception e) {
            LOG.error("Got exception while activating", e);
            notLeader();
            rejoinElection();
        }
    }
841938
public void notifyReceiveAllowed(boolean isAllowed, DestinationHandler destinationBeingModified)
  {
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) SibTr.entry(tc, "notifyReceiveAllowed", Boolean.valueOf(isAllowed));

    if (consumerPoint.destinationMatches(destinationBeingModified, consumerDispatcher))
    {
      consumerPoint.notifyReceiveAllowed(isAllowed);
    }
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) SibTr.exit(tc, "notifyReceiveAllowed");
  }
1086149
protected void notifyToHandlers(ApiZone zone, ApiBuddyImpl buddy) {
        for(ServerHandlerClass handler : handlers) {
            notifyToHandler(handler, zone, buddy);
        }
    }
261894
protected void afterSend(RpcInternalContext context, SofaRequest request) {
        currentRequests.decrementAndGet();
        int cost = context.getStopWatch().tick().read();
        context.setAttachment(RpcConstants.INTERNAL_KEY_REQ_SERIALIZE_TIME, cost);
        if (EventBus.isEnable(ClientAfterSendEvent.class)) {
            EventBus.post(new ClientAfterSendEvent(request));
        }
    }
874964
@Override
	public void filter(final ClientRequestContext requestContext) {
		if (!backend.isEmpty() && backend.getConfiguration().shouldProcessContext(OutgoingRequest)) {
			final Map<String, String> filtered = backend.getConfiguration().filterDeniedParams(backend.copyToMap(), OutgoingRequest);
			requestContext.getHeaders().putSingle(TraceeConstants.TPIC_HEADER, transportSerialization.render(filtered));
		}
	}
1093966
private void errorNewClientConnected(Exception exception)
    {
        Verbose.warning(Server.class, "addClient", "Error on adding client: ", exception.getMessage());
        if (clients.remove(Byte.valueOf(lastId)) != null)
        {
            clientsNumber--;
        }
    }
1009179
@Override
	public void interceptRequest(IHttpRequest theRequest) {
		for (Map.Entry<String, List<String>> header : additionalHttpHeaders.entrySet()) {
			for (String headerValue : header.getValue()) {
				if (headerValue != null) {
					theRequest.addHeader(header.getKey(), headerValue);
				}
			}
		}
	}
835637
public void requestSucceeded()
  {
    if (_tc.isEntryEnabled()) SibTr.entry(this, _tc, "requestSucceeded");
    //lohith liberty change
  //  _invoker.requestSucceeded();
    
    if (_tc.isEntryEnabled()) SibTr.exit(this, _tc, "requestSucceeded");
  }
1183533
private void updateNetwork(final NetworkContext context, final Handler<AsyncResult<Void>> doneHandler) {
    final CountingCompletionHandler<Void> complete = new CountingCompletionHandler<Void>(context.components().size());
    complete.setHandler(new Handler<AsyncResult<Void>>() {
      @Override
      public void handle(AsyncResult<Void> result) {
        if (result.failed()) {
          new DefaultFutureResult<Void>(result.cause()).setHandler(doneHandler);
        } else {
          new DefaultFutureResult<Void>((Void) null).setHandler(doneHandler);
        }
      }
    });
    updateComponents(context.components(), complete);
  }
1054140
@Override
	protected void notifyHandler(ServerHandlerClass handler) {
	    Object instance = handler.newInstance();
	    assignDataToHandler(handler, instance);
	    ReflectMethodUtil.invokeHandleMethod(handler.getHandleMethod(), 
                instance, context);
	}
580126
@Override
  public void doRfAccountingRequestEvent(ServerRfSession appSession, RfAccountingRequest acr)
      throws InternalException, IllegalDiameterStateException, RouteException, OverloadException {
    logger.info("Diameter Base RfSessionFactory :: doAccRequestEvent :: appSession[" + appSession + "], Request[" + acr + "]");
  }
608618
def apply(self, incoming):
        
        assert len(incoming) == self.size
        self.incoming = incoming
        outgoing = self.activation(self.incoming)
        assert len(outgoing) == self.size
        self.outgoing = outgoing
753784
@Override
  public void receivedSuccessMessage(Request request, Answer answer) {
    DiameterListener listener = findListener(request);

    if (listener != null) {
      listener.receivedSuccessMessage(request, answer);
    }
  }
317119
public void update(long aRequestCount, long aMaxTime, long aBytesReceived, long aBytesSent, long aProcessingTime, long aErrorCount) {
        requestCount.setValueAsLong(aRequestCount);
        maxTime.setValueAsLong(aMaxTime);
        bytesReceived.setValueAsLong(aBytesReceived);
        bytesSent.setValueAsLong(aBytesSent);
        processingTime.setValueAsLong(aProcessingTime);
        errorCount.setValueAsLong(aErrorCount);
    }