Package com.linkedin.databus.core.util.RateMonitor

Examples of com.linkedin.databus.core.util.RateMonitor.MockRateMonitor.start()

1461
1462
1463
1464
1465
1466
1467
1468
1469
1470
1471
  {
    RateControl rc = gg.getRateControl();

    MockRateMonitor mrm = new MockRateMonitor("mock");
    mrm.setNanoTime(0L);
    mrm.start();

    Field field = rc.getClass().getDeclaredField("_ra");
    field.setAccessible(true);
    field.set(rc, mrm);
  }
View Full Code Here
77
78
79
80
81
82
83
84
85
86
87
    Assert.assertEquals(true, rc.isEnabled());

    long curTime = 0L;
    MockRateMonitor mrm = new MockRateMonitor("mock");
    mrm.setNanoTime(curTime);
    mrm.start();

    Field field = rc.getClass().getDeclaredField("_ra");
    field.setAccessible(true);
    field.set(rc, mrm);
View Full Code Here
129
130
131
132
133
134
135
136
137
138
139
  public void testIncrementEventCount() throws Exception
  {
    RateControl rc = new RateControl(2,1);
    MockRateMonitor mrm = new MockRateMonitor("mock");
    mrm.setNanoTime(0L);
    mrm.start();

    Field field = rc.getClass().getDeclaredField("_ra");
    field.setAccessible(true);
    field.set(rc, mrm);
View Full Code Here
200
201
202
203
204
205
206
207
208
209
210
    RateControl rc = new RateControl(10,1);
    Assert.assertEquals(true, rc.isEnabled());
    long curTime = 0L;
    MockRateMonitor mrm = new MockRateMonitor("mock");
    mrm.setNanoTime(curTime);
    mrm.start();
    Field field2 = rc.getClass().getDeclaredField("_ra");
    field2.setAccessible(true);
    field2.set(rc, mrm);
     
    curTime = (1L * DbusConstants.NUM_NSECS_IN_SEC) - 10;
View Full Code Here
226
227
228
229
230
231
232
233
234
235
236
    RateControl rc = new RateControl(10,1);
    Assert.assertEquals(true, rc.isEnabled());
    long curTime = 0L;
    MockRateMonitor mrm = new MockRateMonitor("mock");
    mrm.setNanoTime(curTime);
    mrm.start();

    Field field = rc.getClass().getDeclaredField("_ra");
    field.setAccessible(true);
    field.set(rc, mrm);
     
View Full Code Here
256
257
258
259
260
261
262
263
264
265
266
    RateControl rc = new RateControl(10,1);
    Assert.assertEquals(true, rc.isEnabled());
    long curTime = 0L;
    MockRateMonitor mrm = new MockRateMonitor("mock");
    mrm.setNanoTime(curTime);
    mrm.start();

    Field field = rc.getClass().getDeclaredField("_ra");
    field.setAccessible(true);
    field.set(rc, mrm);
   
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.