diff options
author | John Langford <jl@hunch.net> | 2009-10-10 22:26:52 +0400 |
---|---|---|
committer | John Langford <jl@hunch.net> | 2009-10-10 22:26:52 +0400 |
commit | 98712775df028663ff07a3f73fb4b7869bda556c (patch) | |
tree | df42bb5ce7a391547d7aa9e1b3fc4de21aca641d /sender.cc | |
parent | 63c244bb034e1052f15d58986fd7350cce045938 (diff) |
Apparently working cluster parallel.
Diffstat (limited to 'sender.cc')
-rw-r--r-- | sender.cc | 14 |
1 files changed, 11 insertions, 3 deletions
@@ -130,9 +130,16 @@ void* send_thread(void*) else { //close our outputs to signal finishing. for (size_t i = 0; i < d_1; i++) - for (size_t j = 0; j < d_2; j++) - shutdown(bufs[i][j].files[0],SHUT_WR); - + { + for (size_t j = 0; j < d_2; j++) + { + shutdown(bufs[i][j].files[0],SHUT_WR); + free(bufs[i][j].files.begin); + free(bufs[i][j].space.begin); + } + free(bufs[i].begin); + } + free(bufs.begin); return NULL; } } @@ -150,4 +157,5 @@ void setup_send() void destroy_send() { pthread_join(*thread, NULL); + free(thread); } |