diff --git a/src_main/io/pibasetransfer.cpp b/src_main/io/pibasetransfer.cpp index e1518f12..8371171b 100644 --- a/src_main/io/pibasetransfer.cpp +++ b/src_main/io/pibasetransfer.cpp @@ -119,7 +119,10 @@ void PIBaseTransfer::received(PIByteArray data) { int s = pm_string.find('+'), s1 = send_queue; while (s <= (int)h.id && s > 0) { send_queue--; - if (s >= 0) pm_string[s] = '-'; + if (s >= 0) { + pm_string[s] = '-'; + bytes_cur -= packet_size; + } send_up = 0; if (send_queue < 0) { send_queue = 0; @@ -319,7 +322,7 @@ bool PIBaseTransfer::send_process() { send_queue = 0; mutex_send.unlock(); piMSleep(10); - state_string = "sending+"; + state_string = "sending more"; while (rtm.elapsed_s() < timeout_) { //piCoutObj << "recovering..."; mutex_session.lock();