| /dports/databases/xtrabackup/percona-xtrabackup-2.4.21/sql/ |
| H A D | rpl_transaction_write_set_ctx.cc | 42 write_set.reserve(24); in Rpl_transaction_write_set_ctx()
49 write_set.push_back(hash); in add_write_set()
63 write_set.clear(); in clear_write_set()
114 unsigned long write_set_size= write_set->size(); in get_transaction_write_set()
125 result_set->write_set= in get_transaction_write_set()
132 it != write_set->end(); in get_transaction_write_set()
136 result_set->write_set[result_set_index++]=temp; in get_transaction_write_set()
202 DBUG_ASSERT(elem->second <= write_set.size()); in rollback_to_savepoint()
228 if (write_set.size() > 0 && position < write_set.size()) in rollback_to_savepoint()
231 write_set.erase(write_set.begin() + position, write_set.end()); in rollback_to_savepoint()
[all …]
|
| /dports/databases/percona57-server/percona-server-5.7.36-39/sql/ |
| H A D | rpl_transaction_write_set_ctx.cc | 49 write_set.reserve(24); in Rpl_transaction_write_set_ctx()
81 write_set.push_back(hash); in add_write_set()
101 write_set.clear(); in clear_write_set()
138 return sizeof(uint64) * write_set.size(); in write_set_memory_size()
212 result_set->write_set= in get_transaction_write_set()
219 it != write_set->end(); in get_transaction_write_set()
315 if (write_set.size() > 0 && position < write_set.size()) in rollback_to_savepoint()
318 write_set.erase(write_set.begin() + position, write_set.end()); in rollback_to_savepoint()
322 write_set_unique.insert(write_set.begin(), write_set.end()); in rollback_to_savepoint()
326 assert(write_set.size() == 2); in rollback_to_savepoint()
[all …]
|
| /dports/databases/percona57-client/percona-server-5.7.36-39/sql/ |
| H A D | rpl_transaction_write_set_ctx.cc | 49 write_set.reserve(24); in Rpl_transaction_write_set_ctx()
81 write_set.push_back(hash); in add_write_set()
101 write_set.clear(); in clear_write_set()
138 return sizeof(uint64) * write_set.size(); in write_set_memory_size()
212 result_set->write_set= in get_transaction_write_set()
219 it != write_set->end(); in get_transaction_write_set()
315 if (write_set.size() > 0 && position < write_set.size()) in rollback_to_savepoint()
318 write_set.erase(write_set.begin() + position, write_set.end()); in rollback_to_savepoint()
322 write_set_unique.insert(write_set.begin(), write_set.end()); in rollback_to_savepoint()
326 assert(write_set.size() == 2); in rollback_to_savepoint()
[all …]
|
| /dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/sql/ |
| H A D | rpl_transaction_write_set_ctx.cc | 49 write_set.reserve(24); in Rpl_transaction_write_set_ctx()
81 write_set.push_back(hash); in add_write_set()
101 write_set.clear(); in clear_write_set()
138 return sizeof(uint64) * write_set.size(); in write_set_memory_size()
212 result_set->write_set= in get_transaction_write_set()
219 it != write_set->end(); in get_transaction_write_set()
315 if (write_set.size() > 0 && position < write_set.size()) in rollback_to_savepoint()
318 write_set.erase(write_set.begin() + position, write_set.end()); in rollback_to_savepoint()
322 write_set_unique.insert(write_set.begin(), write_set.end()); in rollback_to_savepoint()
326 assert(write_set.size() == 2); in rollback_to_savepoint()
[all …]
|
| /dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/sql/ |
| H A D | rpl_transaction_write_set_ctx.cc | 49 write_set.reserve(24); in Rpl_transaction_write_set_ctx()
81 write_set.push_back(hash); in add_write_set()
101 write_set.clear(); in clear_write_set()
138 return sizeof(uint64) * write_set.size(); in write_set_memory_size()
212 result_set->write_set= in get_transaction_write_set()
219 it != write_set->end(); in get_transaction_write_set()
315 if (write_set.size() > 0 && position < write_set.size()) in rollback_to_savepoint()
318 write_set.erase(write_set.begin() + position, write_set.end()); in rollback_to_savepoint()
322 write_set_unique.insert(write_set.begin(), write_set.end()); in rollback_to_savepoint()
326 assert(write_set.size() == 2); in rollback_to_savepoint()
[all …]
|
| /dports/databases/mysql57-client/mysql-5.7.36/sql/ |
| H A D | rpl_transaction_write_set_ctx.cc | 49 write_set.reserve(24); in Rpl_transaction_write_set_ctx()
81 write_set.push_back(hash); in add_write_set()
101 write_set.clear(); in clear_write_set()
138 return sizeof(uint64) * write_set.size(); in write_set_memory_size()
212 result_set->write_set= in get_transaction_write_set()
219 it != write_set->end(); in get_transaction_write_set()
315 if (write_set.size() > 0 && position < write_set.size()) in rollback_to_savepoint()
318 write_set.erase(write_set.begin() + position, write_set.end()); in rollback_to_savepoint()
322 write_set_unique.insert(write_set.begin(), write_set.end()); in rollback_to_savepoint()
326 assert(write_set.size() == 2); in rollback_to_savepoint()
[all …]
|
| /dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/sql/ |
| H A D | rpl_transaction_write_set_ctx.cc | 49 write_set.reserve(12); in Rpl_transaction_write_set_ctx()
54 write_set.push_back(hash); in add_write_set()
59 return &write_set; in get_write_set()
64 write_set.clear(); in clear_write_set()
122 result_set->write_set[result_set_index++] = temp; in get_transaction_write_set()
135 DBUG_ASSERT(write_set.size() == 0); in add_savepoint()
177 DBUG_ASSERT(elem->second <= write_set.size()); in rollback_to_savepoint()
201 if (write_set.size() > 0 && position < write_set.size()) { in rollback_to_savepoint()
203 write_set.erase(write_set.begin() + position, write_set.end()); in rollback_to_savepoint()
207 DBUG_ASSERT(write_set.size() == 1);); in rollback_to_savepoint()
[all …]
|
| /dports/net/pptpclient/pptp-1.10.0/ |
| H A D | pptp_callmgr.c | 176 fd_set read_set = call_set, write_set; in callmgr_main() local
178 FD_ZERO (&write_set); in callmgr_main()
186 FD_ISSET (max_fd, &write_set)) in callmgr_main()
260 fd_set read_set, write_set; in callmgr_main() local
276 FD_ZERO(&write_set); in callmgr_main()
280 select(max_fd + 1, &read_set, &write_set, NULL, &tv); in callmgr_main()
285 FD_ZERO(&write_set); in callmgr_main()
286 pptp_fd_set(conn, &read_set, &write_set, &max_fd); in callmgr_main()
290 rc = pptp_dispatch(conn, &read_set, &write_set); in callmgr_main()
297 FD_ZERO(&write_set); in callmgr_main()
[all …]
|
| /dports/net/gsk/gsk-1.0.63/src/main-loops/ |
| H A D | gskmainloopselect.c | 68 FD_ISSET (fd, &select_loop->write_set))); in gsk_main_loop_select_config_fd()
81 FD_SET (fd, &select_loop->write_set); in gsk_main_loop_select_config_fd()
83 FD_CLR (fd, &select_loop->write_set); in gsk_main_loop_select_config_fd()
97 fd_set write_set; member
112 writable = FD_ISSET (fd, &iter_data->write_set); in foreach_tree_node_add_event()
148 iter_data.write_set = select_loop->write_set; in gsk_main_loop_select_do_polling()
158 &iter_data.write_set, in gsk_main_loop_select_do_polling()
204 FD_ZERO (&main_loop_select->write_set); in gsk_main_loop_select_init()
|
| /dports/net/mtr-nox11/mtr-0.94/packet/ |
| H A D | wait_unix.c | 43 fd_set * write_set) in gather_read_fds() argument
52 FD_ZERO(write_set); in gather_read_fds()
95 probe_nfds = gather_probe_sockets(net_state, write_set); in gather_read_fds()
115 fd_set write_set; in wait_for_activity() local
121 gather_read_fds(command_buffer, net_state, &read_set, &write_set); in wait_for_activity()
133 select(nfds, &read_set, &write_set, NULL, select_timeout); in wait_for_activity()
|
| /dports/net/mtr/mtr-0.94/packet/ |
| H A D | wait_unix.c | 43 fd_set * write_set) in gather_read_fds() argument
52 FD_ZERO(write_set); in gather_read_fds()
95 probe_nfds = gather_probe_sockets(net_state, write_set); in gather_read_fds()
115 fd_set write_set; in wait_for_activity() local
121 gather_read_fds(command_buffer, net_state, &read_set, &write_set); in wait_for_activity()
133 select(nfds, &read_set, &write_set, NULL, select_timeout); in wait_for_activity()
|
| /dports/sysutils/xvidcap/xvidcap-1.1.7/ffmpeg/libavformat/ |
| H A D | os_support.c | 90 fd_set write_set; in poll() local
104 FD_ZERO(&write_set); in poll()
119 if (fds[i].events & POLLOUT) FD_SET(fds[i].fd, &write_set); in poll()
131 rc = select(n+1, &read_set, &write_set, &exception_set, NULL); in poll()
137 rc = select(n+1, &read_set, &write_set, &exception_set, &tv); in poll()
147 if (FD_ISSET(fds[i].fd, &write_set)) fds[i].revents |= POLLOUT; in poll()
|
| /dports/databases/p5-Cache-Memcached-Fast/Cache-Memcached-Fast-0.27/src/ |
| H A D | poll_select.c | 35 fd_set read_set, write_set, exception_set; in poll_select() local
53 FD_ZERO(&write_set); in poll_select()
77 FD_SET(fds[i].fd, &write_set); in poll_select()
90 select_res = select(max_fd + 1, &read_set, &write_set, &exception_set, pto); in poll_select()
106 if (FD_ISSET(fds[i].fd, &write_set)) in poll_select()
|
| /dports/irc/undernet-ircu/ircu2.10.12.19/ircd/ |
| H A D | engine_select.c | 264 fd_set write_set; in engine_loop() local
273 write_set = global_write_set; in engine_loop()
283 nfds = select(highest_fd + 1, &read_set, &write_set, 0, in engine_loop()
333 if (FD_ISSET(i, &write_set)) { /* connection completed */ in engine_loop()
384 if (FD_ISSET(i, &write_set)) { /* data can be written to socket */ in engine_loop()
388 if (FD_ISSET(i, &read_set) || FD_ISSET(i, &write_set)) in engine_loop()
397 if (FD_ISSET(i, &write_set)) { /* data can be written to socket */ in engine_loop()
401 if (FD_ISSET(i, &read_set) || FD_ISSET(i, &write_set)) in engine_loop()
|
| /dports/devel/efl/efl-1.25.1/src/lib/evil/ |
| H A D | evil_unistd.c | 83 fd_set write_set; in evil_pipe() local
136 FD_ZERO (&write_set); in evil_pipe()
137 FD_SET (socket1, &write_set); in evil_pipe()
139 if (select (0, NULL, &write_set, NULL, NULL) == SOCKET_ERROR) in evil_pipe()
142 if (!FD_ISSET (socket1, &write_set)) in evil_pipe()
|
| /dports/sysutils/calamares/calamares-3.2.44.2/src/modules/keyboard/ |
| H A D | layout-extractor.py | 58 def write_set(file, label, set): function
93 write_set(f, "kb_models", models)
94 write_set(f, "kb_layouts", layouts)
95 write_set(f, "kb_variants", variants)
|
| /dports/devel/libiqxmlrpc/libiqxmlrpc-0.13.5/libiqxmlrpc/ |
| H A D | reactor_select_impl.cc | 26 FD_ZERO( &write_set ); in reset()
34 FD_SET( i->fd, &write_set ); in reset()
54 int code = ::select( static_cast<int>(max_fd+1), &read_set, &write_set, &err_set, ptv ); in poll()
73 revents |= FD_ISSET( i->fd, &write_set ) ? Reactor_base::OUTPUT : 0; in poll()
|
| /dports/databases/mariadb104-server/mariadb-10.4.24/storage/oqgraph/ |
| H A D | oqgraph_thunk.cc | 169 bitmap_set_bit(table.write_set, _graph->_source->field_index); in restore_position()
171 bitmap_clear_bit(table.write_set, _graph->_source->field_index); in restore_position()
176 bitmap_set_bit(table.write_set, _graph->_target->field_index); in restore_position()
383 bitmap_set_bit(table.write_set, source->field_index); in seek_to()
385 bitmap_clear_bit(table.write_set, source->field_index); in seek_to()
414 bitmap_set_bit(table.write_set, target->field_index); in seek_to()
416 bitmap_clear_bit(table.write_set, target->field_index); in seek_to()
450 bitmap_set_bit(table.write_set, source->field_index); in seek_to()
452 bitmap_clear_bit(table.write_set, source->field_index); in seek_to()
454 bitmap_set_bit(table.write_set, target->field_index); in seek_to()
[all …]
|
| /dports/databases/mariadb104-client/mariadb-10.4.24/storage/oqgraph/ |
| H A D | oqgraph_thunk.cc | 169 bitmap_set_bit(table.write_set, _graph->_source->field_index); in restore_position()
171 bitmap_clear_bit(table.write_set, _graph->_source->field_index); in restore_position()
176 bitmap_set_bit(table.write_set, _graph->_target->field_index); in restore_position()
383 bitmap_set_bit(table.write_set, source->field_index); in seek_to()
385 bitmap_clear_bit(table.write_set, source->field_index); in seek_to()
414 bitmap_set_bit(table.write_set, target->field_index); in seek_to()
416 bitmap_clear_bit(table.write_set, target->field_index); in seek_to()
450 bitmap_set_bit(table.write_set, source->field_index); in seek_to()
452 bitmap_clear_bit(table.write_set, source->field_index); in seek_to()
454 bitmap_set_bit(table.write_set, target->field_index); in seek_to()
[all …]
|
| /dports/databases/mariadb103-client/mariadb-10.3.34/storage/oqgraph/ |
| H A D | oqgraph_thunk.cc | 169 bitmap_set_bit(table.write_set, _graph->_source->field_index); in restore_position()
171 bitmap_clear_bit(table.write_set, _graph->_source->field_index); in restore_position()
176 bitmap_set_bit(table.write_set, _graph->_target->field_index); in restore_position()
383 bitmap_set_bit(table.write_set, source->field_index); in seek_to()
385 bitmap_clear_bit(table.write_set, source->field_index); in seek_to()
414 bitmap_set_bit(table.write_set, target->field_index); in seek_to()
416 bitmap_clear_bit(table.write_set, target->field_index); in seek_to()
450 bitmap_set_bit(table.write_set, source->field_index); in seek_to()
452 bitmap_clear_bit(table.write_set, source->field_index); in seek_to()
454 bitmap_set_bit(table.write_set, target->field_index); in seek_to()
[all …]
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/oqgraph/ |
| H A D | oqgraph_thunk.cc | 169 bitmap_set_bit(table.write_set, _graph->_source->field_index); in restore_position()
171 bitmap_clear_bit(table.write_set, _graph->_source->field_index); in restore_position()
176 bitmap_set_bit(table.write_set, _graph->_target->field_index); in restore_position()
383 bitmap_set_bit(table.write_set, source->field_index); in seek_to()
385 bitmap_clear_bit(table.write_set, source->field_index); in seek_to()
414 bitmap_set_bit(table.write_set, target->field_index); in seek_to()
416 bitmap_clear_bit(table.write_set, target->field_index); in seek_to()
450 bitmap_set_bit(table.write_set, source->field_index); in seek_to()
452 bitmap_clear_bit(table.write_set, source->field_index); in seek_to()
454 bitmap_set_bit(table.write_set, target->field_index); in seek_to()
[all …]
|
| /dports/databases/mariadb103-server/mariadb-10.3.34/storage/oqgraph/ |
| H A D | oqgraph_thunk.cc | 169 bitmap_set_bit(table.write_set, _graph->_source->field_index); in restore_position()
171 bitmap_clear_bit(table.write_set, _graph->_source->field_index); in restore_position()
176 bitmap_set_bit(table.write_set, _graph->_target->field_index); in restore_position()
383 bitmap_set_bit(table.write_set, source->field_index); in seek_to()
385 bitmap_clear_bit(table.write_set, source->field_index); in seek_to()
414 bitmap_set_bit(table.write_set, target->field_index); in seek_to()
416 bitmap_clear_bit(table.write_set, target->field_index); in seek_to()
450 bitmap_set_bit(table.write_set, source->field_index); in seek_to()
452 bitmap_clear_bit(table.write_set, source->field_index); in seek_to()
454 bitmap_set_bit(table.write_set, target->field_index); in seek_to()
[all …]
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/oqgraph/ |
| H A D | oqgraph_thunk.cc | 169 bitmap_set_bit(table.write_set, _graph->_source->field_index); in restore_position()
171 bitmap_clear_bit(table.write_set, _graph->_source->field_index); in restore_position()
176 bitmap_set_bit(table.write_set, _graph->_target->field_index); in restore_position()
383 bitmap_set_bit(table.write_set, source->field_index); in seek_to()
385 bitmap_clear_bit(table.write_set, source->field_index); in seek_to()
414 bitmap_set_bit(table.write_set, target->field_index); in seek_to()
416 bitmap_clear_bit(table.write_set, target->field_index); in seek_to()
450 bitmap_set_bit(table.write_set, source->field_index); in seek_to()
452 bitmap_clear_bit(table.write_set, source->field_index); in seek_to()
454 bitmap_set_bit(table.write_set, target->field_index); in seek_to()
[all …]
|
| /dports/devel/ORBit2/ORBit2-2.14.19/linc2/src/ |
| H A D | linc-compat.c | 53 fd_set read_set, write_set; in link_pipe()
147 FD_ZERO (&write_set); in link_pipe()
148 FD_SET (socket1, &write_set); in link_pipe()
153 if (select (0, NULL, &write_set, NULL, NULL) == SOCKET_ERROR) in link_pipe()
159 if (!FD_ISSET (socket1, &write_set)) in link_pipe()
|
| /dports/editors/encryptpad/EncryptPad-0.5.0.1/deps/botan/src/lib/utils/socket/ |
| H A D | socket.cpp | 243 fd_set write_set;
244 FD_ZERO(&write_set);
246 FD_SET(static_cast<int>(m_socket), &write_set);
248 … active = ::select(static_cast<int>(m_socket + 1), nullptr, &write_set, nullptr, &timeout_tv);
292 fd_set write_set;
293 FD_ZERO(&write_set);
294 FD_SET(m_socket, &write_set);
300 … int active = ::select(static_cast<int>(m_socket + 1), nullptr, &write_set, nullptr, &timeout);
|