Tema5

src/aws.c

@@ -128,7 +128,10 @@ void connection_start_async_io(struct connection *conn)
 	io_prep_pread(&conn->iocb, conn->fd, conn->send_buffer, MIN(BUFSIZ, conn->file_size), conn->file_pos);
 	conn->piocb[0] = &conn->iocb;
 	io_set_eventfd(&conn->iocb, conn->eventfd);
-	io_setup(1, &conn->ctx);
+	ret = io_setup(1, &conn->ctx);
+	DIE(ret < 0, "io_setup");
+	ret = io_submit(conn->ctx, 1, conn->piocb);
+	DIE(ret < 0, "io_submit");
 }
 
 void connection_remove(struct connection *conn)
@@ -301,8 +304,8 @@ int connection_send_dynamic(struct connection *conn)
 	// din nou ceea ce a fost citit pana ce el s-a intors in functia connection_send_dynamic
 	if (conn->state != STATE_ASYNC_ONGOING) {
 		int ret = connection_open_file(conn);
-
 		DIE(ret < 0, "connection_open_file");
+
 		connection_start_async_io(conn);
 		return 0;
 	}
@@ -405,6 +408,8 @@ int main(void)
 {
 	int rc;
 
+	/* TODO: Initialize asynchronous operations. */
+
 	/* TODO: Initialize multiplexing. */
 	epollfd = w_epoll_create();
 	DIE(epollfd < 0, "w_epoll_create");