[HAMA-776] localQueue is set as Send queue in init function of AbstractMessageManager

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.6.2
• Fix Version/s: 0.6.3
• Component/s: bsp core
• Assignee: MaoYuan Xian
• Reporter: MaoYuan Xian
• Created: 05/Jul/13 13:34
• Updated: 13/Jul/13 23:07
• Resolved: 13/Jul/13 04:35

Description

In init method of AbstractMessageManager, the following codes found:

  public void init(TaskAttemptID attemptId, BSPPeer<?, ?, ?, ?, M> peer,
      Configuration conf, InetSocketAddress peerAddress) {
    ...
    this.peerAddress = peerAddress;
    this.localQueue = getSenderQueue();
    this.localQueueForNextIteration = getSynchronizedReceiverQueue();
    this.maxCachedConnections = conf.getInt(MAX_CACHED_CONNECTIONS_KEY, 100);
  }

The localQueue should be a receiveQueue but it is assigned here, should it be changed as following?:

 this.localQueue = getSynchronizedReceiverQueue();

Is there any special purpose here when set it as senderQueue?