Revert "[core] Fix logcat (#986)" (#987)

This reverts commit a4abbfa67a.

core/src/main/cpp/daemon/logcat.cpp

@@ -32,8 +32,10 @@ public:
 
 class Logcat {
 public:
-    explicit Logcat(JNIEnv *env, jobject thiz, jmethodID method) :
+    explicit Logcat(JNIEnv *env, jobject thiz, jmethodID method, jlong logger_id) :
-            env_(env), thiz_(thiz), refresh_fd_method_(method) {}
+            env_(env), thiz_(thiz), refresh_fd_method_(method), logger_id_(logger_id),
+            stop_verbose_inst_("!!stop_verbose!!" + std::to_string(logger_id_)),
+            start_verbose_inst_("!!start_verbose!!" + std::to_string(logger_id_)) {}
 
     [[noreturn]] void Run();
 
@@ -47,7 +49,7 @@ private:
     JNIEnv *env_;
     jobject thiz_;
     jmethodID refresh_fd_method_;
-    std::string id_ = "0";
+    jlong logger_id_;
 
     UniqueFile modules_file_{};
     size_t modules_file_part_ = 0;
@@ -59,8 +61,8 @@ private:
 
     bool verbose_ = false;
 
-    const std::string start_verbose_inst_ = "!!start_verbose!!";
+    const std::string stop_verbose_inst_;
-    const std::string stop_verbose_inst_ = "!!stop_verbose!!";
+    const std::string start_verbose_inst_;
 };
 
 int Logcat::PrintLogLine(const AndroidLogEntry &entry, FILE *out) {
@@ -90,18 +92,20 @@ int Logcat::PrintLogLine(const AndroidLogEntry &entry, FILE *out) {
 }
 
 void Logcat::RefreshFd(bool is_verbose) {
+    constexpr const char *start_info = "----%" PRId64 "-%zu start----\n";
+    constexpr const char *stop_info = "----%" PRId64 "-%zu end----\n";
     if (is_verbose) {
         verbose_print_count_ = 0;
-        fprintf(verbose_file_.get(), "----%s-%zu end----\n", id_.data(), verbose_file_part_);
+        fprintf(verbose_file_.get(), stop_info, logger_id_, verbose_file_part_);
-        verbose_file_ = UniqueFile(env_->CallIntMethod(thiz_, refresh_fd_method_, JNI_TRUE), "a");
+        verbose_file_ = UniqueFile(env_->CallIntMethod(thiz_, refresh_fd_method_, JNI_TRUE), "w");
         verbose_file_part_++;
-        fprintf(verbose_file_.get(), "----%s-%zu start----\n", id_.data(), verbose_file_part_);
+        fprintf(verbose_file_.get(), start_info, logger_id_, verbose_file_part_);
     } else {
         modules_print_count_ = 0;
-        fprintf(modules_file_.get(), "----%zu end----\n", modules_file_part_);
+        fprintf(modules_file_.get(), stop_info, logger_id_, modules_file_part_);
-        modules_file_ = UniqueFile(env_->CallIntMethod(thiz_, refresh_fd_method_, JNI_FALSE), "a");
+        modules_file_ = UniqueFile(env_->CallIntMethod(thiz_, refresh_fd_method_, JNI_FALSE), "w");
         modules_file_part_++;
-        fprintf(modules_file_.get(), "----%zu start----\n", modules_file_part_);
+        fprintf(modules_file_.get(), start_info, logger_id_, modules_file_part_);
     }
 }
 
@@ -122,12 +126,11 @@ void Logcat::ProcessBuffer(struct log_msg *buf) {
         verbose_print_count_ += PrintLogLine(entry, verbose_file_.get());
     }
     if (entry.pid == getpid() && tag == "LSPosedLogcat") [[unlikely]] {
-        if (std::string_view(entry.message).starts_with(start_verbose_inst_)) {
+        if (std::string_view(entry.message) == stop_verbose_inst_) {
-            verbose_ = true;
-            RefreshFd(true);
-            id_ = std::string(entry.message, start_verbose_inst_.length(), std::string::npos);
-        } else if (std::string_view(entry.message) == stop_verbose_inst_ + id_) {
             verbose_ = false;
+        } else if (std::string_view(entry.message) == start_verbose_inst_) {
+            RefreshFd(true);
+            verbose_ = true;
         }
     }
 }
@@ -169,9 +172,9 @@ void Logcat::Run() {
 extern "C"
 JNIEXPORT void JNICALL
 // NOLINTNEXTLINE
-Java_org_lsposed_lspd_service_LogcatService_runLogcat(JNIEnv *env, jobject thiz) {
+Java_org_lsposed_lspd_service_LogcatService_runLogcat(JNIEnv *env, jobject thiz, jlong logger_id) {
     jclass clazz = env->GetObjectClass(thiz);
     jmethodID method = env->GetMethodID(clazz, "refreshFd", "(Z)I");
-    Logcat logcat(env, thiz, method);
+    Logcat logcat(env, thiz, method, logger_id);
     logcat.Run();
 }

core/src/main/java/org/lsposed/lspd/service/LogcatService.java

@@ -18,7 +18,6 @@ public class LogcatService implements Runnable {
     private File modulesLog = null;
     private File verboseLog = null;
     private Thread thread = null;
-    private int id = 0;
 
     @SuppressLint("UnsafeDynamicallyLoadedCode")
     public LogcatService() {
@@ -26,12 +25,12 @@ public class LogcatService implements Runnable {
         System.load(libraryPath + "/" + System.mapLibraryName("daemon"));
     }
 
-    private native void runLogcat();
+    private native void runLogcat(long loggerId);
 
     @Override
     public void run() {
         Log.i(TAG, "start running");
-        runLogcat();
+        runLogcat(thread.getId());
         Log.i(TAG, "stoped");
     }
 
@@ -46,7 +45,6 @@ public class LogcatService implements Runnable {
             log = modulesLog;
         }
         try (var fd = ParcelFileDescriptor.open(log, mode)) {
-            Log.i(TAG, "New " + (isVerboseLog ? "verbose log" : "modules log") + " file: " + log);
             return fd.detachFd();
         } catch (IOException e) {
             Log.w(TAG, "someone chattr +i ?", e);
@@ -71,12 +69,11 @@ public class LogcatService implements Runnable {
     }
 
     public void startVerbose() {
-        Log.i(TAG, "!!start_verbose!!" + id);
+        Log.i(TAG, "!!start_verbose!!" + thread.getId());
     }
 
     public void stopVerbose() {
-        Log.i(TAG, "!!stop_verbose!!" + id);
+        Log.i(TAG, "!!stop_verbose!!" + thread.getId());
-        id++;
     }
 
     @Nullable