annotate files/patch-src_apps_relay_hiredis__libevent2.c @ 33:e5d83559f2b5

Recreate patches. Major refactoring because paths have changed and the style of some source files has changed.
author Franz Glasner <fzglas.hg@dom66.de>
date Mon, 17 Mar 2025 11:17:31 +0100
parents files/patch-src_apps_common_hiredis__libevent2.c@4e4af36a675a
children
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
33
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
1 --- src/apps/relay/hiredis_libevent2.c.orig 2024-12-11 18:13:38 UTC
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
2 +++ src/apps/relay/hiredis_libevent2.c
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
3 @@ -52,6 +52,7 @@ struct redisLibeventEvents {
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
4 int port;
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
5 char *user;
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
6 char *pwd;
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
7 + char *usocket;
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
8 int db;
4
9a1ee735f28f Patch to allow redis connections by a Unix socket.
Franz Glasner <fzglas.hg@dom66.de>
parents:
diff changeset
9 };
9a1ee735f28f Patch to allow redis connections by a Unix socket.
Franz Glasner <fzglas.hg@dom66.de>
parents:
diff changeset
10
33
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
11 @@ -213,8 +214,10 @@ void send_message_to_redis(redis_context_handle rch, c
4
9a1ee735f28f Patch to allow redis connections by a Unix socket.
Franz Glasner <fzglas.hg@dom66.de>
parents:
diff changeset
12
9a1ee735f28f Patch to allow redis connections by a Unix socket.
Franz Glasner <fzglas.hg@dom66.de>
parents:
diff changeset
13 ///////////////////////// Attach /////////////////////////////////
9a1ee735f28f Patch to allow redis connections by a Unix socket.
Franz Glasner <fzglas.hg@dom66.de>
parents:
diff changeset
14
33
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
15 -redis_context_handle redisLibeventAttach(struct event_base *base, char *ip0, int port0, char *user, char *pwd, int db) {
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
16 +redis_context_handle redisLibeventAttach(struct event_base *base, char *ip0, int port0, char *usocket, char *user, char *pwd, int db) {
4
9a1ee735f28f Patch to allow redis connections by a Unix socket.
Franz Glasner <fzglas.hg@dom66.de>
parents:
diff changeset
17
33
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
18 + redisAsyncContext *ac = NULL;
4
9a1ee735f28f Patch to allow redis connections by a Unix socket.
Franz Glasner <fzglas.hg@dom66.de>
parents:
diff changeset
19 + char sockpath[256] = "\0";
9a1ee735f28f Patch to allow redis connections by a Unix socket.
Franz Glasner <fzglas.hg@dom66.de>
parents:
diff changeset
20 char ip[256];
33
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
21 if (ip0 && ip0[0]) {
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
22 STRCPY(ip, ip0);
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
23 @@ -227,7 +230,11 @@ redis_context_handle redisLibeventAttach(struct event_
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
24 port = port0;
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
25 }
4
9a1ee735f28f Patch to allow redis connections by a Unix socket.
Franz Glasner <fzglas.hg@dom66.de>
parents:
diff changeset
26
33
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
27 - redisAsyncContext *ac = redisAsyncConnect(ip, port);
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
28 + if(usocket && usocket[0]) {
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
29 + ac = redisAsyncConnectUnix(sockpath);
4
9a1ee735f28f Patch to allow redis connections by a Unix socket.
Franz Glasner <fzglas.hg@dom66.de>
parents:
diff changeset
30 + } else {
33
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
31 + ac = redisAsyncConnect(ip, port);
4
9a1ee735f28f Patch to allow redis connections by a Unix socket.
Franz Glasner <fzglas.hg@dom66.de>
parents:
diff changeset
32 + }
9a1ee735f28f Patch to allow redis connections by a Unix socket.
Franz Glasner <fzglas.hg@dom66.de>
parents:
diff changeset
33 if (!ac) {
33
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
34 fprintf(stderr, "Error: redisAsyncConnect returned NULL\n");
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
35 return NULL;
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
36 @@ -253,6 +260,9 @@ redis_context_handle redisLibeventAttach(struct event_
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
37 if (pwd) {
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
38 e->pwd = strdup(pwd);
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
39 }
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
40 + if (usocket) {
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
41 + e->usocket = strdup(usocket);
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
42 + }
4
9a1ee735f28f Patch to allow redis connections by a Unix socket.
Franz Glasner <fzglas.hg@dom66.de>
parents:
diff changeset
43 e->db = db;
9a1ee735f28f Patch to allow redis connections by a Unix socket.
Franz Glasner <fzglas.hg@dom66.de>
parents:
diff changeset
44
9a1ee735f28f Patch to allow redis connections by a Unix socket.
Franz Glasner <fzglas.hg@dom66.de>
parents:
diff changeset
45 /* Register functions to start/stop listening for events */
33
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
46 @@ -270,6 +280,16 @@ redis_context_handle redisLibeventAttach(struct event_
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
47 e->wev = event_new(e->base, e->context->c.fd, EV_WRITE, redisLibeventWriteEvent, e);
4
9a1ee735f28f Patch to allow redis connections by a Unix socket.
Franz Glasner <fzglas.hg@dom66.de>
parents:
diff changeset
48
9a1ee735f28f Patch to allow redis connections by a Unix socket.
Franz Glasner <fzglas.hg@dom66.de>
parents:
diff changeset
49 if (e->rev == NULL || e->wev == NULL) {
33
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
50 + if (e->rev) {
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
51 + event_free(e->rev);
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
52 + }
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
53 + if (e->wev) {
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
54 + event_free(e->wev);
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
55 + }
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
56 + free(e->ip);
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
57 + free(e->usocket);
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
58 + free(e->user);
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
59 + free(e->pwd);
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
60 free(e);
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
61 return NULL;
4
9a1ee735f28f Patch to allow redis connections by a Unix socket.
Franz Glasner <fzglas.hg@dom66.de>
parents:
diff changeset
62 }
33
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
63 @@ -329,7 +349,11 @@ static void redis_reconnect(struct redisLibeventEvents
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
64 e->context = NULL;
4
9a1ee735f28f Patch to allow redis connections by a Unix socket.
Franz Glasner <fzglas.hg@dom66.de>
parents:
diff changeset
65 }
9a1ee735f28f Patch to allow redis connections by a Unix socket.
Franz Glasner <fzglas.hg@dom66.de>
parents:
diff changeset
66
9a1ee735f28f Patch to allow redis connections by a Unix socket.
Franz Glasner <fzglas.hg@dom66.de>
parents:
diff changeset
67 - ac = redisAsyncConnect(e->ip, e->port);
9a1ee735f28f Patch to allow redis connections by a Unix socket.
Franz Glasner <fzglas.hg@dom66.de>
parents:
diff changeset
68 + if(e->usocket) {
33
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
69 + ac = redisAsyncConnectUnix(e->usocket);
4
9a1ee735f28f Patch to allow redis connections by a Unix socket.
Franz Glasner <fzglas.hg@dom66.de>
parents:
diff changeset
70 + } else {
33
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
71 + ac = redisAsyncConnect(e->ip, e->port);
4
9a1ee735f28f Patch to allow redis connections by a Unix socket.
Franz Glasner <fzglas.hg@dom66.de>
parents:
diff changeset
72 + }
33
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
73 if (!ac) {
e5d83559f2b5 Recreate patches.
Franz Glasner <fzglas.hg@dom66.de>
parents: 26
diff changeset
74 return;
4
9a1ee735f28f Patch to allow redis connections by a Unix socket.
Franz Glasner <fzglas.hg@dom66.de>
parents:
diff changeset
75 }