Home
last modified time | relevance | path

Searched refs:client_msg (Results 1 – 25 of 132) sorted by relevance

123456

/dports/comms/owfs/owfs-3.2p4/module/owserver/src/include/
H A Dowserver.h50 int ToClient(int file_descriptor, struct client_msg *cm, const char *data);
53 void *ReadHandler(struct handlerdata *hd, struct client_msg *cm, struct one_wire_query *owq);
56 void WriteHandler(struct handlerdata *hd, struct client_msg *cm, struct one_wire_query *owq);
59 void DirHandler(struct handlerdata *hd, struct client_msg *cm, const struct parsedname *pn);
62 void *DirallHandler(struct handlerdata *hd, struct client_msg *cm, const struct parsedname *pn);
65 void *DirallslashHandler(struct handlerdata *hd, struct client_msg *cm, const struct parsedname *pn…
74 void ErrorToClient(struct handlerdata *hd, struct client_msg * cm ) ;
/dports/comms/owfs/owfs-3.2p4/module/owshell/src/c/
H A Dow_server.c17 static void *FromServerAlloc(int file_descriptor, struct client_msg *cm);
39 struct client_msg cm; in ServerRead()
51 memset(&cm, 0, sizeof(struct client_msg)); in ServerRead()
81 struct client_msg cm; in ServerWrite()
109 struct client_msg cm; in ServerDirall()
140 struct client_msg cm; in ServerDir()
169 struct client_msg cm; in ServerPresence()
202 ret = tcp_read(file_descriptor, cm, sizeof(struct client_msg), &tv); in FromServerAlloc()
203 if (ret != sizeof(struct client_msg)) { in FromServerAlloc()
204 memset(cm, 0, sizeof(struct client_msg)); in FromServerAlloc()
[all …]
/dports/comms/owfs/owfs-3.2p4/module/ownet/c/src/c/
H A Dow_server.c69 struct client_msg cm; in ServerRead()
75 memset(&cm, 0, sizeof(struct client_msg)); in ServerRead()
105 struct client_msg cm; in ServerPresence()
111 memset(&cm, 0, sizeof(struct client_msg)); in ServerPresence()
140 struct client_msg cm; in ServerWrite()
153 memset(&cm, 0, sizeof(struct client_msg)); in ServerWrite()
206 struct client_msg cm; in ServerDIR()
213 memset(&cm, 0, sizeof(struct client_msg)); in ServerDIR()
244 struct client_msg cm; in ServerDIRALL()
250 memset(&cm, 0, sizeof(struct client_msg)); in ServerDIRALL()
[all …]
/dports/comms/owfs/owfs-3.2p4/module/owserver/src/c/
H A Dto_client.c42 int ToClient(int file_descriptor, struct client_msg *machine_order_cm, const char *data) in ToClient()
44 struct client_msg s_cm; in ToClient()
45 struct client_msg *network_order_cm = &s_cm; in ToClient()
54 {network_order_cm, sizeof(struct client_msg),}, in ToClient()
61 {network_order_cm, sizeof(struct client_msg),}, in ToClient()
H A Ddir.c48 struct client_msg *cm;
68 void DirHandler(struct handlerdata *hd, struct client_msg *cm, const struct parsedname *pn) in DirHandler()
/dports/comms/owfs/owfs-3.2p4/module/owlib/src/c/
H A Dow_server_message.c56 struct client_msg cm; in ServerRead()
66 memset(&cm, 0, sizeof(struct client_msg)); in ServerRead()
99 struct client_msg cm; in ServerPresence()
109 memset(&cm, 0, sizeof(struct client_msg)); in ServerPresence()
142 struct client_msg cm; in ServerWrite()
152 memset(&cm, 0, sizeof(struct client_msg)); in ServerWrite()
218 struct client_msg cm; in ServerDIR()
230 memset(&cm, 0, sizeof(struct client_msg)); in ServerDIR()
280 struct client_msg cm; in ServerDIRALL()
290 memset(&cm, 0, sizeof(struct client_msg)); in ServerDIRALL()
[all …]
/dports/security/sudo/sudo-1.9.8p2/logsrvd/
H A Dsendlog.c363 client_msg.u.hello_msg = &hello_msg; in fmt_client_hello()
555 client_msg.u.reject_msg = &reject_msg; in fmt_reject_message()
614 client_msg.u.accept_msg = &accept_msg; in fmt_accept_message()
653 client_msg.u.restart_msg = &restart_msg; in fmt_restart_message()
689 client_msg.u.exit_msg = &exit_msg; in fmt_exit_message()
731 client_msg.u.ttyout_buf = &iobuf_msg; in fmt_io_buf()
732 client_msg.type_case = type; in fmt_io_buf()
733 if (!fmt_client_message(buf, &client_msg)) in fmt_io_buf()
768 client_msg.u.winsize_event = &winsize_msg; in fmt_winsize()
770 if (!fmt_client_message(buf, &client_msg)) in fmt_winsize()
[all …]
/dports/security/sudo/sudo-1.9.8p2/plugins/sudoers/
H A Dlog_client.c761 client_msg.u.hello_msg = &hello_msg; in fmt_client_hello()
995 client_msg.u.accept_msg = &accept_msg; in fmt_accept_message()
1044 client_msg.u.reject_msg = &reject_msg; in fmt_reject_message()
1093 client_msg.u.alert_msg = &alert_msg; in fmt_alert_message()
1174 client_msg.restart_msg = &restart_msg; in fmt_restart_message()
1248 client_msg.u.exit_msg = &exit_msg; in fmt_exit_message()
1250 if (!fmt_client_message(closure, &client_msg)) in fmt_exit_message()
1287 client_msg.u.ttyout_buf = &iobuf_msg; in fmt_io_buf()
1288 client_msg.type_case = type; in fmt_io_buf()
1324 client_msg.u.winsize_event = &winsize_msg; in fmt_winsize()
[all …]
/dports/databases/percona57-server/percona-server-5.7.36-39/rapid/plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/
H A Dxcom_base.h112 #define RESET_CLIENT_MSG if(ep->client_msg){msg_link_delete(&ep->client_msg);}
114 #define APP ep->client_msg->p->a
120 CHANNEL_GET(&prop_input_queue, &ep->client_msg, msg_link); \
126 sprintf(ep->client_msg->p->v,msg" %s",#x); \
128 ep->client_msg->p->start_type = BOOT; \
129 link_into(&ep->client_msg->l, &ep->boot_list); \
/dports/databases/xtrabackup/percona-xtrabackup-2.4.21/rapid/plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/
H A Dxcom_base.h112 #define RESET_CLIENT_MSG if(ep->client_msg){msg_link_delete(&ep->client_msg);}
114 #define APP ep->client_msg->p->a
120 CHANNEL_GET(&prop_input_queue, &ep->client_msg, msg_link); \
126 sprintf(ep->client_msg->p->v,msg" %s",#x); \
128 ep->client_msg->p->start_type = BOOT; \
129 link_into(&ep->client_msg->l, &ep->boot_list); \
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/rapid/plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/
H A Dxcom_base.h112 #define RESET_CLIENT_MSG if(ep->client_msg){msg_link_delete(&ep->client_msg);}
114 #define APP ep->client_msg->p->a
120 CHANNEL_GET(&prop_input_queue, &ep->client_msg, msg_link); \
126 sprintf(ep->client_msg->p->v,msg" %s",#x); \
128 ep->client_msg->p->start_type = BOOT; \
129 link_into(&ep->client_msg->l, &ep->boot_list); \
/dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/rapid/plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/
H A Dxcom_base.h112 #define RESET_CLIENT_MSG if(ep->client_msg){msg_link_delete(&ep->client_msg);}
114 #define APP ep->client_msg->p->a
120 CHANNEL_GET(&prop_input_queue, &ep->client_msg, msg_link); \
126 sprintf(ep->client_msg->p->v,msg" %s",#x); \
128 ep->client_msg->p->start_type = BOOT; \
129 link_into(&ep->client_msg->l, &ep->boot_list); \
/dports/databases/percona57-client/percona-server-5.7.36-39/rapid/plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/
H A Dxcom_base.h112 #define RESET_CLIENT_MSG if(ep->client_msg){msg_link_delete(&ep->client_msg);}
114 #define APP ep->client_msg->p->a
120 CHANNEL_GET(&prop_input_queue, &ep->client_msg, msg_link); \
126 sprintf(ep->client_msg->p->v,msg" %s",#x); \
128 ep->client_msg->p->start_type = BOOT; \
129 link_into(&ep->client_msg->l, &ep->boot_list); \
/dports/databases/mysql57-client/mysql-5.7.36/rapid/plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/
H A Dxcom_base.h112 #define RESET_CLIENT_MSG if(ep->client_msg){msg_link_delete(&ep->client_msg);}
114 #define APP ep->client_msg->p->a
120 CHANNEL_GET(&prop_input_queue, &ep->client_msg, msg_link); \
126 sprintf(ep->client_msg->p->v,msg" %s",#x); \
128 ep->client_msg->p->start_type = BOOT; \
129 link_into(&ep->client_msg->l, &ep->boot_list); \
/dports/dns/opendnssec2/opendnssec-2.1.10/common/
H A Dclientpipe.c74 client_msg(int sockfd, char opc, const char *cmd, uint16_t count) in client_msg() function
87 return client_msg(sockfd, CLIENT_OPC_STDIN, cmd, count); in client_stdin()
92 return client_msg(sockfd, CLIENT_OPC_STDOUT, cmd, count); in client_stdout()
97 return client_msg(sockfd, CLIENT_OPC_STDERR, cmd, count); in client_stderr()
/dports/devel/libsoup3/libsoup-3.0.3/examples/
H A Dsimple-proxy.c320 SoupMessage *client_msg; in server_callback() local
335 client_msg = soup_message_new (soup_server_message_get_method (msg), uristr); in server_callback()
336 g_assert (client_msg && SOUP_IS_MESSAGE (client_msg)); in server_callback()
337 SoupMessageHeaders *client_msg_headers = soup_message_get_request_headers (client_msg); in server_callback()
349 soup_message_set_request_body_from_bytes (client_msg, content_type, request); in server_callback()
355 g_signal_connect (client_msg, "got_headers", G_CALLBACK (send_headers), msg); in server_callback()
361 soup_session_send_async (session, client_msg, G_PRIORITY_DEFAULT, client_cancellable, in server_callback()
364 g_object_unref (client_msg); in server_callback()
/dports/security/s2n/s2n-tls-1.1.2/tests/integration/common/
H A Ds2n_test_common.py65 client_msg = "Message:" + str(uuid.uuid4())
66 client.stdin.write((client_msg + "\n\n").encode("utf-8"))
69 if not wait_for_output(server.stdout, client_msg, line_limit=200):
70 return Result("Failed to write %s from client to server" % (client_msg))
/dports/multimedia/mpv/mpv-0.34.1/input/
H A Dipc-unix.c108 bstr client_msg = { talloc_strdup(NULL, ""), 0 }; in client_thread() local
187 bstr_xappend(NULL, &client_msg, append); in client_thread()
189 while (bstrchr(client_msg, '\n') != -1) { in client_thread()
191 NULL, &client_msg); in client_thread()
209 if (client_msg.len > 0) in client_thread()
211 talloc_free(client_msg.start); in client_thread()
/dports/games/abstreet/winit-a87ae2661263ff241e8868cbf3ce65aab205863a/src/platform_impl/linux/x11/
H A Devent_processor.rs174 let client_msg: &ffi::XClientMessageEvent = xev.as_ref(); in process_event() localVariable
176 let window = client_msg.window; in process_event()
194 } else if client_msg.message_type == self.dnd.atoms.enter { in process_event()
196 let flags = client_msg.data.get_long(1); in process_event()
202 client_msg.data.get_long(2) as c_ulong, in process_event()
203 client_msg.data.get_long(3) as c_ulong, in process_event()
204 client_msg.data.get_long(4) as c_ulong, in process_event()
211 } else if client_msg.message_type == self.dnd.atoms.position { in process_event()
248 client_msg.data.get_long(3) as c_ulong in process_event()
268 } else if client_msg.message_type == self.dnd.atoms.drop { in process_event()
[all …]
/dports/x11/alacritty/alacritty-0.9.0/cargo-crates/winit-0.24.0/src/platform_impl/linux/x11/
H A Devent_processor.rs177 let client_msg: &ffi::XClientMessageEvent = xev.as_ref(); in process_event() localVariable
179 let window = client_msg.window; in process_event()
197 } else if client_msg.message_type == self.dnd.atoms.enter { in process_event()
199 let flags = client_msg.data.get_long(1); in process_event()
205 client_msg.data.get_long(2) as c_ulong, in process_event()
206 client_msg.data.get_long(3) as c_ulong, in process_event()
207 client_msg.data.get_long(4) as c_ulong, in process_event()
214 } else if client_msg.message_type == self.dnd.atoms.position { in process_event()
251 client_msg.data.get_long(3) as c_ulong in process_event()
271 } else if client_msg.message_type == self.dnd.atoms.drop { in process_event()
[all …]
/dports/net-p2p/vuze/vuze-5.7.4.0_2/com/aelitis/azureus/core/clientmessageservice/impl/
H A DClientConnection.java119 public void sendMessage( final ClientMessage client_msg, final Message msg ) { in sendMessage() argument
121 sending_msgs.add( client_msg ); in sendMessage()
135 sending_msgs.remove( client_msg ); in sendMessage()
139 client_msg.reportComplete(); in sendMessage()
/dports/audio/supercollider/SuperCollider-3.11.0-Source/QtCollider/hacks/
H A Dhacks_x11.cpp90 static int client_msg(Display* disp, Window win, const char* msg, /* {{{ */ in client_msg() function
128 …if (client_msg(disp, DefaultRootWindow(disp), "_NET_CURRENT_DESKTOP", *desktop, 0, 0, 0, 0) != EXI… in activate_window()
135 client_msg(disp, win, "_NET_ACTIVE_WINDOW", 0, 0, 0, 0, 0); in activate_window()
/dports/security/vault/vault-1.8.2/vendor/github.com/apple/foundationdb/FDBLibTLS/
H A Dplugin-test.cpp390 std::string client_msg("FDBLibTLSPlugin Client Write Test"); in client_server_test() local
399 rc = client_session->write((const uint8_t*)&client_msg[cn], client_msg.size()-cn); in client_server_test()
402 if (cn >= client_msg.size()) in client_server_test()
418 if (sn >= client_msg.size()) in client_server_test()
430 if (client_msg != server_msg) { in client_server_test()
431 std::cerr << "FAIL: got client msg '" << server_msg << "' want '" << client_msg << "'\n"; in client_server_test()
443 client_msg.clear(); in client_server_test()
468 client_msg += buf[j]; in client_server_test()
481 if (server_msg != client_msg) { in client_server_test()
482 std::cerr << "FAIL: got server msg '" << client_msg << "' want '" << server_msg << "'\n"; in client_server_test()
/dports/games/abstreet/winit-a87ae2661263ff241e8868cbf3ce65aab205863a/src/platform_impl/linux/x11/util/
H A Dmod.rs5 mod client_msg; module
20 atom::*, client_msg::*, format::*, geometry::*, hint::*, icon::*, input::*, memory::*,
/dports/x11/alacritty/alacritty-0.9.0/cargo-crates/winit-0.24.0/src/platform_impl/linux/x11/util/
H A Dmod.rs5 mod client_msg; module
20 atom::*, client_msg::*, format::*, geometry::*, hint::*, icon::*, input::*, memory::*,

123456