Home
last modified time | relevance | path

Searched refs:mlget_num (Results 1 – 6 of 6) sorted by relevance

/dports/databases/p5-Memcached-libmemcached/Memcached-libmemcached-1.001801/src/libmemcached/clients/
H A Dms_task.c655 mlget_item= &c->mlget_task.mlget_item[c->mlget_task.mlget_num]; in ms_multi_getset_task_sch()
660 c->mlget_task.mlget_num++; in ms_multi_getset_task_sch()
663 if ((c->mlget_task.mlget_num >= ms_setting.mult_key_num) in ms_multi_getset_task_sch()
664 || ((c->remain_exec_num == 0) && (c->mlget_task.mlget_num > 0))) in ms_multi_getset_task_sch()
673 if ((c->remain_exec_num <= 0) && (c->mlget_task.mlget_num > 0)) in ms_multi_getset_task_sch()
722 for (int i= 0; i < c->mlget_task.mlget_num; i++) in ms_update_multi_get_result()
804 c->mlget_task.mlget_num= 0; in ms_update_multi_get_result()
1035 && (c->mlget_task.mlget_num >= ms_setting.mult_key_num)) in ms_update_task_result()
1036 || ((c->remain_exec_num == 0) && (c->mlget_task.mlget_num > 0))) in ms_update_task_result()
H A Dms_task.h58 int mlget_num; /* how many tasks in mlget_task array */ member
H A Dms_conn.c357 c->mlget_task.mlget_num= 0; in ms_conn_init()
1873 && (c->mlget_task.mlget_num >= ms_setting.mult_key_num)) in ms_ascii_complete_nread()
1874 || ((c->remain_exec_num == 0) && (c->mlget_task.mlget_num > 0))) in ms_ascii_complete_nread()
1889 for (int i= 0; i < c->mlget_task.mlget_num; i++) in ms_ascii_complete_nread()
1953 && (c->mlget_task.mlget_num >= ms_setting.mult_key_num)) in ms_bin_complete_nread()
1954 || ((c->remain_exec_num == 0) && (c->mlget_task.mlget_num > 0))) in ms_bin_complete_nread()
1981 if (c->mlget_task.value_index == c->mlget_task.mlget_num - 1) in ms_bin_complete_nread()
3089 for (int i= 0; i < c->mlget_task.mlget_num; i++) in ms_build_ascii_write_buf_mlget()
3125 assert(c->mlget_task.mlget_num >= 1); in ms_mcd_mlget()
3162 for (int i= 0; i < c->mlget_task.mlget_num; i++) in ms_mcd_mlget()
[all …]
/dports/databases/libmemcached/libmemcached-1.0.18/clients/
H A Dms_task.c655 mlget_item= &c->mlget_task.mlget_item[c->mlget_task.mlget_num]; in ms_multi_getset_task_sch()
660 c->mlget_task.mlget_num++; in ms_multi_getset_task_sch()
663 if ((c->mlget_task.mlget_num >= ms_setting.mult_key_num) in ms_multi_getset_task_sch()
664 || ((c->remain_exec_num == 0) && (c->mlget_task.mlget_num > 0))) in ms_multi_getset_task_sch()
673 if ((c->remain_exec_num <= 0) && (c->mlget_task.mlget_num > 0)) in ms_multi_getset_task_sch()
722 for (int i= 0; i < c->mlget_task.mlget_num; i++) in ms_update_multi_get_result()
804 c->mlget_task.mlget_num= 0; in ms_update_multi_get_result()
1035 && (c->mlget_task.mlget_num >= ms_setting.mult_key_num)) in ms_update_task_result()
1036 || ((c->remain_exec_num == 0) && (c->mlget_task.mlget_num > 0))) in ms_update_task_result()
H A Dms_task.h58 int mlget_num; /* how many tasks in mlget_task array */ member
H A Dms_conn.c357 c->mlget_task.mlget_num= 0; in ms_conn_init()
1873 && (c->mlget_task.mlget_num >= ms_setting.mult_key_num)) in ms_ascii_complete_nread()
1874 || ((c->remain_exec_num == 0) && (c->mlget_task.mlget_num > 0))) in ms_ascii_complete_nread()
1889 for (int i= 0; i < c->mlget_task.mlget_num; i++) in ms_ascii_complete_nread()
1953 && (c->mlget_task.mlget_num >= ms_setting.mult_key_num)) in ms_bin_complete_nread()
1954 || ((c->remain_exec_num == 0) && (c->mlget_task.mlget_num > 0))) in ms_bin_complete_nread()
1981 if (c->mlget_task.value_index == c->mlget_task.mlget_num - 1) in ms_bin_complete_nread()
3089 for (int i= 0; i < c->mlget_task.mlget_num; i++) in ms_build_ascii_write_buf_mlget()
3125 assert(c->mlget_task.mlget_num >= 1); in ms_mcd_mlget()
3162 for (int i= 0; i < c->mlget_task.mlget_num; i++) in ms_mcd_mlget()
[all …]