|
7
|
1 /* vi:set ts=8 sts=4 sw=4:
|
|
|
2 *
|
|
|
3 * VIM - Vi IMproved by Bram Moolenaar
|
|
|
4 * X command server by Flemming Madsen
|
|
|
5 *
|
|
|
6 * Do ":help uganda" in Vim to read copying and usage conditions.
|
|
|
7 * Do ":help credits" in Vim to see a list of people who contributed.
|
|
|
8 * See README.txt for an overview of the Vim source code.
|
|
|
9 *
|
|
|
10 * if_xcmdsrv.c: Functions for passing commands through an X11 display.
|
|
|
11 *
|
|
|
12 */
|
|
|
13
|
|
|
14 #include "vim.h"
|
|
|
15 #include "version.h"
|
|
|
16
|
|
|
17 #if defined(FEAT_CLIENTSERVER) || defined(PROTO)
|
|
|
18
|
|
|
19 # ifdef FEAT_X11
|
|
|
20 # include <X11/Intrinsic.h>
|
|
|
21 # include <X11/Xatom.h>
|
|
|
22 # endif
|
|
|
23
|
|
|
24 # if defined(HAVE_SYS_SELECT_H) && \
|
|
|
25 (!defined(HAVE_SYS_TIME_H) || defined(SYS_SELECT_WITH_SYS_TIME))
|
|
|
26 # include <sys/select.h>
|
|
|
27 # endif
|
|
|
28
|
|
|
29 # ifndef HAVE_SELECT
|
|
|
30 # ifdef HAVE_SYS_POLL_H
|
|
|
31 # include <sys/poll.h>
|
|
|
32 # else
|
|
|
33 # ifdef HAVE_POLL_H
|
|
|
34 # include <poll.h>
|
|
|
35 # endif
|
|
|
36 # endif
|
|
|
37 # endif
|
|
|
38
|
|
|
39 /*
|
|
1121
|
40 * This file provides procedures that implement the command server
|
|
|
41 * functionality of Vim when in contact with an X11 server.
|
|
7
|
42 *
|
|
|
43 * Adapted from TCL/TK's send command in tkSend.c of the tk 3.6 distribution.
|
|
|
44 * Adapted for use in Vim by Flemming Madsen. Protocol changed to that of tk 4
|
|
|
45 */
|
|
|
46
|
|
|
47 /*
|
|
|
48 * Copyright (c) 1989-1993 The Regents of the University of California.
|
|
|
49 * All rights reserved.
|
|
|
50 *
|
|
|
51 * Permission is hereby granted, without written agreement and without
|
|
|
52 * license or royalty fees, to use, copy, modify, and distribute this
|
|
|
53 * software and its documentation for any purpose, provided that the
|
|
|
54 * above copyright notice and the following two paragraphs appear in
|
|
|
55 * all copies of this software.
|
|
|
56 *
|
|
|
57 * IN NO EVENT SHALL THE UNIVERSITY OF CALIFORNIA BE LIABLE TO ANY PARTY FOR
|
|
|
58 * DIRECT, INDIRECT, SPECIAL, INCIDENTAL, OR CONSEQUENTIAL DAMAGES ARISING OUT
|
|
|
59 * OF THE USE OF THIS SOFTWARE AND ITS DOCUMENTATION, EVEN IF THE UNIVERSITY OF
|
|
|
60 * CALIFORNIA HAS BEEN ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
|
|
61 *
|
|
|
62 * THE UNIVERSITY OF CALIFORNIA SPECIFICALLY DISCLAIMS ANY WARRANTIES,
|
|
|
63 * INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY
|
|
|
64 * AND FITNESS FOR A PARTICULAR PURPOSE. THE SOFTWARE PROVIDED HEREUNDER IS
|
|
|
65 * ON AN "AS IS" BASIS, AND THE UNIVERSITY OF CALIFORNIA HAS NO OBLIGATION TO
|
|
|
66 * PROVIDE MAINTENANCE, SUPPORT, UPDATES, ENHANCEMENTS, OR MODIFICATIONS.
|
|
|
67 */
|
|
|
68
|
|
|
69
|
|
|
70 /*
|
|
|
71 * When a result is being awaited from a sent command, one of
|
|
|
72 * the following structures is present on a list of all outstanding
|
|
|
73 * sent commands. The information in the structure is used to
|
|
|
74 * process the result when it arrives. You're probably wondering
|
|
|
75 * how there could ever be multiple outstanding sent commands.
|
|
|
76 * This could happen if Vim instances invoke each other recursively.
|
|
|
77 * It's unlikely, but possible.
|
|
|
78 */
|
|
|
79
|
|
|
80 typedef struct PendingCommand
|
|
|
81 {
|
|
|
82 int serial; /* Serial number expected in result. */
|
|
|
83 int code; /* Result Code. 0 is OK */
|
|
|
84 char_u *result; /* String result for command (malloc'ed).
|
|
|
85 * NULL means command still pending. */
|
|
|
86 struct PendingCommand *nextPtr;
|
|
|
87 /* Next in list of all outstanding commands.
|
|
|
88 * NULL means end of list. */
|
|
|
89 } PendingCommand;
|
|
|
90
|
|
|
91 static PendingCommand *pendingCommands = NULL;
|
|
|
92 /* List of all commands currently
|
|
|
93 * being waited for. */
|
|
|
94
|
|
|
95 /*
|
|
|
96 * The information below is used for communication between processes
|
|
|
97 * during "send" commands. Each process keeps a private window, never
|
|
|
98 * even mapped, with one property, "Comm". When a command is sent to
|
|
|
99 * an interpreter, the command is appended to the comm property of the
|
|
|
100 * communication window associated with the interp's process. Similarly,
|
|
|
101 * when a result is returned from a sent command, it is also appended
|
|
|
102 * to the comm property.
|
|
|
103 *
|
|
|
104 * Each command and each result takes the form of ASCII text. For a
|
|
|
105 * command, the text consists of a nul character followed by several
|
|
39
|
106 * nul-terminated ASCII strings. The first string consists of a
|
|
|
107 * single letter:
|
|
|
108 * "c" for an expression
|
|
|
109 * "k" for keystrokes
|
|
|
110 * "r" for reply
|
|
|
111 * "n" for notification.
|
|
|
112 * Subsequent strings have the form "option value" where the following options
|
|
|
113 * are supported:
|
|
7
|
114 *
|
|
|
115 * -r commWindow serial
|
|
|
116 *
|
|
|
117 * This option means that a response should be sent to the window
|
|
|
118 * whose X identifier is "commWindow" (in hex), and the response should
|
|
|
119 * be identified with the serial number given by "serial" (in decimal).
|
|
|
120 * If this option isn't specified then the send is asynchronous and
|
|
|
121 * no response is sent.
|
|
|
122 *
|
|
|
123 * -n name
|
|
|
124 * "Name" gives the name of the application for which the command is
|
|
|
125 * intended. This option must be present.
|
|
|
126 *
|
|
39
|
127 * -E encoding
|
|
|
128 * Encoding name used for the text. This is the 'encoding' of the
|
|
|
129 * sender. The receiver may want to do conversion to his 'encoding'.
|
|
|
130 *
|
|
7
|
131 * -s script
|
|
|
132 * "Script" is the script to be executed. This option must be
|
|
|
133 * present. Taken as a series of keystrokes in a "k" command where
|
|
|
134 * <Key>'s are expanded
|
|
|
135 *
|
|
|
136 * The options may appear in any order. The -n and -s options must be
|
|
|
137 * present, but -r may be omitted for asynchronous RPCs. For compatibility
|
|
|
138 * with future releases that may add new features, there may be additional
|
|
|
139 * options present; as long as they start with a "-" character, they will
|
|
|
140 * be ignored.
|
|
|
141 *
|
|
|
142 * A result also consists of a zero character followed by several null-
|
|
|
143 * terminated ASCII strings. The first string consists of the single
|
|
|
144 * letter "r". Subsequent strings have the form "option value" where
|
|
|
145 * the following options are supported:
|
|
|
146 *
|
|
|
147 * -s serial
|
|
|
148 * Identifies the command for which this is the result. It is the
|
|
|
149 * same as the "serial" field from the -s option in the command. This
|
|
|
150 * option must be present.
|
|
|
151 *
|
|
|
152 * -r result
|
|
|
153 * "Result" is the result string for the script, which may be either
|
|
|
154 * a result or an error message. If this field is omitted then it
|
|
|
155 * defaults to an empty string.
|
|
|
156 *
|
|
|
157 * -c code
|
|
|
158 * 0: for OK. This is the default.
|
|
|
159 * 1: for error: Result is the last error
|
|
|
160 *
|
|
|
161 * -i errorInfo
|
|
|
162 * -e errorCode
|
|
|
163 * Not applicable for Vim
|
|
|
164 *
|
|
|
165 * Options may appear in any order, and only the -s option must be
|
|
|
166 * present. As with commands, there may be additional options besides
|
|
|
167 * these; unknown options are ignored.
|
|
|
168 */
|
|
|
169
|
|
|
170 /*
|
|
|
171 * Maximum size property that can be read at one time by
|
|
|
172 * this module:
|
|
|
173 */
|
|
|
174
|
|
|
175 #define MAX_PROP_WORDS 100000
|
|
|
176
|
|
|
177 struct ServerReply
|
|
|
178 {
|
|
|
179 Window id;
|
|
|
180 garray_T strings;
|
|
|
181 };
|
|
|
182 static garray_T serverReply = { 0, 0, 0, 0, 0 };
|
|
|
183 enum ServerReplyOp { SROP_Find, SROP_Add, SROP_Delete };
|
|
|
184
|
|
|
185 typedef int (*EndCond) __ARGS((void *));
|
|
|
186
|
|
|
187 /*
|
|
|
188 * Forward declarations for procedures defined later in this file:
|
|
|
189 */
|
|
|
190
|
|
|
191 static Window LookupName __ARGS((Display *dpy, char_u *name, int delete, char_u **loose));
|
|
|
192 static int SendInit __ARGS((Display *dpy));
|
|
|
193 static int DoRegisterName __ARGS((Display *dpy, char_u *name));
|
|
|
194 static void DeleteAnyLingerer __ARGS((Display *dpy, Window w));
|
|
|
195 static int GetRegProp __ARGS((Display *dpy, char_u **regPropp, long_u *numItemsp, int domsg));
|
|
|
196 static int WaitForPend __ARGS((void *p));
|
|
|
197 static int WaitForReply __ARGS((void *p));
|
|
|
198 static int WindowValid __ARGS((Display *dpy, Window w));
|
|
|
199 static void ServerWait __ARGS((Display *dpy, Window w, EndCond endCond, void *endData, int localLoop, int seconds));
|
|
|
200 static struct ServerReply *ServerReplyFind __ARGS((Window w, enum ServerReplyOp op));
|
|
|
201 static int AppendPropCarefully __ARGS((Display *display, Window window, Atom property, char_u *value, int length));
|
|
|
202 static int x_error_check __ARGS((Display *dpy, XErrorEvent *error_event));
|
|
|
203 static int IsSerialName __ARGS((char_u *name));
|
|
|
204
|
|
|
205 /* Private variables for the "server" functionality */
|
|
|
206 static Atom registryProperty = None;
|
|
|
207 static Atom vimProperty = None;
|
|
|
208 static int got_x_error = FALSE;
|
|
|
209
|
|
|
210 static char_u *empty_prop = (char_u *)""; /* empty GetRegProp() result */
|
|
|
211
|
|
|
212 /*
|
|
|
213 * Associate an ASCII name with Vim. Try real hard to get a unique one.
|
|
|
214 * Returns FAIL or OK.
|
|
|
215 */
|
|
|
216 int
|
|
|
217 serverRegisterName(dpy, name)
|
|
|
218 Display *dpy; /* display to register with */
|
|
|
219 char_u *name; /* the name that will be used as a base */
|
|
|
220 {
|
|
|
221 int i;
|
|
|
222 int res;
|
|
|
223 char_u *p = NULL;
|
|
|
224
|
|
|
225 res = DoRegisterName(dpy, name);
|
|
|
226 if (res < 0)
|
|
|
227 {
|
|
|
228 i = 1;
|
|
|
229 do
|
|
|
230 {
|
|
|
231 if (res < -1 || i >= 1000)
|
|
|
232 {
|
|
|
233 MSG_ATTR(_("Unable to register a command server name"),
|
|
|
234 hl_attr(HLF_W));
|
|
|
235 return FAIL;
|
|
|
236 }
|
|
|
237 if (p == NULL)
|
|
|
238 p = alloc(STRLEN(name) + 10);
|
|
|
239 if (p == NULL)
|
|
|
240 {
|
|
|
241 res = -10;
|
|
|
242 continue;
|
|
|
243 }
|
|
|
244 sprintf((char *)p, "%s%d", name, i++);
|
|
|
245 res = DoRegisterName(dpy, p);
|
|
|
246 }
|
|
|
247 while (res < 0)
|
|
|
248 ;
|
|
|
249 vim_free(p);
|
|
|
250 }
|
|
|
251 return OK;
|
|
|
252 }
|
|
|
253
|
|
|
254 static int
|
|
|
255 DoRegisterName(dpy, name)
|
|
|
256 Display *dpy;
|
|
|
257 char_u *name;
|
|
|
258 {
|
|
|
259 Window w;
|
|
|
260 XErrorHandler old_handler;
|
|
|
261 #define MAX_NAME_LENGTH 100
|
|
|
262 char_u propInfo[MAX_NAME_LENGTH + 20];
|
|
|
263
|
|
|
264 if (commProperty == None)
|
|
|
265 {
|
|
|
266 if (SendInit(dpy) < 0)
|
|
|
267 return -2;
|
|
|
268 }
|
|
|
269
|
|
|
270 /*
|
|
|
271 * Make sure the name is unique, and append info about it to
|
|
|
272 * the registry property. It's important to lock the server
|
|
|
273 * here to prevent conflicting changes to the registry property.
|
|
|
274 * WARNING: Do not step through this while debugging, it will hangup the X
|
|
|
275 * server!
|
|
|
276 */
|
|
|
277 XGrabServer(dpy);
|
|
|
278 w = LookupName(dpy, name, FALSE, NULL);
|
|
|
279 if (w != (Window)0)
|
|
|
280 {
|
|
|
281 Status status;
|
|
|
282 int dummyInt;
|
|
|
283 unsigned int dummyUns;
|
|
|
284 Window dummyWin;
|
|
|
285
|
|
|
286 /*
|
|
|
287 * The name is currently registered. See if the commWindow
|
|
|
288 * associated with the name exists. If not, or if the commWindow
|
|
|
289 * is *our* commWindow, then just unregister the old name (this
|
|
|
290 * could happen if an application dies without cleaning up the
|
|
|
291 * registry).
|
|
|
292 */
|
|
|
293 old_handler = XSetErrorHandler(x_error_check);
|
|
|
294 status = XGetGeometry(dpy, w, &dummyWin, &dummyInt, &dummyInt,
|
|
|
295 &dummyUns, &dummyUns, &dummyUns, &dummyUns);
|
|
|
296 (void)XSetErrorHandler(old_handler);
|
|
|
297 if (status != Success && w != commWindow)
|
|
|
298 {
|
|
|
299 XUngrabServer(dpy);
|
|
|
300 XFlush(dpy);
|
|
|
301 return -1;
|
|
|
302 }
|
|
|
303 (void)LookupName(dpy, name, /*delete=*/TRUE, NULL);
|
|
|
304 }
|
|
|
305 sprintf((char *)propInfo, "%x %.*s", (int_u)commWindow,
|
|
|
306 MAX_NAME_LENGTH, name);
|
|
|
307 old_handler = XSetErrorHandler(x_error_check);
|
|
|
308 got_x_error = FALSE;
|
|
|
309 XChangeProperty(dpy, RootWindow(dpy, 0), registryProperty, XA_STRING, 8,
|
|
|
310 PropModeAppend, propInfo, STRLEN(propInfo) + 1);
|
|
|
311 XUngrabServer(dpy);
|
|
|
312 XSync(dpy, False);
|
|
|
313 (void)XSetErrorHandler(old_handler);
|
|
|
314
|
|
|
315 if (!got_x_error)
|
|
|
316 {
|
|
|
317 #ifdef FEAT_EVAL
|
|
|
318 set_vim_var_string(VV_SEND_SERVER, name, -1);
|
|
|
319 #endif
|
|
|
320 serverName = vim_strsave(name);
|
|
|
321 #ifdef FEAT_TITLE
|
|
|
322 need_maketitle = TRUE;
|
|
|
323 #endif
|
|
|
324 return 0;
|
|
|
325 }
|
|
|
326 return -2;
|
|
|
327 }
|
|
|
328
|
|
|
329 #if defined(FEAT_GUI) || defined(PROTO)
|
|
|
330 /*
|
|
|
331 * Clean out new ID from registry and set it as comm win.
|
|
|
332 * Change any registered window ID.
|
|
|
333 */
|
|
|
334 void
|
|
|
335 serverChangeRegisteredWindow(dpy, newwin)
|
|
|
336 Display *dpy; /* Display to register with */
|
|
|
337 Window newwin; /* Re-register to this ID */
|
|
|
338 {
|
|
|
339 char_u propInfo[MAX_NAME_LENGTH + 20];
|
|
|
340
|
|
|
341 commWindow = newwin;
|
|
|
342
|
|
|
343 /* Always call SendInit() here, to make sure commWindow is marked as a Vim
|
|
|
344 * window. */
|
|
|
345 if (SendInit(dpy) < 0)
|
|
|
346 return;
|
|
|
347
|
|
|
348 /* WARNING: Do not step through this while debugging, it will hangup the X
|
|
|
349 * server! */
|
|
|
350 XGrabServer(dpy);
|
|
|
351 DeleteAnyLingerer(dpy, newwin);
|
|
|
352 if (serverName != NULL)
|
|
|
353 {
|
|
|
354 /* Reinsert name if we was already registered */
|
|
|
355 (void)LookupName(dpy, serverName, /*delete=*/TRUE, NULL);
|
|
|
356 sprintf((char *)propInfo, "%x %.*s",
|
|
|
357 (int_u)newwin, MAX_NAME_LENGTH, serverName);
|
|
|
358 XChangeProperty(dpy, RootWindow(dpy, 0), registryProperty, XA_STRING, 8,
|
|
|
359 PropModeAppend, (char_u *)propInfo,
|
|
|
360 STRLEN(propInfo) + 1);
|
|
|
361 }
|
|
|
362 XUngrabServer(dpy);
|
|
|
363 }
|
|
|
364 #endif
|
|
|
365
|
|
|
366 /*
|
|
|
367 * Send to an instance of Vim via the X display.
|
|
|
368 * Returns 0 for OK, negative for an error.
|
|
|
369 */
|
|
|
370 int
|
|
|
371 serverSendToVim(dpy, name, cmd, result, server, asExpr, localLoop, silent)
|
|
|
372 Display *dpy; /* Where to send. */
|
|
|
373 char_u *name; /* Where to send. */
|
|
|
374 char_u *cmd; /* What to send. */
|
|
|
375 char_u **result; /* Result of eval'ed expression */
|
|
|
376 Window *server; /* Actual ID of receiving app */
|
|
|
377 Bool asExpr; /* Interpret as keystrokes or expr ? */
|
|
|
378 Bool localLoop; /* Throw away everything but result */
|
|
|
379 int silent; /* don't complain about no server */
|
|
|
380 {
|
|
|
381 Window w;
|
|
|
382 char_u *property;
|
|
|
383 int length;
|
|
|
384 int res;
|
|
|
385 static int serial = 0; /* Running count of sent commands.
|
|
|
386 * Used to give each command a
|
|
|
387 * different serial number. */
|
|
|
388 PendingCommand pending;
|
|
|
389 char_u *loosename = NULL;
|
|
|
390
|
|
|
391 if (result != NULL)
|
|
|
392 *result = NULL;
|
|
|
393 if (name == NULL || *name == NUL)
|
|
|
394 name = (char_u *)"GVIM"; /* use a default name */
|
|
|
395
|
|
|
396 if (commProperty == None && dpy != NULL)
|
|
|
397 {
|
|
|
398 if (SendInit(dpy) < 0)
|
|
|
399 return -1;
|
|
|
400 }
|
|
|
401
|
|
|
402 /* Execute locally if no display or target is ourselves */
|
|
|
403 if (dpy == NULL || (serverName != NULL && STRICMP(name, serverName) == 0))
|
|
|
404 {
|
|
|
405 if (asExpr)
|
|
|
406 {
|
|
|
407 char_u *ret;
|
|
|
408
|
|
|
409 ret = eval_client_expr_to_string(cmd);
|
|
|
410 if (result != NULL)
|
|
|
411 {
|
|
|
412 if (ret == NULL)
|
|
|
413 *result = vim_strsave((char_u *)_(e_invexprmsg));
|
|
|
414 else
|
|
|
415 *result = ret;
|
|
|
416 }
|
|
|
417 else
|
|
|
418 vim_free(ret);
|
|
|
419 return ret == NULL ? -1 : 0;
|
|
|
420 }
|
|
|
421 else
|
|
|
422 server_to_input_buf(cmd);
|
|
|
423 return 0;
|
|
|
424 }
|
|
|
425
|
|
|
426 /*
|
|
|
427 * Bind the server name to a communication window.
|
|
|
428 *
|
|
|
429 * Find any survivor with a serialno attached to the name if the
|
|
|
430 * original registrant of the wanted name is no longer present.
|
|
|
431 *
|
|
|
432 * Delete any lingering names from dead editors.
|
|
|
433 */
|
|
|
434 while (TRUE)
|
|
|
435 {
|
|
|
436 w = LookupName(dpy, name, FALSE, &loosename);
|
|
|
437 /* Check that the window is hot */
|
|
|
438 if (w != None)
|
|
|
439 {
|
|
|
440 if (!WindowValid(dpy, w))
|
|
|
441 {
|
|
|
442 LookupName(dpy, loosename ? loosename : name,
|
|
|
443 /*DELETE=*/TRUE, NULL);
|
|
|
444 continue;
|
|
|
445 }
|
|
|
446 }
|
|
|
447 break;
|
|
|
448 }
|
|
|
449 if (w == None)
|
|
|
450 {
|
|
|
451 if (!silent)
|
|
|
452 EMSG2(_(e_noserver), name);
|
|
|
453 return -1;
|
|
|
454 }
|
|
|
455 else if (loosename != NULL)
|
|
|
456 name = loosename;
|
|
|
457 if (server != NULL)
|
|
|
458 *server = w;
|
|
|
459
|
|
|
460 /*
|
|
|
461 * Send the command to target interpreter by appending it to the
|
|
|
462 * comm window in the communication window.
|
|
500
|
463 * Length must be computed exactly!
|
|
7
|
464 */
|
|
39
|
465 #ifdef FEAT_MBYTE
|
|
500
|
466 length = STRLEN(name) + STRLEN(p_enc) + STRLEN(cmd) + 14;
|
|
|
467 #else
|
|
|
468 length = STRLEN(name) + STRLEN(cmd) + 10;
|
|
39
|
469 #endif
|
|
|
470 property = (char_u *)alloc((unsigned)length + 30);
|
|
7
|
471
|
|
39
|
472 #ifdef FEAT_MBYTE
|
|
|
473 sprintf((char *)property, "%c%c%c-n %s%c-E %s%c-s %s",
|
|
|
474 0, asExpr ? 'c' : 'k', 0, name, 0, p_enc, 0, cmd);
|
|
|
475 #else
|
|
7
|
476 sprintf((char *)property, "%c%c%c-n %s%c-s %s",
|
|
|
477 0, asExpr ? 'c' : 'k', 0, name, 0, cmd);
|
|
39
|
478 #endif
|
|
7
|
479 if (name == loosename)
|
|
|
480 vim_free(loosename);
|
|
|
481 /* Add a back reference to our comm window */
|
|
|
482 serial++;
|
|
|
483 sprintf((char *)property + length, "%c-r %x %d",
|
|
|
484 0, (int_u)commWindow, serial);
|
|
500
|
485 /* Add length of what "-r %x %d" resulted in, skipping the NUL. */
|
|
7
|
486 length += STRLEN(property + length + 1) + 1;
|
|
|
487
|
|
|
488 res = AppendPropCarefully(dpy, w, commProperty, property, length + 1);
|
|
|
489 vim_free(property);
|
|
|
490 if (res < 0)
|
|
|
491 {
|
|
|
492 EMSG(_("E248: Failed to send command to the destination program"));
|
|
|
493 return -1;
|
|
|
494 }
|
|
|
495
|
|
|
496 if (!asExpr) /* There is no answer for this - Keys are sent async */
|
|
|
497 return 0;
|
|
|
498
|
|
|
499 /*
|
|
|
500 * Register the fact that we're waiting for a command to
|
|
|
501 * complete (this is needed by SendEventProc and by
|
|
|
502 * AppendErrorProc to pass back the command's results).
|
|
|
503 */
|
|
|
504 pending.serial = serial;
|
|
|
505 pending.code = 0;
|
|
|
506 pending.result = NULL;
|
|
|
507 pending.nextPtr = pendingCommands;
|
|
|
508 pendingCommands = &pending;
|
|
|
509
|
|
|
510 ServerWait(dpy, w, WaitForPend, &pending, localLoop, 600);
|
|
|
511
|
|
|
512 /*
|
|
|
513 * Unregister the information about the pending command
|
|
|
514 * and return the result.
|
|
|
515 */
|
|
|
516 if (pendingCommands == &pending)
|
|
|
517 pendingCommands = pending.nextPtr;
|
|
|
518 else
|
|
|
519 {
|
|
|
520 PendingCommand *pcPtr;
|
|
|
521
|
|
|
522 for (pcPtr = pendingCommands; pcPtr != NULL; pcPtr = pcPtr->nextPtr)
|
|
|
523 if (pcPtr->nextPtr == &pending)
|
|
|
524 {
|
|
|
525 pcPtr->nextPtr = pending.nextPtr;
|
|
|
526 break;
|
|
|
527 }
|
|
|
528 }
|
|
|
529 if (result != NULL)
|
|
|
530 *result = pending.result;
|
|
|
531 else
|
|
|
532 vim_free(pending.result);
|
|
|
533
|
|
|
534 return pending.code == 0 ? 0 : -1;
|
|
|
535 }
|
|
|
536
|
|
|
537 static int
|
|
|
538 WaitForPend(p)
|
|
|
539 void *p;
|
|
|
540 {
|
|
|
541 PendingCommand *pending = (PendingCommand *) p;
|
|
|
542 return pending->result != NULL;
|
|
|
543 }
|
|
|
544
|
|
|
545 /*
|
|
|
546 * Return TRUE if window "w" exists and has a "Vim" property on it.
|
|
|
547 */
|
|
|
548 static int
|
|
|
549 WindowValid(dpy, w)
|
|
|
550 Display *dpy;
|
|
|
551 Window w;
|
|
|
552 {
|
|
|
553 XErrorHandler old_handler;
|
|
|
554 Atom *plist;
|
|
|
555 int numProp;
|
|
|
556 int i;
|
|
|
557
|
|
|
558 old_handler = XSetErrorHandler(x_error_check);
|
|
|
559 got_x_error = 0;
|
|
|
560 plist = XListProperties(dpy, w, &numProp);
|
|
|
561 XSync(dpy, False);
|
|
|
562 XSetErrorHandler(old_handler);
|
|
|
563 if (plist == NULL || got_x_error)
|
|
|
564 return FALSE;
|
|
|
565
|
|
|
566 for (i = 0; i < numProp; i++)
|
|
|
567 if (plist[i] == vimProperty)
|
|
|
568 {
|
|
|
569 XFree(plist);
|
|
|
570 return TRUE;
|
|
|
571 }
|
|
|
572 XFree(plist);
|
|
|
573 return FALSE;
|
|
|
574 }
|
|
|
575
|
|
|
576 /*
|
|
|
577 * Enter a loop processing X events & polling chars until we see a result
|
|
|
578 */
|
|
|
579 static void
|
|
|
580 ServerWait(dpy, w, endCond, endData, localLoop, seconds)
|
|
|
581 Display *dpy;
|
|
|
582 Window w;
|
|
|
583 EndCond endCond;
|
|
|
584 void *endData;
|
|
|
585 int localLoop;
|
|
|
586 int seconds;
|
|
|
587 {
|
|
|
588 time_t start;
|
|
|
589 time_t now;
|
|
|
590 time_t lastChk = 0;
|
|
|
591 XEvent event;
|
|
|
592 XPropertyEvent *e = (XPropertyEvent *)&event;
|
|
|
593 # define SEND_MSEC_POLL 50
|
|
|
594
|
|
|
595 time(&start);
|
|
|
596 while (endCond(endData) == 0)
|
|
|
597 {
|
|
|
598 time(&now);
|
|
|
599 if (seconds >= 0 && (now - start) >= seconds)
|
|
|
600 break;
|
|
|
601 if (now != lastChk)
|
|
|
602 {
|
|
|
603 lastChk = now;
|
|
|
604 if (!WindowValid(dpy, w))
|
|
|
605 break;
|
|
|
606 /*
|
|
|
607 * Sometimes the PropertyChange event doesn't come.
|
|
|
608 * This can be seen in eg: vim -c 'echo remote_expr("gvim", "3+2")'
|
|
|
609 */
|
|
|
610 serverEventProc(dpy, NULL);
|
|
|
611 }
|
|
|
612 if (localLoop)
|
|
|
613 {
|
|
|
614 /* Just look out for the answer without calling back into Vim */
|
|
|
615 #ifndef HAVE_SELECT
|
|
|
616 struct pollfd fds;
|
|
|
617
|
|
|
618 fds.fd = ConnectionNumber(dpy);
|
|
|
619 fds.events = POLLIN;
|
|
|
620 if (poll(&fds, 1, SEND_MSEC_POLL) < 0)
|
|
|
621 break;
|
|
|
622 #else
|
|
|
623 fd_set fds;
|
|
|
624 struct timeval tv;
|
|
|
625
|
|
|
626 tv.tv_sec = 0;
|
|
|
627 tv.tv_usec = SEND_MSEC_POLL * 1000;
|
|
|
628 FD_ZERO(&fds);
|
|
|
629 FD_SET(ConnectionNumber(dpy), &fds);
|
|
|
630 if (select(ConnectionNumber(dpy) + 1, &fds, NULL, NULL, &tv) < 0)
|
|
|
631 break;
|
|
|
632 #endif
|
|
|
633 while (XEventsQueued(dpy, QueuedAfterReading) > 0)
|
|
|
634 {
|
|
|
635 XNextEvent(dpy, &event);
|
|
|
636 if (event.type == PropertyNotify && e->window == commWindow)
|
|
|
637 serverEventProc(dpy, &event);
|
|
|
638 }
|
|
|
639 }
|
|
|
640 else
|
|
|
641 {
|
|
|
642 if (got_int)
|
|
|
643 break;
|
|
|
644 ui_delay((long)SEND_MSEC_POLL, TRUE);
|
|
|
645 ui_breakcheck();
|
|
|
646 }
|
|
|
647 }
|
|
|
648 }
|
|
|
649
|
|
|
650
|
|
|
651 /*
|
|
|
652 * Fetch a list of all the Vim instance names currently registered for the
|
|
|
653 * display.
|
|
|
654 *
|
|
|
655 * Returns a newline separated list in allocated memory or NULL.
|
|
|
656 */
|
|
|
657 char_u *
|
|
|
658 serverGetVimNames(dpy)
|
|
|
659 Display *dpy;
|
|
|
660 {
|
|
|
661 char_u *regProp;
|
|
|
662 char_u *entry;
|
|
|
663 char_u *p;
|
|
|
664 long_u numItems;
|
|
|
665 int_u w;
|
|
|
666 garray_T ga;
|
|
|
667
|
|
|
668 if (registryProperty == None)
|
|
|
669 {
|
|
|
670 if (SendInit(dpy) < 0)
|
|
|
671 return NULL;
|
|
|
672 }
|
|
|
673 ga_init2(&ga, 1, 100);
|
|
|
674
|
|
|
675 /*
|
|
|
676 * Read the registry property.
|
|
|
677 */
|
|
|
678 if (GetRegProp(dpy, ®Prop, &numItems, TRUE) == FAIL)
|
|
|
679 return NULL;
|
|
|
680
|
|
|
681 /*
|
|
|
682 * Scan all of the names out of the property.
|
|
|
683 */
|
|
|
684 ga_init2(&ga, 1, 100);
|
|
|
685 for (p = regProp; (p - regProp) < numItems; p++)
|
|
|
686 {
|
|
|
687 entry = p;
|
|
|
688 while (*p != 0 && !isspace(*p))
|
|
|
689 p++;
|
|
|
690 if (*p != 0)
|
|
|
691 {
|
|
|
692 w = None;
|
|
|
693 sscanf((char *)entry, "%x", &w);
|
|
|
694 if (WindowValid(dpy, (Window)w))
|
|
|
695 {
|
|
|
696 ga_concat(&ga, p + 1);
|
|
|
697 ga_concat(&ga, (char_u *)"\n");
|
|
|
698 }
|
|
|
699 while (*p != 0)
|
|
|
700 p++;
|
|
|
701 }
|
|
|
702 }
|
|
|
703 if (regProp != empty_prop)
|
|
|
704 XFree(regProp);
|
|
21
|
705 ga_append(&ga, NUL);
|
|
7
|
706 return ga.ga_data;
|
|
|
707 }
|
|
|
708
|
|
|
709 /* ----------------------------------------------------------
|
|
|
710 * Reply stuff
|
|
|
711 */
|
|
|
712
|
|
|
713 static struct ServerReply *
|
|
|
714 ServerReplyFind(w, op)
|
|
|
715 Window w;
|
|
|
716 enum ServerReplyOp op;
|
|
|
717 {
|
|
|
718 struct ServerReply *p;
|
|
|
719 struct ServerReply e;
|
|
|
720 int i;
|
|
|
721
|
|
|
722 p = (struct ServerReply *) serverReply.ga_data;
|
|
|
723 for (i = 0; i < serverReply.ga_len; i++, p++)
|
|
|
724 if (p->id == w)
|
|
|
725 break;
|
|
|
726 if (i >= serverReply.ga_len)
|
|
|
727 p = NULL;
|
|
|
728
|
|
|
729 if (p == NULL && op == SROP_Add)
|
|
|
730 {
|
|
|
731 if (serverReply.ga_growsize == 0)
|
|
|
732 ga_init2(&serverReply, sizeof(struct ServerReply), 1);
|
|
|
733 if (ga_grow(&serverReply, 1) == OK)
|
|
|
734 {
|
|
|
735 p = ((struct ServerReply *) serverReply.ga_data)
|
|
|
736 + serverReply.ga_len;
|
|
|
737 e.id = w;
|
|
|
738 ga_init2(&e.strings, 1, 100);
|
|
|
739 memcpy(p, &e, sizeof(e));
|
|
|
740 serverReply.ga_len++;
|
|
|
741 }
|
|
|
742 }
|
|
|
743 else if (p != NULL && op == SROP_Delete)
|
|
|
744 {
|
|
|
745 ga_clear(&p->strings);
|
|
|
746 mch_memmove(p, p + 1, (serverReply.ga_len - i - 1) * sizeof(*p));
|
|
|
747 serverReply.ga_len--;
|
|
|
748 }
|
|
|
749
|
|
|
750 return p;
|
|
|
751 }
|
|
|
752
|
|
|
753 /*
|
|
|
754 * Convert string to windowid.
|
|
|
755 * Issue an error if the id is invalid.
|
|
|
756 */
|
|
|
757 Window
|
|
|
758 serverStrToWin(str)
|
|
|
759 char_u *str;
|
|
|
760 {
|
|
|
761 unsigned id = None;
|
|
|
762
|
|
|
763 sscanf((char *)str, "0x%x", &id);
|
|
|
764 if (id == None)
|
|
|
765 EMSG2(_("E573: Invalid server id used: %s"), str);
|
|
|
766
|
|
|
767 return (Window)id;
|
|
|
768 }
|
|
|
769
|
|
|
770 /*
|
|
39
|
771 * Send a reply string (notification) to client with id "name".
|
|
7
|
772 * Return -1 if the window is invalid.
|
|
|
773 */
|
|
|
774 int
|
|
|
775 serverSendReply(name, str)
|
|
|
776 char_u *name;
|
|
|
777 char_u *str;
|
|
|
778 {
|
|
|
779 char_u *property;
|
|
|
780 int length;
|
|
|
781 int res;
|
|
|
782 Display *dpy = X_DISPLAY;
|
|
|
783 Window win = serverStrToWin(name);
|
|
|
784
|
|
|
785 if (commProperty == None)
|
|
|
786 {
|
|
|
787 if (SendInit(dpy) < 0)
|
|
|
788 return -2;
|
|
|
789 }
|
|
|
790 if (!WindowValid(dpy, win))
|
|
|
791 return -1;
|
|
|
792
|
|
39
|
793 #ifdef FEAT_MBYTE
|
|
500
|
794 length = STRLEN(p_enc) + STRLEN(str) + 14;
|
|
|
795 #else
|
|
|
796 length = STRLEN(str) + 10;
|
|
39
|
797 #endif
|
|
|
798 if ((property = (char_u *)alloc((unsigned)length + 30)) != NULL)
|
|
7
|
799 {
|
|
39
|
800 #ifdef FEAT_MBYTE
|
|
|
801 sprintf((char *)property, "%cn%c-E %s%c-n %s%c-w %x",
|
|
|
802 0, 0, p_enc, 0, str, 0, (unsigned int)commWindow);
|
|
|
803 #else
|
|
|
804 sprintf((char *)property, "%cn%c-n %s%c-w %x",
|
|
|
805 0, 0, str, 0, (unsigned int)commWindow);
|
|
|
806 #endif
|
|
500
|
807 /* Add length of what "%x" resulted in. */
|
|
7
|
808 length += STRLEN(property + length);
|
|
|
809 res = AppendPropCarefully(dpy, win, commProperty, property, length + 1);
|
|
|
810 vim_free(property);
|
|
|
811 return res;
|
|
|
812 }
|
|
|
813 return -1;
|
|
|
814 }
|
|
|
815
|
|
|
816 static int
|
|
|
817 WaitForReply(p)
|
|
|
818 void *p;
|
|
|
819 {
|
|
|
820 Window *w = (Window *) p;
|
|
|
821 return ServerReplyFind(*w, SROP_Find) != NULL;
|
|
|
822 }
|
|
|
823
|
|
|
824 /*
|
|
|
825 * Wait for replies from id (win)
|
|
|
826 * Return 0 and the malloc'ed string when a reply is available.
|
|
|
827 * Return -1 if the window becomes invalid while waiting.
|
|
|
828 */
|
|
|
829 int
|
|
|
830 serverReadReply(dpy, win, str, localLoop)
|
|
|
831 Display *dpy;
|
|
|
832 Window win;
|
|
|
833 char_u **str;
|
|
|
834 int localLoop;
|
|
|
835 {
|
|
|
836 int len;
|
|
|
837 char_u *s;
|
|
|
838 struct ServerReply *p;
|
|
|
839
|
|
|
840 ServerWait(dpy, win, WaitForReply, &win, localLoop, -1);
|
|
|
841
|
|
|
842 if ((p = ServerReplyFind(win, SROP_Find)) != NULL && p->strings.ga_len > 0)
|
|
|
843 {
|
|
|
844 *str = vim_strsave(p->strings.ga_data);
|
|
|
845 len = STRLEN(*str) + 1;
|
|
|
846 if (len < p->strings.ga_len)
|
|
|
847 {
|
|
|
848 s = (char_u *) p->strings.ga_data;
|
|
|
849 mch_memmove(s, s + len, p->strings.ga_len - len);
|
|
|
850 p->strings.ga_len -= len;
|
|
|
851 }
|
|
|
852 else
|
|
|
853 {
|
|
|
854 /* Last string read. Remove from list */
|
|
|
855 ga_clear(&p->strings);
|
|
|
856 ServerReplyFind(win, SROP_Delete);
|
|
|
857 }
|
|
|
858 return 0;
|
|
|
859 }
|
|
|
860 return -1;
|
|
|
861 }
|
|
|
862
|
|
|
863 /*
|
|
|
864 * Check for replies from id (win).
|
|
|
865 * Return TRUE and a non-malloc'ed string if there is. Else return FALSE.
|
|
|
866 */
|
|
|
867 int
|
|
|
868 serverPeekReply(dpy, win, str)
|
|
|
869 Display *dpy;
|
|
|
870 Window win;
|
|
|
871 char_u **str;
|
|
|
872 {
|
|
|
873 struct ServerReply *p;
|
|
|
874
|
|
|
875 if ((p = ServerReplyFind(win, SROP_Find)) != NULL && p->strings.ga_len > 0)
|
|
|
876 {
|
|
|
877 if (str != NULL)
|
|
|
878 *str = p->strings.ga_data;
|
|
|
879 return 1;
|
|
|
880 }
|
|
|
881 if (!WindowValid(dpy, win))
|
|
|
882 return -1;
|
|
|
883 return 0;
|
|
|
884 }
|
|
|
885
|
|
|
886
|
|
|
887 /*
|
|
|
888 * Initialize the communication channels for sending commands and receiving
|
|
|
889 * results.
|
|
|
890 */
|
|
|
891 static int
|
|
|
892 SendInit(dpy)
|
|
|
893 Display *dpy;
|
|
|
894 {
|
|
|
895 XErrorHandler old_handler;
|
|
|
896
|
|
|
897 /*
|
|
|
898 * Create the window used for communication, and set up an
|
|
|
899 * event handler for it.
|
|
|
900 */
|
|
|
901 old_handler = XSetErrorHandler(x_error_check);
|
|
|
902 got_x_error = FALSE;
|
|
|
903
|
|
|
904 if (commProperty == None)
|
|
|
905 commProperty = XInternAtom(dpy, "Comm", False);
|
|
|
906 if (vimProperty == None)
|
|
|
907 vimProperty = XInternAtom(dpy, "Vim", False);
|
|
|
908 if (registryProperty == None)
|
|
|
909 registryProperty = XInternAtom(dpy, "VimRegistry", False);
|
|
|
910
|
|
|
911 if (commWindow == None)
|
|
|
912 {
|
|
|
913 commWindow = XCreateSimpleWindow(dpy, XDefaultRootWindow(dpy),
|
|
|
914 getpid(), 0, 10, 10, 0,
|
|
|
915 WhitePixel(dpy, DefaultScreen(dpy)),
|
|
|
916 WhitePixel(dpy, DefaultScreen(dpy)));
|
|
|
917 XSelectInput(dpy, commWindow, PropertyChangeMask);
|
|
|
918 /* WARNING: Do not step through this while debugging, it will hangup
|
|
|
919 * the X server! */
|
|
|
920 XGrabServer(dpy);
|
|
|
921 DeleteAnyLingerer(dpy, commWindow);
|
|
|
922 XUngrabServer(dpy);
|
|
|
923 }
|
|
|
924
|
|
|
925 /* Make window recognizable as a vim window */
|
|
|
926 XChangeProperty(dpy, commWindow, vimProperty, XA_STRING,
|
|
|
927 8, PropModeReplace, (char_u *)VIM_VERSION_SHORT,
|
|
|
928 (int)STRLEN(VIM_VERSION_SHORT) + 1);
|
|
|
929
|
|
|
930 XSync(dpy, False);
|
|
|
931 (void)XSetErrorHandler(old_handler);
|
|
|
932
|
|
|
933 return got_x_error ? -1 : 0;
|
|
|
934 }
|
|
|
935
|
|
|
936 /*
|
|
|
937 * Given a server name, see if the name exists in the registry for a
|
|
|
938 * particular display.
|
|
|
939 *
|
|
|
940 * If the given name is registered, return the ID of the window associated
|
|
|
941 * with the name. If the name isn't registered, then return 0.
|
|
|
942 *
|
|
|
943 * Side effects:
|
|
|
944 * If the registry property is improperly formed, then it is deleted.
|
|
|
945 * If "delete" is non-zero, then if the named server is found it is
|
|
|
946 * removed from the registry property.
|
|
|
947 */
|
|
|
948 static Window
|
|
|
949 LookupName(dpy, name, delete, loose)
|
|
|
950 Display *dpy; /* Display whose registry to check. */
|
|
|
951 char_u *name; /* Name of a server. */
|
|
|
952 int delete; /* If non-zero, delete info about name. */
|
|
|
953 char_u **loose; /* Do another search matching -999 if not found
|
|
|
954 Return result here if a match is found */
|
|
|
955 {
|
|
|
956 char_u *regProp, *entry;
|
|
|
957 char_u *p;
|
|
|
958 long_u numItems;
|
|
|
959 int_u returnValue;
|
|
|
960
|
|
|
961 /*
|
|
|
962 * Read the registry property.
|
|
|
963 */
|
|
|
964 if (GetRegProp(dpy, ®Prop, &numItems, FALSE) == FAIL)
|
|
|
965 return 0;
|
|
|
966
|
|
|
967 /*
|
|
|
968 * Scan the property for the desired name.
|
|
|
969 */
|
|
|
970 returnValue = (int_u)None;
|
|
|
971 entry = NULL; /* Not needed, but eliminates compiler warning. */
|
|
|
972 for (p = regProp; (p - regProp) < numItems; )
|
|
|
973 {
|
|
|
974 entry = p;
|
|
|
975 while (*p != 0 && !isspace(*p))
|
|
|
976 p++;
|
|
|
977 if (*p != 0 && STRICMP(name, p + 1) == 0)
|
|
|
978 {
|
|
|
979 sscanf((char *)entry, "%x", &returnValue);
|
|
|
980 break;
|
|
|
981 }
|
|
|
982 while (*p != 0)
|
|
|
983 p++;
|
|
|
984 p++;
|
|
|
985 }
|
|
|
986
|
|
|
987 if (loose != NULL && returnValue == (int_u)None && !IsSerialName(name))
|
|
|
988 {
|
|
|
989 for (p = regProp; (p - regProp) < numItems; )
|
|
|
990 {
|
|
|
991 entry = p;
|
|
|
992 while (*p != 0 && !isspace(*p))
|
|
|
993 p++;
|
|
|
994 if (*p != 0 && IsSerialName(p + 1)
|
|
|
995 && STRNICMP(name, p + 1, STRLEN(name)) == 0)
|
|
|
996 {
|
|
|
997 sscanf((char *)entry, "%x", &returnValue);
|
|
|
998 *loose = vim_strsave(p + 1);
|
|
|
999 break;
|
|
|
1000 }
|
|
|
1001 while (*p != 0)
|
|
|
1002 p++;
|
|
|
1003 p++;
|
|
|
1004 }
|
|
|
1005 }
|
|
|
1006
|
|
|
1007 /*
|
|
|
1008 * Delete the property, if that is desired (copy down the
|
|
|
1009 * remainder of the registry property to overlay the deleted
|
|
|
1010 * info, then rewrite the property).
|
|
|
1011 */
|
|
|
1012 if (delete && returnValue != (int_u)None)
|
|
|
1013 {
|
|
|
1014 int count;
|
|
|
1015
|
|
|
1016 while (*p != 0)
|
|
|
1017 p++;
|
|
|
1018 p++;
|
|
|
1019 count = numItems - (p - regProp);
|
|
|
1020 if (count > 0)
|
|
|
1021 memcpy(entry, p, count);
|
|
|
1022 XChangeProperty(dpy, RootWindow(dpy, 0), registryProperty, XA_STRING,
|
|
|
1023 8, PropModeReplace, regProp,
|
|
|
1024 (int)(numItems - (p - entry)));
|
|
|
1025 XSync(dpy, False);
|
|
|
1026 }
|
|
|
1027
|
|
|
1028 if (regProp != empty_prop)
|
|
|
1029 XFree(regProp);
|
|
|
1030 return (Window)returnValue;
|
|
|
1031 }
|
|
|
1032
|
|
|
1033 /*
|
|
1197
|
1034 * Delete any lingering occurrence of window id. We promise that any
|
|
|
1035 * occurrence is not ours since it is not yet put into the registry (by us)
|
|
7
|
1036 *
|
|
|
1037 * This is necessary in the following scenario:
|
|
|
1038 * 1. There is an old windowid for an exit'ed vim in the registry
|
|
|
1039 * 2. We get that id for our commWindow but only want to send, not register.
|
|
|
1040 * 3. The window will mistakenly be regarded valid because of own commWindow
|
|
|
1041 */
|
|
|
1042 static void
|
|
|
1043 DeleteAnyLingerer(dpy, win)
|
|
|
1044 Display *dpy; /* Display whose registry to check. */
|
|
|
1045 Window win; /* Window to remove */
|
|
|
1046 {
|
|
|
1047 char_u *regProp, *entry = NULL;
|
|
|
1048 char_u *p;
|
|
|
1049 long_u numItems;
|
|
28
|
1050 int_u wwin;
|
|
7
|
1051
|
|
|
1052 /*
|
|
|
1053 * Read the registry property.
|
|
|
1054 */
|
|
|
1055 if (GetRegProp(dpy, ®Prop, &numItems, FALSE) == FAIL)
|
|
|
1056 return;
|
|
|
1057
|
|
|
1058 /* Scan the property for the window id. */
|
|
|
1059 for (p = regProp; (p - regProp) < numItems; )
|
|
|
1060 {
|
|
|
1061 if (*p != 0)
|
|
|
1062 {
|
|
28
|
1063 sscanf((char *)p, "%x", &wwin);
|
|
|
1064 if ((Window)wwin == win)
|
|
7
|
1065 {
|
|
|
1066 int lastHalf;
|
|
|
1067
|
|
|
1068 /* Copy down the remainder to delete entry */
|
|
|
1069 entry = p;
|
|
|
1070 while (*p != 0)
|
|
|
1071 p++;
|
|
|
1072 p++;
|
|
|
1073 lastHalf = numItems - (p - regProp);
|
|
|
1074 if (lastHalf > 0)
|
|
|
1075 memcpy(entry, p, lastHalf);
|
|
|
1076 numItems = (entry - regProp) + lastHalf;
|
|
|
1077 p = entry;
|
|
|
1078 continue;
|
|
|
1079 }
|
|
|
1080 }
|
|
|
1081 while (*p != 0)
|
|
|
1082 p++;
|
|
|
1083 p++;
|
|
|
1084 }
|
|
|
1085
|
|
|
1086 if (entry != NULL)
|
|
|
1087 {
|
|
|
1088 XChangeProperty(dpy, RootWindow(dpy, 0), registryProperty,
|
|
|
1089 XA_STRING, 8, PropModeReplace, regProp,
|
|
|
1090 (int)(p - regProp));
|
|
|
1091 XSync(dpy, False);
|
|
|
1092 }
|
|
|
1093
|
|
|
1094 if (regProp != empty_prop)
|
|
|
1095 XFree(regProp);
|
|
|
1096 }
|
|
|
1097
|
|
|
1098 /*
|
|
|
1099 * Read the registry property. Delete it when it's formatted wrong.
|
|
|
1100 * Return the property in "regPropp". "empty_prop" is used when it doesn't
|
|
|
1101 * exist yet.
|
|
|
1102 * Return OK when successful.
|
|
|
1103 */
|
|
|
1104 static int
|
|
|
1105 GetRegProp(dpy, regPropp, numItemsp, domsg)
|
|
|
1106 Display *dpy;
|
|
|
1107 char_u **regPropp;
|
|
|
1108 long_u *numItemsp;
|
|
|
1109 int domsg; /* When TRUE give error message. */
|
|
|
1110 {
|
|
|
1111 int result, actualFormat;
|
|
|
1112 long_u bytesAfter;
|
|
|
1113 Atom actualType;
|
|
819
|
1114 XErrorHandler old_handler;
|
|
7
|
1115
|
|
|
1116 *regPropp = NULL;
|
|
819
|
1117 old_handler = XSetErrorHandler(x_error_check);
|
|
|
1118 got_x_error = FALSE;
|
|
|
1119
|
|
7
|
1120 result = XGetWindowProperty(dpy, RootWindow(dpy, 0), registryProperty, 0L,
|
|
|
1121 (long)MAX_PROP_WORDS, False,
|
|
|
1122 XA_STRING, &actualType,
|
|
|
1123 &actualFormat, numItemsp, &bytesAfter,
|
|
|
1124 regPropp);
|
|
|
1125
|
|
819
|
1126 XSync(dpy, FALSE);
|
|
|
1127 (void)XSetErrorHandler(old_handler);
|
|
|
1128 if (got_x_error)
|
|
|
1129 return FAIL;
|
|
|
1130
|
|
7
|
1131 if (actualType == None)
|
|
|
1132 {
|
|
|
1133 /* No prop yet. Logically equal to the empty list */
|
|
|
1134 *numItemsp = 0;
|
|
|
1135 *regPropp = empty_prop;
|
|
|
1136 return OK;
|
|
|
1137 }
|
|
|
1138
|
|
|
1139 /* If the property is improperly formed, then delete it. */
|
|
|
1140 if (result != Success || actualFormat != 8 || actualType != XA_STRING)
|
|
|
1141 {
|
|
|
1142 if (*regPropp != NULL)
|
|
|
1143 XFree(*regPropp);
|
|
|
1144 XDeleteProperty(dpy, RootWindow(dpy, 0), registryProperty);
|
|
|
1145 if (domsg)
|
|
|
1146 EMSG(_("E251: VIM instance registry property is badly formed. Deleted!"));
|
|
|
1147 return FAIL;
|
|
|
1148 }
|
|
|
1149 return OK;
|
|
|
1150 }
|
|
|
1151
|
|
|
1152 /*
|
|
1197
|
1153 * This procedure is invoked by the various X event loops throughout Vims when
|
|
7
|
1154 * a property changes on the communication window. This procedure reads the
|
|
|
1155 * property and handles command requests and responses.
|
|
|
1156 */
|
|
|
1157 void
|
|
|
1158 serverEventProc(dpy, eventPtr)
|
|
|
1159 Display *dpy;
|
|
|
1160 XEvent *eventPtr; /* Information about event. */
|
|
|
1161 {
|
|
|
1162 char_u *propInfo;
|
|
|
1163 char_u *p;
|
|
|
1164 int result, actualFormat, code;
|
|
|
1165 long_u numItems, bytesAfter;
|
|
|
1166 Atom actualType;
|
|
39
|
1167 char_u *tofree;
|
|
7
|
1168
|
|
|
1169 if (eventPtr != NULL)
|
|
|
1170 {
|
|
|
1171 if (eventPtr->xproperty.atom != commProperty
|
|
|
1172 || eventPtr->xproperty.state != PropertyNewValue)
|
|
|
1173 return;
|
|
|
1174 }
|
|
|
1175
|
|
|
1176 /*
|
|
|
1177 * Read the comm property and delete it.
|
|
|
1178 */
|
|
|
1179 propInfo = NULL;
|
|
|
1180 result = XGetWindowProperty(dpy, commWindow, commProperty, 0L,
|
|
|
1181 (long)MAX_PROP_WORDS, True,
|
|
|
1182 XA_STRING, &actualType,
|
|
|
1183 &actualFormat, &numItems, &bytesAfter,
|
|
|
1184 &propInfo);
|
|
|
1185
|
|
|
1186 /* If the property doesn't exist or is improperly formed then ignore it. */
|
|
|
1187 if (result != Success || actualType != XA_STRING || actualFormat != 8)
|
|
|
1188 {
|
|
|
1189 if (propInfo != NULL)
|
|
|
1190 XFree(propInfo);
|
|
|
1191 return;
|
|
|
1192 }
|
|
|
1193
|
|
|
1194 /*
|
|
|
1195 * Several commands and results could arrive in the property at
|
|
|
1196 * one time; each iteration through the outer loop handles a
|
|
|
1197 * single command or result.
|
|
|
1198 */
|
|
|
1199 for (p = propInfo; (p - propInfo) < numItems; )
|
|
|
1200 {
|
|
|
1201 /*
|
|
|
1202 * Ignore leading NULs; each command or result starts with a
|
|
|
1203 * NUL so that no matter how badly formed a preceding command
|
|
|
1204 * is, we'll be able to tell that a new command/result is
|
|
|
1205 * starting.
|
|
|
1206 */
|
|
|
1207 if (*p == 0)
|
|
|
1208 {
|
|
|
1209 p++;
|
|
|
1210 continue;
|
|
|
1211 }
|
|
|
1212
|
|
|
1213 if ((*p == 'c' || *p == 'k') && (p[1] == 0))
|
|
|
1214 {
|
|
|
1215 Window resWindow;
|
|
|
1216 char_u *name, *script, *serial, *end, *res;
|
|
|
1217 Bool asKeys = *p == 'k';
|
|
|
1218 garray_T reply;
|
|
39
|
1219 char_u *enc;
|
|
7
|
1220
|
|
|
1221 /*
|
|
|
1222 * This is an incoming command from some other application.
|
|
|
1223 * Iterate over all of its options. Stop when we reach
|
|
|
1224 * the end of the property or something that doesn't look
|
|
|
1225 * like an option.
|
|
|
1226 */
|
|
|
1227 p += 2;
|
|
|
1228 name = NULL;
|
|
|
1229 resWindow = None;
|
|
|
1230 serial = (char_u *)"";
|
|
|
1231 script = NULL;
|
|
39
|
1232 enc = NULL;
|
|
7
|
1233 while (p - propInfo < numItems && *p == '-')
|
|
|
1234 {
|
|
|
1235 switch (p[1])
|
|
|
1236 {
|
|
|
1237 case 'r':
|
|
|
1238 end = skipwhite(p + 2);
|
|
|
1239 resWindow = 0;
|
|
|
1240 while (vim_isxdigit(*end))
|
|
|
1241 {
|
|
|
1242 resWindow = 16 * resWindow + (long_u)hex2nr(*end);
|
|
|
1243 ++end;
|
|
|
1244 }
|
|
|
1245 if (end == p + 2 || *end != ' ')
|
|
|
1246 resWindow = None;
|
|
|
1247 else
|
|
|
1248 {
|
|
|
1249 p = serial = end + 1;
|
|
|
1250 clientWindow = resWindow; /* Remember in global */
|
|
|
1251 }
|
|
|
1252 break;
|
|
|
1253 case 'n':
|
|
|
1254 if (p[2] == ' ')
|
|
|
1255 name = p + 3;
|
|
|
1256 break;
|
|
|
1257 case 's':
|
|
|
1258 if (p[2] == ' ')
|
|
|
1259 script = p + 3;
|
|
|
1260 break;
|
|
39
|
1261 case 'E':
|
|
|
1262 if (p[2] == ' ')
|
|
|
1263 enc = p + 3;
|
|
|
1264 break;
|
|
7
|
1265 }
|
|
|
1266 while (*p != 0)
|
|
|
1267 p++;
|
|
|
1268 p++;
|
|
|
1269 }
|
|
|
1270
|
|
|
1271 if (script == NULL || name == NULL)
|
|
|
1272 continue;
|
|
|
1273
|
|
|
1274 /*
|
|
|
1275 * Initialize the result property, so that we're ready at any
|
|
|
1276 * time if we need to return an error.
|
|
|
1277 */
|
|
|
1278 if (resWindow != None)
|
|
|
1279 {
|
|
|
1280 ga_init2(&reply, 1, 100);
|
|
39
|
1281 #ifdef FEAT_MBYTE
|
|
|
1282 ga_grow(&reply, 50 + STRLEN(p_enc));
|
|
|
1283 sprintf(reply.ga_data, "%cr%c-E %s%c-s %s%c-r ",
|
|
|
1284 0, 0, p_enc, 0, serial, 0);
|
|
502
|
1285 reply.ga_len = 14 + STRLEN(p_enc) + STRLEN(serial);
|
|
39
|
1286 #else
|
|
7
|
1287 ga_grow(&reply, 50);
|
|
|
1288 sprintf(reply.ga_data, "%cr%c-s %s%c-r ", 0, 0, serial, 0);
|
|
500
|
1289 reply.ga_len = 10 + STRLEN(serial);
|
|
39
|
1290 #endif
|
|
7
|
1291 }
|
|
|
1292 res = NULL;
|
|
|
1293 if (serverName != NULL && STRICMP(name, serverName) == 0)
|
|
|
1294 {
|
|
39
|
1295 script = serverConvert(enc, script, &tofree);
|
|
7
|
1296 if (asKeys)
|
|
|
1297 server_to_input_buf(script);
|
|
|
1298 else
|
|
|
1299 res = eval_client_expr_to_string(script);
|
|
39
|
1300 vim_free(tofree);
|
|
7
|
1301 }
|
|
|
1302 if (resWindow != None)
|
|
|
1303 {
|
|
|
1304 if (res != NULL)
|
|
|
1305 ga_concat(&reply, res);
|
|
|
1306 else if (asKeys == 0)
|
|
|
1307 {
|
|
|
1308 ga_concat(&reply, (char_u *)_(e_invexprmsg));
|
|
|
1309 ga_append(&reply, 0);
|
|
|
1310 ga_concat(&reply, (char_u *)"-c 1");
|
|
|
1311 }
|
|
21
|
1312 ga_append(&reply, NUL);
|
|
7
|
1313 (void)AppendPropCarefully(dpy, resWindow, commProperty,
|
|
|
1314 reply.ga_data, reply.ga_len);
|
|
39
|
1315 ga_clear(&reply);
|
|
7
|
1316 }
|
|
|
1317 vim_free(res);
|
|
|
1318 }
|
|
|
1319 else if (*p == 'r' && p[1] == 0)
|
|
|
1320 {
|
|
39
|
1321 int serial, gotSerial;
|
|
|
1322 char_u *res;
|
|
|
1323 PendingCommand *pcPtr;
|
|
|
1324 char_u *enc;
|
|
7
|
1325
|
|
|
1326 /*
|
|
|
1327 * This is a reply to some command that we sent out. Iterate
|
|
|
1328 * over all of its options. Stop when we reach the end of the
|
|
|
1329 * property or something that doesn't look like an option.
|
|
|
1330 */
|
|
|
1331 p += 2;
|
|
|
1332 gotSerial = 0;
|
|
|
1333 res = (char_u *)"";
|
|
|
1334 code = 0;
|
|
39
|
1335 enc = NULL;
|
|
7
|
1336 while ((p-propInfo) < numItems && *p == '-')
|
|
|
1337 {
|
|
|
1338 switch (p[1])
|
|
|
1339 {
|
|
|
1340 case 'r':
|
|
|
1341 if (p[2] == ' ')
|
|
|
1342 res = p + 3;
|
|
|
1343 break;
|
|
39
|
1344 case 'E':
|
|
|
1345 if (p[2] == ' ')
|
|
|
1346 enc = p + 3;
|
|
|
1347 break;
|
|
7
|
1348 case 's':
|
|
|
1349 if (sscanf((char *)p + 2, " %d", &serial) == 1)
|
|
|
1350 gotSerial = 1;
|
|
|
1351 break;
|
|
|
1352 case 'c':
|
|
|
1353 if (sscanf((char *)p + 2, " %d", &code) != 1)
|
|
|
1354 code = 0;
|
|
|
1355 break;
|
|
|
1356 }
|
|
|
1357 while (*p != 0)
|
|
|
1358 p++;
|
|
|
1359 p++;
|
|
|
1360 }
|
|
|
1361
|
|
|
1362 if (!gotSerial)
|
|
|
1363 continue;
|
|
|
1364
|
|
|
1365 /*
|
|
|
1366 * Give the result information to anyone who's
|
|
|
1367 * waiting for it.
|
|
|
1368 */
|
|
|
1369 for (pcPtr = pendingCommands; pcPtr != NULL; pcPtr = pcPtr->nextPtr)
|
|
|
1370 {
|
|
|
1371 if (serial != pcPtr->serial || pcPtr->result != NULL)
|
|
|
1372 continue;
|
|
|
1373
|
|
|
1374 pcPtr->code = code;
|
|
|
1375 if (res != NULL)
|
|
39
|
1376 {
|
|
|
1377 res = serverConvert(enc, res, &tofree);
|
|
|
1378 if (tofree == NULL)
|
|
|
1379 res = vim_strsave(res);
|
|
|
1380 pcPtr->result = res;
|
|
|
1381 }
|
|
7
|
1382 else
|
|
|
1383 pcPtr->result = vim_strsave((char_u *)"");
|
|
|
1384 break;
|
|
|
1385 }
|
|
|
1386 }
|
|
|
1387 else if (*p == 'n' && p[1] == 0)
|
|
|
1388 {
|
|
|
1389 Window win = 0;
|
|
|
1390 unsigned int u;
|
|
|
1391 int gotWindow;
|
|
|
1392 char_u *str;
|
|
|
1393 char_u winstr[30];
|
|
|
1394 struct ServerReply *r;
|
|
39
|
1395 char_u *enc;
|
|
7
|
1396
|
|
|
1397 /*
|
|
|
1398 * This is a (n)otification. Sent with serverreply_send in VimL.
|
|
|
1399 * Execute any autocommand and save it for later retrieval
|
|
|
1400 */
|
|
|
1401 p += 2;
|
|
|
1402 gotWindow = 0;
|
|
|
1403 str = (char_u *)"";
|
|
39
|
1404 enc = NULL;
|
|
7
|
1405 while ((p-propInfo) < numItems && *p == '-')
|
|
|
1406 {
|
|
|
1407 switch (p[1])
|
|
|
1408 {
|
|
|
1409 case 'n':
|
|
|
1410 if (p[2] == ' ')
|
|
|
1411 str = p + 3;
|
|
|
1412 break;
|
|
39
|
1413 case 'E':
|
|
|
1414 if (p[2] == ' ')
|
|
|
1415 enc = p + 3;
|
|
|
1416 break;
|
|
7
|
1417 case 'w':
|
|
|
1418 if (sscanf((char *)p + 2, " %x", &u) == 1)
|
|
|
1419 {
|
|
|
1420 win = u;
|
|
|
1421 gotWindow = 1;
|
|
|
1422 }
|
|
|
1423 break;
|
|
|
1424 }
|
|
|
1425 while (*p != 0)
|
|
|
1426 p++;
|
|
|
1427 p++;
|
|
|
1428 }
|
|
|
1429
|
|
|
1430 if (!gotWindow)
|
|
|
1431 continue;
|
|
39
|
1432 str = serverConvert(enc, str, &tofree);
|
|
7
|
1433 if ((r = ServerReplyFind(win, SROP_Add)) != NULL)
|
|
|
1434 {
|
|
|
1435 ga_concat(&(r->strings), str);
|
|
21
|
1436 ga_append(&(r->strings), NUL);
|
|
7
|
1437 }
|
|
|
1438 #ifdef FEAT_AUTOCMD
|
|
|
1439 sprintf((char *)winstr, "0x%x", (unsigned int)win);
|
|
|
1440 apply_autocmds(EVENT_REMOTEREPLY, winstr, str, TRUE, curbuf);
|
|
|
1441 #endif
|
|
39
|
1442 vim_free(tofree);
|
|
7
|
1443 }
|
|
|
1444 else
|
|
|
1445 {
|
|
|
1446 /*
|
|
|
1447 * Didn't recognize this thing. Just skip through the next
|
|
|
1448 * null character and try again.
|
|
|
1449 * Even if we get an 'r'(eply) we will throw it away as we
|
|
|
1450 * never specify (and thus expect) one
|
|
|
1451 */
|
|
|
1452 while (*p != 0)
|
|
|
1453 p++;
|
|
|
1454 p++;
|
|
|
1455 }
|
|
|
1456 }
|
|
|
1457 XFree(propInfo);
|
|
|
1458 }
|
|
|
1459
|
|
|
1460 /*
|
|
|
1461 * Append a given property to a given window, but set up an X error handler so
|
|
|
1462 * that if the append fails this procedure can return an error code rather
|
|
|
1463 * than having Xlib panic.
|
|
|
1464 * Return: 0 for OK, -1 for error
|
|
|
1465 */
|
|
|
1466 static int
|
|
|
1467 AppendPropCarefully(dpy, window, property, value, length)
|
|
|
1468 Display *dpy; /* Display on which to operate. */
|
|
|
1469 Window window; /* Window whose property is to be modified. */
|
|
|
1470 Atom property; /* Name of property. */
|
|
|
1471 char_u *value; /* Characters to append to property. */
|
|
|
1472 int length; /* How much to append */
|
|
|
1473 {
|
|
|
1474 XErrorHandler old_handler;
|
|
|
1475
|
|
|
1476 old_handler = XSetErrorHandler(x_error_check);
|
|
|
1477 got_x_error = FALSE;
|
|
|
1478 XChangeProperty(dpy, window, property, XA_STRING, 8,
|
|
|
1479 PropModeAppend, value, length);
|
|
|
1480 XSync(dpy, False);
|
|
|
1481 (void) XSetErrorHandler(old_handler);
|
|
|
1482 return got_x_error ? -1 : 0;
|
|
|
1483 }
|
|
|
1484
|
|
|
1485
|
|
|
1486 /*
|
|
|
1487 * Another X Error handler, just used to check for errors.
|
|
|
1488 */
|
|
|
1489 /* ARGSUSED */
|
|
|
1490 static int
|
|
|
1491 x_error_check(dpy, error_event)
|
|
|
1492 Display *dpy;
|
|
|
1493 XErrorEvent *error_event;
|
|
|
1494 {
|
|
|
1495 got_x_error = TRUE;
|
|
|
1496 return 0;
|
|
|
1497 }
|
|
|
1498
|
|
|
1499 /*
|
|
|
1500 * Check if "str" looks like it had a serial number appended.
|
|
|
1501 * Actually just checks if the name ends in a digit.
|
|
|
1502 */
|
|
|
1503 static int
|
|
|
1504 IsSerialName(str)
|
|
|
1505 char_u *str;
|
|
|
1506 {
|
|
|
1507 int len = STRLEN(str);
|
|
|
1508
|
|
|
1509 return (len > 1 && vim_isdigit(str[len - 1]));
|
|
|
1510 }
|
|
|
1511 #endif /* FEAT_CLIENTSERVER */
|
