← Back to branch summary

~piotr-sikora/libmemcached/fix-tests-on-openbsd

« back to all changes in this revision

Viewing changes to libmemcached/server.c

Merge in all of build.

Show diffs side-by-side

added added

removed removed

Lines of Context:
libmemcached/server.c
168
168
                                           void *context,
169
169
                                           uint32_t number_of_callbacks)
170
170
{
 
171
  memcached_return_t rc;
 
172
  if ((rc= initialize_const_query(ptr)) != MEMCACHED_SUCCESS)
 
173
  {
 
174
    return rc;
 
175
  }
 
176
 
171
177
  for (uint32_t x= 0; x < memcached_server_count(ptr); x++)
172
178
  {
173
179
    memcached_server_instance_st instance=
215
221
  uint32_t server_key;
216
222
  memcached_server_instance_st instance;
217
223
 
218
 
  *error= memcached_validate_key_length(key_length,
219
 
                                        ptr->flags.binary_protocol);
220
 
  unlikely (*error != MEMCACHED_SUCCESS)
 
224
  memcached_return_t rc;
 
225
  if ((rc= initialize_const_query(ptr)) != MEMCACHED_SUCCESS)
 
226
  {
 
227
    if (error)
 
228
      *error= rc;
 
229
 
221
230
    return NULL;
 
231
  }
222
232
 
223
 
  unlikely (memcached_server_count(ptr) == 0)
 
233
  if ((rc= memcached_validate_key_length(key_length, ptr->flags.binary_protocol)) != MEMCACHED_SUCCESS)
224
234
  {
225
 
    *error= MEMCACHED_NO_SERVERS;
 
235
    if (error)
 
236
      *error= rc;
 
237
 
226
238
    return NULL;
227
239
  }
228
240
 
239
251
 
240
252
}
241
253
 
242
 
void memcached_server_error_reset(memcached_server_st *ptr)
 
254
void memcached_server_error_reset(memcached_server_st *self)
243
255
{
244
 
  ptr->cached_server_error[0]= 0;
 
256
  WATCHPOINT_ASSERT(self);
 
257
  if (! self)
 
258
    return;
 
259
 
 
260
  self->cached_server_error[0]= 0;
245
261
}
246
262
 
247
 
memcached_server_instance_st memcached_server_get_last_disconnect(const memcached_st *ptr)
 
263
memcached_server_instance_st memcached_server_get_last_disconnect(const memcached_st *self)
248
264
{
249
 
  return ptr->last_disconnected_server;
 
265
  WATCHPOINT_ASSERT(self);
 
266
  if (! self)
 
267
    return 0;
 
268
 
 
269
  return self->last_disconnected_server;
250
270
}
251
271
 
252
272
void memcached_server_list_free(memcached_server_list_st self)
276
296
 
277
297
uint32_t memcached_servers_set_count(memcached_server_st *servers, uint32_t count)
278
298
{
 
299
  WATCHPOINT_ASSERT(servers);
 
300
  if (! servers)
 
301
    return 0;
 
302
 
279
303
  return servers->number_of_hosts= count;
280
304
}
281
305
 
282
306
uint32_t memcached_server_count(const memcached_st *self)
283
307
{
 
308
  WATCHPOINT_ASSERT(self);
 
309
  if (! self)
 
310
    return 0;
 
311
 
284
312
  return self->number_of_hosts;
285
313
}
286
314
 
287
315
const char *memcached_server_name(memcached_server_instance_st self)
288
316
{
 
317
  WATCHPOINT_ASSERT(self);
 
318
  if (! self)
 
319
    return NULL;
 
320
 
289
321
  return self->hostname;
290
322
}
291
323
 
292
324
in_port_t memcached_server_port(memcached_server_instance_st self)
293
325
{
 
326
  WATCHPOINT_ASSERT(self);
 
327
  if (! self)
 
328
    return 0;
 
329
 
294
330
  return self->port;
295
331
}
296
332
 
297
333
uint32_t memcached_server_response_count(memcached_server_instance_st self)
298
334
{
 
335
  WATCHPOINT_ASSERT(self);
 
336
  if (! self)
 
337
    return 0;
 
338
 
299
339
  return self->cursor_active;
300
340
}
301
341