Changeset 596 for Tests


Ignore:
Timestamp:
12/12/13 21:25:38 (8 years ago)
Author:
BegemoT
Message:
 
Location:
Tests/JAVA/logger
Files:
19 added
5 edited

Legend:

Unmodified
Added
Removed
  • Tests/JAVA/logger/logger.iml

    r595 r596  
    77      <sourceFolder url="file://$MODULE_DIR$/src/main/java" isTestSource="false" /> 
    88      <sourceFolder url="file://$MODULE_DIR$/src/test/java" isTestSource="true" /> 
     9      <sourceFolder url="file://$MODULE_DIR$/target/generated-test-sources/test-annotations" isTestSource="true" /> 
    910      <sourceFolder url="file://$MODULE_DIR$/target/generated-sources/annotations" isTestSource="false" /> 
    1011      <excludeFolder url="file://$MODULE_DIR$/target/classes" /> 
     12      <excludeFolder url="file://$MODULE_DIR$/target/maven-archiver" /> 
    1113      <excludeFolder url="file://$MODULE_DIR$/target/maven-status" /> 
     14      <excludeFolder url="file://$MODULE_DIR$/target/test-classes" /> 
    1215    </content> 
    1316    <orderEntry type="inheritedJdk" /> 
     
    4043    <orderEntry type="library" name="Maven: org.springframework:spring-beans:3.0.5.RELEASE" level="project" /> 
    4144    <orderEntry type="library" name="Maven: net.jcip:jcip-annotations:1.0" level="project" /> 
    42     <orderEntry type="library" name="Maven: com.lmax:disruptor:3.2.0" level="project" /> 
     45    <orderEntry type="library" name="Maven: com.googlecode.disruptor:disruptor:2.10.4" level="project" /> 
    4346    <orderEntry type="library" name="Maven: net.java.dev.jna:jna:3.4.0" level="project" /> 
    4447    <orderEntry type="library" name="Maven: org.affinity:affinity:0.1.1-SNAPSHOT" level="project" /> 
  • Tests/JAVA/logger/pom.xml

    r595 r596  
    123123            <artifactId>gflogger</artifactId> 
    124124            <version>0.9</version> 
    125             <scope>system</scope> 
    126             <systemPath>${project.basedir}/libs/gflogger-20131211.jar</systemPath> 
    127125        </dependency> 
    128126 
     
    177175 
    178176        <dependency> 
    179             <groupId>com.lmax</groupId> 
     177            <groupId>com.googlecode.disruptor</groupId> 
    180178            <artifactId>disruptor</artifactId> 
    181             <version>3.2.0</version> 
    182         </dependency> 
     179            <!--<version>3.2.0</version>--> 
     180            <version>2.10.4</version> 
     181        </dependency> 
     182 
     183 
    183184 
    184185        <dependency> 
  • Tests/JAVA/logger/scripts/batch.sh

    r595 r596  
    11#!/bin/bash 
    22 
    3 for PAYLOAD in 400 800 1200 
     3for PAYLOAD in 400 800 1200 2000 
    44#for PAYLOAD in 0 20 40 60 80 120 200 
    55do 
  • Tests/JAVA/logger/src/main/java/com/db/logger/benchmarks/GFLoggerBenchmark.java

    r595 r596  
    1010import org.apache.log4j.Logger; 
    1111import org.gflogger.*; 
     12import org.gflogger.appender.AbstractAppenderFactory; 
    1213import org.gflogger.appender.AppenderFactory; 
    1314import org.gflogger.appender.FileAppenderFactory; 
     
    3031@State( Scope.Group ) 
    3132public class GFLoggerBenchmark { 
    32         private static final Logger log = Logger.getLogger( GFLoggerBenchmark.class ); 
    3333        public static final int LENGTH_POW = Integer.getInteger( "length-pow", 14 ); 
    3434        public static final int LENGTH = 1 << LENGTH_POW; 
     
    3939        public static final int CELLS_PER_RECORD = Integer.getInteger( "cells-per-record", 8 );//8longs = 1 cache line 
    4040 
    41         public static final int MAX_MESSAGE_SIZE = getIntProperty( "gflogger.service.maxMessageSize", 1 << 8 ); 
     41        public static final int MAX_MESSAGE_SIZE = getIntProperty( "gflogger.service.maxMessageSize", 1 << 7 ); 
    4242 
    4343        public static final int PAYLOAD = Integer.getInteger( "writer-backoff", 20 ); 
     
    5555 
    5656        @Setup 
    57         public void setup() { 
     57        public void setup() throws Exception { 
    5858                gfloggerService = createLoggerImpl(); 
    5959 
     
    125125                        //with previous benchmarks 
    126126                        for( int i = 1; i < CELLS_PER_RECORD; i++ ) { 
    127                                 sb.append( " %d" ); 
     127                                sb.append( " %s" ); 
    128128                        } 
    129129                        message = sb.toString(); 
     
    133133 
    134134        protected AppenderFactory[] createAppenderFactories() { 
    135                 final FileAppenderFactory fileAppender = new FileAppenderFactory(); 
    136                 fileAppender.setLogLevel( LogLevel.INFO ); 
    137                 fileAppender.setFileName( "log.log" ); 
    138                 fileAppender.setAppend( false ); 
    139                 fileAppender.setImmediateFlush( false ); 
    140                 fileAppender.setLayout( new PatternLayout( "%d{HH:mm:ss,SSS zzz} %p %m [%c{2}] [%t]%n" ) ); 
    141  
    142                 return new AppenderFactory[] { fileAppender }; 
     135//              final FileAppenderFactory fileAppender = new FileAppenderFactory(); 
     136//              fileAppender.setLogLevel( LogLevel.INFO ); 
     137//              fileAppender.setFileName( "log.log" ); 
     138//              fileAppender.setAppend( false ); 
     139//              fileAppender.setImmediateFlush( false ); 
     140//              fileAppender.setLayout( new PatternLayout( "%d{HH:mm:ss,SSS zzz} %p %m [%c{2}] [%t]%n" ) ); 
     141 
     142                return new AppenderFactory[] { new AbstractAppenderFactory(){ 
     143                        @Override 
     144                        public Appender createAppender( final Class<? extends LoggerService> aClass ) { 
     145                                return new Appender() { 
     146                                        @Override 
     147                                        public boolean isMultibyte() { 
     148                                                return false; 
     149                                        } 
     150 
     151                                        @Override 
     152                                        public boolean isEnabled() { 
     153                                                return true; 
     154                                        } 
     155 
     156                                        @Override 
     157                                        public LogLevel getLogLevel() { 
     158                                                return LogLevel.DEBUG; 
     159                                        } 
     160 
     161                                        @Override 
     162                                        public String getName() { 
     163                                                return "fake"; 
     164                                        } 
     165 
     166                                        @Override 
     167                                        public int getIndex() { 
     168                                                return index; 
     169                                        } 
     170 
     171                                        @Override 
     172                                        public void workerIsAboutToFinish() { 
     173 
     174                                        } 
     175 
     176                                        @Override 
     177                                        public void flush() { 
     178 
     179                                        } 
     180 
     181                                        @Override 
     182                                        public void flush( final boolean b ) { 
     183 
     184                                        } 
     185 
     186                                        @Override 
     187                                        public void process( final LogEntryItem logEntryItem ) { 
     188 
     189                                        } 
     190 
     191                                        @Override 
     192                                        public void start() { 
     193 
     194                                        } 
     195 
     196                                        @Override 
     197                                        public void stop() { 
     198 
     199                                        } 
     200                                }; 
     201                        } 
     202 
     203                        @Override 
     204                        public LogLevel getLogLevel() { 
     205                                return LogLevel.DEBUG; 
     206                        } 
     207 
     208                } }; 
    143209        } 
    144210 
  • Tests/JAVA/logger/src/main/java/com/db/logger/benchmarks/PerThreadMappedFileBenchmark.java

    r595 r596  
    137137                public ByteBuffer buffer; 
    138138 
    139                 public ThreadState() throws Exception { 
    140                         final int length = ( 1 << LENGTH_POW ); 
    141  
    142                         this.sequencer = new SCSDSequencer( length ); 
    143                         final File file = new File( "" ); 
    144                         final FileChannel channel = new FileOutputStream( file ).getChannel(); 
    145                         this.buffer = channel.map( 
    146                                         FileChannel.MapMode.READ_WRITE, 
    147                                         0, 
    148                                         length << 3 
    149                         ); 
    150                 } 
     139//              public ThreadState() throws Exception { 
     140//                      final int length = ( 1 << LENGTH_POW ); 
     141// 
     142//                      this.sequencer = new SCSDSequencer( length ); 
     143//                      final File file = new File( "" ); 
     144//                      final FileChannel channel = new FileOutputStream( file ).getChannel(); 
     145//                      this.buffer = channel.map( 
     146//                                      FileChannel.MapMode.READ_WRITE, 
     147//                                      0, 
     148//                                      length << 3 
     149//                      ); 
     150//              } 
    151151 
    152152                @Setup 
Note: See TracChangeset for help on using the changeset viewer.