1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19 package org.apache.giraph.comm.flow_control;
20
21 import org.apache.giraph.comm.netty.NettyClient;
22 import org.apache.giraph.comm.netty.handler.AckSignalFlag;
23 import org.apache.giraph.comm.requests.WritableRequest;
24
25
26
27
28
29 public class NoOpFlowControl implements FlowControl {
30
31 private final NettyClient nettyClient;
32
33
34
35
36
37
38 public NoOpFlowControl(NettyClient nettyClient) {
39 this.nettyClient = nettyClient;
40 }
41
42 @Override
43 public void sendRequest(int destTaskId, WritableRequest request) {
44 nettyClient.doSend(destTaskId, request);
45 }
46
47 @Override
48 public void messageAckReceived(int taskId, long requestId, int response) { }
49
50 @Override
51 public AckSignalFlag getAckSignalFlag(int response) {
52 return AckSignalFlag.values()[response];
53 }
54
55 @Override
56 public void waitAllRequests() { }
57
58 @Override
59 public int getNumberOfUnsentRequests() {
60 return 0;
61 }
62
63 @Override
64 public int calculateResponse(AckSignalFlag alreadyDone, int taskId) {
65 return alreadyDone.ordinal();
66 }
67
68 @Override
69 public void logInfo() { }
70 }