• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

Java HttpConnectionMetrics类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中org.apache.http.HttpConnectionMetrics的典型用法代码示例。如果您正苦于以下问题:Java HttpConnectionMetrics类的具体用法?Java HttpConnectionMetrics怎么用?Java HttpConnectionMetrics使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



HttpConnectionMetrics类属于org.apache.http包,在下文中一共展示了HttpConnectionMetrics类的16个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: releaseConnection

import org.apache.http.HttpConnectionMetrics; //导入依赖的package包/类
public final void releaseConnection(ManagedClientConnection paramManagedClientConnection, long paramLong, TimeUnit paramTimeUnit)
{
  HttpConnectionMetrics localHttpConnectionMetrics = paramManagedClientConnection.getMetrics();
  if (localHttpConnectionMetrics != null)
  {
    long l1 = localHttpConnectionMetrics.getReceivedBytesCount();
    ArrayList localArrayList1 = (ArrayList)jsm.b.get();
    int i = localArrayList1.size();
    if (i > 0)
    {
      jso localjso2 = (jso)localArrayList1.get(i - 1);
      localjso2.d = (l1 + localjso2.d);
    }
    long l2 = localHttpConnectionMetrics.getSentBytesCount();
    ArrayList localArrayList2 = (ArrayList)jsm.b.get();
    int j = localArrayList2.size();
    if (j > 0)
    {
      jso localjso1 = (jso)localArrayList2.get(j - 1);
      localjso1.e = (l2 + localjso1.e);
    }
  }
  super.releaseConnection(paramManagedClientConnection, paramLong, paramTimeUnit);
}
 
开发者ID:ChiangC,项目名称:FMTech,代码行数:25,代码来源:jsj.java


示例2: examine

import org.apache.http.HttpConnectionMetrics; //导入依赖的package包/类
public void examine(final HttpServerConnection connection) {
  if (null != connection &&
      log.isDebugEnabled() &&
      !connection.isOpen()) {
    log.debug("Connection [{}] closed. Capturing metrics.", connection);

    final HttpConnectionMetrics metrics = connection.getMetrics();

    final WeakReference<StringBuilder> sb = new WeakReference<StringBuilder>(new StringBuilder("{'connection_metrics':{'requests':'"));

    sb.get().append(metrics.getRequestCount()).append("','responses':'").append(metrics.getResponseCount())
        .append("', 'received_bytes':'").append(metrics.getReceivedBytesCount()).append("', 'sent_bytes':'").append(metrics.getSentBytesCount()).append("'}}");

    log.debug("[{}]", sb.get().toString());
  }
}
 
开发者ID:Sabadios,项目名称:Cherry,代码行数:17,代码来源:MetricsService.java


示例3: getConnection

import org.apache.http.HttpConnectionMetrics; //导入依赖的package包/类
public final ManagedClientConnection getConnection(long paramLong, TimeUnit paramTimeUnit)
{
  ManagedClientConnection localManagedClientConnection = this.a.getConnection(paramLong, paramTimeUnit);
  HttpConnectionMetrics localHttpConnectionMetrics = localManagedClientConnection.getMetrics();
  if (localHttpConnectionMetrics != null) {
    localHttpConnectionMetrics.reset();
  }
  return localManagedClientConnection;
}
 
开发者ID:ChiangC,项目名称:FMTech,代码行数:10,代码来源:jsk.java


示例4: sendRequests

import org.apache.http.HttpConnectionMetrics; //导入依赖的package包/类
public void sendRequests() throws IOException, HttpException {
    this.connection.flush();
    HttpConnectionMetrics localHttpConnectionMetrics = this.connection.getMetrics();
    while (localHttpConnectionMetrics.getResponseCount() < localHttpConnectionMetrics.getRequestCount()) {
        HttpResponse localHttpResponse = this.connection.receiveResponseHeader();
        if (!localHttpResponse.getStatusLine().getProtocolVersion().greaterEquals(HttpVersion.HTTP_1_1)) {
            this.callbacks.pipelineModeChanged(false);
            this.canPipeline = false;
        }
        Header[] arrayOfHeader1 = localHttpResponse.getHeaders("Connection");
        if (arrayOfHeader1 != null)
            for (Header localHeader : arrayOfHeader1) {
                if (!"close".equalsIgnoreCase(localHeader.getValue()))
                    continue;
                this.callbacks.pipelineModeChanged(false);
                this.canPipeline = false;
            }
        this.lastStatusCode = localHttpResponse.getStatusLine().getStatusCode();
        if (this.lastStatusCode != 200) {
            this.callbacks.serverError(this.lastStatusCode);
            closeConnection();
            return;
        }
        this.connection.receiveResponseEntity(localHttpResponse);
        localHttpResponse.getEntity().consumeContent();
        this.callbacks.requestSent();

        if (!this.canPipeline) {
            closeConnection();
            return;
        }
    }
}
 
开发者ID:ddinsight,项目名称:dd-collector,代码行数:34,代码来源:PipelinedRequester.java


