本文整理了Java中org.apache.zookeeper.server.ZooTrace.logTraceMessage()方法的一些代码示例，展示了ZooTrace.logTraceMessage()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ZooTrace.logTraceMessage()方法的具体详情如下：
包路径：org.apache.zookeeper.server.ZooTrace
类名称：ZooTrace
方法名：logTraceMessage

ZooTrace.logTraceMessage介绍

暂无

代码示例

代码示例来源：origin: apache/zookeeper

private void logTraceTouchSession(long sessionId, int timeout, String sessionStatus){
  if (!LOG.isTraceEnabled())
    return;
  String msg = MessageFormat.format(
      "SessionTrackerImpl --- Touch {0}session: 0x{1} with timeout {2}",
      sessionStatus, Long.toHexString(sessionId), Integer.toString(timeout));
  ZooTrace.logTraceMessage(LOG, ZooTrace.CLIENT_PING_TRACE_MASK, msg);
}

代码示例来源：origin: apache/zookeeper

public void shutdown() {
  LOG.info("Shutting down");
  running = false;
  if (LOG.isTraceEnabled()) {
    ZooTrace.logTraceMessage(LOG, ZooTrace.getTextTraceLevel(),
                 "Shutdown SessionTrackerImpl!");
  }
}

代码示例来源：origin: apache/zookeeper

synchronized public void removeSession(long sessionId) {
  LOG.debug("Removing session 0x" + Long.toHexString(sessionId));
  SessionImpl s = sessionsById.remove(sessionId);
  sessionsWithTimeout.remove(sessionId);
  if (LOG.isTraceEnabled()) {
    ZooTrace.logTraceMessage(LOG, ZooTrace.SESSION_TRACE_MASK,
        "SessionTrackerImpl --- Removing session 0x"
        + Long.toHexString(sessionId));
  }
  if (s != null) {
    sessionExpiryQueue.remove(s);
  }
}

代码示例来源：origin: apache/zookeeper

protected void killSession(long sessionId, long zxid) {
  zkDb.killSession(sessionId, zxid);
  if (LOG.isTraceEnabled()) {
    ZooTrace.logTraceMessage(LOG, ZooTrace.SESSION_TRACE_MASK,
                   "ZooKeeperServer --- killSession: 0x"
        + Long.toHexString(sessionId));
  }
  if (sessionTracker != null) {
    sessionTracker.removeSession(sessionId);
  }
}

代码示例来源：origin: apache/zookeeper

protected void revalidateSession(ServerCnxn cnxn, long sessionId,
    int sessionTimeout) throws IOException {
  boolean rc = sessionTracker.touchSession(sessionId, sessionTimeout);
  if (LOG.isTraceEnabled()) {
    ZooTrace.logTraceMessage(LOG, ZooTrace.SESSION_TRACE_MASK,
        "Session 0x" + Long.toHexString(sessionId) +
            " is valid: " + rc);
  }
  finishSessionInit(cnxn, rc);
}

代码示例来源：origin: org.apache.zookeeper/zookeeper

public void shutdown() {
  LOG.info("Shutting down");
  running = false;
  if (LOG.isTraceEnabled()) {
    ZooTrace.logTraceMessage(LOG, ZooTrace.getTextTraceLevel(),
                 "Shutdown SessionTrackerImpl!");
  }
}

代码示例来源：origin: org.apache.zookeeper/zookeeper

synchronized public void removeSession(long sessionId) {
  SessionImpl s = sessionsById.remove(sessionId);
  sessionsWithTimeout.remove(sessionId);
  if (LOG.isTraceEnabled()) {
    ZooTrace.logTraceMessage(LOG, ZooTrace.SESSION_TRACE_MASK,
        "SessionTrackerImpl --- Removing session 0x"
        + Long.toHexString(sessionId));
  }
  if (s != null) {
    SessionSet set = sessionSets.get(s.tickTime);
    // Session expiration has been removing the sessions   
    if(set != null){
      set.sessions.remove(s);
    }
  }
}

代码示例来源：origin: apache/zookeeper

