Work

Signed-off-by: Cole Miller <[email protected]>

src/gateway.c

@@ -718,6 +718,7 @@ static void handle_exec_sql_next(struct gateway *g,
 static void handle_exec_sql_cb(struct exec *exec, int status)
 {
 	tracef("handle exec sql cb status %d", status);
+	fprintf(stderr, "[INFO FOR COLE] handle exec sql cb %p %d finalizing\n", exec->stmt, status);
 	struct gateway *g = exec->data;
 	struct handle *req = g->req;
 

src/leader.c

@@ -192,6 +192,8 @@ void leader__close(struct leader *l)
 		assert(l->inflight == NULL);
 		l->exec->status = SQLITE_ERROR;
 		exec_done(l->exec, 0);
+	} else {
+		fprintf(stderr, "[INFO FOR COLE] leader close nothing happening\n");
 	}
 	rc = sqlite3_close(l->conn);
 	if (rc != SQLITE_OK) {
@@ -457,10 +459,14 @@ static void exec_done(struct exec *req, int asyncness)
 	}
 	sm_fini(&req->sm);
 	req->leader->exec = NULL;
-	if (req->cb != NULL && asyncness == 0) {
-		req->cb(req, status);
+	fprintf(stderr, "[INFO FOR COLE] exec_done clearing %p\n", req->stmt);
+	if (req->cb == NULL) {
+		fprintf(stderr, "[INFO FOR COLE] skip callback for %p because cb is NULL\n", req->stmt);
 	} else if (asyncness != 0) {
 		fprintf(stderr, "[INFO FOR COLE] skip callback for %p because asyncness is %d\n", req->stmt, asyncness);
+	} else {
+		fprintf(stderr, "[INFO FOR COLE] invoke callback for %p\n", req->stmt);
+		req->cb(req, status);
 	}
 }