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-08-23 00:07:02 +0400
committerJohn Langford <jl@hunch.net>2009-08-23 00:07:02 +0400
commit848527b1e758755879d27deebdb45ef4251acf1e (patch)
tree725eaa75b4a3daad2a7755648e9a2beaa1d6f5b7 /cache.cc
parentc29c0673e41581989bd515014a0581c7fb2018c7 (diff)
Made binary mode sending work.
Diffstat (limited to 'cache.cc')
-rw-r--r--cache.cc14
1 files changed, 7 insertions, 7 deletions
diff --git a/cache.cc b/cache.cc
index 8c35d014..3201d59c 100644
--- a/cache.cc
+++ b/cache.cc
@@ -22,21 +22,21 @@ int read_cached_features(parser* p, example* ae)
{
size_t mask = p->source->global->mask;
- size_t total = p->lp->read_cached_label(ae->ld, p->source->cache);
+ size_t total = p->lp->read_cached_label(ae->ld, p->source->binary);
if (total == 0)
return 0;
char* c;
size_t num_indices = 0;
- if (buf_read(p->source->cache, c, int_size) < int_size)
+ if (buf_read(p->source->binary, c, int_size) < int_size)
return 0;
c = run_len_decode(c, num_indices);
- p->source->cache.set(c);
+ p->source->binary.set(c);
for (;num_indices > 0; num_indices--)
{
size_t temp;
- if((temp = buf_read(p->source->cache,c,int_size + sizeof(size_t))) < char_size + sizeof(size_t)) {
+ if((temp = buf_read(p->source->binary,c,int_size + sizeof(size_t))) < char_size + sizeof(size_t)) {
cerr << "truncated example! " << temp << " " << char_size +sizeof(size_t) << endl;
return 0;
}
@@ -47,9 +47,9 @@ int read_cached_features(parser* p, example* ae)
v_array<feature>* ours = ae->atomics+index;
size_t storage = *(size_t *)c;
c += sizeof(size_t);
- p->source->cache.set(c);
+ p->source->binary.set(c);
total += storage;
- if (buf_read(p->source->cache,c,storage) < storage) {
+ if (buf_read(p->source->binary,c,storage) < storage) {
cerr << "truncated example!" << endl;
return 0;
}
@@ -75,7 +75,7 @@ int read_cached_features(parser* p, example* ae)
f.weight_index = f.weight_index & mask;
push(*ours, f);
}
- p->source->cache.set(c);
+ p->source->binary.set(c);
}
return total;