|
|
|
@@ -21,6 +21,10 @@
|
|
|
|
|
|
|
|
|
|
#include "el_runtime.h"
|
|
|
|
|
|
|
|
|
|
#ifdef _WIN32
|
|
|
|
|
/* Windows OS-boundary shim (winsock/dlsym/popen). Threading stays on <pthread.h> (winpthreads). */
|
|
|
|
|
#include "el_platform_win.h"
|
|
|
|
|
#else
|
|
|
|
|
#include <stdarg.h>
|
|
|
|
|
#include <strings.h> /* strcasecmp */
|
|
|
|
|
#include <stdint.h>
|
|
|
|
@@ -43,6 +47,10 @@
|
|
|
|
|
#include <errno.h>
|
|
|
|
|
#include <pthread.h>
|
|
|
|
|
#include <sys/resource.h> /* getrusage — memory guard */
|
|
|
|
|
/* On POSIX, sockets close with the same close() as files; el_platform_win.h supplies the Windows
|
|
|
|
|
variant. Defined here so the socket call sites are identical across platforms. */
|
|
|
|
|
static inline int el_closesocket(int s) { return close(s); }
|
|
|
|
|
#endif
|
|
|
|
|
#ifdef HAVE_CURL
|
|
|
|
|
#include <curl/curl.h>
|
|
|
|
|
#endif
|
|
|
|
@@ -1054,7 +1062,6 @@ el_val_t http_post_to_file(el_val_t url, el_val_t body, el_val_t headers_map, el
|
|
|
|
|
|
|
|
|
|
#define HTTP_MAX_CONNS 64
|
|
|
|
|
|
|
|
|
|
typedef el_val_t (*http_handler_fn)(el_val_t method, el_val_t path, el_val_t body);
|
|
|
|
|
|
|
|
|
|
typedef struct {
|
|
|
|
|
char* name;
|
|
|
|
@@ -1529,12 +1536,20 @@ static void http_send_response(int fd, const char* body) {
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
typedef struct {
|
|
|
|
|
#ifdef _WIN32
|
|
|
|
|
SOCKET fd;
|
|
|
|
|
#else
|
|
|
|
|
int fd;
|
|
|
|
|
#endif
|
|
|
|
|
} HttpWorkerArg;
|
|
|
|
|
|
|
|
|
|
static void* http_worker(void* arg) {
|
|
|
|
|
HttpWorkerArg* a = (HttpWorkerArg*)arg;
|
|
|
|
|
#ifdef _WIN32
|
|
|
|
|
SOCKET fd = a->fd;
|
|
|
|
|
#else
|
|
|
|
|
int fd = a->fd;
|
|
|
|
|
#endif
|
|
|
|
|
free(a);
|
|
|
|
|
char *method = NULL, *path = NULL, *body = NULL;
|
|
|
|
|
if (http_read_request(fd, &method, &path, &body, NULL) == 0) {
|
|
|
|
@@ -1566,7 +1581,7 @@ static void* http_worker(void* arg) {
|
|
|
|
|
free(response);
|
|
|
|
|
}
|
|
|
|
|
free(method); free(path); free(body);
|
|
|
|
|
close(fd);
|
|
|
|
|
el_closesocket(fd);
|
|
|
|
|
/* release a slot */
|
|
|
|
|
pthread_mutex_lock(&_http_conn_mu);
|
|
|
|
|
_http_conn_active--;
|
|
|
|
@@ -1588,22 +1603,26 @@ el_val_t http_serve(el_val_t port, el_val_t handler) {
|
|
|
|
|
int sock = socket(AF_INET6, SOCK_STREAM, 0);
|
|
|
|
|
if (sock < 0) { perror("socket"); return 0; }
|
|
|
|
|
int yes = 1; int no = 0;
|
|
|
|
|
setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, &yes, sizeof(yes));
|
|
|
|
|
setsockopt(sock, IPPROTO_IPV6, IPV6_V6ONLY, &no, sizeof(no));
|
|
|
|
|
setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, (const char*)&yes, sizeof(yes));
|
|
|
|
|
setsockopt(sock, IPPROTO_IPV6, IPV6_V6ONLY, (const char*)&no, sizeof(no));
|
|
|
|
|
struct sockaddr_in6 addr;
|
|
|
|
|
memset(&addr, 0, sizeof(addr));
|
|
|
|
|
addr.sin6_family = AF_INET6;
|
|
|
|
|
addr.sin6_addr = in6addr_any;
|
|
|
|
|
addr.sin6_port = htons((uint16_t)p);
|
|
|
|
|
if (bind(sock, (struct sockaddr*)&addr, sizeof(addr)) < 0) {
|
|
|
|
|
perror("bind"); close(sock); return 0;
|
|
|
|
|
perror("bind"); el_closesocket(sock); return 0;
|
|
|
|
|
}
|
|
|
|
|
if (listen(sock, 64) < 0) { perror("listen"); close(sock); return 0; }
|
|
|
|
|
if (listen(sock, 64) < 0) { perror("listen"); el_closesocket(sock); return 0; }
|
|
|
|
|
fprintf(stderr, "[http] listening on [::]:%d (dual-stack)\n", p);
|
|
|
|
|
while (1) {
|
|
|
|
|
struct sockaddr_in6 cli;
|
|
|
|
|
socklen_t clen = sizeof(cli);
|
|
|
|
|
#ifdef _WIN32
|
|
|
|
|
SOCKET cfd = accept(sock, (struct sockaddr*)&cli, &clen);
|
|
|
|
|
#else
|
|
|
|
|
int cfd = accept(sock, (struct sockaddr*)&cli, &clen);
|
|
|
|
|
#endif
|
|
|
|
|
if (cfd < 0) {
|
|
|
|
|
if (errno == EINTR) continue;
|
|
|
|
|
perror("accept"); break;
|
|
|
|
@@ -1615,11 +1634,11 @@ el_val_t http_serve(el_val_t port, el_val_t handler) {
|
|
|
|
|
_http_conn_active++;
|
|
|
|
|
pthread_mutex_unlock(&_http_conn_mu);
|
|
|
|
|
HttpWorkerArg* arg = malloc(sizeof(HttpWorkerArg));
|
|
|
|
|
if (!arg) { close(cfd); continue; }
|
|
|
|
|
if (!arg) { el_closesocket(cfd); continue; }
|
|
|
|
|
arg->fd = cfd;
|
|
|
|
|
pthread_t tid;
|
|
|
|
|
if (pthread_create(&tid, NULL, http_worker, arg) != 0) {
|
|
|
|
|
close(cfd); free(arg);
|
|
|
|
|
el_closesocket(cfd); free(arg);
|
|
|
|
|
pthread_mutex_lock(&_http_conn_mu);
|
|
|
|
|
_http_conn_active--;
|
|
|
|
|
pthread_cond_signal(&_http_conn_cv);
|
|
|
|
@@ -1628,7 +1647,7 @@ el_val_t http_serve(el_val_t port, el_val_t handler) {
|
|
|
|
|
}
|
|
|
|
|
pthread_detach(tid);
|
|
|
|
|
}
|
|
|
|
|
close(sock);
|
|
|
|
|
el_closesocket(sock);
|
|
|
|
|
return 0;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
@@ -1649,8 +1668,6 @@ el_val_t http_serve(el_val_t port, el_val_t handler) {
|
|
|
|
|
* separate active-handler slot, separate dlsym fallback. Mixing v1 and v2
|
|
|
|
|
* handlers in the same process is fine — they don't share the active slot. */
|
|
|
|
|
|
|
|
|
|
typedef el_val_t (*http_handler4_fn)(el_val_t method, el_val_t path,
|
|
|
|
|
el_val_t headers_map, el_val_t body);
|
|
|
|
|
|
|
|
|
|
typedef struct {
|
|
|
|
|
char* name;
|
|
|
|
@@ -1786,7 +1803,11 @@ static el_val_t http_build_headers_map(const char* hdr_block) {
|
|
|
|
|
|
|
|
|
|
static void* http_worker_v2(void* arg) {
|
|
|
|
|
HttpWorkerArg* a = (HttpWorkerArg*)arg;
|
|
|
|
|
#ifdef _WIN32
|
|
|
|
|
SOCKET fd = a->fd;
|
|
|
|
|
#else
|
|
|
|
|
int fd = a->fd;
|
|
|
|
|
#endif
|
|
|
|
|
free(a);
|
|
|
|
|
char *method = NULL, *path = NULL, *body = NULL, *hdr_block = NULL;
|
|
|
|
|
if (http_read_request(fd, &method, &path, &body, &hdr_block) == 0) {
|
|
|
|
@@ -1816,7 +1837,7 @@ static void* http_worker_v2(void* arg) {
|
|
|
|
|
free(response);
|
|
|
|
|
}
|
|
|
|
|
free(method); free(path); free(body); free(hdr_block);
|
|
|
|
|
close(fd);
|
|
|
|
|
el_closesocket(fd);
|
|
|
|
|
pthread_mutex_lock(&_http_conn_mu);
|
|
|
|
|
_http_conn_active--;
|
|
|
|
|
pthread_cond_signal(&_http_conn_cv);
|
|
|
|
@@ -1838,22 +1859,26 @@ el_val_t http_serve_v2(el_val_t port, el_val_t handler) {
|
|
|
|
|
int sock = socket(AF_INET6, SOCK_STREAM, 0);
|
|
|
|
|
if (sock < 0) { perror("socket"); return 0; }
|
|
|
|
|
int yes = 1; int no = 0;
|
|
|
|
|
setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, &yes, sizeof(yes));
|
|
|
|
|
setsockopt(sock, IPPROTO_IPV6, IPV6_V6ONLY, &no, sizeof(no));
|
|
|
|
|
setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, (const char*)&yes, sizeof(yes));
|
|
|
|
|
setsockopt(sock, IPPROTO_IPV6, IPV6_V6ONLY, (const char*)&no, sizeof(no));
|
|
|
|
|
struct sockaddr_in6 addr;
|
|
|
|
|
memset(&addr, 0, sizeof(addr));
|
|
|
|
|
addr.sin6_family = AF_INET6;
|
|
|
|
|
addr.sin6_addr = in6addr_any;
|
|
|
|
|
addr.sin6_port = htons((uint16_t)p);
|
|
|
|
|
if (bind(sock, (struct sockaddr*)&addr, sizeof(addr)) < 0) {
|
|
|
|
|
perror("bind"); close(sock); return 0;
|
|
|
|
|
perror("bind"); el_closesocket(sock); return 0;
|
|
|
|
|
}
|
|
|
|
|
if (listen(sock, 64) < 0) { perror("listen"); close(sock); return 0; }
|
|
|
|
|
if (listen(sock, 64) < 0) { perror("listen"); el_closesocket(sock); return 0; }
|
|
|
|
|
fprintf(stderr, "[http v2] listening on [::]:%d (dual-stack)\n", p);
|
|
|
|
|
while (1) {
|
|
|
|
|
struct sockaddr_in6 cli;
|
|
|
|
|
socklen_t clen = sizeof(cli);
|
|
|
|
|
#ifdef _WIN32
|
|
|
|
|
SOCKET cfd = accept(sock, (struct sockaddr*)&cli, &clen);
|
|
|
|
|
#else
|
|
|
|
|
int cfd = accept(sock, (struct sockaddr*)&cli, &clen);
|
|
|
|
|
#endif
|
|
|
|
|
if (cfd < 0) {
|
|
|
|
|
if (errno == EINTR) continue;
|
|
|
|
|
perror("accept"); break;
|
|
|
|
@@ -1865,11 +1890,11 @@ el_val_t http_serve_v2(el_val_t port, el_val_t handler) {
|
|
|
|
|
_http_conn_active++;
|
|
|
|
|
pthread_mutex_unlock(&_http_conn_mu);
|
|
|
|
|
HttpWorkerArg* arg = malloc(sizeof(HttpWorkerArg));
|
|
|
|
|
if (!arg) { close(cfd); continue; }
|
|
|
|
|
if (!arg) { el_closesocket(cfd); continue; }
|
|
|
|
|
arg->fd = cfd;
|
|
|
|
|
pthread_t tid;
|
|
|
|
|
if (pthread_create(&tid, NULL, http_worker_v2, arg) != 0) {
|
|
|
|
|
close(cfd); free(arg);
|
|
|
|
|
el_closesocket(cfd); free(arg);
|
|
|
|
|
pthread_mutex_lock(&_http_conn_mu);
|
|
|
|
|
_http_conn_active--;
|
|
|
|
|
pthread_cond_signal(&_http_conn_cv);
|
|
|
|
@@ -1878,7 +1903,7 @@ el_val_t http_serve_v2(el_val_t port, el_val_t handler) {
|
|
|
|
|
}
|
|
|
|
|
pthread_detach(tid);
|
|
|
|
|
}
|
|
|
|
|
close(sock);
|
|
|
|
|
el_closesocket(sock);
|
|
|
|
|
return 0;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
@@ -2129,6 +2154,23 @@ el_val_t exec(el_val_t cmdv) {
|
|
|
|
|
el_val_t exec_bg(el_val_t cmdv) {
|
|
|
|
|
const char* cmd = EL_CSTR(cmdv);
|
|
|
|
|
if (!cmd || !*cmd) return el_wrap_str(el_strdup(""));
|
|
|
|
|
#ifdef _WIN32
|
|
|
|
|
/* Windows: no fork/exec. Launch a detached `cmd /c <command>` with no console window via
|
|
|
|
|
CreateProcess (DETACHED_PROCESS | CREATE_NO_WINDOW). Returns the PID as a string, "" on fail.
|
|
|
|
|
Mirrors the POSIX branch: child runs independently, caller is not blocked. */
|
|
|
|
|
char cmdline[8192];
|
|
|
|
|
snprintf(cmdline, sizeof(cmdline), "cmd.exe /c %s", cmd);
|
|
|
|
|
STARTUPINFOA si; ZeroMemory(&si, sizeof(si)); si.cb = sizeof(si);
|
|
|
|
|
PROCESS_INFORMATION pi; ZeroMemory(&pi, sizeof(pi));
|
|
|
|
|
BOOL ok = CreateProcessA(NULL, cmdline, NULL, NULL, FALSE,
|
|
|
|
|
DETACHED_PROCESS | CREATE_NO_WINDOW, NULL, NULL, &si, &pi);
|
|
|
|
|
if (!ok) return el_wrap_str(el_strdup(""));
|
|
|
|
|
char pidbuf[32];
|
|
|
|
|
snprintf(pidbuf, sizeof(pidbuf), "%lu", (unsigned long)pi.dwProcessId);
|
|
|
|
|
CloseHandle(pi.hProcess);
|
|
|
|
|
CloseHandle(pi.hThread);
|
|
|
|
|
return el_wrap_str(el_strdup(pidbuf));
|
|
|
|
|
#else
|
|
|
|
|
pid_t pid = fork();
|
|
|
|
|
if (pid < 0) {
|
|
|
|
|
/* fork failed */
|
|
|
|
@@ -2151,6 +2193,7 @@ el_val_t exec_bg(el_val_t cmdv) {
|
|
|
|
|
char pidbuf[32];
|
|
|
|
|
snprintf(pidbuf, sizeof(pidbuf), "%d", (int)pid);
|
|
|
|
|
return el_wrap_str(el_strdup(pidbuf));
|
|
|
|
|
#endif
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
el_val_t fs_list(el_val_t pathv) {
|
|
|
|
@@ -4478,7 +4521,12 @@ static int _el_decompose_earth(el_caltime_t* ct, struct tm* tm_out, int* abbr_le
|
|
|
|
|
localtime_r(&s, &tm);
|
|
|
|
|
*tm_out = tm;
|
|
|
|
|
if (abbr_buf && abbr_cap > 0) {
|
|
|
|
|
/* mingw's struct tm has no tm_zone (BSD/glibc extension); no abbrev available there. */
|
|
|
|
|
#ifdef _WIN32
|
|
|
|
|
const char* z_str = "";
|
|
|
|
|
#else
|
|
|
|
|
const char* z_str = tm.tm_zone ? tm.tm_zone : "";
|
|
|
|
|
#endif
|
|
|
|
|
size_t n = strlen(z_str);
|
|
|
|
|
if (n >= abbr_cap) n = abbr_cap - 1;
|
|
|
|
|
memcpy(abbr_buf, z_str, n);
|
|
|
|
@@ -6031,6 +6079,14 @@ void el_cgi_init(el_val_t name, el_val_t dharma_id, el_val_t principal,
|
|
|
|
|
#define ENGRAM_LAYER_DOMAIN 2u
|
|
|
|
|
#define ENGRAM_LAYER_IMPRINT 3u
|
|
|
|
|
#define ENGRAM_LAYER_SUIT 4u
|
|
|
|
|
#define ENGRAM_LAYER_ACCUMULATION 5u
|
|
|
|
|
/* New user-facing nodes (memories, knowledge, conversations) are created in the
|
|
|
|
|
* accumulation layer — the top of the consciousness stack, the engram the user
|
|
|
|
|
* sees; every layer below shapes behavior but is hidden from the user (Layered
|
|
|
|
|
* Consciousness architecture, app 64/064,262). ENGRAM_LAYER_DEFAULT stays
|
|
|
|
|
* core-identity ON PURPOSE: it is the fallback home for LEGACY nodes loaded from
|
|
|
|
|
* snapshots without a layer_id, so existing data (the originator corpus) is
|
|
|
|
|
* never migrated out of its established layer. New != legacy. */
|
|
|
|
|
#define ENGRAM_LAYER_DEFAULT ENGRAM_LAYER_CORE_IDENTITY
|
|
|
|
|
|
|
|
|
|
/* Pass 3 override floor. Layer 0 nodes that received any background
|
|
|
|
@@ -6208,6 +6264,20 @@ static void engram_init_layers(EngramStore* g) {
|
|
|
|
|
.transparent = 0,
|
|
|
|
|
.injectable = 1
|
|
|
|
|
};
|
|
|
|
|
/* Layer 5 — accumulation. The TOP of the consciousness stack: the default
|
|
|
|
|
* home for all new user-facing nodes. This is the engram the user sees;
|
|
|
|
|
* every layer below shapes behavior but is hidden from the user. Not
|
|
|
|
|
* injectable — it is the persistent user accumulation, not a swappable
|
|
|
|
|
* overlay. transparent=0: its content is surfaced to introspection (it is
|
|
|
|
|
* the user's own knowledge/memory), unlike the lower behavioral layers. */
|
|
|
|
|
g->layers[g->layer_count++] = (EngramLayer){
|
|
|
|
|
.layer_id = ENGRAM_LAYER_ACCUMULATION,
|
|
|
|
|
.name = el_strdup_persist("accumulation"),
|
|
|
|
|
.activation_priority = 50,
|
|
|
|
|
.suppressible = 1,
|
|
|
|
|
.transparent = 0,
|
|
|
|
|
.injectable = 0
|
|
|
|
|
};
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
static EngramStore* engram_get(void) {
|
|
|
|
@@ -6322,7 +6392,9 @@ static void engram_grow_edges(void) {
|
|
|
|
|
static char* engram_new_id(void) {
|
|
|
|
|
el_val_t v = uuid_new();
|
|
|
|
|
const char* s = EL_CSTR(v);
|
|
|
|
|
return el_strdup(s ? s : "");
|
|
|
|
|
/* Persistent: node ids live in the global store; an arena (el_strdup) id is
|
|
|
|
|
* freed at el_request_end(), corrupting the node after the creating request. */
|
|
|
|
|
return el_strdup_persist(s ? s : "");
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/* Convert a node into an ElMap of its fields. */
|
|
|
|
@@ -6399,7 +6471,7 @@ el_val_t engram_node(el_val_t content, el_val_t node_type, el_val_t salience) {
|
|
|
|
|
n->last_activated = now;
|
|
|
|
|
n->created_at = now;
|
|
|
|
|
n->updated_at = now;
|
|
|
|
|
n->layer_id = ENGRAM_LAYER_DEFAULT;
|
|
|
|
|
n->layer_id = ENGRAM_LAYER_ACCUMULATION; /* new user-facing node → top layer */
|
|
|
|
|
g->node_count++;
|
|
|
|
|
return el_wrap_str(el_strdup(n->id));
|
|
|
|
|
}
|
|
|
|
@@ -6417,12 +6489,17 @@ el_val_t engram_node_full(el_val_t content, el_val_t node_type, el_val_t label,
|
|
|
|
|
const char* lb = EL_CSTR(label);
|
|
|
|
|
const char* ti = EL_CSTR(tier);
|
|
|
|
|
const char* tg = EL_CSTR(tags);
|
|
|
|
|
n->content = el_strdup(c ? c : "");
|
|
|
|
|
n->node_type = el_strdup(nt && *nt ? nt : "Memory");
|
|
|
|
|
n->label = el_strdup(lb && *lb ? lb : (c ? engram_first_n_chars(c, 60) : ""));
|
|
|
|
|
n->tier = el_strdup(ti && *ti ? ti : "Working");
|
|
|
|
|
n->tags = el_strdup(tg ? tg : "");
|
|
|
|
|
n->metadata = el_strdup("{}");
|
|
|
|
|
/* Persistent (el_strdup_persist, NOT el_strdup): these strings are owned by the
|
|
|
|
|
* persistent global node store. el_strdup tracks into the per-request arena, which
|
|
|
|
|
* el_request_end() frees when the creating HTTP request completes — leaving the
|
|
|
|
|
* stored node with dangling pointers (corrupted ids, "saved but never listed").
|
|
|
|
|
* This is the root cause of the hallucinated/lost-saves class of bugs. */
|
|
|
|
|
n->content = el_strdup_persist(c ? c : "");
|
|
|
|
|
n->node_type = el_strdup_persist(nt && *nt ? nt : "Memory");
|
|
|
|
|
n->label = el_strdup_persist(lb && *lb ? lb : (c ? engram_first_n_chars(c, 60) : ""));
|
|
|
|
|
n->tier = el_strdup_persist(ti && *ti ? ti : "Working");
|
|
|
|
|
n->tags = el_strdup_persist(tg ? tg : "");
|
|
|
|
|
n->metadata = el_strdup_persist("{}");
|
|
|
|
|
n->salience = engram_decode_score(salience);
|
|
|
|
|
n->importance = engram_decode_score(importance);
|
|
|
|
|
n->confidence = engram_decode_score(confidence);
|
|
|
|
@@ -6435,7 +6512,7 @@ el_val_t engram_node_full(el_val_t content, el_val_t node_type, el_val_t label,
|
|
|
|
|
n->last_activated = now;
|
|
|
|
|
n->created_at = now;
|
|
|
|
|
n->updated_at = now;
|
|
|
|
|
n->layer_id = ENGRAM_LAYER_DEFAULT;
|
|
|
|
|
n->layer_id = ENGRAM_LAYER_ACCUMULATION; /* new user-facing node → top layer */
|
|
|
|
|
g->node_count++;
|
|
|
|
|
return el_wrap_str(el_strdup(n->id));
|
|
|
|
|
}
|
|
|
|
@@ -7365,13 +7442,28 @@ el_val_t engram_save(el_val_t path) {
|
|
|
|
|
jb_putc(&b, '}');
|
|
|
|
|
}
|
|
|
|
|
jb_puts(&b, "]}");
|
|
|
|
|
FILE* f = fopen(p, "wb");
|
|
|
|
|
if (!f) { free(b.buf); return 0; }
|
|
|
|
|
{
|
|
|
|
|
struct stat _st;
|
|
|
|
|
if (stat(p, &_st) == 0 && _st.st_size > 200000 &&
|
|
|
|
|
(uint64_t)b.len < (uint64_t)_st.st_size / 16) {
|
|
|
|
|
fprintf(stderr, "[engram_save] REFUSED sparse write: new %zu vs existing %lld (<1/16) protecting %s\n",
|
|
|
|
|
b.len, (long long)_st.st_size, p);
|
|
|
|
|
free(b.buf); return 0;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
size_t _plen = strlen(p);
|
|
|
|
|
char* _tmp = (char*)malloc(_plen + 5);
|
|
|
|
|
if (!_tmp) { free(b.buf); return 0; }
|
|
|
|
|
memcpy(_tmp, p, _plen); memcpy(_tmp + _plen, ".tmp", 5);
|
|
|
|
|
FILE* f = fopen(_tmp, "wb");
|
|
|
|
|
if (!f) { free(_tmp); free(b.buf); return 0; }
|
|
|
|
|
size_t w = fwrite(b.buf, 1, b.len, f);
|
|
|
|
|
fclose(f);
|
|
|
|
|
int ok = (w == b.len);
|
|
|
|
|
free(b.buf);
|
|
|
|
|
return ok ? 1 : 0;
|
|
|
|
|
int wok = (w == b.len);
|
|
|
|
|
if (wok) { fflush(f); fsync(fileno(f)); }
|
|
|
|
|
fclose(f); free(b.buf);
|
|
|
|
|
if (!wok) { unlink(_tmp); free(_tmp); return 0; }
|
|
|
|
|
if (rename(_tmp, p) != 0) { unlink(_tmp); free(_tmp); return 0; }
|
|
|
|
|
free(_tmp); return 1;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/* Helper: extract a string field from a JSON object substring. */
|
|
|
|
|