projects
/
m6w6
/
libmemcached
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
|
github
raw
|
inline
| side by side
Final bits for 1.0.9
[m6w6/libmemcached]
/
libmemcached
/
io.cc
diff --git
a/libmemcached/io.cc
b/libmemcached/io.cc
index defe234316adf3f8308f74c608253b6c4f885f8b..d2e40043dfaa1c958ae1e346ed8dc1dbacb6bd3a 100644
(file)
--- a/
libmemcached/io.cc
+++ b/
libmemcached/io.cc
@@
-39,6
+39,13
@@
#include <libmemcached/common.h>
#include <libmemcached/common.h>
+void initialize_binary_request(memcached_server_write_instance_st server, protocol_binary_request_header& header)
+{
+ server->request_id++;
+ header.request.magic= PROTOCOL_BINARY_REQ;
+ header.request.opaque= htons(server->request_id);
+}
+
enum memc_read_or_write {
MEM_READ,
MEM_WRITE
enum memc_read_or_write {
MEM_READ,
MEM_WRITE
@@
-280,7
+287,7
@@
static memcached_return_t io_wait(memcached_server_write_instance_st ptr,
if (memcached_has_error(ptr))
{
if (memcached_has_error(ptr))
{
- return memcached_
server
_error_return(ptr);
+ return memcached_
instance
_error_return(ptr);
}
return memcached_set_error(*ptr, MEMCACHED_CONNECTION_FAILURE, MEMCACHED_AT,
}
return memcached_set_error(*ptr, MEMCACHED_CONNECTION_FAILURE, MEMCACHED_AT,
@@
-442,7
+449,7
@@
static memcached_return_t _io_fill(memcached_server_write_instance_st ptr)
break;
}
break;
}
- return memcached_
server
_error_return(ptr);
+ return memcached_
instance
_error_return(ptr);
}
else if (data_read == 0)
{
}
else if (data_read == 0)
{
@@
-722,11
+729,11
@@
memcached_server_write_instance_st memcached_io_get_readable_server(memcached_st
return instance;
}
return instance;
}
- if (memcached_
server
_response_count(instance) > 0)
+ if (memcached_
instance
_response_count(instance) > 0)
{
{
- fds[host_index].events
= POLLIN;
- fds[host_index].revents
= 0;
- fds[host_index].fd
= instance->fd;
+ fds[host_index].events= POLLIN;
+ fds[host_index].revents= 0;
+ fds[host_index].fd= instance->fd;
++host_index;
}
}
++host_index;
}
}
@@
-736,10
+743,9
@@
memcached_server_write_instance_st memcached_io_get_readable_server(memcached_st
/* We have 0 or 1 server with pending events.. */
for (uint32_t x= 0; x< memcached_server_count(memc); ++x)
{
/* We have 0 or 1 server with pending events.. */
for (uint32_t x= 0; x< memcached_server_count(memc); ++x)
{
- memcached_server_write_instance_st instance=
- memcached_server_instance_fetch(memc, x);
+ memcached_server_write_instance_st instance= memcached_server_instance_fetch(memc, x);
- if (memcached_
server
_response_count(instance) > 0)
+ if (memcached_
instance
_response_count(instance) > 0)
{
return instance;
}
{
return instance;
}