protected void revalidate(QuorumPacket qp) throws IOException {
  ByteArrayInputStream bis = new ByteArrayInputStream(qp
      .getData());
  DataInputStream dis = new DataInputStream(bis);
  long sessionId = dis.readLong();
  boolean valid = dis.readBoolean();
  ServerCnxn cnxn = pendingRevalidations.remove(sessionId);
  if (cnxn == null) {
    LOG.warn("Missing session 0x"
        + Long.toHexString(sessionId)
        + " for validation");
  } else {
    zk.finishSessionInit(cnxn, valid);
  }
  if (LOG.isTraceEnabled()) {
    ZooTrace.logTraceMessage(LOG,
        ZooTrace.SESSION_TRACE_MASK,
        "Session 0x" + Long.toHexString(sessionId)
        + " is valid: " + valid);
  }
}

代码示例来源：origin: apache/zookeeper

static public void logQuorumPacket(Logger log, long mask,
    char direction, QuorumPacket qp)
{
  if (isTraceEnabled(log, mask)) { 
    logTraceMessage(log, mask, direction +
        " " + LearnerHandler.packetToString(qp));
   }
}

代码示例来源：origin: apache/zookeeper

@Override
public synchronized boolean trackSession(long id, int sessionTimeout) {
  boolean added = false;
  SessionImpl session = sessionsById.get(id);
  if (session == null){
    session = new SessionImpl(id, sessionTimeout);
  }
  // findbugs2.0.3 complains about get after put.
  // long term strategy would be use computeIfAbsent after JDK 1.8
  SessionImpl existedSession = sessionsById.putIfAbsent(id, session);
  if (existedSession != null) {
    session = existedSession;
  } else {
    added = true;
    LOG.debug("Adding session 0x" + Long.toHexString(id));
  }
  if (LOG.isTraceEnabled()) {
    String actionStr = added ? "Adding" : "Existing";
    ZooTrace.logTraceMessage(LOG, ZooTrace.SESSION_TRACE_MASK,
        "SessionTrackerImpl --- " + actionStr + " session 0x"
        + Long.toHexString(id) + " " + sessionTimeout);
  }
  updateSessionExpiry(session, sessionTimeout);
  return added;
}

代码示例来源：origin: apache/zookeeper

/**
 * validate a session for a client
 *
 * @param clientId
 *                the client to be revalidated
 * @param timeout
 *                the timeout for which the session is valid
 * @return
 * @throws IOException
 */
void validateSession(ServerCnxn cnxn, long clientId, int timeout)
    throws IOException {
  LOG.info("Revalidating client: 0x" + Long.toHexString(clientId));
  ByteArrayOutputStream baos = new ByteArrayOutputStream();
  DataOutputStream dos = new DataOutputStream(baos);
  dos.writeLong(clientId);
  dos.writeInt(timeout);
  dos.close();
  QuorumPacket qp = new QuorumPacket(Leader.REVALIDATE, -1, baos
      .toByteArray(), null);
  pendingRevalidations.put(clientId, cnxn);
  if (LOG.isTraceEnabled()) {
    ZooTrace.logTraceMessage(LOG,
                 ZooTrace.SESSION_TRACE_MASK,
                 "To validate session 0x"
                 + Long.toHexString(clientId));
  }
  writePacket(qp, true);
}

代码示例来源：origin: apache/zookeeper

@Override
public void process(WatchedEvent event) {
  ReplyHeader h = new ReplyHeader(-1, -1L, 0);
  if (LOG.isTraceEnabled()) {
    ZooTrace.logTraceMessage(LOG, ZooTrace.EVENT_DELIVERY_TRACE_MASK,
                 "Deliver event " + event + " to 0x"
                 + Long.toHexString(this.sessionId)
                 + " through " + this);
  }
  // Convert WatchedEvent to a type that can be sent over the wire
  WatcherEvent e = event.getWrapper();
  sendResponse(h, e, "notification", null, null);
}

代码示例来源：origin: org.apache.zookeeper/zookeeper

protected void killSession(long sessionId, long zxid) {
  zkDb.killSession(sessionId, zxid);
  if (LOG.isTraceEnabled()) {
    ZooTrace.logTraceMessage(LOG, ZooTrace.SESSION_TRACE_MASK,
                   "ZooKeeperServer --- killSession: 0x"
        + Long.toHexString(sessionId));
  }
  if (sessionTracker != null) {
    sessionTracker.removeSession(sessionId);
  }
}

代码示例来源：origin: org.apache.zookeeper/zookeeper

