X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;ds=sidebyside;f=src%2Fbin%2Fmemcapable.cc;h=122c294e79adc6e4c9b1008e6eeb8c1d9255ea96;hb=92d18858b417309f6bdee6bce464a4f3d6a375fd;hp=1b9af02a5dc4bd596408351b8df6845255e55199;hpb=aeac01630eed825d8a624e7fd7c107d47bb2e40c;p=awesomized%2Flibmemcached

diff --git a/src/bin/memcapable.cc b/src/bin/memcapable.cc
index 1b9af02a..122c294e 100644
--- a/src/bin/memcapable.cc
+++ b/src/bin/memcapable.cc
@@ -1,6 +1,6 @@
 /*
     +--------------------------------------------------------------------+
-    | libmemcached - C/C++ Client Library for memcached                  |
+    | libmemcached-awesome - C/C++ Client Library for memcached          |
     +--------------------------------------------------------------------+
     | Redistribution and use in source and binary forms, with or without |
     | modification, are permitted under the terms of the BSD license.    |
@@ -9,7 +9,7 @@
     | the terms online at: https://opensource.org/licenses/BSD-3-Clause  |
     +--------------------------------------------------------------------+
     | Copyright (c) 2006-2014 Brian Aker   https://datadifferential.com/ |
-    | Copyright (c) 2020 Michael Wallner   <mike@php.net>                |
+    | Copyright (c) 2020-2021 Michael Wallner        https://awesome.co/ |
     +--------------------------------------------------------------------+
 */
 
@@ -32,13 +32,11 @@
 #  include <unistd.h>
 #endif
 
-#ifndef HAVE_GETOPT_H
-#  include "../../win32/getopt.h"
-#endif
+#include "p9y/getopt.hpp"
+#include "p9y/socket.hpp"
+#include "p9y/poll.hpp"
 
 #include "libmemcached-1.0/memcached.h"
-#include "libmemcached/poll.h"
-#include "libmemcached/socket.hpp"
 #include "libmemcachedprotocol-0.0/binary.h"
 #include "libmemcached/byteorder.h"
 
@@ -132,14 +130,14 @@ static memcached_socket_t set_noblock(void) {
   int flags = fcntl(sock, F_GETFL, 0);
   if (flags == -1) {
     perror("Failed to get socket flags");
-    memcached_close_socket(sock);
+    closesocket(sock);
     return INVALID_SOCKET;
   }
 
   if ((flags & O_NONBLOCK) != O_NONBLOCK) {
     if (fcntl(sock, F_SETFL, flags | O_NONBLOCK) == -1) {
       perror("Failed to set socket to nonblocking mode");
-      memcached_close_socket(sock);
+      closesocket(sock);
       return INVALID_SOCKET;
     }
   }
@@ -183,8 +181,8 @@ static ssize_t timeout_io_op(memcached_socket_t fd, short direction, const char
   } else {
     ret = recv(fd, const_cast<char *>(buf), len, 0);
   }
-
-  if (ret == SOCKET_ERROR && get_socket_errno() == EWOULDBLOCK) {
+  int local_errno = get_socket_errno();
+  if (ret == SOCKET_ERROR && local_errno == EWOULDBLOCK || (EAGAIN != EWOULDBLOCK && local_errno == EAGAIN)) {
     struct pollfd fds;
     memset(&fds, 0, sizeof(struct pollfd));
     fds.events = direction;
@@ -1870,7 +1868,8 @@ int main(int argc, char **argv) {
               "\t\t\tEverything else will start the test\n"
               "\t-T n\tJust run the test named n\n"
               "\t-a\tOnly test the ascii protocol\n"
-              "\t-b\tOnly test the binary protocol\n",
+              "\t-b\tOnly test the binary protocol\n\n"
+              "WARNING: This will FLUSH your server!\n\n",
               argv[0]);
       return EXIT_SUCCESS;
     }
@@ -1881,7 +1880,7 @@ int main(int argc, char **argv) {
     return EXIT_FAILURE;
   }
 
-  #ifdef _WIN32
+#ifdef _WIN32
   WSADATA wsaData;
   if (WSAStartup(MAKEWORD(2, 2), &wsaData)) {
     fprintf(stderr, "Socket Initialization Error.\n");