DEBUG cli_push/cli_pull

diff --git a/source3/libsmb/clireadwrite.c b/source3/libsmb/clireadwrite.c
index adcd98bb0d9b6a2070405943568aa452a44936fe..19986260d466610aedebcdae89ff82b496275c72 100644 (file)
--- a/source3/libsmb/clireadwrite.c
+++ b/source3/libsmb/clireadwrite.c
@@ -440,7 +440,7 @@ static void cli_pull_setup_chunks(struct tevent_req *req)
                DLIST_ADD_END(state->chunks, chunk, NULL);
                state->num_chunks++;
                state->num_waiting++;
-
+DEBUG(0,("add chunk num_chunks[%u]\n", state->num_chunks));
                cli_pull_chunk_ship(chunk);
                if (!tevent_req_is_in_progress(req)) {
                        return;
@@ -511,6 +511,7 @@ static void cli_pull_chunk_ship(struct cli_pull_chunk *chunk)
                state->num_chunks--;
                TALLOC_FREE(chunk);
 
+DEBUG(0,("remove chunk num_chunks[%u]\n", state->num_chunks));
                return;
        }
 
@@ -528,6 +529,7 @@ static void cli_pull_chunk_ship(struct cli_pull_chunk *chunk)
 
                ok = smb2cli_conn_req_possible(state->cli->conn, &max_size);
                if (!ok) {
+DEBUG(0,("still waiting smb2 chunk num_chunks[%u] num_waiting[%u]\n", state->num_chunks, state->num_waiting));
                        return;
                }
 
@@ -535,6 +537,8 @@ static void cli_pull_chunk_ship(struct cli_pull_chunk *chunk)
                 * downgrade depending on the available credits
                 */
                size = MIN(max_size, size);
+if (size == max_size) DEBUG(0,("downgrade to max_size[%u] num_chunks[%u] num_waiting[%u]\n",
+                       (unsigned)max_size, state->num_chunks, state->num_waiting));
 
                chunk->subreq = cli_smb2_read_send(chunk,
                                                   state->ev,
@@ -548,6 +552,7 @@ static void cli_pull_chunk_ship(struct cli_pull_chunk *chunk)
        } else {
                ok = smb1cli_conn_req_possible(state->cli->conn);
                if (!ok) {
+DEBUG(0,("still waiting smb1 chunk num_chunks[%u] num_waiting[%u]\n", state->num_chunks, state->num_waiting));
                        return;
                }
 
@@ -1256,6 +1261,7 @@ static void cli_push_setup_chunks(struct tevent_req *req)
                state->num_chunks++;
                state->num_waiting++;
 
+DEBUG(0,("add chunk num_chunks[%u]\n", state->num_chunks));
                cli_push_chunk_ship(chunk);
                if (!tevent_req_is_in_progress(req)) {
                        return;
@@ -1290,6 +1296,7 @@ static void cli_push_chunk_ship(struct cli_push_chunk *chunk)
                state->num_chunks--;
                TALLOC_FREE(chunk);
 
+DEBUG(0,("remove chunk num_chunks[%u]\n", state->num_chunks));
                return;
        }
 
@@ -1308,6 +1315,7 @@ static void cli_push_chunk_ship(struct cli_push_chunk *chunk)
 
                ok = smb2cli_conn_req_possible(state->cli->conn, &max_size);
                if (!ok) {
+DEBUG(0,("still waiting smb2 chunk num_chunks[%u] num_waiting[%u]\n", state->num_chunks, state->num_waiting));
                        return;
                }
 
@@ -1315,6 +1323,8 @@ static void cli_push_chunk_ship(struct cli_push_chunk *chunk)
                 * downgrade depending on the available credits
                 */
                size = MIN(max_size, size);
+if (size == max_size) DEBUG(0,("downgrade to max_size[%u] num_chunks[%u] num_waiting[%u]\n",
+                       (unsigned)max_size, state->num_chunks, state->num_waiting));
 
                chunk->subreq = cli_smb2_write_send(chunk,
                                                    state->ev,
@@ -1330,6 +1340,7 @@ static void cli_push_chunk_ship(struct cli_push_chunk *chunk)
        } else {
                ok = smb1cli_conn_req_possible(state->cli->conn);
                if (!ok) {
+DEBUG(0,("still waiting smb1 chunk num_chunks[%u] num_waiting[%u]\n", state->num_chunks, state->num_waiting));
                        return;
                }
 
@@ -1394,6 +1405,7 @@ static void cli_push_chunk_done(struct tevent_req *subreq)
                chunk->done = true;
        } else {
                state->num_waiting++;
+DEBUG(0,("short chunk num_chunks[%u] num_waiting[%u]\n", state->num_chunks, state->num_waiting));
        }
 
        cli_push_setup_chunks(req);