Lines Matching refs:cmd
30 assert(c->cmd >= 0); in complete_nread_binary()
99 c->cmd = c->binary_header.request.opcode; in try_read_command_binary()
245 if (!c->noreply || c->cmd == PROTOCOL_BINARY_CMD_GET || in write_bin_response()
246 c->cmd == PROTOCOL_BINARY_CMD_GETK) { in write_bin_response()
294 switch(add_delta(c->thread, key, nkey, c->cmd == PROTOCOL_BINARY_CMD_INCREMENT, in complete_incr_bin()
342 if (c->cmd == PROTOCOL_BINARY_CMD_INCREMENT) { in complete_incr_bin()
386 …ret = store_item(it, c->cmd, c->thread, NULL, &cas, (settings.use_cas) ? get_cas_id() : 0, CAS_NO_… in complete_update_bin()
390 switch (c->cmd) { in complete_update_bin()
428 if (c->cmd == NREAD_ADD) { in complete_update_bin()
430 } else if(c->cmd == NREAD_REPLACE) { in complete_update_bin()
462 int should_touch = (c->cmd == PROTOCOL_BINARY_CMD_TOUCH || in process_bin_get_or_touch()
463 c->cmd == PROTOCOL_BINARY_CMD_GAT || in process_bin_get_or_touch()
464 c->cmd == PROTOCOL_BINARY_CMD_GATK); in process_bin_get_or_touch()
465 int should_return_key = (c->cmd == PROTOCOL_BINARY_CMD_GETK || in process_bin_get_or_touch()
466 c->cmd == PROTOCOL_BINARY_CMD_GATK); in process_bin_get_or_touch()
467 int should_return_value = (c->cmd != PROTOCOL_BINARY_CMD_TOUCH); in process_bin_get_or_touch()
508 if (c->cmd == PROTOCOL_BINARY_CMD_TOUCH) { in process_bin_get_or_touch()
802 switch (c->cmd) { in process_bin_complete_sasl_auth()
827 c->cmd, challenge); in process_bin_complete_sasl_auth()
867 switch (c->cmd) { in authenticated()
880 c->cmd, rv ? "true" : "false"); in authenticated()
915 switch (c->cmd) { in dispatch_bin_command()
917 c->cmd = PROTOCOL_BINARY_CMD_SET; in dispatch_bin_command()
920 c->cmd = PROTOCOL_BINARY_CMD_ADD; in dispatch_bin_command()
923 c->cmd = PROTOCOL_BINARY_CMD_REPLACE; in dispatch_bin_command()
926 c->cmd = PROTOCOL_BINARY_CMD_DELETE; in dispatch_bin_command()
929 c->cmd = PROTOCOL_BINARY_CMD_INCREMENT; in dispatch_bin_command()
932 c->cmd = PROTOCOL_BINARY_CMD_DECREMENT; in dispatch_bin_command()
935 c->cmd = PROTOCOL_BINARY_CMD_QUIT; in dispatch_bin_command()
938 c->cmd = PROTOCOL_BINARY_CMD_FLUSH; in dispatch_bin_command()
941 c->cmd = PROTOCOL_BINARY_CMD_APPEND; in dispatch_bin_command()
944 c->cmd = PROTOCOL_BINARY_CMD_PREPEND; in dispatch_bin_command()
947 c->cmd = PROTOCOL_BINARY_CMD_GET; in dispatch_bin_command()
950 c->cmd = PROTOCOL_BINARY_CMD_GETK; in dispatch_bin_command()
953 c->cmd = PROTOCOL_BINARY_CMD_GAT; in dispatch_bin_command()
956 c->cmd = PROTOCOL_BINARY_CMD_GATK; in dispatch_bin_command()
962 switch (c->cmd) { in dispatch_bin_command()
1100 if (c->cmd == PROTOCOL_BINARY_CMD_ADD) { in process_bin_update()
1102 } else if (c->cmd == PROTOCOL_BINARY_CMD_SET) { in process_bin_update()
1140 if (c->cmd == PROTOCOL_BINARY_CMD_SET) { in process_bin_update()
1156 switch (c->cmd) { in process_bin_update()
1158 c->cmd = NREAD_ADD; in process_bin_update()
1161 c->cmd = NREAD_SET; in process_bin_update()
1164 c->cmd = NREAD_REPLACE; in process_bin_update()
1171 c->cmd = NREAD_CAS; in process_bin_update()
1226 switch (c->cmd) { in process_bin_append_prepend()
1228 c->cmd = NREAD_APPEND; in process_bin_append_prepend()
1231 c->cmd = NREAD_PREPEND; in process_bin_append_prepend()