void function ( ) { Set < Member > loc0 = this . getHazelcast ( ) . getCluster ( ) . getMembers ( ) ; Iterator < Member > loc1 = this . membersMap . values ( ) . iterator ( ) ; while ( loc1 . hasNext ( ) ) { if ( ! loc0 . contains ( loc1 . next ( ) ) ) { loc1 . remove ( ) ; } } }
this method checks and removes older non-existing nodes from the map . this can happen when there are multiple servers , for example a server which has ntask component and another server which just has hazelcast . when the server with ntask shutsdown , the other server still contain the queue , and that queue contain the member id of the earlier server which had ntask . so at startup , we have to check the queue and see if there are non-existing members by comparing it to the current list of active members . concode_field_sep Map<String,ClusterGroupCommunicator> communicatorMap concode_elem_sep String taskType concode_elem_sep Log log concode_elem_sep String CARBON_TASKS_MEMBER_ID_MAP concode_elem_sep HazelcastInstance hazelcast concode_elem_sep String TASK_SERVER_STARTUP_COUNTER concode_elem_sep int MISSING_TASKS_ON_ERROR_RETRY_COUNT concode_elem_sep TaskService taskService concode_elem_sep String TASK_SERVER_COUNT_SYS_PROP concode_elem_sep Map<String,Member> membersMap concode_elem_sep String NTASK_P2P_COMM_EXECUTOR concode_field_sep Map<String,Member> getMemberMap concode_elem_sep String getStartupCounterName concode_elem_sep List<String> getMemberIds concode_elem_sep Member getMemberFromId concode_elem_sep boolean isLeader concode_elem_sep void cleanupTaskCluster concode_elem_sep void memberRemoved concode_elem_sep void checkServers concode_elem_sep HazelcastInstance getHazelcast concode_elem_sep String getMemberId concode_elem_sep void memberAttributeChanged concode_elem_sep String getIdFromMember concode_elem_sep void refreshMembers concode_elem_sep V sendReceive concode_elem_sep void addMyselfToGroup concode_elem_sep void memberAdded concode_elem_sep void scheduleMissingTasksWithRetryOnError concode_elem_sep TaskService getTaskService concode_elem_sep ClusterGroupCommunicator getInstance concode_elem_sep String getTaskType concode_elem_sep void scheduleAllMissingTasks