[libfibre] fix receiving end of write tasks

samuelsadok · Sep 1, 2021 · 50e3ece · 50e3ece
1 parent 79a1f0b
commit 50e3ece
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/cpp/legacy_object_client.cpp b/cpp/legacy_object_client.cpp
@@ -440,14 +440,14 @@ Cont TheStateMachine::iteration(WriteArgs args) {
                     arg_num_ = args_.size() + start_arg;
                     status_ = kFibreInternalError;
                     changed_state = true;
-                    return Cont1{kFibreOk, args.buf.begin()};
+                    return Cont1{kFibreInternalError, args.buf.begin()};
                 }
 
             } else {
                 arg_num_ = args_.size() + start_arg;
                 status_ = kFibreInternalError;
                 changed_state = true;
-                return Cont1{kFibreOk, args.buf.begin()};
+                return Cont1{kFibreInternalError, args.buf.begin()};
             }
         }
         return Cont1{kFibreOk, args.buf.begin()};
@@ -469,7 +469,7 @@ Cont TheStateMachine::iteration(WriteArgs args) {
                     arg_num_ = args_.size() + start_arg;
                     status_ = kFibreInternalError;
                     changed_state = true;
-                    return Cont1{kFibreOk, args.buf.begin()};
+                    return Cont1{kFibreInternalError, args.buf.begin()};
                 }
                 chunks_[0] = Chunk{0, buf};
                 chunks_[1] = Chunk::frame_boundary(0);
@@ -480,7 +480,7 @@ Cont TheStateMachine::iteration(WriteArgs args) {
                 arg_num_ = args_.size() + start_arg;
                 status_ = kFibreInternalError;
                 changed_state = true;
-                return Cont1{kFibreOk, args.buf.begin()};
+                return Cont1{kFibreInternalError, args.buf.begin()};
             }
         }
         return Cont1{kFibreOk, args.buf.begin()};

diff --git a/cpp/libfibre.cpp b/cpp/libfibre.cpp
@@ -335,7 +335,7 @@ void LibFibreCtx::handle_tasks(LibFibreTask* tasks, size_t n_tasks) {
                 LibFibreCall* call = it->second;
 
                 WriteResult result = call->call->write({
-                    {tasks[i].write.b_begin, from_c(tasks[i].write.c_begin), from_c(tasks[i].write.c_end), tasks[0].write.elevation},
+                    {tasks[i].write.b_begin, from_c(tasks[i].write.c_begin), from_c(tasks[i].write.c_end), tasks[i].write.elevation},
                     from_c(tasks[i].write.status)});
 
                 if (result.is_busy()) {