1 /* vim:expandtab:shiftwidth=2:tabstop=2:smarttab:
2 *
3 * Gearmand client and server library.
4 *
5 * Copyright (C) 2011 Data Differential, http://datadifferential.com/
6 * Copyright (C) 2008 Brian Aker, Eric Day
7 * All rights reserved.
8 *
9 * Redistribution and use in source and binary forms, with or without
10 * modification, are permitted provided that the following conditions are
11 * met:
12 *
13 * * Redistributions of source code must retain the above copyright
14 * notice, this list of conditions and the following disclaimer.
15 *
16 * * Redistributions in binary form must reproduce the above
17 * copyright notice, this list of conditions and the following disclaimer
18 * in the documentation and/or other materials provided with the
19 * distribution.
20 *
21 * * The names of its contributors may not be used to endorse or
22 * promote products derived from this software without specific prior
23 * written permission.
24 *
25 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
26 * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
27 * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
28 * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
29 * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
30 * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
31 * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
32 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
33 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
34 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
35 * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
36 *
37 */
38
39 #include "gear_config.h"
40 #include <libgearman/common.h>
41 #include <cstdlib>
42
gearman_parse_servers(const char * servers,gearman_parse_server_fn * function,void * context)43 gearman_return_t gearman_parse_servers(const char *servers,
44 gearman_parse_server_fn *function,
45 void *context)
46 {
47 const char *ptr= servers;
48 char host[GEARMAN_NI_MAXHOST];
49 char port[GEARMAN_NI_MAXSERV];
50
51 if (ptr == NULL)
52 {
53 return (*function)(NULL, 0, context);
54 }
55
56 while (1)
57 {
58 size_t x= 0;
59
60 while (*ptr != 0 && *ptr != ',' && *ptr != ':')
61 {
62 if (x < (NI_MAXHOST - 1))
63 {
64 host[x++]= *ptr;
65 }
66
67 ptr++;
68 }
69
70 host[x]= 0;
71
72 if (*ptr == ':')
73 {
74 ptr++;
75 x= 0;
76
77 while (*ptr != 0 && *ptr != ',')
78 {
79 if (x < (NI_MAXSERV - 1))
80 port[x++]= *ptr;
81
82 ptr++;
83 }
84
85 port[x]= 0;
86 }
87 else
88 port[0]= 0;
89
90 gearman_return_t ret= (*function)(host, static_cast<in_port_t>(atoi(port)), context);
91 if (gearman_failed(ret))
92 {
93 return ret;
94 }
95
96 if (*ptr == 0)
97 break;
98
99 ptr++;
100 }
101
102 return GEARMAN_SUCCESS;
103 }
104