Method receiveMessage

simulator/src/main/java/simblock/node/Node.java:391–443

Receive message. @param message the message

(AbstractMessageTask message)

   * @param message the message
   */
  public void receiveMessage(AbstractMessageTask message) {
    Node from = message.getFrom();

    if (message instanceof InvMessageTask) {
      Block block = ((InvMessageTask) message).getBlock();
      if (!this.orphans.contains(block) && !this.downloadingBlocks.contains(block)) {
        if (this.consensusAlgo.isReceivedBlockValid(block, this.block)) {
          AbstractMessageTask task = new RecMessageTask(this, from, block);
          putTask(task);
          downloadingBlocks.add(block);
        } else if (!block.isOnSameChainAs(this.block)) {
          // get new orphan block
          AbstractMessageTask task = new RecMessageTask(this, from, block);
          putTask(task);
          downloadingBlocks.add(block);
        }
      }
    }

    if (message instanceof RecMessageTask) {
      this.messageQue.add((RecMessageTask) message);
      if (!sendingBlock) {
        this.sendNextBlockMessage();
      }
    }

    if(message instanceof GetBlockTxnMessageTask){
			this.messageQue.add((GetBlockTxnMessageTask) message);
			if(!sendingBlock){
				this.sendNextBlockMessage();
			}
		}

    if(message instanceof CmpctBlockMessageTask){
			Block block = ((CmpctBlockMessageTask) message).getBlock();
      Random random = new Random();
      float CBRfailureRate = this.isChurnNode ? CBR_FAILURE_RATE_FOR_CHURN_NODE : CBR_FAILURE_RATE_FOR_CONTROL_NODE;
			boolean success = random.nextDouble() > CBRfailureRate ? true : false;
			if(success){
				downloadingBlocks.remove(block);
				this.receiveBlock(block);
			}else{
				AbstractMessageTask task = new GetBlockTxnMessageTask(this, from, block);
				putTask(task);
			}
		}

    if (message instanceof BlockMessageTask) {
      Block block = ((BlockMessageTask) message).getBlock();
      downloadingBlocks.remove(block);
      this.receiveBlock(block);
    }
  }


  /**