Merge lp:~brianaker/gearmand/GEARMAN_TASK_STATE_EXCEPTION-state-fix into lp:gearmand

Proposed by Brian Aker
Status: Merged
Merged at revision: 778
Proposed branch: lp:~brianaker/gearmand/GEARMAN_TASK_STATE_EXCEPTION-state-fix
Merge into: lp:gearmand
Diff against target: 24 lines (+3/-4)
1 file modified
libgearman/run.cc (+3/-4)
To merge this branch: bzr merge lp:~brianaker/gearmand/GEARMAN_TASK_STATE_EXCEPTION-state-fix
Reviewer Review Type Date Requested Status
Tangent Trunk Pending
Review via email: mp+169609@code.launchpad.net
To post a comment you must log in.

Preview Diff

[H/L] Next/Prev Comment, [J/K] Next/Prev File, [N/P] Next/Prev Hunk
=== modified file 'libgearman/run.cc'
--- libgearman/run.cc 2013-06-11 01:05:38 +0000
+++ libgearman/run.cc 2013-06-15 09:06:28 +0000
@@ -354,17 +354,16 @@
354 }354 }
355 else if (task->recv->command == GEARMAN_COMMAND_WORK_EXCEPTION)355 else if (task->recv->command == GEARMAN_COMMAND_WORK_EXCEPTION)
356 {356 {
357 case GEARMAN_TASK_STATE_EXCEPTION:
358 task->options.is_known= false;357 task->options.is_known= false;
359 task->options.is_running= false;358 task->options.is_running= false;
360 task->free_result();
361 task->result_rc= GEARMAN_WORK_EXCEPTION;
362
363 if (task->recv->argc == 1 and task->recv->data_size)359 if (task->recv->argc == 1 and task->recv->data_size)
364 {360 {
365 task->exception.store((const char*)(task->recv->data), task->recv->data_size);361 task->exception.store((const char*)(task->recv->data), task->recv->data_size);
366 }362 }
363 task->free_result();
364 task->result_rc= GEARMAN_WORK_EXCEPTION;
367365
366 case GEARMAN_TASK_STATE_EXCEPTION:
368 if (task->func.exception_fn)367 if (task->func.exception_fn)
369 {368 {
370 gearman_return_t ret= task->func.exception_fn(task->shell());369 gearman_return_t ret= task->func.exception_fn(task->shell());

Subscribers

People subscribed via source and target branches

to all changes: