/dports/comms/owfs/owfs-3.2p4/module/owserver/src/include/ |
H A D | owserver.h | 50 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 D | ow_server.c | 17 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 D | ow_server.c | 69 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 D | to_client.c | 42 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 D | dir.c | 48 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 D | ow_server_message.c | 56 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 D | sendlog.c | 363 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 D | log_client.c | 761 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 D | xcom_base.h | 112 #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 D | xcom_base.h | 112 #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 D | xcom_base.h | 112 #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 D | xcom_base.h | 112 #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 D | xcom_base.h | 112 #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 D | xcom_base.h | 112 #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 D | clientpipe.c | 74 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 D | simple-proxy.c | 320 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 D | s2n_test_common.py | 65 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 D | ipc-unix.c | 108 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 D | event_processor.rs | 174 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 D | event_processor.rs | 177 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 D | ClientConnection.java | 119 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 D | hacks_x11.cpp | 90 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 D | plugin-test.cpp | 390 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 D | mod.rs | 5 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 D | mod.rs | 5 mod client_msg; module 20 atom::*, client_msg::*, format::*, geometry::*, hint::*, icon::*, input::*, memory::*,
|