| /dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/sql/dd/impl/types/ |
| H A D | view_impl.cc | 100 this, otx, otx->get_table<View_table>(), in restore_children()
103 this, otx, otx->get_table<View_routine>(), in restore_children()
110 return Abstract_table_impl::store_children(otx) || in store_children()
111 m_tables.store_items(otx) || m_routines.store_items(otx); in store_children()
118 otx, otx->get_table<View_routine>(), in drop_children()
121 otx, otx->get_table<View_table>(), in drop_children()
123 Abstract_table_impl::drop_children(otx); in drop_children()
275 otx->add_table<Tables>(); in register_tables()
277 otx->register_tables<Column>(); in register_tables()
278 otx->register_tables<View_table>(); in register_tables()
[all …]
|
| H A D | table_impl.cc | 268 m_indexes.restore_items(this, otx, otx->get_table<Index>(), in restore_children()
271 this, otx, otx->get_table<Foreign_key>(), in restore_children()
275 this, otx, otx->get_table<Partition>(), in restore_children()
286 this, otx, otx->get_table<Check_constraint>(), in restore_children()
338 if (m_triggers.drop_items(otx, otx->get_table<Trigger>(), in store_triggers()
368 m_partitions.store_items(otx) || store_triggers(otx) || in store_children()
379 otx, otx->get_table<Check_constraint>(), in drop_children()
381 m_triggers.drop_items(otx, otx->get_table<Trigger>(), in drop_children()
384 otx, otx->get_table<Partition>(), in drop_children()
387 otx, otx->get_table<Foreign_key>(), in drop_children()
[all …]
|
| H A D | tablespace_impl.cc | 125 this, otx, otx->get_table<Tablespace_file>(), in restore_children()
134 otx, otx->get_table<Tablespace_file>(), in store_children()
142 return m_files.store_items(otx); in store_children()
149 otx, otx->get_table<Tablespace_file>(), in drop_children()
332 otx->add_table<Tablespaces>(); in register_tables()
412 trx.otx.register_tables<Partition>(); in fetch_tablespace_table_refs()
413 trx.otx.register_tables<Index>(); in fetch_tablespace_table_refs()
415 trx.otx.register_tables<Schema>(); in fetch_tablespace_table_refs()
417 if (trx.otx.open_tables()) { in fetch_tablespace_table_refs()
468 trx.otx.get_table<Index>(), in fetch_tablespace_table_refs()
[all …]
|
| H A D | partition_impl.cc | 163 this, otx, otx->get_table<Partition_value>(), in restore_children()
169 this, otx, otx->get_table<Partition_index>(), in restore_children()
173 this, otx, otx->get_table<Partition>(), in restore_children()
184 return m_values.store_items(otx) || m_indexes.store_items(otx) || in store_children()
185 m_subpartitions.store_items(otx); in store_children()
192 otx, otx->get_table<Partition_value>(), in drop_children()
195 otx, otx->get_table<Partition_index>(), in drop_children()
198 otx, otx->get_table<Partition>(), in drop_children()
450 otx->add_table<Table_partitions>(); in register_tables()
452 otx->register_tables<Partition_value>(); in register_tables()
[all …]
|
| H A D | foreign_key_impl.cc | 106 bool Foreign_key_impl::store(Open_dictionary_tables_ctx *otx) { in store() argument
113 otx->get_thd()->push_internal_handler(&error_handler); in store()
114 bool error = Weak_object_impl::store(otx); in store()
115 otx->get_thd()->pop_internal_handler(); in store()
151 bool Foreign_key_impl::restore_children(Open_dictionary_tables_ctx *otx) { in restore_children() argument
153 this, otx, otx->get_table<Foreign_key_element>(), in restore_children()
159 bool Foreign_key_impl::store_children(Open_dictionary_tables_ctx *otx) { in store_children() argument
160 return m_elements.store_items(otx); in store_children()
167 otx, otx->get_table<Foreign_key_element>(), in drop_children()
326 otx->add_table<Foreign_keys>(); in register_tables()
[all …]
|
| H A D | weak_object_impl.cc | 57 bool Weak_object_impl::store(Open_dictionary_tables_ctx *otx) { in store() argument
69 Raw_table *t = otx->get_table(obj_table.name()); in store()
112 return store_children(otx); in store()
151 if (store_children(otx)) return true; in store()
175 bool Weak_object_impl::drop(Open_dictionary_tables_ctx *otx) const { in drop()
187 Raw_table *t = otx->get_table(obj_table.name()); in drop()
214 if (this->drop_children(otx) || r->drop()) return true; in drop()
|
| H A D | abstract_table_impl.cc | 118 bool Abstract_table_impl::restore_children(Open_dictionary_tables_ctx *otx) { in restore_children() argument
119 return m_columns.restore_items(this, otx, otx->get_table<Column>(), in restore_children()
125 bool Abstract_table_impl::store_children(Open_dictionary_tables_ctx *otx) { in store_children() argument
126 return m_columns.store_items(otx); in store_children()
131 bool Abstract_table_impl::drop_children(Open_dictionary_tables_ctx *otx) const { in drop_children()
132 return m_columns.drop_items(otx, otx->get_table<Column>(), in drop_children()
326 void Abstract_table_impl::register_tables(Open_dictionary_tables_ctx *otx) { in register_tables() argument
327 otx->register_tables<Table>(); in register_tables()
328 otx->register_tables<View>(); in register_tables()
|
| H A D | parameter_impl.cc | 125 bool Parameter_impl::restore_children(Open_dictionary_tables_ctx *otx) { in restore_children() argument
130 this, otx, otx->get_table<Parameter_type_element>(), in restore_children()
142 bool Parameter_impl::store_children(Open_dictionary_tables_ctx *otx) { in store_children() argument
143 return m_elements.store_items(otx); in store_children()
148 bool Parameter_impl::drop_children(Open_dictionary_tables_ctx *otx) const { in drop_children()
152 otx, otx->get_table<Parameter_type_element>(), in drop_children()
311 void Parameter_impl::register_tables(Open_dictionary_tables_ctx *otx) { in register_tables() argument
312 otx->add_table<Parameters>(); in register_tables()
314 otx->register_tables<Parameter_type_element>(); in register_tables()
|
| H A D | routine_impl.cc | 85 bool Routine_impl::restore_children(Open_dictionary_tables_ctx *otx) { in restore_children() argument
87 this, otx, otx->get_table<Parameter>(), in restore_children()
93 bool Routine_impl::store_children(Open_dictionary_tables_ctx *otx) { in store_children() argument
94 return m_parameters.store_items(otx); in store_children()
99 bool Routine_impl::drop_children(Open_dictionary_tables_ctx *otx) const { in drop_children()
101 otx, otx->get_table<Parameter>(), in drop_children()
249 void Routine_impl::register_tables(Open_dictionary_tables_ctx *otx) { in register_tables() argument
250 otx->add_table<Routines>(); in register_tables()
252 otx->register_tables<Parameter>(); in register_tables()
|
| H A D | tablespace_file_impl.cc | 95 bool Tablespace_file_impl::store(Open_dictionary_tables_ctx *otx) { in store() argument
102 otx->get_thd()->push_internal_handler(&error_handler); in store()
103 bool error = Weak_object_impl::store(otx); in store()
104 otx->get_thd()->pop_internal_handler(); in store()
209 void Tablespace_file_impl::register_tables(Open_dictionary_tables_ctx *otx) { in register_tables() argument
210 otx->add_table<Tablespace_files>(); in register_tables()
|
| H A D | index_impl.cc | 133 bool Index_impl::restore_children(Open_dictionary_tables_ctx *otx) { in restore_children() argument
137 this, otx, otx->get_table<Index_element>(), in restore_children()
143 bool Index_impl::store_children(Open_dictionary_tables_ctx *otx) { in store_children() argument
144 return m_elements.store_items(otx); in store_children()
149 bool Index_impl::drop_children(Open_dictionary_tables_ctx *otx) const { in drop_children()
151 otx, otx->get_table<Index_element>(), in drop_children()
418 void Index_impl::register_tables(Open_dictionary_tables_ctx *otx) { in register_tables() argument
419 otx->add_table<Indexes>(); in register_tables()
421 otx->register_tables<Index_element>(); in register_tables()
|
| /dports/net-p2p/c-lightning/lightning-0.10.2/lightningd/ |
| H A D | chaintopology.c | 180 list_del(&otx->list); in destroy_outgoing_tx()
186 fatal("channel %p, otx %p has channel %p", channel, otx, otx->channel); in clear_otx_channel()
187 otx->channel = NULL; in clear_otx_channel()
195 if (!otx->channel) { in broadcast_done()
196 tal_free(otx); in broadcast_done()
201 tal_del_destructor2(otx->channel, clear_otx_channel, otx); in broadcast_done()
204 otx->failed_or_success(otx->channel, success, msg); in broadcast_done()
205 tal_free(otx); in broadcast_done()
208 tal_steal(otx->channel, otx); in broadcast_done()
227 otx->hextx = tal_hex(otx, rawtx); in broadcast_tx_ahf()
[all …]
|
| /dports/multimedia/neolink/neolink-cf54129/cargo-crates/futures-channel-0.3.16/tests/ |
| H A D | oneshot.rs | 47 let (otx, orx) = oneshot::channel::<u32>(); in cancel_lots()
49 tx.send((otx, tx2)).unwrap(); in cancel_lots()
106 for otx in rx { in cancel_sends()
107 let _ = otx.send(42); in cancel_sends()
112 let (otx, mut orx) = oneshot::channel::<u32>(); in cancel_sends()
113 tx.send(otx).unwrap(); in cancel_sends()
|
| /dports/multimedia/librespot/librespot-0.1.3/cargo-crates/futures-channel-0.3.5/tests/ |
| H A D | oneshot.rs | 47 let (otx, orx) = oneshot::channel::<u32>(); in cancel_lots()
49 tx.send((otx, tx2)).unwrap(); in cancel_lots()
106 for otx in rx { in cancel_sends()
107 let _ = otx.send(42); in cancel_sends()
112 let (otx, mut orx) = oneshot::channel::<u32>(); in cancel_sends()
113 tx.send(otx).unwrap(); in cancel_sends()
|
| /dports/devel/sccache/sccache-0.2.15/cargo-crates/futures-channel-0.3.9/tests/ |
| H A D | oneshot.rs | 47 let (otx, orx) = oneshot::channel::<u32>(); in cancel_lots()
49 tx.send((otx, tx2)).unwrap(); in cancel_lots()
106 for otx in rx { in cancel_sends()
107 let _ = otx.send(42); in cancel_sends()
112 let (otx, mut orx) = oneshot::channel::<u32>(); in cancel_sends()
113 tx.send(otx).unwrap(); in cancel_sends()
|
| /dports/multimedia/gstreamer1-plugins-rust/gst-plugins-rs-d0466b3eee114207f851b37cae0015c0e718f021/cargo-crates/futures-channel-0.3.16/tests/ |
| H A D | oneshot.rs | 47 let (otx, orx) = oneshot::channel::<u32>(); in cancel_lots()
49 tx.send((otx, tx2)).unwrap(); in cancel_lots()
106 for otx in rx { in cancel_sends()
107 let _ = otx.send(42); in cancel_sends()
112 let (otx, mut orx) = oneshot::channel::<u32>(); in cancel_sends()
113 tx.send(otx).unwrap(); in cancel_sends()
|
| /dports/security/vaultwarden/vaultwarden-1.23.1/cargo-crates/futures-channel-0.3.18/tests/ |
| H A D | oneshot.rs | 47 let (otx, orx) = oneshot::channel::<u32>(); in cancel_lots()
49 tx.send((otx, tx2)).unwrap(); in cancel_lots()
106 for otx in rx { in cancel_sends()
107 let _ = otx.send(42); in cancel_sends()
112 let (otx, mut orx) = oneshot::channel::<u32>(); in cancel_sends()
113 tx.send(otx).unwrap(); in cancel_sends()
|
| /dports/games/genact/genact-0.10.0/cargo-crates/futures-channel-0.3.5/tests/ |
| H A D | oneshot.rs | 47 let (otx, orx) = oneshot::channel::<u32>(); in cancel_lots()
49 tx.send((otx, tx2)).unwrap(); in cancel_lots()
106 for otx in rx { in cancel_sends()
107 let _ = otx.send(42); in cancel_sends()
112 let (otx, mut orx) = oneshot::channel::<u32>(); in cancel_sends()
113 tx.send(otx).unwrap(); in cancel_sends()
|
| /dports/lang/gleam/gleam-0.18.2/cargo-crates/futures-channel-0.3.18/tests/ |
| H A D | oneshot.rs | 47 let (otx, orx) = oneshot::channel::<u32>(); in cancel_lots()
49 tx.send((otx, tx2)).unwrap(); in cancel_lots()
106 for otx in rx { in cancel_sends()
107 let _ = otx.send(42); in cancel_sends()
112 let (otx, mut orx) = oneshot::channel::<u32>(); in cancel_sends()
113 tx.send(otx).unwrap(); in cancel_sends()
|
| /dports/x11-wm/leftwm/leftwm-0.2.11/cargo-crates/futures-channel-0.3.18/tests/ |
| H A D | oneshot.rs | 47 let (otx, orx) = oneshot::channel::<u32>(); in cancel_lots()
49 tx.send((otx, tx2)).unwrap(); in cancel_lots()
106 for otx in rx { in cancel_sends()
107 let _ = otx.send(42); in cancel_sends()
112 let (otx, mut orx) = oneshot::channel::<u32>(); in cancel_sends()
113 tx.send(otx).unwrap(); in cancel_sends()
|
| /dports/dns/encrypted-dns-server/encrypted-dns-server-0.9.1/cargo-crates/futures-channel-0.3.17/tests/ |
| H A D | oneshot.rs | 47 let (otx, orx) = oneshot::channel::<u32>(); in cancel_lots()
49 tx.send((otx, tx2)).unwrap(); in cancel_lots()
106 for otx in rx { in cancel_sends()
107 let _ = otx.send(42); in cancel_sends()
112 let (otx, mut orx) = oneshot::channel::<u32>(); in cancel_sends()
113 tx.send(otx).unwrap(); in cancel_sends()
|
| /dports/dns/doh-proxy/doh-proxy-0.9.2/cargo-crates/futures-channel-0.3.17/tests/ |
| H A D | oneshot.rs | 47 let (otx, orx) = oneshot::channel::<u32>(); in cancel_lots()
49 tx.send((otx, tx2)).unwrap(); in cancel_lots()
106 for otx in rx { in cancel_sends()
107 let _ = otx.send(42); in cancel_sends()
112 let (otx, mut orx) = oneshot::channel::<u32>(); in cancel_sends()
113 tx.send(otx).unwrap(); in cancel_sends()
|
| /dports/net/routinator/routinator-0.10.2/cargo-crates/futures-channel-0.3.15/tests/ |
| H A D | oneshot.rs | 47 let (otx, orx) = oneshot::channel::<u32>(); in cancel_lots()
49 tx.send((otx, tx2)).unwrap(); in cancel_lots()
106 for otx in rx { in cancel_sends()
107 let _ = otx.send(42); in cancel_sends()
112 let (otx, mut orx) = oneshot::channel::<u32>(); in cancel_sends()
113 tx.send(otx).unwrap(); in cancel_sends()
|
| /dports/editors/kak-lsp/kak-lsp-11.1.0/cargo-crates/futures-channel-0.3.17/tests/ |
| H A D | oneshot.rs | 47 let (otx, orx) = oneshot::channel::<u32>(); in cancel_lots()
49 tx.send((otx, tx2)).unwrap(); in cancel_lots()
106 for otx in rx { in cancel_sends()
107 let _ = otx.send(42); in cancel_sends()
112 let (otx, mut orx) = oneshot::channel::<u32>(); in cancel_sends()
113 tx.send(otx).unwrap(); in cancel_sends()
|
| /dports/textproc/angle-grinder/angle-grinder-0.18.0/cargo-crates/futures-channel-0.3.15/tests/ |
| H A D | oneshot.rs | 47 let (otx, orx) = oneshot::channel::<u32>(); in cancel_lots()
49 tx.send((otx, tx2)).unwrap(); in cancel_lots()
106 for otx in rx { in cancel_sends()
107 let _ = otx.send(42); in cancel_sends()
112 let (otx, mut orx) = oneshot::channel::<u32>(); in cancel_sends()
113 tx.send(otx).unwrap(); in cancel_sends()
|