projects
/
awesomized
/
libmemcached
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
|
github
raw
|
inline
| side by side
p9y
[awesomized/libmemcached]
/
src
/
libmemcached
/
io.cc
diff --git
a/src/libmemcached/io.cc
b/src/libmemcached/io.cc
index 087ae60665da251fb71e00b192876d6c4e5a8646..94aca6177acc929f50811fa1276810de621c02fc 100644
(file)
--- a/
src/libmemcached/io.cc
+++ b/
src/libmemcached/io.cc
@@
-15,9
+15,8
@@
#include "libmemcached/common.h"
#include "libmemcached/common.h"
-#ifdef HAVE_SYS_SOCKET_H
-# include <sys/socket.h>
-#endif
+#include "p9y/socket.hpp"
+#include "p9y/poll.hpp"
void initialize_binary_request(memcached_instance_st *server,
protocol_binary_request_header &header) {
void initialize_binary_request(memcached_instance_st *server,
protocol_binary_request_header &header) {
@@
-56,7
+55,8
@@
static bool repack_input_buffer(memcached_instance_st *instance) {
memcached_set_error(*instance, MEMCACHED_CONNECTION_FAILURE, MEMCACHED_AT);
} else {
switch (get_socket_errno()) {
memcached_set_error(*instance, MEMCACHED_CONNECTION_FAILURE, MEMCACHED_AT);
} else {
switch (get_socket_errno()) {
- case EINTR: continue;
+ case EINTR:
+ continue;
#if EWOULDBLOCK != EAGAIN
case EWOULDBLOCK:
#if EWOULDBLOCK != EAGAIN
case EWOULDBLOCK:
@@
-67,7
+67,8
@@
static bool repack_input_buffer(memcached_instance_st *instance) {
#endif
break; // No IO is fine, we can just move on
#endif
break; // No IO is fine, we can just move on
- default: memcached_set_errno(*instance, get_socket_errno(), MEMCACHED_AT);
+ default:
+ memcached_set_errno(*instance, get_socket_errno(), MEMCACHED_AT);
}
}
}
}
@@
-99,7
+100,7
@@
static bool process_input_buffer(memcached_instance_st *instance) {
** We might be able to process some of the response messages if we
** have a callback set up
*/
** We might be able to process some of the response messages if we
** have a callback set up
*/
- if (instance->root->callbacks
!= NULL
) {
+ if (instance->root->callbacks) {
/*
* We might have responses... try to read them out and fire
* callbacks
/*
* We might have responses... try to read them out and fire
* callbacks
@@
-213,7
+214,8
@@
static memcached_return_t io_wait(memcached_instance_st *instance, const short e
#ifdef __linux
case ERESTART:
#endif
#ifdef __linux
case ERESTART:
#endif
- case EINTR: continue;
+ case EINTR:
+ continue;
case EFAULT:
case ENOMEM:
case EFAULT:
case ENOMEM:
@@
-293,7
+295,8
@@
static bool io_flush(memcached_instance_st *instance, const bool with_flush,
WATCHPOINT_NUMBER(get_socket_errno());
#endif
switch (get_socket_errno()) {
WATCHPOINT_NUMBER(get_socket_errno());
#endif
switch (get_socket_errno()) {
- case ENOBUFS: continue;
+ case ENOBUFS:
+ continue;
#if EWOULDBLOCK != EAGAIN
case EWOULDBLOCK:
#if EWOULDBLOCK != EAGAIN
case EWOULDBLOCK:
@@
-515,7
+518,8
@@
memcached_return_t memcached_io_slurp(memcached_instance_st *instance) {
case EINVAL:
case EFAULT:
case ECONNREFUSED:
case EINVAL:
case EFAULT:
case ECONNREFUSED:
- default: return MEMCACHED_CONNECTION_FAILURE; // We want this!
+ default:
+ return MEMCACHED_CONNECTION_FAILURE; // We want this!
}
}
} while (data_read > 0);
}
}
} while (data_read > 0);
@@
-694,7
+698,8
@@
memcached_instance_st *memcached_io_get_readable_server(Memcached *memc, memcach
case -1:
memcached_set_errno(*memc, get_socket_errno(), MEMCACHED_AT);
/* FALLTHROUGH */
case -1:
memcached_set_errno(*memc, get_socket_errno(), MEMCACHED_AT);
/* FALLTHROUGH */
- case 0: break;
+ case 0:
+ break;
default:
for (nfds_t x = 0; x < host_index; ++x) {
default:
for (nfds_t x = 0; x < host_index; ++x) {