本文整理了Java中org.apache.zookeeper.server.ZooTrace.logRequest()
方法的一些代码示例,展示了ZooTrace.logRequest()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZooTrace.logRequest()
方法的具体详情如下:
包路径:org.apache.zookeeper.server.ZooTrace
类名称:ZooTrace
方法名:logRequest
暂无
代码示例来源:origin: apache/zookeeper
@Override
public void run() {
try {
while (true) {
Request request = submittedRequests.take();
long traceMask = ZooTrace.CLIENT_REQUEST_TRACE_MASK;
if (request.type == OpCode.ping) {
traceMask = ZooTrace.CLIENT_PING_TRACE_MASK;
}
if (LOG.isTraceEnabled()) {
ZooTrace.logRequest(LOG, traceMask, 'P', request, "");
}
if (Request.requestOfDeath == request) {
break;
}
pRequest(request);
}
} catch (RequestProcessorException e) {
if (e.getCause() instanceof XidRolloverException) {
LOG.info(e.getCause().getMessage());
}
handleException(this.getName(), e);
} catch (Exception e) {
handleException(this.getName(), e);
}
LOG.info("PrepRequestProcessor exited loop!");
}
代码示例来源:origin: org.apache.zookeeper/zookeeper
@Override
public void run() {
try {
while (true) {
Request request = submittedRequests.take();
long traceMask = ZooTrace.CLIENT_REQUEST_TRACE_MASK;
if (request.type == OpCode.ping) {
traceMask = ZooTrace.CLIENT_PING_TRACE_MASK;
}
if (LOG.isTraceEnabled()) {
ZooTrace.logRequest(LOG, traceMask, 'P', request, "");
}
if (Request.requestOfDeath == request) {
break;
}
pRequest(request);
}
} catch (RequestProcessorException e) {
if (e.getCause() instanceof XidRolloverException) {
LOG.info(e.getCause().getMessage());
}
handleException(this.getName(), e);
} catch (Exception e) {
handleException(this.getName(), e);
}
LOG.info("PrepRequestProcessor exited loop!");
}
代码示例来源:origin: apache/zookeeper
ZooTrace.logRequest(LOG, traceMask, 'R', request, "");
代码示例来源:origin: org.apache.zookeeper/zookeeper
Request request = queuedRequests.take();
if (LOG.isTraceEnabled()) {
ZooTrace.logRequest(LOG, ZooTrace.CLIENT_REQUEST_TRACE_MASK,
'F', request, "");
代码示例来源:origin: org.apache.zookeeper/zookeeper
Request request = queuedRequests.take();
if (LOG.isTraceEnabled()) {
ZooTrace.logRequest(LOG, ZooTrace.CLIENT_REQUEST_TRACE_MASK,
'F', request, "");
代码示例来源:origin: apache/zookeeper
Request request = queuedRequests.take();
if (LOG.isTraceEnabled()) {
ZooTrace.logRequest(LOG, ZooTrace.CLIENT_REQUEST_TRACE_MASK,
'F', request, "");
代码示例来源:origin: apache/zookeeper
Request request = queuedRequests.take();
if (LOG.isTraceEnabled()) {
ZooTrace.logRequest(LOG, ZooTrace.CLIENT_REQUEST_TRACE_MASK,
'F', request, "");
代码示例来源:origin: org.apache.zookeeper/zookeeper
ZooTrace.logRequest(LOG, traceMask, 'R', request, "");
代码示例来源:origin: apache/zookeeper
ZooTrace.logRequest(LOG, traceMask, 'E', request, "");
代码示例来源:origin: org.apache.zookeeper/zookeeper
ZooTrace.logRequest(LOG, traceMask, 'E', request, "");
代码示例来源:origin: org.apache.hadoop/zookeeper
@Override
public void run() {
try {
while (true) {
Request request = submittedRequests.take();
long traceMask = ZooTrace.CLIENT_REQUEST_TRACE_MASK;
if (request.type == OpCode.ping) {
traceMask = ZooTrace.CLIENT_PING_TRACE_MASK;
}
if (LOG.isTraceEnabled()) {
ZooTrace.logRequest(LOG, traceMask, 'P', request, "");
}
if (Request.requestOfDeath == request) {
break;
}
pRequest(request);
}
} catch (InterruptedException e) {
LOG.error("Unexpected interruption", e);
}
LOG.info("PrepRequestProcessor exited loop!");
}
代码示例来源:origin: org.apache.hadoop/zookeeper
Request request = queuedRequests.take();
if (LOG.isTraceEnabled()) {
ZooTrace.logRequest(LOG, ZooTrace.CLIENT_REQUEST_TRACE_MASK,
'F', request, "");
代码示例来源:origin: org.apache.hadoop/zookeeper
Request request = queuedRequests.take();
if (LOG.isTraceEnabled()) {
ZooTrace.logRequest(LOG, ZooTrace.CLIENT_REQUEST_TRACE_MASK,
'F', request, "");
代码示例来源:origin: org.apache.hadoop/zookeeper
ZooTrace.logRequest(LOG, traceMask, 'E', request, "");
内容来源于网络,如有侵权,请联系作者删除!