Home
last modified time | relevance | path

Searched refs:wqitem (Results 1 – 25 of 49) sorted by relevance

12

/dports/databases/xtrabackup/percona-xtrabackup-2.4.21/storage/ndb/memcache/src/
H A Dndb_worker.cc95 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 DExternalValue.cc267 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 Dndb_engine.c323 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 Dndb_worker.cc95 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 DExternalValue.cc267 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 Dndb_engine.c323 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 Dndb_worker.cc95 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 DExternalValue.cc267 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 Dndb_engine.c323 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 Dndb_worker.cc95 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 DExternalValue.cc267 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 Dndb_engine.c323 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 Dndb_worker.cc95 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 DExternalValue.cc267 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 Dndb_engine.c323 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 Dndb_worker.cc92 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 DExternalValue.cc265 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 Dndb_engine.cc321 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 DNdbInstance.cc37 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 DNdbInstance.h57 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 DNdbInstance.h59 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 DNdbInstance.h59 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 DNdbInstance.h59 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 DNdbInstance.h59 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 DNdbInstance.h59 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()

12