Commit d7c27c627c1f9c035d444345c45907e3787b042b
1 parent
9026a8db
quit the message queue at the end of operations in ftp download
Showing
1 changed file
with
4 additions
and
2 deletions
Show diff stats
calexium_lib/net_services_protocols/ftp_client.anubis
| @@ -139,11 +139,13 @@ public define Maybe(One) | @@ -139,11 +139,13 @@ public define Maybe(One) | ||
| 139 | { | 139 | { |
| 140 | error(_) then println("can't connect to ftp server"); failure, | 140 | error(_) then println("can't connect to ftp server"); failure, |
| 141 | ok(conn) then | 141 | ok(conn) then |
| 142 | - with queue = create_MessageQueue, | 142 | + with queue = create_MessageQueue("ftp_get_file"), |
| 143 | message_transceiver(conn, queue); | 143 | message_transceiver(conn, queue); |
| 144 | if request_for_service(queue) then | 144 | if request_for_service(queue) then |
| 145 | - get_file(queue, remote_file, local_file) | 145 | + with result = get_file(queue, remote_file, local_file), |
| 146 | + queue.quit(unique);result | ||
| 146 | else | 147 | else |
| 148 | + queue.quit(unique); | ||
| 147 | println("Service not found");failure | 149 | println("Service not found");failure |
| 148 | } | 150 | } |
| 149 | else | 151 | else |