komamitsu

public int trySetChildrenBlockedToReadyOrShortCircuitPlannedOrCanceled(long taskId)
{
    return handle.createStatement("update tasks" +
            " set updated_at = now(), state = case" +
            " when task_type = " + TaskType.GROUPING_ONLY + " then " + TaskStateCode.PLANNED_CODE +
            " when " + bitAnd("state_flags", Integer.toString(TaskStateFlags.CANCEL_REQUESTED)) + " != 0 then " + TaskStateCode.CANCELED_CODE +
            " else " + TaskStateCode.READY_CODE +
            " end" +
            " where state = " + TaskStateCode.BLOCKED_CODE +

komamitsu

[komamitsu@potato mtrace]$ pwd
/Users/komamitsu/src/openjdk/jdk/src/share/demo/jvmti/mtrace
[komamitsu@potato mtrace]$ clang -I${JAVA_HOME}/include -I${JAVA_HOME}/include/darwin -I../agent_util -I../java_crw_demo -c ../agent_util/agent_util.c ../java_crw_demo/java_crw_demo.c *.c
[komamitsu@potato mtrace]$ clang -dynamiclib -L${JAVA_HOME} -shared -o libmtrace.so *.o
[komamitsu@potato mtrace]$

komamitsu

Throughput comparison

Instances

• fluency/fluent-logger-java:
• m3.large
• fleuentd
• m3.large

Result

komamitsu

- rust - Error when a trait is used as a type but not when used as a bound in a where clause - Stack Overflow http://stackoverflow.com/questions/37347695/error-when-a-trait-is-used-as-a-type-but-not-when-used-as-a-bound-in-a-where-cla

komamitsu

# Java 7

## master

serialize(pojo) with JSON:
mean :  150.873
min  :  140.398
max  :  158.998
stdev:    7.883

komamitsu

    16:14:47.771 WARN  [pool-2-thread-1] o.k.f.s.RetryableSender This sender is already closed
    16:14:47.771 WARN  [pool-2-thread-1] o.k.f.s.RetryableSender This sender is already closed
    16:14:47.771 WARN  [pool-2-thread-1] o.k.f.s.RetryableSender This sender is already closed
    16:14:47.772 ERROR [pool-2-thread-1] o.k.f.f.AsyncFlusher Failed to flush
    java.io.IOException: Failed to move retention buffer due to interruption
        at org.komamitsu.fluency.buffer.PackedForwardBuffer.moveRetentionBufferToFlushable(PackedForwardBuffer.java:178) ~[main/:na]
        at org.komamitsu.fluency.buffer.PackedForwardBuffer.moveRetentionBuffersToFlushable(PackedForwardBuffer.java:161) ~[main/:na]
        at org.komamitsu.fluency.buffer.PackedForwardBuffer.flushInternal(PackedForwardBuffer.java:192) ~[main/:na]
        at org.komamitsu.fluency.buffer.Buffer.flush(Buffer.java:88) ~[main/:na]
        at org.komamitsu.fluency.flusher.AsyncFlusher$1.run(AsyncFlusher.java:40) ~[main/:na]

komamitsu

/Library/Java/JavaVirtualMachines/jdk1.7.0_45.jdk/Contents/Home/bin/java -ea -Didea.launcher.port=7532 "-Didea.launcher.bin.path=/Applications/IntelliJ IDEA 15 CE.app/Contents/bin" -Didea.junit.sm_runner -Dfile.encoding=UTF-8 -classpath "/Applications/IntelliJ IDEA 15 CE.app/Contents/lib/idea_rt.jar:/Applications/IntelliJ IDEA 15 CE.app/Contents/plugins/junit/lib/junit-rt.jar:/Library/Java/JavaVirtualMachines/jdk1.7.0_45.jdk/Contents/Home/lib/ant-javafx.jar:/Library/Java/JavaVirtualMachines/jdk1.7.0_45.jdk/Contents/Home/lib/dt.jar:/Library/Java/JavaVirtualMachines/jdk1.7.0_45.jdk/Contents/Home/lib/javafx-doclet.jar:/Library/Java/JavaVirtualMachines/jdk1.7.0_45.jdk/Contents/Home/lib/javafx-mx.jar:/Library/Java/JavaVirtualMachines/jdk1.7.0_45.jdk/Contents/Home/lib/jconsole.jar:/Library/Java/JavaVirtualMachines/jdk1.7.0_45.jdk/Contents/Home/lib/sa-jdi.jar:/Library/Java/JavaVirtualMachines/jdk1.7.0_45.jdk/Contents/Home/lib/tools.jar:/Library/Java/JavaVirtualMachines/jdk1.7.0_45.jdk/Contents/Home/jre/lib/charsets.

komamitsu

Connected to the target VM, address: '127.0.0.1:55933', transport: 'socket'
01:37:47.102 DEBUG o.k.f.MockTCPServer ServerTask: accepting... this=org.komamitsu.fluency.MockTCPServer$ServerTask@213b8493, local.port=56065
01:37:47.301 DEBUG o.k.f.MockTCPServer ServerTask: accepting... this=org.komamitsu.fluency.MockTCPServer$ServerTask@398a1cf1, local.port=56066
01:37:48.031 DEBUG o.k.f.MockTCPServer ServerTask: accepted. this=org.komamitsu.fluency.MockTCPServer$ServerTask@213b8493, local.port=56065, remote.port=56131
01:37:48.034 DEBUG o.k.f.MockTCPServer ServerTask: accepting... this=org.komamitsu.fluency.MockTCPServer$ServerTask@213b8493, local.port=56065
01:37:48.034 DEBUG o.k.f.MockTCPServer AcceptTask: connected. this=org.komamitsu.fluency.MockTCPServer$ServerTask$AcceptTask@3ab81057, local=56065, remote=56131
if (remaining >= readLength): position=17, readLength=4
if (remaining >= readLength): position=28, readLength=8
if (remaining >= readLength): position=190, readLength=4
if (remaining >= readLength): 

komamitsu

package org.komamitsu.test;

import org.komamitsu.fluency.Fluency;

import java.io.IOException;
import java.util.HashMap;
import java.util.Map;

public class FluencyTest
{

komamitsu

  public static void main(String[] args)
          throws IOException
  {
      byte[] bytes;
      {
          MessagePack messagePack = new MessagePack();
          ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
          Packer packer = messagePack.createPacker(outputStream);
          packer.writeArrayBegin(3);
          packer.write(42);