protected void revalidateSession(ServerCnxn cnxn, long sessionId,
    int sessionTimeout) throws IOException {
  boolean rc = sessionTracker.touchSession(sessionId, sessionTimeout);
  if (LOG.isTraceEnabled()) {
    ZooTrace.logTraceMessage(LOG,ZooTrace.SESSION_TRACE_MASK,
                 "Session 0x" + Long.toHexString(sessionId) +
        " is valid: " + rc);
  }
  finishSessionInit(cnxn, rc);
}

代码示例来源：origin: apache/zookeeper

@Override
public void revalidateSession(QuorumPacket qp, LearnerHandler learnerHandler) throws IOException {
  ByteArrayInputStream bis = new ByteArrayInputStream(qp.getData());
  DataInputStream dis = new DataInputStream(bis);
  long id = dis.readLong();
  int to = dis.readInt();
  ByteArrayOutputStream bos = new ByteArrayOutputStream();
  DataOutputStream dos = new DataOutputStream(bos);
  dos.writeLong(id);
  boolean valid = zk.checkIfValidGlobalSession(id, to);
  if (valid) {
    try {
      // set the session owner as the follower that owns the session
      zk.setOwner(id, learnerHandler);
    } catch (KeeperException.SessionExpiredException e) {
      LOG.error("Somehow session " + Long.toHexString(id) + " expired right after being renewed! (impossible)", e);
    }
  }
  if (LOG.isTraceEnabled()) {
    ZooTrace.logTraceMessage(LOG,
        ZooTrace.SESSION_TRACE_MASK,
        "Session 0x" + Long.toHexString(id)
            + " is valid: "+ valid);
  }
  dos.writeBoolean(valid);
  qp.setData(bos.toByteArray());
  learnerHandler.queuePacket(qp);
}

代码示例来源：origin: org.apache.zookeeper/zookeeper

static public void logQuorumPacket(Logger log, long mask,
    char direction, QuorumPacket qp)
{
  if (isTraceEnabled(log, mask)) { 
    logTraceMessage(log, mask, direction +
        " " + LearnerHandler.packetToString(qp));
   }
}

代码示例来源：origin: apache/zookeeper

public static void deserializeSnapshot(DataTree dt,InputArchive ia,
    Map<Long, Integer> sessions) throws IOException {
  int count = ia.readInt("count");
  while (count > 0) {
    long id = ia.readLong("id");
    int to = ia.readInt("timeout");
    sessions.put(id, to);
    if (LOG.isTraceEnabled()) {
      ZooTrace.logTraceMessage(LOG, ZooTrace.SESSION_TRACE_MASK,
          "loadData --- session in archive: " + id
          + " with timeout: " + to);
    }
    count--;
  }
  dt.deserialize(ia, "tree");
}

代码示例来源：origin: org.apache.zookeeper/zookeeper

@Override
synchronized public void process(WatchedEvent event) {
  ReplyHeader h = new ReplyHeader(-1, -1L, 0);
  if (LOG.isTraceEnabled()) {
    ZooTrace.logTraceMessage(LOG, ZooTrace.EVENT_DELIVERY_TRACE_MASK,
                 "Deliver event " + event + " to 0x"
                 + Long.toHexString(this.sessionId)
                 + " through " + this);
  }
  // Convert WatchedEvent to a type that can be sent over the wire
  WatcherEvent e = event.getWrapper();
  sendResponse(h, e, "notification");
}

代码示例来源：origin: apache/zookeeper

@Override
public void process(WatchedEvent event) {
  ReplyHeader h = new ReplyHeader(-1, -1L, 0);
  if (LOG.isTraceEnabled()) {
    ZooTrace.logTraceMessage(LOG, ZooTrace.EVENT_DELIVERY_TRACE_MASK,
                 "Deliver event " + event + " to 0x"
                 + Long.toHexString(this.sessionId)
                 + " through " + this);
  }
  // Convert WatchedEvent to a type that can be sent over the wire
  WatcherEvent e = event.getWrapper();
  try {
    sendResponse(h, e, "notification");
  } catch (IOException e1) {
    if (LOG.isDebugEnabled()) {
      LOG.debug("Problem sending to " + getRemoteSocketAddress(), e1);
    }
    close();
  }
}

代码示例来源：origin: apache/zookeeper

if (watchers == null || watchers.isEmpty()) {
  if (LOG.isTraceEnabled()) {
    ZooTrace.logTraceMessage(LOG,
        ZooTrace.EVENT_DELIVERY_TRACE_MASK,
        "No watchers for " + path);