Method invoke

src/main/java/bftsmart/tom/ServiceProxy.java:199–280

This method sends a request to the replicas, and returns the related reply. If the servers take more than invokeTimeout seconds the method returns null. This method is thread-safe. @param request Request to be sent @param reqType ORDERED_REQUEST/ORDERED_HASHED_REQUEST/UNORDERED_REQUEST/UNORDERED_HA

(byte[] request, TOMMessageType reqType)

	 * @return The reply from the replicas related to request
	 */
	public byte[] invoke(byte[] request, TOMMessageType reqType) {
		try {
			canSendLock.lock();

			requestHandler = createRequestHandler(reqType);

			TOMMessage requestMessage = requestHandler.createRequest(request);

			logger.debug("Sending request ({}) with seqId = {}", reqType, requestHandler.getSequenceId());
			TOMulticast(requestMessage);

			logger.debug("Expected number of matching replies: {}", requestHandler.getReplyQuorumSize());

			// This instruction blocks the thread, until a response is obtained.
			// The thread will be unblocked when the method replyReceived is invoked
			// by the client side communication system
			requestHandler.waitForResponse();

			if (requestHandler.isRequestTimeout()) {
				logger.info("###### TIMEOUT ({}s) OF REQUEST {} | seqId: {} | replies received: {} ######",
						invokeTimeout, reqType, requestHandler.getSequenceId(),
						requestHandler.getNumberReceivedReplies());
				if (reqType == TOMMessageType.UNORDERED_HASHED_REQUEST || reqType == TOMMessageType.UNORDERED_REQUEST) {
					return invoke(request, TOMMessageType.ORDERED_REQUEST);
				} else {
					return null;
				}
			}

			TOMMessage response = requestHandler.getResponse();
			logger.debug("Response extracted: " + response);

			if (response == null) {
				//the response can be null if n-f replies are received but there isn't
				//a replyQuorumSize of matching replies
				logger.debug("Received n-f replies and no response could be extracted.");

				if (reqType == TOMMessageType.UNORDERED_REQUEST || reqType == TOMMessageType.UNORDERED_HASHED_REQUEST) {
					//invoke the operation again, whitout the read-only flag
					logger.debug("###################RETRY#######################");
					return invokeOrdered(request);
				} else {
					requestHandler.printState();
					throw new RuntimeException("Received n-f replies without f+1 of them matching.");
				}
			} else {
				if (response.getViewID() == getViewManager().getCurrentViewId()) {// normal operation
					return response.getContent();
				} else if (response.getViewID() > getViewManager().getCurrentViewId()) {
					if (reqType == TOMMessageType.ORDERED_REQUEST) {
						reconfigureTo((View) TOMUtil.getObject(response.getContent()));
						return invokeOrdered(request);
					} else if (reqType == TOMMessageType.UNORDERED_REQUEST
							|| reqType == TOMMessageType.UNORDERED_HASHED_REQUEST) {
						// Ignore the response and request again because servers are in a later view
						return invokeOrdered(request);
					} else {// Reply to a reconfigure request!
						logger.debug("Reconfiguration request' reply received!");