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

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

392
393
394
395
396
397
398
399
400
401
402
            assertSame(segment3, this.messageStore.findSegment(segmentList.view(), 2048));
            assertSame(segment3, this.messageStore.findSegment(segmentList.view(), 2049));
            assertSame(segment3, this.messageStore.findSegment(segmentList.view(), 3000));
            assertSame(segment4, this.messageStore.findSegment(segmentList.view(), 3072));
            assertSame(segment4, this.messageStore.findSegment(segmentList.view(), 3073));
            assertNull(this.messageStore.findSegment(segmentList.view(), 4097));
            assertNull(this.messageStore.findSegment(segmentList.view(), 4098));
            assertNull(this.messageStore.findSegment(segmentList.view(), 16 * 1024));
            try {
                this.messageStore.findSegment(segmentList.view(), -1);
                fail();
View Full Code Here
393
394
395
396
397
398
399
400
401
402
403
            assertSame(segment3, this.messageStore.findSegment(segmentList.view(), 2049));
            assertSame(segment3, this.messageStore.findSegment(segmentList.view(), 3000));
            assertSame(segment4, this.messageStore.findSegment(segmentList.view(), 3072));
            assertSame(segment4, this.messageStore.findSegment(segmentList.view(), 3073));
            assertNull(this.messageStore.findSegment(segmentList.view(), 4097));
            assertNull(this.messageStore.findSegment(segmentList.view(), 4098));
            assertNull(this.messageStore.findSegment(segmentList.view(), 16 * 1024));
            try {
                this.messageStore.findSegment(segmentList.view(), -1);
                fail();
            }
View Full Code Here
394
395
396
397
398
399
400
401
402
403
404
            assertSame(segment3, this.messageStore.findSegment(segmentList.view(), 3000));
            assertSame(segment4, this.messageStore.findSegment(segmentList.view(), 3072));
            assertSame(segment4, this.messageStore.findSegment(segmentList.view(), 3073));
            assertNull(this.messageStore.findSegment(segmentList.view(), 4097));
            assertNull(this.messageStore.findSegment(segmentList.view(), 4098));
            assertNull(this.messageStore.findSegment(segmentList.view(), 16 * 1024));
            try {
                this.messageStore.findSegment(segmentList.view(), -1);
                fail();
            }
            catch (final ArrayIndexOutOfBoundsException e) {
View Full Code Here
396
397
398
399
400
401
402
403
404
405
406
            assertSame(segment4, this.messageStore.findSegment(segmentList.view(), 3073));
            assertNull(this.messageStore.findSegment(segmentList.view(), 4097));
            assertNull(this.messageStore.findSegment(segmentList.view(), 4098));
            assertNull(this.messageStore.findSegment(segmentList.view(), 16 * 1024));
            try {
                this.messageStore.findSegment(segmentList.view(), -1);
                fail();
            }
            catch (final ArrayIndexOutOfBoundsException e) {
                assertTrue(true);
            }
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.