return "tosserror"; /* This is impossible, fixes issue for compiler warning in VisualStudio */
};
- return SET_OP;
+ /* NOTREACHED */
}
static memcached_return memcached_send_binary(memcached_server_st* server,
if (ptr->flags & MEM_NOREPLY)
{
- memcached_server_response_decrement(&ptr->hosts[server_key]);
return (to_write == 0) ? MEMCACHED_BUFFERED : MEMCACHED_SUCCESS;
}
return rc;
}
+static inline uint8_t get_com_code(memcached_storage_action verb, bool noreply) {
+ uint8_t ret;
+
+ if (noreply)
+ switch (verb)
+ {
+ case SET_OP:
+ ret=PROTOCOL_BINARY_CMD_SETQ;
+ break;
+ case ADD_OP:
+ ret=PROTOCOL_BINARY_CMD_ADDQ;
+ break;
+ case CAS_OP: /* FALLTHROUGH */
+ case REPLACE_OP:
+ ret=PROTOCOL_BINARY_CMD_REPLACEQ;
+ break;
+ case APPEND_OP:
+ ret=PROTOCOL_BINARY_CMD_APPENDQ;
+ break;
+ case PREPEND_OP:
+ ret=PROTOCOL_BINARY_CMD_PREPENDQ;
+ break;
+ }
+ else
+ switch (verb)
+ {
+ case SET_OP:
+ ret=PROTOCOL_BINARY_CMD_SET;
+ break;
+ case ADD_OP:
+ ret=PROTOCOL_BINARY_CMD_ADD;
+ break;
+ case CAS_OP: /* FALLTHROUGH */
+ case REPLACE_OP:
+ ret=PROTOCOL_BINARY_CMD_REPLACE;
+ break;
+ case APPEND_OP:
+ ret=PROTOCOL_BINARY_CMD_APPEND;
+ break;
+ case PREPEND_OP:
+ ret=PROTOCOL_BINARY_CMD_PREPEND;
+ break;
+ }
+
+ return ret;
+}
+
+
+
static memcached_return memcached_send_binary(memcached_server_st* server,
const char *key,
size_t key_length,
char flush;
protocol_binary_request_set request= {.bytes= {0}};
size_t send_length= sizeof(request.bytes);
+ bool noreply = server->root->flags & MEM_NOREPLY;
request.message.header.request.magic= PROTOCOL_BINARY_REQ;
- switch (verb)
- {
- case SET_OP:
- request.message.header.request.opcode= PROTOCOL_BINARY_CMD_SET;
- break;
- case ADD_OP:
- request.message.header.request.opcode= PROTOCOL_BINARY_CMD_ADD;
- break;
- case REPLACE_OP:
- request.message.header.request.opcode= PROTOCOL_BINARY_CMD_REPLACE;
- break;
- case APPEND_OP:
- request.message.header.request.opcode= PROTOCOL_BINARY_CMD_APPEND;
- break;
- case PREPEND_OP:
- request.message.header.request.opcode= PROTOCOL_BINARY_CMD_PREPEND;
- break;
- case CAS_OP:
- request.message.header.request.opcode= PROTOCOL_BINARY_CMD_REPLACE;
- break;
- }
-
+ request.message.header.request.opcode= get_com_code(verb, noreply);
request.message.header.request.keylen= htons((uint16_t)key_length);
request.message.header.request.datatype= PROTOCOL_BINARY_RAW_BYTES;
if (verb == APPEND_OP || verb == PREPEND_OP)
memcached_io_reset(server);
return MEMCACHED_WRITE_FAILURE;
}
-
+
if (flush == 0)
return MEMCACHED_BUFFERED;
+ if (noreply)
+ return MEMCACHED_SUCCESS;
+
return memcached_response(server, NULL, 0, NULL);
}