From 3b64e0bf2057a1662ddb18fc28b3a089f1046089 Mon Sep 17 00:00:00 2001
From: Recolic <git@me.recolic.net>
Date: Wed, 19 Feb 2025 21:20:30 -0800
Subject: [PATCH] .
---
fish-config/functions/p.fish | 3 +
mybin/ban-xunlei-d.sh | 9 ++
rflog2.h | 173 +++++++++++++++++++++++++++++++++++
3 files changed, 185 insertions(+)
create mode 100644 rflog2.h
diff --git a/fish-config/functions/p.fish b/fish-config/functions/p.fish
index a76f478..d22d334 100644
--- a/fish-config/functions/p.fish
+++ b/fish-config/functions/p.fish
@@ -3,6 +3,9 @@ function p --description 'proxychains with port 10809 / 10829'
if test (count $argv) != 0 ; and test $argv[1] = h
echo "PORT 10829" >&2
proxychains-with-port.sh 10829 $argv[2..]
+ else if test (count $argv) != 0 ; and test $argv[1] = 8
+ echo "PORT 10808" >&2
+ proxychains-with-port.sh 10808 $argv[2..]
else if test (count $argv) != 0 ; and test $argv[1] = 9
echo "PORT 10809" >&2
proxychains-with-port.sh 10809 $argv[2..]
diff --git a/mybin/ban-xunlei-d.sh b/mybin/ban-xunlei-d.sh
index 4c72436..f7ea9c6 100755
--- a/mybin/ban-xunlei-d.sh
+++ b/mybin/ban-xunlei-d.sh
@@ -18,6 +18,15 @@ function curl_wrapped () {
curl -s "$@" || echo "Warning: CURL $@ failed with error code $?" 1>&2
}
+function show_mercy () {
+ # This is only valid after NEXT qBitTorrent restart
+ local conf_path="$USER/.config/qBittorrent/qBittorrent.conf"
+ [[ -f "$conf_path" ]] && sed -i 's/^BannedIPs=[, ]*[0-9a-f].*$/BannedIPs=/' "$conf_path"
+}
+
+echo "Unban all banned client, because IP might be reused by legit users... (valid after NEXT qBitTorrent startup)"
+show_mercy
+
echo "Checking all peers every 5 seconds..."
while true; do
tasks=`curl_wrapped "$api_endpoint/sync/maindata?rid=0" | grep -oE '"[0-9a-f]{40}"' | tr -d '"' | sort | uniq`
diff --git a/rflog2.h b/rflog2.h
new file mode 100644
index 0000000..bfb9300
--- /dev/null
+++ b/rflog2.h
@@ -0,0 +1,173 @@
+// GPT-4o generated. NOT thread safe.
+// v2502.1
+#ifndef SIMPLE_LOGGER_H
+#define SIMPLE_LOGGER_H
+
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <time.h>
+
+#if defined(_WIN32) && defined(NTDDI_VERSION)
+#include <ntddk.h>
+#include <ntstrsafe.h> // For RtlStringCbPrintfA
+#include <wdf.h> // For TCP conn
+#include <winsock2.h> // For TCP conn
+#define RL_SNPRINTF_FUNC RtlStringCbPrintfA
+#define RL_LOG_FILE_PATH "N/A"
+#elif defined(_WIN32)
+#include <windows.h>
+#define RL_SNPRINTF_FUNC snprintf
+#define RL_LOG_FILE_PATH "C:\\rflog.txt"
+#else
+#include <sys/time.h>
+#define RL_SNPRINTF_FUNC snprintf
+#define RL_LOG_FILE_PATH "/tmp/rflog.txt"
+#endif
+
+#ifdef __GNUC__
+#define RL_THREAD_LOC __thread
+#define RL_UNUSED __attribute__ ((unused))
+#else
+#define RL_THREAD_LOC /*__declspec( thread ) Not Supported*/
+#define RL_UNUSED
+#endif
+
+// Define static buffers
+#define RL_DATETIME_BUFFER_SIZE 64
+#define RL_LOG_BUFFER_SIZE 512
+
+// Static buffers for reduced memory allocation. NOT THREAD SAFE!!
+static RL_THREAD_LOC char datetime_buffer[RL_DATETIME_BUFFER_SIZE];
+static RL_THREAD_LOC char log_buffer[RL_LOG_BUFFER_SIZE];
+#if defined(_WIN32) && defined(NTDDI_VERSION)
+static RL_THREAD_LOC WCHAR wideBuffer[RL_LOG_BUFFER_SIZE];
+#endif
+
+RL_UNUSED static const char *get_current_datetime() {
+#if defined(_WIN32) && defined(NTDDI_VERSION)
+ // Windows kernel-mode implementation
+ LARGE_INTEGER system_time, local_time;
+ TIME_FIELDS time_fields;
+
+ KeQuerySystemTime(&system_time);
+ ExSystemTimeToLocalTime(&system_time, &local_time);
+ RtlTimeToTimeFields(&local_time, &time_fields);
+
+ // Format the datetime string
+ RL_SNPRINTF_FUNC (datetime_buffer, RL_DATETIME_BUFFER_SIZE,
+ "%04d-%02d-%02d %02d:%02d:%02d.%03d",
+ time_fields.Year, time_fields.Month, time_fields.Day,
+ time_fields.Hour, time_fields.Minute, time_fields.Second, 0); // No millisecond precision in kernel
+#else
+ // User-mode implementation
+ #ifdef _WIN32
+ SYSTEMTIME st;
+ GetLocalTime(&st);
+ snprintf(datetime_buffer, RL_DATETIME_BUFFER_SIZE, "%04d-%02d-%02d %02d:%02d:%02d.%03d",
+ st.wYear, st.wMonth, st.wDay, st.wHour, st.wMinute, st.wSecond, st.wMilliseconds);
+ #else
+ // Linux or other Unix-like systems
+ struct timeval tv;
+ struct tm *tm_info;
+ gettimeofday(&tv, NULL);
+ tm_info = localtime(&tv.tv_sec);
+ snprintf(datetime_buffer, RL_DATETIME_BUFFER_SIZE, "%04d-%02d-%02d %02d:%02d:%02d.%03ld",
+ tm_info->tm_year + 1900, tm_info->tm_mon + 1, tm_info->tm_mday,
+ tm_info->tm_hour, tm_info->tm_min, tm_info->tm_sec, tv.tv_usec / 1000);
+ #endif
+#endif
+ return datetime_buffer;
+}
+
+#if defined(_WIN32) && defined(NTDDI_VERSION)
+static SOCKET TcpTryConnect(int _close) {
+ static SOCKET sock = INVALID_SOCKET;
+ if (_close == 1) { // We want to close(), not connect()
+ closesocket(sock);
+ return (sock = INVALID_SOCKET);
+ }
+ if (sock != INVALID_SOCKET)
+ return sock; // Already connected
+
+ WSADATA wsaData;
+ if (WSAStartup(MAKEWORD(2, 2), &wsaData) != 0)
+ return sock;
+
+ sock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
+ if (sock == INVALID_SOCKET) {
+ WSACleanup();
+ return sock;
+ }
+
+ struct sockaddr_in sa;
+ sa.sin_family = AF_INET;
+ sa.sin_port = htons(30410);
+ sa.sin_addr.s_addr = inet_addr("127.0.0.1");
+
+ if (connect(sock, (struct sockaddr*)&sa, sizeof(sa)) == SOCKET_ERROR) {
+ closesocket(sock);
+ sock = INVALID_SOCKET;
+ WSACleanup();
+ }
+ return sock;
+}
+// Windows kernel-mode only
+static size_t NaiveStrlen(const char *str) {
+ if (!str) return 0;
+ size_t len = 0;
+ while (str[len]) len++;
+ return len;
+}
+#endif
+
+RL_UNUSED static void log_to_file(const char *message) {
+#if defined(_WIN32) && defined(NTDDI_VERSION)
+ // Windows kernel-mode: rfloga
+ SOCKET conn = TcpTryConnect(0);
+ if (conn == INVALID_SOCKET) {
+ TraceDtlsMiscTraceOnPort(NULL, L"rfloga_send: conn fail");
+ return;
+ }
+
+ uint64_t len = (uint64_t)NaiveStrlen(msg);
+ if (send(conn, (char*)&len, sizeof(len), 0) == SOCKET_ERROR || send(conn, msg, (int)len, 0) == SOCKET_ERROR) {
+ TraceDtlsMiscTraceOnPort(NULL, L"rfloga_send: send fail");
+ TcpTryConnect(1);
+ }
+#else
+ // User mode
+ FILE *file = fopen(RL_LOG_FILE_PATH, "a");
+ if (file) {
+ fprintf(file, "%s\n", message);
+ fclose(file);
+ } else {
+ fprintf(stderr, "Failed to open log file: %s\n", RL_LOG_FILE_PATH);
+ }
+#endif
+}
+
+
+RL_UNUSED static void rflogs(const char *message) {
+ RL_SNPRINTF_FUNC(log_buffer, RL_LOG_BUFFER_SIZE, "[%s] %s", get_current_datetime(), message);
+ log_to_file(log_buffer);
+}
+RL_UNUSED static void rflogsi(const char *message, int value) {
+ RL_SNPRINTF_FUNC(log_buffer, RL_LOG_BUFFER_SIZE, "[%s] %s: %d", get_current_datetime(), message, value);
+ log_to_file(log_buffer);
+}
+RL_UNUSED static void rflogsii(const char *message, int value, int i2) {
+ RL_SNPRINTF_FUNC(log_buffer, RL_LOG_BUFFER_SIZE, "[%s] %s: %d, %d", get_current_datetime(), message, value, i2);
+ log_to_file(log_buffer);
+}
+RL_UNUSED static void rflogsiip(const char *message, int value, int i2, void *ptr) {
+ RL_SNPRINTF_FUNC(log_buffer, RL_LOG_BUFFER_SIZE, "[%s] %s: %d, %d, %p", get_current_datetime(), message, value, i2, ptr);
+ log_to_file(log_buffer);
+}
+RL_UNUSED static void rflogss(const char *message1, const char *message2) {
+ RL_SNPRINTF_FUNC(log_buffer, RL_LOG_BUFFER_SIZE, "[%s] %s: %s", get_current_datetime(), message1, message2);
+ log_to_file(log_buffer);
+}
+
+#endif // SIMPLE_LOGGER_H
+
--
GitLab