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;
state->num_chunks--;
TALLOC_FREE(chunk);
-DEBUG(0,("remove chunk num_chunks[%u]\n", state->num_chunks));
return;
}
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;
}
* 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,
} 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;
}
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;
state->num_chunks--;
TALLOC_FREE(chunk);
-DEBUG(0,("remove chunk num_chunks[%u]\n", state->num_chunks));
return;
}
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;
}
* 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,
} 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;
}
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);