/dports/databases/xtrabackup/percona-xtrabackup-2.4.21/storage/ndb/memcache/src/ |
H A D | ndb_worker.cc | 95 workitem *wqitem; member in WorkerStep1 321 wqitem(newitem), in WorkerStep1() 382 hash_item_set_cas(wqitem->cache_item, * wqitem->cas); // store it in do_write() 602 worker_set_cas(wqitem->pipeline, wqitem->cas); in do_math() 788 if(wqitem->cas) * wqitem->cas = 0ULL; // see note re. valgrind in callback_main() 803 if(wqitem->cas) * wqitem->cas = 0ULL; // see note re. valgrind in callback_main() 881 wqitem->math_value = stored + wqitem->math_flags; in callback_incr() 887 wqitem->math_value = stored - wqitem->math_flags; in callback_incr() 944 DEBUG_PRINT_DETAIL("%d.%d", wqitem->pipeline->id, wqitem->id); in worker_close() 1066 wqitem->math_flags = htonl(wqitem->plan->static_flags); in worker_finalize_read() [all …]
|
H A D | ExternalValue.cc | 267 wqitem(item), in ExternalValue() 305 wqitem->math_flags = htonl(wqitem->plan->static_flags); in worker_read_external() 427 hash_item_set_cas(wqitem->cache_item, * wqitem->cas); // store it in update() 661 hash_item_set_cas(wqitem->cache_item, * wqitem->cas); // store it in insert() 802 wqitem->base.nkey, wqitem->key); in warnMissingParts() 824 hash_item * item = item_alloc(se, wqitem->key, wqitem->base.nkey, in build_hash_item() 864 DEBUG_PRINT_DETAIL(" %d.%d", wqitem->pipeline->id, wqitem->id); in delete_after_header_read() 871 wqitem->ext_val = new ExternalValue(wqitem, tx); in delete_after_header_read() 885 DEBUG_PRINT_DETAIL(" %d.%d", wqitem->pipeline->id, wqitem->id); in callback_ext_parts_read() 923 DEBUG_PRINT_DETAIL(" %d.%d", wqitem->pipeline->id, wqitem->id); in callback_ext_write() [all …]
|
H A D | ndb_engine.c | 323 scheduler_release(wqitem->pipeline, wqitem); in release_and_free() 369 workitem *wqitem; in ndb_remove() local 373 if(wqitem) { in ndb_remove() 432 if(wqitem) { in ndb_release() 461 if(wqitem && ! wqitem->base.complete) { in ndb_get() 463 wqitem->pipeline->id, wqitem->id, wqitem->status->comment); in ndb_get() 569 if(wqitem) { in ndb_store() 571 pipeline->id, wqitem->id, wqitem->status->comment); in ndb_store() 629 if(wqitem && ! wqitem->base.complete) { in ndb_arithmetic() 740 item_info->cas = wqitem->cas ? *(wqitem->cas) : 0; in ndb_get_item_info() [all …]
|
/dports/databases/percona57-server/percona-server-5.7.36-39/storage/ndb/memcache/src/ |
H A D | ndb_worker.cc | 95 workitem *wqitem; member in WorkerStep1 321 wqitem(newitem), in WorkerStep1() 382 hash_item_set_cas(wqitem->cache_item, * wqitem->cas); // store it in do_write() 602 worker_set_cas(wqitem->pipeline, wqitem->cas); in do_math() 788 if(wqitem->cas) * wqitem->cas = 0ULL; // see note re. valgrind in callback_main() 803 if(wqitem->cas) * wqitem->cas = 0ULL; // see note re. valgrind in callback_main() 881 wqitem->math_value = stored + wqitem->math_flags; in callback_incr() 887 wqitem->math_value = stored - wqitem->math_flags; in callback_incr() 944 DEBUG_PRINT_DETAIL("%d.%d", wqitem->pipeline->id, wqitem->id); in worker_close() 1066 wqitem->math_flags = htonl(wqitem->plan->static_flags); in worker_finalize_read() [all …]
|
H A D | ExternalValue.cc | 267 wqitem(item), in ExternalValue() 305 wqitem->math_flags = htonl(wqitem->plan->static_flags); in worker_read_external() 427 hash_item_set_cas(wqitem->cache_item, * wqitem->cas); // store it in update() 661 hash_item_set_cas(wqitem->cache_item, * wqitem->cas); // store it in insert() 802 wqitem->base.nkey, wqitem->key); in warnMissingParts() 824 hash_item * item = item_alloc(se, wqitem->key, wqitem->base.nkey, in build_hash_item() 864 DEBUG_PRINT_DETAIL(" %d.%d", wqitem->pipeline->id, wqitem->id); in delete_after_header_read() 871 wqitem->ext_val = new ExternalValue(wqitem, tx); in delete_after_header_read() 885 DEBUG_PRINT_DETAIL(" %d.%d", wqitem->pipeline->id, wqitem->id); in callback_ext_parts_read() 923 DEBUG_PRINT_DETAIL(" %d.%d", wqitem->pipeline->id, wqitem->id); in callback_ext_write() [all …]
|
H A D | ndb_engine.c | 323 scheduler_release(wqitem->pipeline, wqitem); in release_and_free() 369 workitem *wqitem; in ndb_remove() local 373 if(wqitem) { in ndb_remove() 432 if(wqitem) { in ndb_release() 461 if(wqitem && ! wqitem->base.complete) { in ndb_get() 463 wqitem->pipeline->id, wqitem->id, wqitem->status->comment); in ndb_get() 569 if(wqitem) { in ndb_store() 571 pipeline->id, wqitem->id, wqitem->status->comment); in ndb_store() 629 if(wqitem && ! wqitem->base.complete) { in ndb_arithmetic() 740 item_info->cas = wqitem->cas ? *(wqitem->cas) : 0; in ndb_get_item_info() [all …]
|
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/storage/ndb/memcache/src/ |
H A D | ndb_worker.cc | 95 workitem *wqitem; member in WorkerStep1 321 wqitem(newitem), in WorkerStep1() 382 hash_item_set_cas(wqitem->cache_item, * wqitem->cas); // store it in do_write() 602 worker_set_cas(wqitem->pipeline, wqitem->cas); in do_math() 788 if(wqitem->cas) * wqitem->cas = 0ULL; // see note re. valgrind in callback_main() 803 if(wqitem->cas) * wqitem->cas = 0ULL; // see note re. valgrind in callback_main() 881 wqitem->math_value = stored + wqitem->math_flags; in callback_incr() 887 wqitem->math_value = stored - wqitem->math_flags; in callback_incr() 944 DEBUG_PRINT_DETAIL("%d.%d", wqitem->pipeline->id, wqitem->id); in worker_close() 1066 wqitem->math_flags = htonl(wqitem->plan->static_flags); in worker_finalize_read() [all …]
|
H A D | ExternalValue.cc | 267 wqitem(item), in ExternalValue() 305 wqitem->math_flags = htonl(wqitem->plan->static_flags); in worker_read_external() 427 hash_item_set_cas(wqitem->cache_item, * wqitem->cas); // store it in update() 661 hash_item_set_cas(wqitem->cache_item, * wqitem->cas); // store it in insert() 802 wqitem->base.nkey, wqitem->key); in warnMissingParts() 824 hash_item * item = item_alloc(se, wqitem->key, wqitem->base.nkey, in build_hash_item() 864 DEBUG_PRINT_DETAIL(" %d.%d", wqitem->pipeline->id, wqitem->id); in delete_after_header_read() 871 wqitem->ext_val = new ExternalValue(wqitem, tx); in delete_after_header_read() 885 DEBUG_PRINT_DETAIL(" %d.%d", wqitem->pipeline->id, wqitem->id); in callback_ext_parts_read() 923 DEBUG_PRINT_DETAIL(" %d.%d", wqitem->pipeline->id, wqitem->id); in callback_ext_write() [all …]
|
H A D | ndb_engine.c | 323 scheduler_release(wqitem->pipeline, wqitem); in release_and_free() 369 workitem *wqitem; in ndb_remove() local 373 if(wqitem) { in ndb_remove() 432 if(wqitem) { in ndb_release() 461 if(wqitem && ! wqitem->base.complete) { in ndb_get() 463 wqitem->pipeline->id, wqitem->id, wqitem->status->comment); in ndb_get() 569 if(wqitem) { in ndb_store() 571 pipeline->id, wqitem->id, wqitem->status->comment); in ndb_store() 629 if(wqitem && ! wqitem->base.complete) { in ndb_arithmetic() 740 item_info->cas = wqitem->cas ? *(wqitem->cas) : 0; in ndb_get_item_info() [all …]
|
/dports/databases/percona57-client/percona-server-5.7.36-39/storage/ndb/memcache/src/ |
H A D | ndb_worker.cc | 95 workitem *wqitem; member in WorkerStep1 321 wqitem(newitem), in WorkerStep1() 382 hash_item_set_cas(wqitem->cache_item, * wqitem->cas); // store it in do_write() 602 worker_set_cas(wqitem->pipeline, wqitem->cas); in do_math() 788 if(wqitem->cas) * wqitem->cas = 0ULL; // see note re. valgrind in callback_main() 803 if(wqitem->cas) * wqitem->cas = 0ULL; // see note re. valgrind in callback_main() 881 wqitem->math_value = stored + wqitem->math_flags; in callback_incr() 887 wqitem->math_value = stored - wqitem->math_flags; in callback_incr() 944 DEBUG_PRINT_DETAIL("%d.%d", wqitem->pipeline->id, wqitem->id); in worker_close() 1066 wqitem->math_flags = htonl(wqitem->plan->static_flags); in worker_finalize_read() [all …]
|
H A D | ExternalValue.cc | 267 wqitem(item), in ExternalValue() 305 wqitem->math_flags = htonl(wqitem->plan->static_flags); in worker_read_external() 427 hash_item_set_cas(wqitem->cache_item, * wqitem->cas); // store it in update() 661 hash_item_set_cas(wqitem->cache_item, * wqitem->cas); // store it in insert() 802 wqitem->base.nkey, wqitem->key); in warnMissingParts() 824 hash_item * item = item_alloc(se, wqitem->key, wqitem->base.nkey, in build_hash_item() 864 DEBUG_PRINT_DETAIL(" %d.%d", wqitem->pipeline->id, wqitem->id); in delete_after_header_read() 871 wqitem->ext_val = new ExternalValue(wqitem, tx); in delete_after_header_read() 885 DEBUG_PRINT_DETAIL(" %d.%d", wqitem->pipeline->id, wqitem->id); in callback_ext_parts_read() 923 DEBUG_PRINT_DETAIL(" %d.%d", wqitem->pipeline->id, wqitem->id); in callback_ext_write() [all …]
|
H A D | ndb_engine.c | 323 scheduler_release(wqitem->pipeline, wqitem); in release_and_free() 369 workitem *wqitem; in ndb_remove() local 373 if(wqitem) { in ndb_remove() 432 if(wqitem) { in ndb_release() 461 if(wqitem && ! wqitem->base.complete) { in ndb_get() 463 wqitem->pipeline->id, wqitem->id, wqitem->status->comment); in ndb_get() 569 if(wqitem) { in ndb_store() 571 pipeline->id, wqitem->id, wqitem->status->comment); in ndb_store() 629 if(wqitem && ! wqitem->base.complete) { in ndb_arithmetic() 740 item_info->cas = wqitem->cas ? *(wqitem->cas) : 0; in ndb_get_item_info() [all …]
|
/dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/storage/ndb/memcache/src/ |
H A D | ndb_worker.cc | 95 workitem *wqitem; member in WorkerStep1 321 wqitem(newitem), in WorkerStep1() 382 hash_item_set_cas(wqitem->cache_item, * wqitem->cas); // store it in do_write() 602 worker_set_cas(wqitem->pipeline, wqitem->cas); in do_math() 788 if(wqitem->cas) * wqitem->cas = 0ULL; // see note re. valgrind in callback_main() 803 if(wqitem->cas) * wqitem->cas = 0ULL; // see note re. valgrind in callback_main() 881 wqitem->math_value = stored + wqitem->math_flags; in callback_incr() 887 wqitem->math_value = stored - wqitem->math_flags; in callback_incr() 944 DEBUG_PRINT_DETAIL("%d.%d", wqitem->pipeline->id, wqitem->id); in worker_close() 1066 wqitem->math_flags = htonl(wqitem->plan->static_flags); in worker_finalize_read() [all …]
|
H A D | ExternalValue.cc | 267 wqitem(item), in ExternalValue() 305 wqitem->math_flags = htonl(wqitem->plan->static_flags); in worker_read_external() 427 hash_item_set_cas(wqitem->cache_item, * wqitem->cas); // store it in update() 661 hash_item_set_cas(wqitem->cache_item, * wqitem->cas); // store it in insert() 802 wqitem->base.nkey, wqitem->key); in warnMissingParts() 824 hash_item * item = item_alloc(se, wqitem->key, wqitem->base.nkey, in build_hash_item() 864 DEBUG_PRINT_DETAIL(" %d.%d", wqitem->pipeline->id, wqitem->id); in delete_after_header_read() 871 wqitem->ext_val = new ExternalValue(wqitem, tx); in delete_after_header_read() 885 DEBUG_PRINT_DETAIL(" %d.%d", wqitem->pipeline->id, wqitem->id); in callback_ext_parts_read() 923 DEBUG_PRINT_DETAIL(" %d.%d", wqitem->pipeline->id, wqitem->id); in callback_ext_write() [all …]
|
H A D | ndb_engine.c | 323 scheduler_release(wqitem->pipeline, wqitem); in release_and_free() 369 workitem *wqitem; in ndb_remove() local 373 if(wqitem) { in ndb_remove() 432 if(wqitem) { in ndb_release() 461 if(wqitem && ! wqitem->base.complete) { in ndb_get() 463 wqitem->pipeline->id, wqitem->id, wqitem->status->comment); in ndb_get() 569 if(wqitem) { in ndb_store() 571 pipeline->id, wqitem->id, wqitem->status->comment); in ndb_store() 629 if(wqitem && ! wqitem->base.complete) { in ndb_arithmetic() 740 item_info->cas = wqitem->cas ? *(wqitem->cas) : 0; in ndb_get_item_info() [all …]
|
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/storage/ndb/memcache/src/ |
H A D | ndb_worker.cc | 92 workitem *wqitem; member in WorkerStep1 318 wqitem(newitem), in WorkerStep1() 379 hash_item_set_cas(wqitem->cache_item, * wqitem->cas); // store it in do_write() 599 worker_set_cas(wqitem->pipeline, wqitem->cas); in do_math() 776 if(wqitem->cas) * wqitem->cas = 0ULL; // see note re. valgrind in callback_main() 791 if(wqitem->cas) * wqitem->cas = 0ULL; // see note re. valgrind in callback_main() 870 wqitem->math_value = stored + wqitem->math_flags; in callback_incr() 876 wqitem->math_value = stored - wqitem->math_flags; in callback_incr() 933 DEBUG_PRINT_DETAIL("%d.%d", wqitem->pipeline->id, wqitem->id); in worker_close() 1055 wqitem->math_flags = htonl(wqitem->plan->static_flags); in worker_finalize_read() [all …]
|
H A D | ExternalValue.cc | 265 wqitem(item), in ExternalValue() 303 wqitem->math_flags = htonl(wqitem->plan->static_flags); in worker_read_external() 425 hash_item_set_cas(wqitem->cache_item, * wqitem->cas); // store it in update() 659 hash_item_set_cas(wqitem->cache_item, * wqitem->cas); // store it in insert() 800 wqitem->base.nkey, wqitem->key); in warnMissingParts() 822 hash_item * item = item_alloc(se, wqitem->key, wqitem->base.nkey, in build_hash_item() 862 DEBUG_PRINT_DETAIL(" %d.%d", wqitem->pipeline->id, wqitem->id); in delete_after_header_read() 869 wqitem->ext_val = new ExternalValue(wqitem, tx); in delete_after_header_read() 883 DEBUG_PRINT_DETAIL(" %d.%d", wqitem->pipeline->id, wqitem->id); in callback_ext_parts_read() 921 DEBUG_PRINT_DETAIL(" %d.%d", wqitem->pipeline->id, wqitem->id); in callback_ext_write() [all …]
|
H A D | ndb_engine.cc | 321 scheduler_release(wqitem->pipeline, wqitem); in release_and_free() 367 workitem *wqitem; in ndb_remove() local 371 if(wqitem) { in ndb_remove() 430 if(wqitem) { in ndb_release() 459 if(wqitem && ! wqitem->base.complete) { in ndb_get() 461 wqitem->pipeline->id, wqitem->id, wqitem->status->comment); in ndb_get() 567 if(wqitem) { in ndb_store() 569 pipeline->id, wqitem->id, wqitem->status->comment); in ndb_store() 627 if(wqitem && ! wqitem->base.complete) { in ndb_arithmetic() 738 item_info->cas = wqitem->cas ? *(wqitem->cas) : 0; in ndb_get_item_info() [all …]
|
H A D | NdbInstance.cc | 37 next(0), wqitem(0), ndb_owner(false) in NdbInstance() 53 db(_db), wqitem(_item), ndb_owner(false) in NdbInstance() 55 wqitem->ndb_instance = this; in NdbInstance()
|
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/storage/ndb/memcache/include/ |
H A D | NdbInstance.h | 57 workitem *wqitem; variable 67 assert(wqitem == NULL); in link_workitem() 70 wqitem = item; in link_workitem() 75 assert(wqitem == item); in unlink_workitem() 76 wqitem->ndb_instance = NULL; in unlink_workitem() 77 wqitem = NULL; in unlink_workitem()
|
/dports/databases/percona57-server/percona-server-5.7.36-39/storage/ndb/memcache/include/ |
H A D | NdbInstance.h | 59 workitem *wqitem; variable 69 assert(wqitem == NULL); in link_workitem() 72 wqitem = item; in link_workitem() 77 assert(wqitem == item); in unlink_workitem() 78 wqitem->ndb_instance = NULL; in unlink_workitem() 79 wqitem = NULL; in unlink_workitem()
|
/dports/databases/percona57-client/percona-server-5.7.36-39/storage/ndb/memcache/include/ |
H A D | NdbInstance.h | 59 workitem *wqitem; variable 69 assert(wqitem == NULL); in link_workitem() 72 wqitem = item; in link_workitem() 77 assert(wqitem == item); in unlink_workitem() 78 wqitem->ndb_instance = NULL; in unlink_workitem() 79 wqitem = NULL; in unlink_workitem()
|
/dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/storage/ndb/memcache/include/ |
H A D | NdbInstance.h | 59 workitem *wqitem; variable 69 assert(wqitem == NULL); in link_workitem() 72 wqitem = item; in link_workitem() 77 assert(wqitem == item); in unlink_workitem() 78 wqitem->ndb_instance = NULL; in unlink_workitem() 79 wqitem = NULL; in unlink_workitem()
|
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/storage/ndb/memcache/include/ |
H A D | NdbInstance.h | 59 workitem *wqitem; variable 69 assert(wqitem == NULL); in link_workitem() 72 wqitem = item; in link_workitem() 77 assert(wqitem == item); in unlink_workitem() 78 wqitem->ndb_instance = NULL; in unlink_workitem() 79 wqitem = NULL; in unlink_workitem()
|
/dports/databases/xtrabackup/percona-xtrabackup-2.4.21/storage/ndb/memcache/include/ |
H A D | NdbInstance.h | 59 workitem *wqitem; variable 69 assert(wqitem == NULL); in link_workitem() 72 wqitem = item; in link_workitem() 77 assert(wqitem == item); in unlink_workitem() 78 wqitem->ndb_instance = NULL; in unlink_workitem() 79 wqitem = NULL; in unlink_workitem()
|