Package com.higherfrequencytrading.chronicle

Examples of com.higherfrequencytrading.chronicle.Excerpt.writeLong()

17
18
19
20
21
22
23
24
25
26
27
        final Excerpt excerpt = chronicle.createExcerpt();
        final int[] consolidates = new int[]{1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16};
        int repeats = 10000;
        for (int i = 0; i < repeats; i++) {
            excerpt.startExcerpt(8 + 4 + 4 * consolidates.length);
            excerpt.writeLong(System.nanoTime());
            excerpt.writeInt(consolidates.length);
            for (final int consolidate : consolidates) {
                excerpt.writeInt(consolidate);
            }
            excerpt.finish();
View Full Code Here
45
46
47
48
49
50
51
52
53
54
55
    public void testLookup() throws Exception {
        PackedHashedTable pht = new PackedHashedTable(baseDir + "/deleteme", 2, 4, 64);
        pht.deleteOnExit();

        Excerpt record = pht.startRecord();
        record.writeLong(1234567890L);
        pht.endRecord(1111);

        final boolean[] found = {false};
        pht.lookup(1111, new PackedHashedTable.HashRecordIterator() {
            @Override
View Full Code Here
66
67
68
69
70
71
72
73
74
75
76
                        long time = excerpt.readLong();
                        excerpt.finish();

                        excerpt2.startExcerpt(8);
                        excerpt2.writeLong(time);
                        excerpt2.finish();
                    }
                } catch (IOException e) {
                    e.printStackTrace();
                }
View Full Code Here
70
71
72
73
74
75
76
77
78
79
80
                        long time = excerpt.readLong();
                        excerpt.finish();

                        excerpt2.startExcerpt(8);
                        excerpt2.writeLong(time);
                        excerpt2.finish();
                    }
                } catch (IOException e) {
                    e.printStackTrace();
                } finally {
View Full Code Here
136
137
138
139
140
141
142
143
144
145
146
                    do {
                        /* busy wait */
                    } while (System.nanoTime() < next);
                    // when it should have been sent, not when it was.
                    excerpt.startExcerpt(128);
                    excerpt.writeLong(next);
                    excerpt.position(128);
                    excerpt.finish();
                }
                future.get();

View Full Code Here
63
64
65
66
67
68
69
70
71
72
73
        int counter = 1;
        for (int i = 0; i < 1024; i++) {
            excerpt.startExcerpt(129);
            for (int j = 0; j < 128; j += 8)
                excerpt.writeLong(counter++);
            excerpt.write(-1);
            excerpt.finish();
        }

        int counter2 = 1;
View Full Code Here
129
130
131
132
133
134
135
136
137
138
139
                ic.useUnsafe(true);
                ic.clear();
                Excerpt excerpt = ic.createExcerpt();
                for (int i = 1; i <= records; i++) {
                    excerpt.startExcerpt(16);
                    excerpt.writeLong(i);
                    excerpt.writeDouble(i);
                    excerpt.finish();
                }
                ic.close();
            }
View Full Code Here
43
44
45
46
47
48
49
50
51
52
53
                    Excerpt excerpt = ic.createExcerpt();
                    for (long i = 1; i <= runs; i += batchSize) {
                        excerpt.startExcerpt(13 * batchSize);
                        for (int k = 0; k < batchSize; k++) {
                            excerpt.writeUnsignedByte('M'); // message type
                            excerpt.writeLong(i); // e.g. time stamp
                            excerpt.writeFloat(i);
                        }
                        excerpt.finish();
                    }
                    ic.close();
View Full Code Here
44
45
46
47
48
49
50
51
52
53
54
                    chronicle.useUnsafe(true); // for benchmarks.
                    final Excerpt excerpt = chronicle.createExcerpt();
                    for (int i = -warmup; i < repeats; i++) {
                        doSomeThinking();
                        excerpt.startExcerpt(8 + 4 + 4 * consolidates.length);
                        excerpt.writeLong(System.nanoTime());
                        excerpt.writeUnsignedShort(consolidates.length);
                        for (final int consolidate : consolidates) {
                            excerpt.writeStopBit(consolidate);
                        }
                        excerpt.finish();
View Full Code Here
52
53
54
55
56
57
58
59
60
61
62
                try {
                    Excerpt excerpt = source.createExcerpt();
                    for (int i = 1; i <= messages; i++) {
                        // use a size which will cause mis-alignment.
                        excerpt.startExcerpt(9);
                        excerpt.writeLong(i);
                        excerpt.writeByte(i);
                        excerpt.finish();
//                        Thread.sleep(1);
                    }
                    System.out.println(System.currentTimeMillis() + ": Finished writing messages");
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.