| /dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/unittest/gunit/xplugin/xpl/ |
| H A D | cursor_t.cc | 199 Mysqlx::Cursor::Close close_msg; in TEST_F() local
200 close_msg.set_cursor_id(cursor_id); in TEST_F()
212 ASSERT_ERROR_CODE(ER_X_SUCCESS, m_handler.execute_cursor_close(close_msg)); in TEST_F()
219 Mysqlx::Cursor::Close close_msg; in TEST_F() local
220 close_msg.set_cursor_id(cursor_id); in TEST_F()
226 m_handler.execute_cursor_close(close_msg)); in TEST_F()
|
| /dports/net/libtrace/libtrace-3.0.19/lib/ |
| H A D | format_rt.c | 265 rt_header_t close_msg; in rt_pause_input() local
267 close_msg.type = TRACE_RT_CLOSE; in rt_pause_input()
268 close_msg.length = 0; in rt_pause_input()
271 if (send(RT_INFO->input_fd, (void*)&close_msg, sizeof(rt_header_t) + in rt_pause_input()
272 close_msg.length, 0) != (int)sizeof(rt_header_t) in rt_pause_input()
273 + close_msg.length) { in rt_pause_input()
|
| /dports/net/google-cloud-sdk/google-cloud-sdk/lib/googlecloudsdk/api_lib/compute/ |
| H A D | iap_tunnel_websocket_helper.py | 164 close_msg = '%r: %r' % (close_code, close_reason)
165 log.info('Received WebSocket Close message [%s].', close_msg)
166 self.Close(msg=close_msg)
|
| /dports/devel/codeblocks/codeblocks-20.03/src/plugins/contrib/FortranProject/images/fortranproject/ |
| H A D | gdb_fortran_extensions_v1.0.py | 650 close_msg = "Click on button to close"
652 close_msg = "Hit return to close"
653 dem_str = dem_str.replace("$gnuplot_close_msg$", close_msg)
702 close_msg = "Click on button to close"
704 close_msg = "Hit return to close"
705 dem_str = dem_str.replace("$gnuplot_close_msg$", close_msg)
|
| /dports/cad/sumo/sumo-1.2.0/tools/webWizard/ |
| H A D | SimpleWebSocketServer.py | 312 close_msg = bytearray()
313 close_msg.extend(struct.pack("!H", status))
315 close_msg.extend(reason.encode('utf-8'))
317 close_msg.extend(reason)
319 self._sendMessage(False, CLOSE, close_msg)
|
| /dports/x11/ulauncher/ulauncher/ulauncher/utils/ |
| H A D | SimpleWebSocketServer.py | 300 close_msg = bytearray()
301 close_msg.extend(struct.pack("!H", status))
303 close_msg.extend(reason.encode('utf-8'))
305 close_msg.extend(reason)
307 self._sendMessage(False, CLOSE, close_msg)
|
| /dports/multimedia/libv4l/linux-5.13-rc2/drivers/tty/ipwireless/ |
| H A D | setup_protocol.h | 104 struct tl_setup_close_msg close_msg; member
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/tty/ipwireless/ |
| H A D | setup_protocol.h | 104 struct tl_setup_close_msg close_msg; member
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/tty/ipwireless/ |
| H A D | setup_protocol.h | 104 struct tl_setup_close_msg close_msg; member
|
| /dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/router/src/routing/tests/ |
| H A D | test_x_protocol.cc | 244 Mysqlx::Session::Close close_msg{}; in TEST_F() local
247 close_msg, in TEST_F()
309 Mysqlx::Connection::Close close_msg{}; in TEST_F() local
312 close_msg, in TEST_F()
|
| /dports/devel/gitui/gitui-0.10.1/src/components/ |
| H A D | msg.rs | 65 strings::commands::close_msg(&self.key_config), in commands()
|
| /dports/net/waypipe/waypipe-a11a59c58bee3972ce9e1e18731eba28cc0a8f0a/src/ |
| H A D | mainloop.c | 1503 uint32_t close_msg[2]; in main_interface_loop() local
1504 close_msg[0] = transfer_header(sizeof(close_msg), WMSG_CLOSE); in main_interface_loop()
1505 close_msg[1] = exit_code == ERR_STOP ? 0 : (uint32_t)exit_code; in main_interface_loop()
1506 wp_debug("Sending close message, modecode=%d", close_msg[1]); in main_interface_loop()
1507 if (write(chanfd, &close_msg, sizeof(close_msg)) == -1) { in main_interface_loop()
|
| /dports/net-p2p/bazarr/bazarr-1.0.2/libs/websocket/tests/ |
| H A D | test_app.py | 158 def on_close(wsapp, close_status_code, close_msg):
|
| /dports/multimedia/tautulli/Tautulli-2.8.0/lib/websocket/tests/ |
| H A D | test_app.py | 160 def on_close(wsapp, close_status_code, close_msg): argument
|
| /dports/net/mpich/mpich-3.4.3/src/mpid/ch4/netmod/ofi/ |
| H A D | ofi_init.c | 467 int *close_msg; in conn_manager_destroy() local
486 MPIR_CHKLMEM_MALLOC(close_msg, int *, max_n_conn * sizeof(int), mpi_errno, "int", in conn_manager_destroy()
504 &close_msg[j], in conn_manager_destroy()
544 unsigned int close_msg = 0xcccccccc; in dynproc_send_disconnect() local
561 msg_iov.iov_base = &close_msg; in dynproc_send_disconnect()
562 msg_iov.iov_len = sizeof(close_msg); in dynproc_send_disconnect()
|
| /dports/lang/mit-scheme/mit-scheme-9.2/src/microcode/ |
| H A D | ntgui.c | 191 MSG close_msg; in nt_gui_high_priority_poll() local
193 if (PeekMessage (&close_msg, master_tty_window, in nt_gui_high_priority_poll()
196 DispatchMessage (&close_msg); in nt_gui_high_priority_poll()
|
| /dports/www/nginx-full/nchan-1.2.12/src/subscribers/ |
| H A D | websocket.c | 1953 ngx_str_t *close_msg = NULL; in websocket_respond_status() local
1972 close_msg = (ngx_str_t *)(status_line ? status_line : &STATUS_410); in websocket_respond_status()
1977 close_msg = (ngx_str_t *)(status_line ? status_line : &STATUS_403); in websocket_respond_status()
1982 close_msg = (ngx_str_t *)(status_line ? status_line : &STATUS_500); in websocket_respond_status()
1987 close_msg = (ngx_str_t *)(status_line ? status_line : &STATUS_507); in websocket_respond_status()
1994 close_msg = &custom_close_msg; in websocket_respond_status()
2002 websocket_send_close_frame(fsub, close_code, close_msg); in websocket_respond_status()
|
| /dports/sysutils/usermin/usermin-1.830/mailbox/ |
| H A D | reply_mail.cgi | 473 my $close_msg = "e_escape($text{'send_eclosemsg'}, '"');
500 return "$close_msg";
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/block/rnbd/ |
| H A D | rnbd-srv.c | 350 const struct rnbd_msg_close *close_msg = usr; in process_msg_close() local
353 sess_dev = rnbd_get_sess_dev(le32_to_cpu(close_msg->device_id), in process_msg_close()
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/block/rnbd/ |
| H A D | rnbd-srv.c | 350 const struct rnbd_msg_close *close_msg = usr; in process_msg_close() local
353 sess_dev = rnbd_get_sess_dev(le32_to_cpu(close_msg->device_id), in process_msg_close()
|
| /dports/multimedia/libv4l/linux-5.13-rc2/drivers/block/rnbd/ |
| H A D | rnbd-srv.c | 350 const struct rnbd_msg_close *close_msg = usr; in process_msg_close() local
353 sess_dev = rnbd_get_sess_dev(le32_to_cpu(close_msg->device_id), in process_msg_close()
|
| /dports/net-mgmt/nagios-check_bacula9/bacula-9.6.7/src/lib/ |
| H A D | jcr.c | 550 close_msg(jcr); /* close messages for this job */
603 close_msg(NULL); /* flush any daemon messages */
|
| /dports/net-mgmt/nagios-check_bacula11/bacula-11.0.5/src/lib/ |
| H A D | jcr.c | 552 close_msg(jcr); /* close messages for this job */
605 close_msg(NULL); /* flush any daemon messages */
|
| /dports/sysutils/bacula9-server/bacula-9.6.7/src/lib/ |
| H A D | jcr.c | 550 close_msg(jcr); /* close messages for this job */
603 close_msg(NULL); /* flush any daemon messages */
|
| /dports/sysutils/bacula11-client-static/bacula-11.0.5/src/lib/ |
| H A D | jcr.c | 552 close_msg(jcr); /* close messages for this job */
605 close_msg(NULL); /* flush any daemon messages */
|