| /dports/mail/dovecot/dovecot-2.3.17/src/lib-master/ |
| H A D | ipc-client.c | 22 struct ipc_client { struct
35 static void ipc_client_disconnect(struct ipc_client *client); argument
84 static void ipc_client_input(struct ipc_client *client) in ipc_client_input()
97 static int ipc_client_connect(struct ipc_client *client) in ipc_client_connect()
145 struct ipc_client *
148 struct ipc_client *client; in ipc_client_init()
150 client = i_new(struct ipc_client, 1); in ipc_client_init()
156 void ipc_client_deinit(struct ipc_client **_client) in ipc_client_deinit()
158 struct ipc_client *client = *_client; in ipc_client_deinit()
174 ipc_client_cmd(struct ipc_client *client, const char *cmd, in ipc_client_cmd()
[all …]
|
| H A D | ipc-client.h | 13 struct ipc_client *
15 void ipc_client_deinit(struct ipc_client **client);
18 ipc_client_cmd(struct ipc_client *client, const char *cmd,
21 void ipc_client_cmd_abort(struct ipc_client *client,
|
| /dports/net/pacemaker1/pacemaker-Pacemaker-1.1.24/lrmd/ |
| H A D | ipc_proxy.c | 160 crm_client_t *ipc_client; in ipc_proxy_forward_client() local
177 ipc_client = crm_client_get_by_id(session); in ipc_proxy_forward_client()
178 if (ipc_client == NULL) { in ipc_proxy_forward_client()
207 crm_trace("Sending response to %d - %s", ipc_client->request_id, ipc_client->id); in ipc_proxy_forward_client()
211 ipc_client->request_id = 0; in ipc_proxy_forward_client()
214 qb_ipcs_disconnect(ipc_client->ipcs); in ipc_proxy_forward_client()
394 crm_client_t *ipc_client = NULL; in ipc_proxy_remove_provider() local
403 const char *proxy_id = ipc_client->userdata; in ipc_proxy_remove_provider()
406 ipc_client->id, ipc_client->pid); in ipc_proxy_remove_provider()
414 ipc_client = gIter->data; in ipc_proxy_remove_provider()
[all …]
|
| /dports/net/pacemaker2/pacemaker-Pacemaker-2.1.1/daemons/execd/ |
| H A D | remoted_proxy.c | 153 pcmk__client_t *ipc_client; in ipc_proxy_forward_client() local
170 ipc_client = pcmk__find_client_by_id(session); in ipc_proxy_forward_client()
171 if (ipc_client == NULL) { in ipc_proxy_forward_client()
202 crm_trace("Sending response to %d - %s", ipc_client->request_id, ipc_client->id); in ipc_proxy_forward_client()
206 ipc_client->request_id = 0; in ipc_proxy_forward_client()
209 qb_ipcs_disconnect(ipc_client->ipcs); in ipc_proxy_forward_client()
401 pcmk__client_t *ipc_client = NULL; in ipc_proxy_remove_provider() local
410 const char *proxy_id = ipc_client->userdata; in ipc_proxy_remove_provider()
413 ipc_client->id, ipc_client->pid); in ipc_proxy_remove_provider()
421 ipc_client = gIter->data; in ipc_proxy_remove_provider()
[all …]
|
| /dports/net/corosync2/corosync-2.4.5/qdevices/ |
| H A D | qdevice-net-poll.c | 216 struct unix_socket_client *ipc_client; in qdevice_net_pr_poll_array_create() local
308 TAILQ_FOREACH(ipc_client, ipc_client_list, entries) { in qdevice_net_pr_poll_array_create()
309 if (!ipc_client->reading_line && !ipc_client->writing_buffer) { in qdevice_net_pr_poll_array_create()
319 if (ipc_client->reading_line) { in qdevice_net_pr_poll_array_create()
323 if (ipc_client->writing_buffer) { in qdevice_net_pr_poll_array_create()
328 user_data->ipc_client = ipc_client; in qdevice_net_pr_poll_array_create()
344 struct unix_socket_client *ipc_client; in qdevice_net_poll() local
360 ipc_client = user_data->ipc_client; in qdevice_net_poll()
384 qdevice_ipc_io_read(instance->qdevice_instance_ptr, ipc_client); in qdevice_net_poll()
476 ipc_client->schedule_disconnect = 1; in qdevice_net_poll()
[all …]
|
| H A D | corosync-qnetd.c | 98 struct unix_socket_client *ipc_client; in qnetd_pr_poll_array_create() local
145 if (!ipc_client->reading_line && !ipc_client->writing_buffer) { in qnetd_pr_poll_array_create()
154 if (ipc_client->reading_line) { in qnetd_pr_poll_array_create()
158 if (ipc_client->writing_buffer) { in qnetd_pr_poll_array_create()
163 user_data->ipc_client = ipc_client; in qnetd_pr_poll_array_create()
180 struct unix_socket_client *ipc_client; in qnetd_poll() local
201 ipc_client = NULL; in qnetd_poll()
214 ipc_client = user_data->ipc_client; in qnetd_poll()
230 qnetd_ipc_accept(instance, &ipc_client); in qnetd_poll()
233 qnetd_ipc_io_read(instance, ipc_client); in qnetd_poll()
[all …]
|
| H A D | qdevice-net-instance.c | 155 struct unix_socket_client *ipc_client; in qdevice_net_instance_destroy() local
162 TAILQ_FOREACH(ipc_client, ipc_client_list, entries) { in qdevice_net_instance_destroy()
163 qdevice_ipc_user_data = (struct qdevice_ipc_user_data *)ipc_client->user_data; in qdevice_net_instance_destroy()
|
| H A D | qnetd-poll-array-user-data.h | 54 struct unix_socket_client *ipc_client; member
|
| /dports/x11-wm/i3/i3-4.20.1/include/ |
| H A D | ipc.h | 26 typedef struct ipc_client { struct
43 TAILQ_ENTRY(ipc_client) clients; argument
44 } ipc_client; typedef
56 typedef void (*handler_t)(ipc_client *, uint8_t *, int, uint32_t, uint32_t);
60 static void handle_##name(ipc_client *client, uint8_t *message, \
81 ipc_client *ipc_new_client_on_fd(EV_P_ int fd);
147 void ipc_confirm_restart(ipc_client *client);
|
| H A D | commands_parser.h | 27 ipc_client *client;
68 CommandResult *parse_command(const char *input, yajl_gen gen, ipc_client *client);
|
| /dports/x11-wm/i3-gaps/i3-4.20.1/include/ |
| H A D | ipc.h | 26 typedef struct ipc_client { struct
43 TAILQ_ENTRY(ipc_client) clients; argument
44 } ipc_client; typedef
56 typedef void (*handler_t)(ipc_client *, uint8_t *, int, uint32_t, uint32_t);
60 static void handle_##name(ipc_client *client, uint8_t *message, \
81 ipc_client *ipc_new_client_on_fd(EV_P_ int fd);
147 void ipc_confirm_restart(ipc_client *client);
|
| H A D | commands_parser.h | 27 ipc_client *client;
68 CommandResult *parse_command(const char *input, yajl_gen gen, ipc_client *client);
|
| /dports/x11-wm/sway/sway-1.5.1/sway/ |
| H A D | ipc-server.c | 45 struct ipc_client { struct
63 void ipc_client_disconnect(struct ipc_client *client); argument
64 void ipc_client_handle_command(struct ipc_client *client, uint32_t payload_length,
66 bool ipc_send_reply(struct ipc_client *client, enum ipc_command_type payload_type,
176 struct ipc_client *client = malloc(sizeof(struct ipc_client)); in ipc_handle_connection()
205 struct ipc_client *client = data; in ipc_client_handle_readable()
276 struct ipc_client *client = ipc_client_list->items[i]; in ipc_has_event_listeners()
285 struct ipc_client *client; in ipc_send_event()
518 struct ipc_client *client = data; in ipc_client_handle_writable()
559 void ipc_client_disconnect(struct ipc_client *client) { in ipc_client_disconnect()
[all …]
|
| /dports/x11-wm/i3/i3-4.20.1/src/ |
| H A D | ipc.c | 45 static void ipc_push_pending(ipc_client *client) { in ipc_push_pending()
117 static void free_ipc_client(ipc_client *client, int exempt_fd) { in free_ipc_client()
148 ipc_client *current; in ipc_send_event()
195 ipc_client *current; in ipc_shutdown()
1157 ipc_client *client = extra; in add_subscription()
1404 ipc_client *client = (ipc_client *)w->data; in ipc_receive_message()
1436 ipc_client *client = (ipc_client *)w->data; in ipc_client_timeout()
1481 ipc_client *client = (ipc_client *)w->data; in ipc_socket_writeable_cb()
1521 ipc_client *ipc_new_client_on_fd(EV_P_ int fd) { in ipc_new_client_on_fd()
1524 ipc_client *client = scalloc(1, sizeof(ipc_client)); in ipc_new_client_on_fd()
[all …]
|
| /dports/x11-wm/i3-gaps/i3-4.20.1/src/ |
| H A D | ipc.c | 45 static void ipc_push_pending(ipc_client *client) { in ipc_push_pending()
117 static void free_ipc_client(ipc_client *client, int exempt_fd) { in free_ipc_client()
148 ipc_client *current; in ipc_send_event()
195 ipc_client *current; in ipc_shutdown()
1186 ipc_client *client = extra; in add_subscription()
1433 ipc_client *client = (ipc_client *)w->data; in ipc_receive_message()
1465 ipc_client *client = (ipc_client *)w->data; in ipc_client_timeout()
1510 ipc_client *client = (ipc_client *)w->data; in ipc_socket_writeable_cb()
1550 ipc_client *ipc_new_client_on_fd(EV_P_ int fd) { in ipc_new_client_on_fd()
1553 ipc_client *client = scalloc(1, sizeof(ipc_client)); in ipc_new_client_on_fd()
[all …]
|
| /dports/multimedia/mpv/mpv-0.34.1/input/ |
| H A D | ipc-unix.c | 398 if (opts->ipc_client && opts->ipc_client[0]) { in mp_init_ipc()
400 if (strncmp(opts->ipc_client, "fd://", 5) == 0) { in mp_init_ipc()
402 unsigned long l = strtoul(opts->ipc_client + 5, &end, 0); in mp_init_ipc()
407 MP_ERR(arg, "Invalid IPC client argument: '%s'\n", opts->ipc_client); in mp_init_ipc()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/remoting/host/security_key/ |
| H A D | security_key_message_handler.cc | 30 std::unique_ptr<SecurityKeyIpcClient> ipc_client, in Start() argument
35 DCHECK(ipc_client); in Start()
49 ipc_client_ = std::move(ipc_client); in Start()
|
| H A D | remote_security_key_main.cc | 151 std::unique_ptr<SecurityKeyIpcClient> ipc_client(new SecurityKeyIpcClient()); in StartRemoteSecurityKey() local
155 std::move(ipc_client), run_loop.QuitClosure()); in StartRemoteSecurityKey()
|
| H A D | security_key_message_handler_unittest.cc | 75 auto ipc_client = std::make_unique<FakeSecurityKeyIpcClient>( in SetUp() local
78 ipc_client_weak_ptr_ = ipc_client->AsWeakPtr(); in SetUp()
96 std::move(read_file), std::move(write_file), std::move(ipc_client), in SetUp()
|
| /dports/x11-wm/qtile/qtile-0.18.1/libqtile/interactive/ |
| H A D | iqshell_kernel.py | 37 ipc_client = ipc.Client(socket_path)
38 cmd_object = command.interface.IPCCommandInterface(ipc_client)
|
| /dports/x11-wm/qtile/qtile-0.18.1/test/ |
| H A D | helpers.py | 130 ipc_client = ipc.Client(socket_path)
131 ipc_command = command.interface.IPCCommandInterface(ipc_client)
191 ipc_client = ipc.Client(self.sockfile)
192 ipc_command = command.interface.IPCCommandInterface(ipc_client)
|
| /dports/mail/thunderbird/thunderbird-91.8.0/third_party/rust/audioipc-server/src/ |
| H A D | lib.rs | 137 .map(|(ipc_server, ipc_client)| { in audioipc_server_new_client()
158 unsafe { PlatformHandle::from(ipc_client).into_raw() } in audioipc_server_new_client()
|
| /dports/www/firefox-esr/firefox-91.8.0/third_party/rust/audioipc-server/src/ |
| H A D | lib.rs | 137 .map(|(ipc_server, ipc_client)| { in audioipc_server_new_client()
158 unsafe { PlatformHandle::from(ipc_client).into_raw() } in audioipc_server_new_client()
|
| /dports/lang/spidermonkey78/firefox-78.9.0/media/audioipc/server/src/ |
| H A D | lib.rs | 135 .and_then(|(ipc_server, ipc_client)| { in audioipc_server_new_client()
157 Ok(unsafe { PlatformHandle::from(ipc_client).into_raw() }) in audioipc_server_new_client()
|
| /dports/x11-wm/qtile/qtile-0.18.1/libqtile/command/ |
| H A D | interface.py | 206 def __init__(self, ipc_client: ipc.Client):
214 self._client = ipc_client
|