Loading src/lib/kinetic_operation.c +3 −2 Original line number Diff line number Diff line Loading @@ -750,12 +750,13 @@ void KineticOperation_Complete(KineticOperation* operation, KineticStatus status { assert(operation != NULL); // ExecuteOperation should ensure a callback exists (either a user supplied one, or the a default) assert(operation->closure.callback != NULL) ; KineticCompletionData completionData = {.status = status}; KineticCountingSemaphore_Give(operation->connection->outstandingOperations); if(operation->closure.callback != NULL) { operation->closure.callback(&completionData, operation->closure.clientData); } KineticAllocator_FreeOperation(operation); } Loading
src/lib/kinetic_operation.c +3 −2 Original line number Diff line number Diff line Loading @@ -750,12 +750,13 @@ void KineticOperation_Complete(KineticOperation* operation, KineticStatus status { assert(operation != NULL); // ExecuteOperation should ensure a callback exists (either a user supplied one, or the a default) assert(operation->closure.callback != NULL) ; KineticCompletionData completionData = {.status = status}; KineticCountingSemaphore_Give(operation->connection->outstandingOperations); if(operation->closure.callback != NULL) { operation->closure.callback(&completionData, operation->closure.clientData); } KineticAllocator_FreeOperation(operation); }