Java源码示例:org.littleshoot.proxy.FlowContext
示例1
@Override
protected void bytesRead(int numberOfBytes) {
FlowContext flowContext = flowContext();
for (ActivityTracker tracker : proxyServer
.getActivityTrackers()) {
tracker.bytesReceivedFromClient(flowContext, numberOfBytes);
}
}
示例2
@Override
protected void requestRead(HttpRequest httpRequest) {
FlowContext flowContext = flowContext();
for (ActivityTracker tracker : proxyServer
.getActivityTrackers()) {
tracker.requestReceivedFromClient(flowContext, httpRequest);
}
}
示例3
@Override
protected void bytesWritten(int numberOfBytes) {
FlowContext flowContext = flowContext();
for (ActivityTracker tracker : proxyServer
.getActivityTrackers()) {
tracker.bytesSentToClient(flowContext, numberOfBytes);
}
}
示例4
@Override
protected void responseWritten(HttpResponse httpResponse) {
FlowContext flowContext = flowContext();
for (ActivityTracker tracker : proxyServer
.getActivityTrackers()) {
tracker.responseSentToClient(flowContext,
httpResponse);
}
}
示例5
private FlowContext flowContext() {
if (currentServerConnection != null) {
return new FullFlowContext(this, currentServerConnection);
} else {
return new FlowContext(this);
}
}
示例6
@Override
public void requestReceivedFromClient(FlowContext flowContext, HttpRequest httpRequest)
{
clientRequestsReceived.incrementAndGet();
}
示例7
public void requestReceivedFromClient(FlowContext flowContext,
HttpRequest httpRequest) {
if (httpRequest.getMethod() != HttpMethod.CONNECT) {
count.incrementAndGet();
}
}
示例8
public void requestReceivedFromClient(FlowContext flowContext,
HttpRequest httpRequest) {
if (httpRequest.getMethod() != HttpMethod.CONNECT) {
count.incrementAndGet();
}
}
示例9
public void requestReceivedFromClient(FlowContext flowContext,
HttpRequest httpRequest) {
count.incrementAndGet();
}
示例10
public void requestReceivedFromClient(FlowContext flowContext,
HttpRequest httpRequest) {
count.incrementAndGet();
}