summary |
shortlog |
log |
commit | commitdiff |
tree |
github
raw |
patch |
inline | side by side (from parent 1:
e4dbb63)
I've also added an ASSERT during debug for read() calls of zero. I would
like to determine if there is anything broken in the protocol.
}
else if (data_read)
break;
}
else if (data_read)
break;
- /* If zero, just keep looping */
+ /* If zero, just keep looping unless testing, then assert() */
+ else
+ WATCHPOINT_ASSERT(0);
}
ptr->hosts[server_key].read_data_length= data_read;
}
ptr->hosts[server_key].read_data_length= data_read;
rc= memcached_set(memc, key, strlen(key),
value, strlen(value),
(time_t)0, (uint32_t)0);
rc= memcached_set(memc, key, strlen(key),
value, strlen(value),
(time_t)0, (uint32_t)0);
- assert(rc == MEMCACHED_SUCCESS);
+ assert(rc == MEMCACHED_SUCCESS || rc == MEMCACHED_BUFFERED);
rc= memcached_set(memc, key, strlen(key),
value, strlen(value),
(time_t)0, (uint32_t)0);
rc= memcached_set(memc, key, strlen(key),
value, strlen(value),
(time_t)0, (uint32_t)0);
- assert(rc == MEMCACHED_SUCCESS);
+ assert(rc == MEMCACHED_SUCCESS || rc == MEMCACHED_BUFFERED);
memcached_quit(memc);
rc= memcached_add(memc, key, strlen(key),
value, strlen(value),
memcached_quit(memc);
rc= memcached_add(memc, key, strlen(key),
value, strlen(value),
rc= memcached_set(memc, key, strlen(key),
value, strlen(value),
(time_t)0, (uint32_t)0);
rc= memcached_set(memc, key, strlen(key),
value, strlen(value),
(time_t)0, (uint32_t)0);
- assert(rc == MEMCACHED_SUCCESS);
+ assert(rc == MEMCACHED_SUCCESS || rc == MEMCACHED_BUFFERED);
rc= memcached_delete(memc, key, strlen(key), (time_t)0);
rc= memcached_delete(memc, key, strlen(key), (time_t)0);
- assert(rc == MEMCACHED_SUCCESS);
+ assert(rc == MEMCACHED_SUCCESS || rc == MEMCACHED_BUFFERED);
uint32_t flags;
rc= memcached_delete(memc, key, strlen(key), (time_t)0);
uint32_t flags;
rc= memcached_delete(memc, key, strlen(key), (time_t)0);
- assert(rc == MEMCACHED_SUCCESS || rc == MEMCACHED_NOTFOUND);
+ assert(rc == MEMCACHED_BUFFERED || rc == MEMCACHED_NOTFOUND);
string= memcached_get(memc, key, strlen(key),
&string_length, &flags, &rc);
string= memcached_get(memc, key, strlen(key),
&string_length, &flags, &rc);
rc= memcached_set(memc, key, strlen(key),
value, strlen(value),
(time_t)0, (uint32_t)0);
rc= memcached_set(memc, key, strlen(key),
value, strlen(value),
(time_t)0, (uint32_t)0);
- assert(rc == MEMCACHED_SUCCESS);
+ assert(rc == MEMCACHED_SUCCESS || rc == MEMCACHED_BUFFERED);
string= memcached_get(memc, key, strlen(key),
&string_length, &flags, &rc);
string= memcached_get(memc, key, strlen(key),
&string_length, &flags, &rc);
rc= memcached_set(memc, key, strlen(key),
value, value_length,
(time_t)0, (uint32_t)0);
rc= memcached_set(memc, key, strlen(key),
value, value_length,
(time_t)0, (uint32_t)0);
- assert(rc == MEMCACHED_SUCCESS);
+ assert(rc == MEMCACHED_SUCCESS || rc == MEMCACHED_BUFFERED);
rc= memcached_set(memc, key, strlen(key),
value, value_length,
(time_t)0, (uint32_t)0);
rc= memcached_set(memc, key, strlen(key),
value, value_length,
(time_t)0, (uint32_t)0);
- assert(rc == MEMCACHED_SUCCESS);
+ assert(rc == MEMCACHED_SUCCESS || rc == MEMCACHED_BUFFERED);
rc= memcached_set(memc, key, strlen(key),
value, value_length,
(time_t)0, (uint32_t)0);
rc= memcached_set(memc, key, strlen(key),
value, value_length,
(time_t)0, (uint32_t)0);
- assert(rc == MEMCACHED_SUCCESS);
+ assert(rc == MEMCACHED_SUCCESS || rc == MEMCACHED_BUFFERED);
string= memcached_get(memc, key, strlen(key),
&string_length, &flags, &rc);
string= memcached_get(memc, key, strlen(key),
&string_length, &flags, &rc);
rc= memcached_set(memc, key, strlen(key),
value, value_length,
(time_t)0, (uint32_t)0);
rc= memcached_set(memc, key, strlen(key),
value, value_length,
(time_t)0, (uint32_t)0);
- assert(rc == MEMCACHED_SUCCESS);
+ assert(rc == MEMCACHED_SUCCESS || rc == MEMCACHED_BUFFERED);
for (x= 0; x < 10; x++)
{
for (x= 0; x < 10; x++)
{
rc= memcached_set(memc, key, strlen(key),
value, strlen(value),
(time_t)0, (uint32_t)0);
rc= memcached_set(memc, key, strlen(key),
value, strlen(value),
(time_t)0, (uint32_t)0);
- assert(rc == MEMCACHED_SUCCESS);
+ assert(rc == MEMCACHED_SUCCESS || rc == MEMCACHED_BUFFERED);
rc= memcached_increment(memc, key, strlen(key),
1, &new_number);
rc= memcached_increment(memc, key, strlen(key),
1, &new_number);
rc= memcached_set(memc, key, strlen(key),
value, strlen(value),
(time_t)0, (uint32_t)0);
rc= memcached_set(memc, key, strlen(key),
value, strlen(value),
(time_t)0, (uint32_t)0);
- assert(rc == MEMCACHED_SUCCESS);
+ assert(rc == MEMCACHED_SUCCESS || rc == MEMCACHED_BUFFERED);
rc= memcached_decrement(memc, key, strlen(key),
1, &new_number);
rc= memcached_decrement(memc, key, strlen(key),
1, &new_number);
rc= memcached_set(memc, key, strlen(key),
value, strlen(value),
(time_t)10, (uint32_t)3);
rc= memcached_set(memc, key, strlen(key),
value, strlen(value),
(time_t)10, (uint32_t)3);
- assert(rc == MEMCACHED_SUCCESS);
+ assert(rc == MEMCACHED_SUCCESS || rc == MEMCACHED_BUFFERED);
memcached_quit(memc);
rc= memcached_set(memc, key, strlen(key),
value, strlen(value),
(time_t)50, (uint32_t)9);
memcached_quit(memc);
rc= memcached_set(memc, key, strlen(key),
value, strlen(value),
(time_t)50, (uint32_t)9);
- assert(rc == MEMCACHED_SUCCESS);
+ assert(rc == MEMCACHED_SUCCESS || rc == MEMCACHED_BUFFERED);
rc= memcached_set(memc, keys[x], key_length[x],
keys[x], key_length[x],
(time_t)50, (uint32_t)9);
rc= memcached_set(memc, keys[x], key_length[x],
keys[x], key_length[x],
(time_t)50, (uint32_t)9);
- assert(rc == MEMCACHED_SUCCESS);
+ assert(rc == MEMCACHED_SUCCESS || rc == MEMCACHED_BUFFERED);
}
rc= memcached_mget(memc, keys, key_length, 3);
}
rc= memcached_mget(memc, keys, key_length, 3);
rc= memcached_set(memc, keys[x], key_length[x],
keys[x], key_length[x],
(time_t)50, (uint32_t)9);
rc= memcached_set(memc, keys[x], key_length[x],
keys[x], key_length[x],
(time_t)50, (uint32_t)9);
- assert(rc == MEMCACHED_SUCCESS);
+ assert(rc == MEMCACHED_SUCCESS || rc == MEMCACHED_BUFFERED);
}
rc= memcached_mget(memc, keys, key_length, 3);
}
rc= memcached_mget(memc, keys, key_length, 3);
rc= memcached_set(memc, keys[x], key_length[x],
keys[x], key_length[x],
(time_t)50, (uint32_t)9);
rc= memcached_set(memc, keys[x], key_length[x],
keys[x], key_length[x],
(time_t)50, (uint32_t)9);
- assert(rc == MEMCACHED_SUCCESS);
+ assert(rc == MEMCACHED_SUCCESS || rc == MEMCACHED_BUFFERED);
}
rc= memcached_mget(memc, keys, key_length, 3);
}
rc= memcached_mget(memc, keys, key_length, 3);
rc= memcached_set(memc, keys[x], key_length[x],
keys[x], key_length[x],
(time_t)50, (uint32_t)9);
rc= memcached_set(memc, keys[x], key_length[x],
keys[x], key_length[x],
(time_t)50, (uint32_t)9);
- assert(rc == MEMCACHED_SUCCESS);
+ assert(rc == MEMCACHED_SUCCESS || rc == MEMCACHED_BUFFERED);
}
rc= memcached_mget(memc, keys, key_length, 3);
}
rc= memcached_mget(memc, keys, key_length, 3);
rc = memcached_set(memc, key, strlen(key),
randomstuff, strlen(randomstuff), 10, 0);
/* If we fail, lets try again */
rc = memcached_set(memc, key, strlen(key),
randomstuff, strlen(randomstuff), 10, 0);
/* If we fail, lets try again */
- if (rc != MEMCACHED_SUCCESS)
+ if (rc != MEMCACHED_SUCCESS && rc != MEMCACHED_BUFFERED)
rc = memcached_set(memc, key, strlen(key),
randomstuff, strlen(randomstuff), 10, 0);
rc = memcached_set(memc, key, strlen(key),
randomstuff, strlen(randomstuff), 10, 0);
- assert(rc == MEMCACHED_SUCCESS);
+ assert(rc == MEMCACHED_SUCCESS || rc == MEMCACHED_BUFFERED);
{
rc= memcached_set(mclone, key, key_len,value, value_length, 0, 0);
{
rc= memcached_set(mclone, key, key_len,value, value_length, 0, 0);
- assert(rc == MEMCACHED_SUCCESS || rc == MEMCACHED_WRITE_FAILURE);
+ assert(rc == MEMCACHED_SUCCESS || rc == MEMCACHED_WRITE_FAILURE || rc == MEMCACHED_BUFFERED);
if (rc == MEMCACHED_WRITE_FAILURE)
x--;
if (rc == MEMCACHED_WRITE_FAILURE)
x--;
rc= memcached_set(mclone, key, key_len,value, value_length, 0, 0);
WATCHPOINT_IFERROR(rc);
rc= memcached_set(mclone, key, key_len,value, value_length, 0, 0);
WATCHPOINT_IFERROR(rc);
- //assert(rc == MEMCACHED_SUCCESS);