projects
/
m6w6
/
libmemcached
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
|
github
raw
|
inline
| side by side
Bool fix.
[m6w6/libmemcached]
/
libmemcached
/
io.c
diff --git
a/libmemcached/io.c
b/libmemcached/io.c
index 3a523213357aaf3c15a7c7f29ac3d472630c992e..232b58d3358260dac0fec408a8cab85c14d0f25c 100644
(file)
--- a/
libmemcached/io.c
+++ b/
libmemcached/io.c
@@
-127,20
+127,21
@@
static bool process_input_buffer(memcached_server_instance_st *ptr)
*/
memcached_callback_st cb= *ptr->root->callbacks;
*/
memcached_callback_st cb= *ptr->root->callbacks;
-
ptr->root->options.is_processing_input= true
;
+
memcached_set_processing_input((memcached_st *)ptr->root, true)
;
char buffer[MEMCACHED_DEFAULT_COMMAND_SIZE];
memcached_return_t error;
char buffer[MEMCACHED_DEFAULT_COMMAND_SIZE];
memcached_return_t error;
+ memcached_st *root= (memcached_st *)ptr->root;
error= memcached_response(ptr, buffer, sizeof(buffer),
error= memcached_response(ptr, buffer, sizeof(buffer),
- &
ptr->
root->result);
+ &root->result);
-
ptr->root->options.is_processing_input = false
;
+
memcached_set_processing_input(root, false)
;
if (error == MEMCACHED_SUCCESS)
{
for (unsigned int x= 0; x < cb.number_of_callback; x++)
{
if (error == MEMCACHED_SUCCESS)
{
for (unsigned int x= 0; x < cb.number_of_callback; x++)
{
- error= (*cb.callback[x])(ptr->root, &
ptr->
root->result, cb.context);
+ error= (*cb.callback[x])(ptr->root, &root->result, cb.context);
if (error != MEMCACHED_SUCCESS)
break;
}
if (error != MEMCACHED_SUCCESS)
break;
}
@@
-306,7
+307,7
@@
memcached_return_t memcached_io_read(memcached_server_instance_st *ptr,
}
ssize_t memcached_io_write(memcached_server_instance_st *ptr,
}
ssize_t memcached_io_write(memcached_server_instance_st *ptr,
- const void *buffer, size_t length,
char
with_flush)
+ const void *buffer, size_t length,
bool
with_flush)
{
size_t original_length;
const char* buffer_ptr;
{
size_t original_length;
const char* buffer_ptr;