atproto pds in zig
pds.zat.dev
pds
atproto
Tune subscribeRepos guard
+2
-2
+2
-2
src/atproto/sync.zig
+2
-2
src/atproto/sync.zig
···
7
7
8
8
const http = std.http;
9
9
10
-
const max_subscribe_repos_connections = 4;
10
+
const max_subscribe_repos_connections = 32;
11
11
const subscribe_repos_idle_limit = 30;
12
12
var subscribe_repos_connections: usize = 0;
13
13
···
118
118
const active = @atomicRmw(usize, &subscribe_repos_connections, .Add, 1, .monotonic);
119
119
if (active >= max_subscribe_repos_connections) {
120
120
_ = @atomicRmw(usize, &subscribe_repos_connections, .Sub, 1, .monotonic);
121
-
log.err("sync subscribeRepos rejected too_many_connections active={d} max={d}\n", .{ active + 1, max_subscribe_repos_connections });
121
+
log.debug("sync subscribeRepos rejected too_many_connections active={d} max={d}\n", .{ active + 1, max_subscribe_repos_connections });
122
122
return http_api.xrpcError(request, .too_many_requests, "RateLimitExceeded", "too many subscribeRepos connections");
123
123
}
124
124
defer _ = @atomicRmw(usize, &subscribe_repos_connections, .Sub, 1, .monotonic);