1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
|
/*
Copyright (c) by respective owners including Yahoo!, Microsoft, and
individual contributors. All rights reserved. Released under a BSD
license as described in the file LICENSE.
*/
#include <math.h>
#include <iostream>
#include <fstream>
#include <float.h>
#include <time.h>
#ifdef _WIN32
#include <WinSock2.h>
#else
#include <sys/socket.h>
#include <arpa/inet.h>
#endif
#include <sys/timeb.h>
#include "global_data.h"
#include "parse_example.h"
#include "parse_args.h"
#include "accumulate.h"
#include "best_constant.h"
#include "vw.h"
using namespace std;
int main(int argc, char *argv[])
{
try {
vw *all = parse_args(argc, argv);
struct timeb t_start, t_end;
ftime(&t_start);
if (!all->quiet && !all->bfgs && !all->searchstr)
{
const char * header_fmt = "%-10s %-10s %10s %11s %8s %8s %8s\n";
fprintf(stderr, header_fmt,
"average", "since", "example", "example",
"current", "current", "current");
fprintf(stderr, header_fmt,
"loss", "last", "counter", "weight", "label", "predict", "features");
cerr.precision(5);
}
VW::start_parser(*all);
LEARNER::generic_driver(*all);
VW::end_parser(*all);
ftime(&t_end);
double net_time = (int) (1000.0 * (t_end.time - t_start.time) + (t_end.millitm - t_start.millitm));
if(!all->quiet && all->span_server != "")
cerr<<"Net time taken by process = "<<net_time/(double)(1000)<<" seconds\n";
if(all->span_server != "") {
float loss = (float)all->sd->sum_loss;
all->sd->sum_loss = (double)accumulate_scalar(*all, all->span_server, loss);
float weighted_examples = (float)all->sd->weighted_examples;
all->sd->weighted_examples = (double)accumulate_scalar(*all, all->span_server, weighted_examples);
float weighted_labels = (float)all->sd->weighted_labels;
all->sd->weighted_labels = (double)accumulate_scalar(*all, all->span_server, weighted_labels);
float weighted_unlabeled_examples = (float)all->sd->weighted_unlabeled_examples;
all->sd->weighted_unlabeled_examples = (double)accumulate_scalar(*all, all->span_server, weighted_unlabeled_examples);
float example_number = (float)all->sd->example_number;
all->sd->example_number = (uint64_t)accumulate_scalar(*all, all->span_server, example_number);
float total_features = (float)all->sd->total_features;
all->sd->total_features = (uint64_t)accumulate_scalar(*all, all->span_server, total_features);
}
if (!all->quiet)
{
cerr.precision(6);
cerr << endl << "finished run";
if(all->current_pass == 0)
cerr << endl << "number of examples = " << all->sd->example_number;
else{
cerr << endl << "number of examples per pass = " << all->sd->example_number / all->current_pass;
cerr << endl << "passes used = " << all->current_pass;
}
cerr << endl << "weighted example sum = " << all->sd->weighted_examples;
cerr << endl << "weighted label sum = " << all->sd->weighted_labels;
if(all->holdout_set_off || (all->sd->holdout_best_loss == FLT_MAX))
{
cerr << endl << "average loss = " << all->sd->sum_loss / all->sd->weighted_examples;
}
else
{
cerr << endl << "average loss = " << all->sd->holdout_best_loss << " h";
}
float best_constant; float best_constant_loss;
if (get_best_constant(*all, best_constant, best_constant_loss))
{
cerr << endl << "best constant = " << best_constant;
if (best_constant_loss != FLT_MIN)
cerr << endl << "best constant's loss = " << best_constant_loss;
}
cerr << endl << "total feature number = " << all->sd->total_features;
if (all->sd->queries > 0)
cerr << endl << "total queries = " << all->sd->queries << endl;
cerr << endl;
}
VW::finish(*all);
} catch (exception& e) {
// vw is implemented as a library, so we use 'throw exception()'
// error 'handling' everywhere. To reduce stderr pollution
// everything gets caught here & the error message is printed
// sans the excess exception noise, and core dump.
cerr << "vw: " << e.what() << endl;
exit(1);
}
return 0;
}
|
