Specialized instrumentation for different cases

ulyp-agent-core/src/main/java/com/ulyp/agent/AgentDataWriter.java

@@ -23,7 +23,6 @@ public class AgentDataWriter {
     @Getter
     private final MethodRepository methodRepository;
     private final AtomicInteger lastIndexOfMethodWritten = new AtomicInteger(-1);
-    private final AtomicInteger lastIndexOfMethodToRecordWritten = new AtomicInteger(-1);
     private final AtomicInteger lastIndexOfTypeWritten = new AtomicInteger(-1);
 
     public AgentDataWriter(RecordingDataWriter recordingDataWriter, MethodRepository methodRepository) {
@@ -59,31 +58,6 @@ public void write(TypeResolver typeResolver, RecordingMetadata recordingMetadata
             }
         }
 
-        methodsList = new SerializedMethodList();
-        methods = methodRepository.getRecordingStartMethods();
-        upToExcluding = methods.size() - 1;
-        startFrom = lastIndexOfMethodToRecordWritten.get() + 1;
-
-        for (int i = startFrom; i <= upToExcluding; i++) {
-            Method method = methods.get(i);
-            log.debug("Will write {} to storage", method);
-            methodsList.add(method);
-        }
-        if (methodsList.size() > 0) {
-            recordingDataWriter.write(methodsList);
-            for (;;) {
-                int currentIndex = lastIndexOfMethodToRecordWritten.get();
-                if (currentIndex < upToExcluding) {
-                    if (lastIndexOfMethodToRecordWritten.compareAndSet(currentIndex, upToExcluding)) {
-                        break;
-                    }
-                } else {
-                    // Someone else must have written methods already
-                    break;
-                }
-            }
-        }
-
         SerializedTypeList typesList = new SerializedTypeList();
         ConcurrentArrayList<Type> types = typeResolver.values();
         upToExcluding = types.size() - 1;

ulyp-agent-core/src/main/java/com/ulyp/agent/Recorder.java

@@ -149,6 +149,10 @@ public int onConstructorEnter(RecordingState recordingState, int methodId, Objec
         return onMethodEnter(recordingState, methodId, null, args);
     }
 
+    public int onMethodEnter(int methodId, @Nullable Object callee) {
+        return onMethodEnter(threadLocalRecordingState.get(), methodId, callee, null);
+    }
+
     public int onMethodEnter(int methodId, @Nullable Object callee, Object[] args) {
         return onMethodEnter(threadLocalRecordingState.get(), methodId, callee, args);
     }

ulyp-agent-core/src/main/java/com/ulyp/agent/Settings.java

@@ -1,19 +1,18 @@
 package com.ulyp.agent;
 
+import com.ulyp.core.ProcessMetadata;
 import com.ulyp.core.recorders.collections.CollectionsRecordingMode;
+import com.ulyp.core.util.MethodMatcher;
 import com.ulyp.core.util.TypeMatcher;
 import com.ulyp.core.util.CommaSeparatedList;
 import com.ulyp.core.util.PackageList;
-import com.ulyp.storage.writer.RecordingDataWriter;
 import lombok.Getter;
 import org.jetbrains.annotations.NotNull;
 import org.jetbrains.annotations.Nullable;
 
-import java.nio.file.Paths;
 import java.util.List;
 import java.util.Optional;
 import java.util.Set;
-import java.util.function.Supplier;
 import java.util.regex.Pattern;
 import java.util.stream.Collectors;
 
@@ -121,6 +120,11 @@ public static Settings fromSystemProperties() {
         String methodsToRecordRaw = System.getProperty(START_RECORDING_METHODS_PROPERTY, "");
         String excludeMethodsToRecordRaw = System.getProperty(EXCLUDE_RECORDING_METHODS_PROPERTY, "");
         StartRecordingMethods recordingStartMethods = StartRecordingMethods.parse(methodsToRecordRaw, excludeMethodsToRecordRaw);
+        if (recordingStartMethods.isEmpty()) {
+            recordingStartMethods = StartRecordingMethods.of(
+                    new MethodMatcher(TypeMatcher.parse(ProcessMetadata.getMainClassNameFromProp()), "main")
+            );
+        }
 
         String recordingDataFilePath = System.getProperty(FILE_PATH_PROPERTY);
         if (recordingDataFilePath == null) {

ulyp-agent-core/src/main/java/com/ulyp/agent/queue/RecordingEventProcessor.java

@@ -58,7 +58,7 @@ void onEnterCallRecord(EnterRecordQueueEvent enterRecord) {
         buffer.recordMethodEnter(
                 enterRecord.getCallId(),
                 typeResolver,
-                /* TODO remove after advice split */methodRepository.get(enterRecord.getMethodId()).getId(),
+                enterRecord.getMethodId(),
                 cachedQueuedIdentityCallee,
                 enterRecord.getArgs(),
                 nanoTime

ulyp-agent-core/src/main/java/com/ulyp/agent/queue/RecordingQueue.java

@@ -128,6 +128,9 @@ public void enqueueMethodExit(int recordingId, int callId, Object returnValue, b
     }
 
     private Object[] convert(Object[] args) {
+        if (args == null) {
+            return null;
+        }
         for (int i = 0; i < args.length; i++) {
             args[i] = convert(args[i]);
         }

ulyp-agent-core/src/main/java/com/ulyp/agent/queue/disruptor/EventHandlerGroup.java

@@ -1,5 +1,6 @@
 package com.ulyp.agent.queue.disruptor;
 
+import com.lmax.disruptor.EventHandler;
 import com.lmax.disruptor.EventProcessor;
 import com.lmax.disruptor.Sequence;
 import com.lmax.disruptor.WorkHandler;