Merged trunk.
[m6w6/libmemcached] / libmemcached / server_list.c
1 /* LibMemcached
2 * Copyright (C) 2006-2010 Brian Aker
3 * All rights reserved.
4 *
5 * Use and distribution licensed under the BSD license. See
6 * the COPYING file in the parent directory for full text.
7 *
8 * Summary:
9 *
10 */
11
12
13 #include "common.h"
14
15 memcached_server_list_st
16 memcached_server_list_append_with_weight(memcached_server_list_st ptr,
17 const char *hostname, in_port_t port,
18 uint32_t weight,
19 memcached_return_t *error)
20 {
21 uint32_t count;
22 memcached_server_list_st new_host_list;
23
24 if (hostname == NULL || error == NULL)
25 return NULL;
26
27 if (! port)
28 port= MEMCACHED_DEFAULT_PORT;
29
30 /* Increment count for hosts */
31 count= 1;
32 if (ptr != NULL)
33 {
34 count+= memcached_server_list_count(ptr);
35 }
36
37 new_host_list= (memcached_server_write_instance_st)realloc(ptr, sizeof(memcached_server_st) * count);
38 if (!new_host_list)
39 {
40 ptr->cached_errno= errno;
41 *error= MEMCACHED_MEMORY_ALLOCATION_FAILURE;
42 return NULL;
43 }
44
45 /* @todo Check return type */
46 memcached_server_create_with(NULL, &new_host_list[count-1], hostname, port, weight, MEMCACHED_CONNECTION_TCP);
47
48 // Handset allocated since
49 new_host_list->options.is_allocated= true;
50
51 /* Backwards compatibility hack */
52 memcached_servers_set_count(new_host_list, count);
53
54 *error= MEMCACHED_SUCCESS;
55 return new_host_list;
56 }
57
58 memcached_server_list_st
59 memcached_server_list_append(memcached_server_list_st ptr,
60 const char *hostname, in_port_t port,
61 memcached_return_t *error)
62 {
63 return memcached_server_list_append_with_weight(ptr, hostname, port, 0, error);
64 }
65
66 uint32_t memcached_server_list_count(const memcached_server_list_st self)
67 {
68 return (self == NULL)
69 ? 0
70 : self->number_of_hosts;
71 }
72
73 memcached_server_st *memcached_server_list(const memcached_st *self)
74 {
75 return self->servers;
76 }
77
78 void memcached_server_list_set(memcached_st *self, memcached_server_st *list)
79 {
80 self->servers= list;
81 }