@@ -31,6 +31,7 @@ public class ChunkBufferNGTest {
31
31
32
32
private long m_keyid = 22L ;
33
33
private volatile long m_checksum ;
34
+ private volatile long m_count ;
34
35
private int m_bufsize = 90 * 1024 * 1024 ;
35
36
36
37
@ Test
@@ -55,7 +56,7 @@ public boolean reclaim(Long mres, Long sz) {
55
56
long bufcnt = mch .getSize () / m_bufsize ;
56
57
ChunkBuffer ckbuf ;
57
58
byte [] rdbytes ;
58
- for (int idx = 0 ; idx < bufcnt ; ++idx ) {
59
+ for (long idx = 0 ; idx < bufcnt ; ++idx ) {
59
60
// System.err.println(String.format("---- bufcnt: %d, bufsize: %d, idx: %d", bufcnt, m_bufsize, idx));
60
61
ckbuf = mch .getChunkBuffer (idx * m_bufsize , m_bufsize );
61
62
Assert .assertNotNull (ckbuf );
@@ -66,6 +67,7 @@ public boolean reclaim(Long mres, Long sz) {
66
67
cs .update (rdbytes , 0 , rdbytes .length );
67
68
}
68
69
m_checksum = cs .getValue ();
70
+ m_count = bufcnt ;
69
71
act .close ();
70
72
}
71
73
@@ -90,7 +92,7 @@ public boolean reclaim(Long mres, Long sz) {
90
92
91
93
ChunkBuffer ckbuf ;
92
94
byte [] buf ;
93
- for (int idx = 0 ; idx < bufcnt ; ++idx ) {
95
+ for (long idx = 0 ; idx < bufcnt ; ++idx ) {
94
96
ckbuf = mch .getChunkBuffer (idx * m_bufsize , m_bufsize );
95
97
Assert .assertNotNull (ckbuf );
96
98
buf = new byte [m_bufsize ];
@@ -101,7 +103,8 @@ public boolean reclaim(Long mres, Long sz) {
101
103
act .close ();
102
104
103
105
Assert .assertEquals (m_checksum , cs .getValue ());
104
- System .out .println (String .format ("The checksum of chunk buffers are %d" , m_checksum ));
106
+ Assert .assertEquals (m_count , bufcnt );
107
+ System .out .println (String .format ("The checksum of chunk buffers are %d, Total count is %d" , m_checksum , m_count ));
105
108
}
106
109
107
110
}
0 commit comments