prefix and capitalize ObMenu ObMenuEntry and ObMenuEntryRenderType
[mikachu/openbox.git] / plugins / menu / fifo_menu.c
1 #include <glib.h>
2 #include <sys/types.h>
3 #include <sys/stat.h>
4 #include <errno.h>
5 #include <fcntl.h>
6 #include <unistd.h>
7 #include <string.h>
8 #include <stdio.h>
9
10 #include "kernel/menu.h"
11 #include "kernel/event.h"
12
13 static char *PLUGIN_NAME = "fifo_menu";
14
15 typedef struct Fifo_Menu_Data{
16     char *fifo;
17     char *buf; /* buffer to hold partially read menu */
18     unsigned long buflen; /* how many bytes are in the buffer */
19     int fd; /* file descriptor to read menu from */
20     event_fd_handler *handler;
21 } Fifo_Menu_Data;
22
23 #define FIFO_MENU(m) ((ObMenu *)m)
24 #define FIFO_MENU_DATA(m) ((Fifo_Menu_Data *)((ObMenu *)m)->plugin_data)
25
26
27 void fifo_menu_clean_up(ObMenu *m) {
28     if (FIFO_MENU_DATA(m)->buf != NULL) {
29         g_free(FIFO_MENU_DATA(m)->buf);
30         FIFO_MENU_DATA(m)->buf = NULL;
31         FIFO_MENU_DATA(m)->buflen = 0;
32     }
33
34     if (FIFO_MENU_DATA(m)->fd != -1) {
35         close(FIFO_MENU_DATA(m)->fd);
36         FIFO_MENU_DATA(m)->fd = -1;
37     }
38 }
39
40 void plugin_setup_config() { }
41 void plugin_startup()
42 { }
43 void plugin_shutdown() { }
44
45 void fifo_menu_handler(int fd, void *d) {
46     ObMenu *menu = d;
47     char *tmpbuf = NULL;
48     unsigned long num_read;
49 #ifdef DEBUG
50     /* because gdb is dumb */
51 #if 0
52     Fifo_Menu_Data *d = FIFO_MENU_DATA(menu);
53 #endif
54 #endif
55     
56     /* if the menu is shown this will go into busy loop :(
57      fix me*/
58     if (!menu->shown) { 
59         unsigned long num_realloc;
60         /* if we have less than a quarter BUFSIZ left, allocate more */
61         num_realloc = (BUFSIZ - (FIFO_MENU_DATA(menu)->buflen % BUFSIZ) <
62                        BUFSIZ >> 2) ?
63             0 : BUFSIZ;
64     
65         tmpbuf = g_try_realloc(FIFO_MENU_DATA(menu)->buf,             
66                                FIFO_MENU_DATA(menu)->buflen + num_realloc);
67
68         if (tmpbuf == NULL) {
69             g_warning("Unable to allocate memory for read()");
70             return;
71         }
72     
73         FIFO_MENU_DATA(menu)->buf = tmpbuf;
74     
75         num_read = read(fd,
76                         FIFO_MENU_DATA(menu)->buf + FIFO_MENU_DATA(menu)->buflen,
77                         num_realloc);
78
79         if (num_read == 0) { /* eof */
80             unsigned long count = 0;
81             char *found = NULL;
82
83             menu->invalid = TRUE;
84             menu_clear(menu);
85
86             /* TEMP: list them */
87             while (NULL !=
88                    (found = strchr(&FIFO_MENU_DATA(menu)->buf[count], '\n'))) {
89                 FIFO_MENU_DATA(menu)->buf
90                     [found - FIFO_MENU_DATA(menu)->buf] = '\0';
91                 menu_add_entry(menu,
92                                menu_entry_new_separator
93                                (&FIFO_MENU_DATA(menu)->buf[count]));
94                 count = found - FIFO_MENU_DATA(menu)->buf + 1;
95             }
96
97             FIFO_MENU_DATA(menu)->buf[FIFO_MENU_DATA(menu)->buflen] = '\0';
98             fifo_menu_clean_up(menu);
99
100             event_remove_fd(FIFO_MENU_DATA(menu)->handler->fd);
101         
102             if ((FIFO_MENU_DATA(menu)->fd =
103                  open(FIFO_MENU_DATA(menu)->fifo, O_NONBLOCK | O_RDONLY)) == -1) {
104                 g_warning("Can't reopen FIFO");
105                 fifo_menu_clean_up(menu);
106                 return;
107             }
108
109             FIFO_MENU_DATA(menu)->handler->fd = FIFO_MENU_DATA(menu)->fd;
110         
111             event_add_fd_handler(FIFO_MENU_DATA(menu)->handler);
112         } else if (num_read > 0) {
113             FIFO_MENU_DATA(menu)->buflen += num_read;
114             FIFO_MENU_DATA(menu)->buf[FIFO_MENU_DATA(menu)->buflen] = '\0';
115         }
116     }
117 }
118
119 void plugin_destroy (ObMenu *m)
120 {
121     fifo_menu_clean_up(m);
122     if (FIFO_MENU_DATA(m)->handler != NULL) {
123         g_free(FIFO_MENU_DATA(m)->handler);
124         FIFO_MENU_DATA(m)->handler = NULL;
125     }
126
127     if (FIFO_MENU_DATA(m)->fifo != NULL) {
128         g_free(FIFO_MENU_DATA(m)->fifo);
129         FIFO_MENU_DATA(m)->fifo = NULL;
130     }
131
132     g_free(m->plugin_data);
133
134     menu_free(m->name);
135 }
136
137 void *plugin_create() /* TODO: need config */
138 {
139     char *fifo;
140     char *dir;
141     event_fd_handler *h;
142     
143     Fifo_Menu_Data *d = g_new(Fifo_Menu_Data, 1);
144     ObMenu *m = menu_new("", PLUGIN_NAME, NULL);
145
146     d->fd = -1;
147     d->buf = NULL;
148     d->buflen = 0;
149     d->handler = NULL;
150     
151     m->plugin = PLUGIN_NAME;
152
153     d->fd = -1;
154     
155     m->plugin_data = (void *)d;
156
157     dir = g_build_filename(g_get_home_dir(), ".openbox", PLUGIN_NAME, NULL);
158
159     if (mkdir(dir, S_IRWXU | S_IRWXG | S_IRWXO) == -1 && errno != EEXIST) {
160 /* technically, if ~/.openbox/fifo_menu exists and isn't a directory
161    this will fail, but we don't care because mkfifo will fail and warn
162    anyway */
163         g_warning("Can't create %s: %s", dir, strerror(errno));
164         g_free(dir);
165         plugin_destroy(m);
166         return NULL;
167     }
168
169     fifo = g_build_filename(g_get_home_dir(), ".openbox", PLUGIN_NAME,
170                             m->name, NULL);
171     if (mkfifo(fifo, S_IRUSR | S_IWUSR |
172                S_IRGRP | S_IWGRP | /* let umask do its thing */
173                S_IROTH | S_IWOTH) == -1 && errno != EEXIST) {
174         g_warning("Can't create FIFO %s: %s", fifo, strerror(errno));
175         g_free(fifo);
176         g_free(d);
177         menu_free(m->name);
178         return NULL;
179     }
180
181 /* open in non-blocking mode so we don't wait for a process to open FIFO
182    for writing */
183     if ((d->fd = open(fifo, O_NONBLOCK | O_RDONLY)) == -1) { 
184         g_warning("Can't open FIFO %s: %s", fifo, strerror(errno));
185         g_free(fifo);
186         g_free(d);
187         menu_free(m->name);
188         return NULL;
189     }
190
191     d->fifo = fifo;
192     
193     h = g_new(event_fd_handler, 1);
194
195     if (h == NULL) {
196         g_warning("Out of memory");
197         close(d->fd);
198         g_free(fifo);
199         g_free(d);
200         menu_free(m->name);
201         return NULL;
202     }
203     
204     h->fd = d->fd;
205     h->data = m;
206     h->handler = fifo_menu_handler;
207     d->handler = h;
208     
209     event_add_fd_handler(h);
210     
211     g_free(dir);
212     return (void *)m;
213 }