Welcome to mirror list, hosted at ThFree Co, Russian Federation.

github.com/moses-smt/vowpal_wabbit.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorJohn Langford <jl@hunch.net>2009-10-10 22:26:52 +0400
committerJohn Langford <jl@hunch.net>2009-10-10 22:26:52 +0400
commit98712775df028663ff07a3f73fb4b7869bda556c (patch)
treedf42bb5ce7a391547d7aa9e1b3fc4de21aca641d /sender.cc
parent63c244bb034e1052f15d58986fd7350cce045938 (diff)
Apparently working cluster parallel.
Diffstat (limited to 'sender.cc')
-rw-r--r--sender.cc14
1 files changed, 11 insertions, 3 deletions
diff --git a/sender.cc b/sender.cc
index f9cce040..94a25326 100644
--- a/sender.cc
+++ b/sender.cc
@@ -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);
}