3 #include "simple-ipc.h"
4 #include "fsmonitor-ipc.h"
5 #include "run-command.h"
9 #ifndef HAVE_FSMONITOR_DAEMON_BACKEND
12 * A trivial implementation of the fsmonitor_ipc__ API for unsupported
16 int fsmonitor_ipc__is_supported(void)
21 const char *fsmonitor_ipc__get_path(struct repository
*r
)
26 enum ipc_active_state
fsmonitor_ipc__get_state(void)
28 return IPC_STATE__OTHER_ERROR
;
31 int fsmonitor_ipc__send_query(const char *since_token
,
32 struct strbuf
*answer
)
37 int fsmonitor_ipc__send_command(const char *command
,
38 struct strbuf
*answer
)
45 int fsmonitor_ipc__is_supported(void)
50 enum ipc_active_state
fsmonitor_ipc__get_state(void)
52 return ipc_get_active_state(fsmonitor_ipc__get_path(the_repository
));
55 static int spawn_daemon(void)
57 const char *args
[] = { "fsmonitor--daemon", "start", NULL
};
59 return run_command_v_opt_tr2(args
, RUN_COMMAND_NO_STDIN
| RUN_GIT_CMD
,
63 int fsmonitor_ipc__send_query(const char *since_token
,
64 struct strbuf
*answer
)
67 int tried_to_spawn
= 0;
68 enum ipc_active_state state
= IPC_STATE__OTHER_ERROR
;
69 struct ipc_client_connection
*connection
= NULL
;
70 struct ipc_client_connect_options options
71 = IPC_CLIENT_CONNECT_OPTIONS_INIT
;
72 const char *tok
= since_token
? since_token
: "";
73 size_t tok_len
= since_token
? strlen(since_token
) : 0;
75 options
.wait_if_busy
= 1;
76 options
.wait_if_not_found
= 0;
78 trace2_region_enter("fsm_client", "query", NULL
);
79 trace2_data_string("fsm_client", NULL
, "query/command", tok
);
82 state
= ipc_client_try_connect(fsmonitor_ipc__get_path(the_repository
),
83 &options
, &connection
);
86 case IPC_STATE__LISTENING
:
87 ret
= ipc_client_send_command_to_connection(
88 connection
, tok
, tok_len
, answer
);
89 ipc_client_close_connection(connection
);
91 trace2_data_intmax("fsm_client", NULL
,
92 "query/response-length", answer
->len
);
95 case IPC_STATE__NOT_LISTENING
:
96 case IPC_STATE__PATH_NOT_FOUND
:
105 * Try again, but this time give the daemon a chance to
106 * actually create the pipe/socket.
108 * Granted, the daemon just started so it can't possibly have
109 * any FS cached yet, so we'll always get a trivial answer.
110 * BUT the answer should include a new token that can serve
111 * as the basis for subsequent requests.
113 options
.wait_if_not_found
= 1;
116 case IPC_STATE__INVALID_PATH
:
117 ret
= error(_("fsmonitor_ipc__send_query: invalid path '%s'"),
118 fsmonitor_ipc__get_path(the_repository
));
121 case IPC_STATE__OTHER_ERROR
:
123 ret
= error(_("fsmonitor_ipc__send_query: unspecified error on '%s'"),
124 fsmonitor_ipc__get_path(the_repository
));
129 trace2_region_leave("fsm_client", "query", NULL
);
134 int fsmonitor_ipc__send_command(const char *command
,
135 struct strbuf
*answer
)
137 struct ipc_client_connection
*connection
= NULL
;
138 struct ipc_client_connect_options options
139 = IPC_CLIENT_CONNECT_OPTIONS_INIT
;
141 enum ipc_active_state state
;
142 const char *c
= command
? command
: "";
143 size_t c_len
= command
? strlen(command
) : 0;
145 strbuf_reset(answer
);
147 options
.wait_if_busy
= 1;
148 options
.wait_if_not_found
= 0;
150 state
= ipc_client_try_connect(fsmonitor_ipc__get_path(the_repository
),
151 &options
, &connection
);
152 if (state
!= IPC_STATE__LISTENING
) {
153 die(_("fsmonitor--daemon is not running"));
157 ret
= ipc_client_send_command_to_connection(connection
, c
, c_len
,
159 ipc_client_close_connection(connection
);
162 die(_("could not send '%s' command to fsmonitor--daemon"), c
);