本文整理汇总了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;未经允许,请勿转载。 |
请发表评论