示例5: process

import org.apache.http.HttpConnectionMetrics; //导入依赖的package包/类
@Override
public void process(HttpResponse response, HttpContext context)
        throws HttpException, IOException {
    HttpConnection conn = (HttpConnection) context.getAttribute(ExecutionContext.HTTP_CONNECTION);
    HttpConnectionMetrics metrics = conn.getMetrics();
    context.setAttribute(CONTEXT_METRICS, metrics);
}
 
开发者ID:botelhojp,项目名称:apache-jmeter-2.10,代码行数:8,代码来源:HTTPHC4Impl.java


示例6: getMetrics

import org.apache.http.HttpConnectionMetrics; //导入依赖的package包/类
public HttpConnectionMetrics getMetrics() {
    OperatedClientConnection conn = getWrappedConnection();
    assertValid(conn);
    return conn.getMetrics();
}
 
开发者ID:lamsfoundation,项目名称:lams,代码行数:6,代码来源:AbstractClientConnAdapter.java


示例7: getMetrics

import org.apache.http.HttpConnectionMetrics; //导入依赖的package包/类
public HttpConnectionMetrics getMetrics() {
    OperatedClientConnection conn = ensureConnection();
    return conn.getMetrics();
}
 
开发者ID:lamsfoundation,项目名称:lams,代码行数:5,代码来源:ManagedClientConnectionImpl.java


示例8: getMetrics

import org.apache.http.HttpConnectionMetrics; //导入依赖的package包/类
public HttpConnectionMetrics getMetrics() {
    return this.metrics;
}
 
开发者ID:lamsfoundation,项目名称:lams,代码行数:4,代码来源:AbstractHttpClientConnection.java


示例9: getMetrics

import org.apache.http.HttpConnectionMetrics; //导入依赖的package包/类
public HttpConnectionMetrics getMetrics() {
    return this.connMetrics;
}
 
开发者ID:xxonehjh,项目名称:remote-files-sync,代码行数:4,代码来源:BHttpConnectionBase.java


示例10: getMetrics

import org.apache.http.HttpConnectionMetrics; //导入依赖的package包/类
public HttpConnectionMetrics getMetrics() {
    return getValidConnection().getMetrics();
}
 
开发者ID:xxonehjh,项目名称:remote-files-sync,代码行数:4,代码来源:CPoolProxy.java


示例11: process

import org.apache.http.HttpConnectionMetrics; //导入依赖的package包/类
@Override
public void process(HttpResponse response, HttpContext context)
        throws HttpException, IOException {
    HttpConnectionMetrics metrics = ((HttpConnection) context.getAttribute(HttpCoreContext.HTTP_CONNECTION)).getMetrics();
    context.setAttribute(CONTEXT_METRICS, metrics);
}
 
开发者ID:johrstrom,项目名称:cloud-meter,代码行数:7,代码来源:HTTPHC4Impl.java


示例12: getMetrics

import org.apache.http.HttpConnectionMetrics; //导入依赖的package包/类
@Override
public HttpConnectionMetrics getMetrics() {
    return handler.getMetrics();
}
 
开发者ID:johrstrom,项目名称:cloud-meter,代码行数:5,代码来源:MeasuringConnectionManager.java


示例13: getMetrics

import org.apache.http.HttpConnectionMetrics; //导入依赖的package包/类
@Override
public HttpConnectionMetrics getMetrics() {
    final OperatedClientConnection conn = getWrappedConnection();
    assertValid(conn);
    return conn.getMetrics();
}
 
开发者ID:MyPureCloud,项目名称:purecloud-iot,代码行数:7,代码来源:AbstractClientConnAdapter.java


示例14: getMetrics

import org.apache.http.HttpConnectionMetrics; //导入依赖的package包/类
@Override
public HttpConnectionMetrics getMetrics() {
    final OperatedClientConnection conn = ensureConnection();
    return conn.getMetrics();
}
 
开发者ID:MyPureCloud,项目名称:purecloud-iot,代码行数:6,代码来源:ManagedClientConnectionImpl.java


示例15: getMetrics

import org.apache.http.HttpConnectionMetrics; //导入依赖的package包/类
@Override
public HttpConnectionMetrics getMetrics() {
    return getValidConnection().getMetrics();
}
 
开发者ID:MyPureCloud,项目名称:purecloud-iot,代码行数:5,代码来源:CPoolProxy.java


示例16: getMetrics

import org.apache.http.HttpConnectionMetrics; //导入依赖的package包/类
public HttpConnectionMetrics getMetrics() {
    return null;
}
 
开发者ID:wso2,项目名称:wso2-axis2,代码行数:4,代码来源:AxisHttpConnectionImpl.java



注:本文中的org.apache.http.HttpConnectionMetrics类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java ObjectMap类代码示例发布时间:2022-05-22
下一篇:
Java WordDelimiterFilterFactory类代码示例发布时间:2022-05-22
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap