<BUG>conn = getConnection();boolean authorized = node.clusterManager.checkAuthorization(groupName, password, conn.getEndPoint());</BUG><CONTEXT>Connection conn = null;while (running) {try {RecordUpdate ru = (failureQ.size() > 0) ? failureQ.removeFirst() : q.take();if (conn == null) {<extra_id_0>if (!authorized) {conn.close();conn = null;</CONTEXT>
if (conn != null) {boolean authorized = node.clusterManager.checkAuthorization(groupName, password, conn.getEndPoint());