extern memcached_binary_protocol_callback_st interface_v0_impl;
extern memcached_binary_protocol_callback_st interface_v1_impl;
-static SOCKET server_sockets[1024];
+static memcached_socket_t server_sockets[1024];
static int num_server_sockets= 0;
struct connection
* @param which identifying the event that occurred (not used)
* @param arg the connection structure for the client
*/
-static void drive_client(SOCKET fd, short which, void *arg)
+static void drive_client(memcached_socket_t fd, short which, void *arg)
{
(void)which;
struct connection *client= arg;
* @param which identifying the event that occurred (not used)
* @param arg the connection structure for the server
*/
-static void accept_handler(SOCKET fd, short which, void *arg)
+static void accept_handler(memcached_socket_t fd, short which, void *arg)
{
(void)which;
struct connection *server= arg;
/* accept new client */
struct sockaddr_storage addr;
socklen_t addrlen= sizeof(addr);
- SOCKET sock= accept(fd, (struct sockaddr *)&addr, &addrlen);
+ memcached_socket_t sock= accept(fd, (struct sockaddr *)&addr, &addrlen);
if (sock == INVALID_SOCKET)
{
else
perror("getaddrinfo()");
- return 1;
+ return 0;
}
struct linger ling= {0, 0};
for (struct addrinfo *next= ai; next; next= next->ai_next)
{
- SOCKET sock= socket(ai->ai_family, ai->ai_socktype, ai->ai_protocol);
+ memcached_socket_t sock= socket(ai->ai_family, ai->ai_socktype, ai->ai_protocol);
if (sock == INVALID_SOCKET)
{
perror("Failed to create socket");
/**
* Print out the command we are about to execute
*/
-static void pre_execute(const void *cookie __attribute__((unused)),
- protocol_binary_request_header *header __attribute__((unused)))
+static void pre_execute(const void *cookie,
+ protocol_binary_request_header *header)
{
if (verbose)
{
/**
* Print out the command we just executed
*/
-static void post_execute(const void *cookie __attribute__((unused)),
- protocol_binary_request_header *header __attribute__((unused)))
+static void post_execute(const void *cookie,
+ protocol_binary_request_header *header)
{
if (verbose)
{
*
* @param argc number of items in the argument vector
* @param argv argument vector
- * @return 0 on success, 1 otherwise
+ * @return EXIT_SUCCESS on success, 1 otherwise
*/
int main(int argc, char **argv)
{
if (event_base == NULL)
{
fprintf(stderr, "Failed to create an instance of libevent\n");
- return 1;
+ return EXIT_FAILURE;
}
/*
default:
(void)fprintf(stderr, "Usage: %s [-p port] [-v] [-1] [-c #clients] [-P pidfile]\n",
argv[0]);
- return 1;
+ return EXIT_FAILURE;
}
}
if (! initialize_storage())
{
/* Error message already printed */
- return 1;
+ return EXIT_FAILURE;
}
if (! global_options.has_port)
if (num_server_sockets == 0)
{
fprintf(stderr, "I don't have any server sockets\n");
- return 1;
+ return EXIT_FAILURE;
}
/*
if ((protocol_handle= memcached_protocol_create_instance()) == NULL)
{
fprintf(stderr, "Failed to allocate protocol handle\n");
- return 1;
+ return EXIT_FAILURE;
}
socket_userdata_map= calloc((size_t)(maxconns), sizeof(struct connection));
if (socket_userdata_map == NULL)
{
fprintf(stderr, "Failed to allocate room for connections\n");
- return 1;
+ return EXIT_FAILURE;
}
memcached_binary_protocol_set_callbacks(protocol_handle, interface);
event_base_loop(event_base, 0);
/* NOTREACHED */
- return 0;
+ return EXIT_SUCCESS;
}