Package org.directmemory.memory

Examples of org.directmemory.memory.OffHeapMemoryBuffer.store()

57
58
59
60
61
62
63
64
65
66
67
   
    long start = System.currentTimeMillis();

    byte[] payload = new byte[size];
    for (int i = 0; i < howMany; i++) {
      mem.store(payload);
    }
   
    logger.info("...done in " + (System.currentTimeMillis() - start) + " msecs.");
    logger.info("---------------------------------");
    dump(mem);
View Full Code Here
37
38
39
40
41
42
43
44
45
46
47
   
    int size = rnd.nextInt(10) * mem.capacity() / 100;
   
    logger.info("size=" + size);
   
    Pointer p = mem.store(new byte[size]);
    assertNotNull(p);
    assertEquals(size,p.end);
    assertEquals(size, mem.used());
    mem.free(p);
    assertEquals(0, mem.used());   
View Full Code Here
97
98
99
100
101
102
103
104
105
106
107
    logger.info("payload size is variable");
    logger.info("entries=" + howMany);
    String test = "this is a nicely crafted test";
    for (int i = 0; i < howMany; i++) {
      final byte[] payload = (test + " - " + i).getBytes();
      Pointer p = mem.store(payload);
      final byte[] check = mem.retrieve(p);
      assertNotNull(check);
      assertEquals(test + " - " + i, new String(check));
      long crc1 = OffHeapMemoryBuffer.crc32(payload);
      long crc2 = OffHeapMemoryBuffer.crc32(check);
View Full Code Here
121
122
123
124
125
126
127
128
129
130
131
    logger.info("entries=" + howMany);
    String test = "this is a nicely crafted test";
    Pointer lastP = null;
    for (int i = 0; i < howMany; i++) {
      byte[] payload = (test + " - " + i).getBytes();
      Pointer p = mem.store(payload);
      logger.info("p.start=" + p.start);
      logger.info("p.end=" + p.end);
      if (lastP != null) {
        assertEquals(lastP.end +1, p.start);
      }
View Full Code Here
148
149
150
151
152
153
154
155
156
157
158
    logger.info("payload size=" + Ram.inKb(size));
    logger.info("entries=" + howMany);
   
    byte[] payload = new byte[size];
    for (int i = 0; i < howMany; i++) {
      mem.store(payload, 2000);
    }
   
    assertEquals(size*howMany, mem.used());
   
    logger.info("entries with relative expiration=" + (howMany/2));
View Full Code Here
155
156
157
158
159
160
161
162
163
164
165
   
    assertEquals(size*howMany, mem.used());
   
    logger.info("entries with relative expiration=" + (howMany/2));
    for (int i = 0; i < howMany/2; i++) {
      mem.store(payload, 100);
    }
    assertEquals(size*howMany+size*howMany/2, mem.used());

    logger.info("entries with absolute expiration=" + (howMany/2));
    for (int i = 0; i < howMany/2; i++) {
View Full Code Here
161
162
163
164
165
166
167
168
169
170
171
    }
    assertEquals(size*howMany+size*howMany/2, mem.used());

    logger.info("entries with absolute expiration=" + (howMany/2));
    for (int i = 0; i < howMany/2; i++) {
      mem.store(payload, new Date());
    }
    assertEquals(size*howMany*2, mem.used());
    logger.info("total used=" + Ram.inMb(mem.used()));
   
    Thread.sleep(500);
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.