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

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


        segmentList.append(segment1);
        segmentList.append(segment2);
        segmentList.append(segment3);
        segmentList.append(segment4);
        try {
            assertSame(segment1, this.messageStore.findSegment(segmentList.view(), 0));
            assertSame(segment1, this.messageStore.findSegment(segmentList.view(), 1));
            assertSame(segment1, this.messageStore.findSegment(segmentList.view(), 1023));
            assertSame(segment2, this.messageStore.findSegment(segmentList.view(), 1024));
            assertSame(segment2, this.messageStore.findSegment(segmentList.view(), 1536));
            assertSame(segment3, this.messageStore.findSegment(segmentList.view(), 2048));
View Full Code Here


        segmentList.append(segment2);
        segmentList.append(segment3);
        segmentList.append(segment4);
        try {
            assertSame(segment1, this.messageStore.findSegment(segmentList.view(), 0));
            assertSame(segment1, this.messageStore.findSegment(segmentList.view(), 1));
            assertSame(segment1, this.messageStore.findSegment(segmentList.view(), 1023));
            assertSame(segment2, this.messageStore.findSegment(segmentList.view(), 1024));
            assertSame(segment2, this.messageStore.findSegment(segmentList.view(), 1536));
            assertSame(segment3, this.messageStore.findSegment(segmentList.view(), 2048));
            assertSame(segment3, this.messageStore.findSegment(segmentList.view(), 2049));
View Full Code Here

        segmentList.append(segment3);
        segmentList.append(segment4);
        try {
            assertSame(segment1, this.messageStore.findSegment(segmentList.view(), 0));
            assertSame(segment1, this.messageStore.findSegment(segmentList.view(), 1));
            assertSame(segment1, this.messageStore.findSegment(segmentList.view(), 1023));
            assertSame(segment2, this.messageStore.findSegment(segmentList.view(), 1024));
            assertSame(segment2, this.messageStore.findSegment(segmentList.view(), 1536));
            assertSame(segment3, this.messageStore.findSegment(segmentList.view(), 2048));
            assertSame(segment3, this.messageStore.findSegment(segmentList.view(), 2049));
            assertSame(segment3, this.messageStore.findSegment(segmentList.view(), 3000));
View Full Code Here

        segmentList.append(segment4);
        try {
            assertSame(segment1, this.messageStore.findSegment(segmentList.view(), 0));
            assertSame(segment1, this.messageStore.findSegment(segmentList.view(), 1));
            assertSame(segment1, this.messageStore.findSegment(segmentList.view(), 1023));
            assertSame(segment2, this.messageStore.findSegment(segmentList.view(), 1024));
            assertSame(segment2, this.messageStore.findSegment(segmentList.view(), 1536));
            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));
View Full Code Here

        try {
            assertSame(segment1, this.messageStore.findSegment(segmentList.view(), 0));
            assertSame(segment1, this.messageStore.findSegment(segmentList.view(), 1));
            assertSame(segment1, this.messageStore.findSegment(segmentList.view(), 1023));
            assertSame(segment2, this.messageStore.findSegment(segmentList.view(), 1024));
            assertSame(segment2, this.messageStore.findSegment(segmentList.view(), 1536));
            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));
View Full Code Here

            assertSame(segment1, this.messageStore.findSegment(segmentList.view(), 0));
            assertSame(segment1, this.messageStore.findSegment(segmentList.view(), 1));
            assertSame(segment1, this.messageStore.findSegment(segmentList.view(), 1023));
            assertSame(segment2, this.messageStore.findSegment(segmentList.view(), 1024));
            assertSame(segment2, this.messageStore.findSegment(segmentList.view(), 1536));
            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));
View Full Code Here

            assertSame(segment1, this.messageStore.findSegment(segmentList.view(), 1));
            assertSame(segment1, this.messageStore.findSegment(segmentList.view(), 1023));
            assertSame(segment2, this.messageStore.findSegment(segmentList.view(), 1024));
            assertSame(segment2, this.messageStore.findSegment(segmentList.view(), 1536));
            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));
View Full Code Here

            assertSame(segment1, this.messageStore.findSegment(segmentList.view(), 1023));
            assertSame(segment2, this.messageStore.findSegment(segmentList.view(), 1024));
            assertSame(segment2, this.messageStore.findSegment(segmentList.view(), 1536));
            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));
 
View Full Code Here

            assertSame(segment2, this.messageStore.findSegment(segmentList.view(), 1024));
            assertSame(segment2, this.messageStore.findSegment(segmentList.view(), 1536));
            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 {
View Full Code Here

            assertSame(segment2, this.messageStore.findSegment(segmentList.view(), 1536));
            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);
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.