← Back to branch summary

~clint-fewbar/ubuntu/precise/gearmand/drop-unneeded-patches

« back to all changes in this revision

Viewing changes to bin/gearman.c

  • Committer: Bazaar Package Importer
  • Author(s): Monty Taylor
  • Date: 2009-09-28 21:43:31 UTC
  • mto: (1.2.3 upstream) (6.1.1 sid)
  • mto: This revision was merged to the branch mainline in revision 5.
  • Revision ID: james.westby@ubuntu.com-20090928214331-9bku0d3v1b1ypgp4
Import upstream version 0.10

Show diffs side-by-side

added added

removed removed

Lines of Context:
bin/gearman.c
48
48
  bool prefix;
49
49
  bool background;
50
50
  gearman_job_priority_t priority;
 
51
  int timeout;
51
52
  char **argv;
52
53
  gearman_task_st *task;
53
54
  char return_value;
112
113
 
113
114
  memset(&args, 0, sizeof(gearman_args_st));
114
115
  args.priority= GEARMAN_JOB_PRIORITY_NORMAL;
 
116
  args.timeout= -1;
115
117
 
116
118
  /* Allocate the maximum number of possible functions. */
117
119
  args.function= malloc(sizeof(char *) * (size_t)argc);
118
120
  if (args.function == NULL)
119
121
    GEARMAN_ERROR("malloc:%d", errno)
120
122
 
121
 
  while ((c = getopt(argc, argv, "bc:f:h:HILnNp:Psu:w")) != -1)
 
123
  while ((c = getopt(argc, argv, "bc:f:h:HILnNp:Pst:u:w")) != -1)
122
124
  {
123
125
    switch(c)
124
126
    {
168
170
      args.suppress_input= true;
169
171
      break;
170
172
 
 
173
    case 't':
 
174
      args.timeout= atoi(optarg);
 
175
      break;
 
176
 
171
177
    case 'u':
172
178
      args.unique= optarg;
173
179
      break;
208
214
  if (gearman_client_create(&client) == NULL)
209
215
    GEARMAN_ERROR("Memory allocation failure on client creation")
210
216
 
 
217
  if (args->timeout >= 0)
 
218
    gearman_client_set_timeout(&client, args->timeout);
 
219
 
211
220
  ret= gearman_client_add_server(&client, args->host, args->port);
212
221
  if (ret != GEARMAN_SUCCESS)
213
222
    GEARMAN_ERROR("gearman_client_add_server:%s", gearman_client_error(&client))
349
358
{
350
359
  gearman_args_st *args;
351
360
 
352
 
  args= gearman_task_fn_arg(task);
 
361
  args= gearman_task_context(task);
353
362
  if (args->prefix)
354
363
  {
355
 
    fprintf(stdout, "%s: ", gearman_task_function(task));
 
364
    fprintf(stdout, "%s: ", gearman_task_function_name(task));
356
365
    fflush(stdout);
357
366
  }
358
367
 
366
375
{
367
376
  gearman_args_st *args;
368
377
 
369
 
  args= gearman_task_fn_arg(task);
 
378
  args= gearman_task_context(task);
370
379
  if (args->prefix)
371
380
  {
372
 
    fprintf(stderr, "%s: ", gearman_task_function(task));
 
381
    fprintf(stderr, "%s: ", gearman_task_function_name(task));
373
382
    fflush(stderr);
374
383
  }
375
384
 
383
392
{
384
393
  gearman_args_st *args;
385
394
 
386
 
  args= gearman_task_fn_arg(task);
 
395
  args= gearman_task_context(task);
387
396
  if (args->prefix)
388
 
    printf("%s: ", gearman_task_function(task));
 
397
    printf("%s: ", gearman_task_function_name(task));
389
398
 
390
399
  printf("%u%% Complete\n", (gearman_task_numerator(task) * 100) /
391
400
         gearman_task_denominator(task));
397
406
{
398
407
  gearman_args_st *args;
399
408
 
400
 
  args= gearman_task_fn_arg(task);
 
409
  args= gearman_task_context(task);
401
410
  if (args->prefix)
402
 
    fprintf(stderr, "%s: ", gearman_task_function(task));
 
411
    fprintf(stderr, "%s: ", gearman_task_function_name(task));
403
412
 
404
413
  fprintf(stderr, "Job failed\n");
405
414
 
416
425
  if (gearman_worker_create(&worker) == NULL)
417
426
    GEARMAN_ERROR("Memory allocation failure on client creation")
418
427
 
 
428
  if (args->timeout >= 0)
 
429
    gearman_worker_set_timeout(&worker, args->timeout);
 
430
 
419
431
  ret= gearman_worker_add_server(&worker, args->host, args->port);
420
432
  if (ret != GEARMAN_SUCCESS)
421
433
    GEARMAN_ERROR("gearman_worker_add_server:%s", gearman_worker_error(&worker))
527
539
          break;
528
540
 
529
541
        if (args->strip_newline)
530
 
          *ret_ptr= gearman_job_data(job, result, strlen(result) - 1);
 
542
          *ret_ptr= gearman_job_send_data(job, result, strlen(result) - 1);
531
543
        else
532
 
          *ret_ptr= gearman_job_data(job, result, strlen(result));
 
544
          *ret_ptr= gearman_job_send_data(job, result, strlen(result));
533
545
 
534
546
        if (*ret_ptr != GEARMAN_SUCCESS)
535
547
          break;
552
564
    {
553
565
      if (result != NULL)
554
566
      {
555
 
        *ret_ptr= gearman_job_data(job, result, *result_size);
 
567
        *ret_ptr= gearman_job_send_data(job, result, *result_size);
556
568
        if (*ret_ptr != GEARMAN_SUCCESS)
557
569
          return NULL;
558
570
      }
605
617
  printf("\t-h <host>     - Job server host\n");
606
618
  printf("\t-H            - Print this help menu\n");
607
619
  printf("\t-p <port>     - Job server port\n");
 
620
  printf("\t-t <timeout>  - Timeout in milliseconds\n");
608
621
 
609
622
  printf("\nClient options:\n");
610
623
  printf("\t-b            - Run jobs in the background\n");