Package com.taobao.metamorphosis.server.store.MessageStore

Examples of com.taobao.metamorphosis.server.store.MessageStore.SegmentList.first()

136
137
138
139
140
141
142
143
144
145
146
        final Segment segment2 = new Segment(1024, file);
        final Segment segment3 = new Segment(2048, file);
        try {
            segmentList.append(segment1);
            assertEquals(1, segmentList.contents.get().length);
            assertSame(segment1, segmentList.first());
            assertSame(segment1, segmentList.last());
            segmentList.append(segment2);
            assertEquals(2, segmentList.contents.get().length);
            assertSame(segment1, segmentList.first());
            assertSame(segment2, segmentList.last());
View Full Code Here
140
141
142
143
144
145
146
147
148
149
150
            assertEquals(1, segmentList.contents.get().length);
            assertSame(segment1, segmentList.first());
            assertSame(segment1, segmentList.last());
            segmentList.append(segment2);
            assertEquals(2, segmentList.contents.get().length);
            assertSame(segment1, segmentList.first());
            assertSame(segment2, segmentList.last());
            segmentList.append(segment3);
            assertEquals(3, segmentList.contents.get().length);
            assertSame(segment1, segmentList.first());
            assertSame(segment3, segmentList.last());
View Full Code Here
144
145
146
147
148
149
150
151
152
153
154
            assertEquals(2, segmentList.contents.get().length);
            assertSame(segment1, segmentList.first());
            assertSame(segment2, segmentList.last());
            segmentList.append(segment3);
            assertEquals(3, segmentList.contents.get().length);
            assertSame(segment1, segmentList.first());
            assertSame(segment3, segmentList.last());

            segmentList.delete(segment1);
            assertEquals(2, segmentList.contents.get().length);
            assertSame(segment2, segmentList.first());
View Full Code Here
149
150
151
152
153
154
155
156
157
158
159
            assertSame(segment1, segmentList.first());
            assertSame(segment3, segmentList.last());

            segmentList.delete(segment1);
            assertEquals(2, segmentList.contents.get().length);
            assertSame(segment2, segmentList.first());
            assertSame(segment3, segmentList.last());

            segmentList.delete(segment3);
            assertEquals(1, segmentList.contents.get().length);
            assertSame(segment2, segmentList.first());
View Full Code Here
154
155
156
157
158
159
160
161
162
163
164
            assertSame(segment2, segmentList.first());
            assertSame(segment3, segmentList.last());

            segmentList.delete(segment3);
            assertEquals(1, segmentList.contents.get().length);
            assertSame(segment2, segmentList.first());
            assertSame(segment2, segmentList.last());
            // delete not existing
            segmentList.delete(segment3);
            assertEquals(1, segmentList.contents.get().length);
            assertSame(segment2, segmentList.first());
View Full Code Here
159
160
161
162
163
164
165
166
167
168
169
            assertSame(segment2, segmentList.first());
            assertSame(segment2, segmentList.last());
            // delete not existing
            segmentList.delete(segment3);
            assertEquals(1, segmentList.contents.get().length);
            assertSame(segment2, segmentList.first());
            assertSame(segment2, segmentList.last());

            segmentList.delete(segment2);
            assertEquals(0, segmentList.contents.get().length);
            assertNull(segmentList.first());
View Full Code Here
164
165
166
167
168
169
170
171
172
173
174
            assertSame(segment2, segmentList.first());
            assertSame(segment2, segmentList.last());

            segmentList.delete(segment2);
            assertEquals(0, segmentList.contents.get().length);
            assertNull(segmentList.first());
            assertNull(segmentList.last());
        }
        finally {
            if (segment1 != null) {
                segment1.fileMessageSet.close();
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.