@@ -37,40 +37,6 @@ impl DocBuilder {
37
37
. get ( 0 ) )
38
38
}
39
39
40
- /// Builds packages from queue
41
- pub fn build_packages_queue ( & mut self ) -> Result < usize > {
42
- let conn = try!( connect_db ( ) ) ;
43
- let mut build_count = 0 ;
44
-
45
- for row in & try!( conn. query ( "SELECT id, name, version
46
- FROM queue
47
- WHERE attempt < 5
48
- ORDER BY priority ASC, attempt ASC, id ASC" ,
49
- & [ ] ) ) {
50
- let id: i32 = row. get ( 0 ) ;
51
- let name: String = row. get ( 1 ) ;
52
- let version: String = row. get ( 2 ) ;
53
-
54
- match self . build_package ( & name[ ..] , & version[ ..] ) {
55
- Ok ( _) => {
56
- build_count += 1 ;
57
- let _ = conn. execute ( "DELETE FROM queue WHERE id = $1" , & [ & id] ) ;
58
- }
59
- Err ( e) => {
60
- // Increase attempt count
61
- let _ = conn. execute ( "UPDATE queue SET attempt = attempt + 1 WHERE id = $1" ,
62
- & [ & id] ) ;
63
- error ! ( "Failed to build package {}-{} from queue: {}" ,
64
- name,
65
- version,
66
- e)
67
- }
68
- }
69
- }
70
-
71
- Ok ( build_count)
72
- }
73
-
74
40
/// Builds the top package from the queue. Returns whether the queue was empty.
75
41
pub fn build_next_queue_package ( & mut self ) -> Result < bool > {
76
42
let conn = try!( connect_db ( ) ) ;
@@ -128,14 +94,4 @@ mod test {
128
94
}
129
95
assert ! ( res. is_ok( ) ) ;
130
96
}
131
-
132
-
133
- #[ test]
134
- #[ ignore]
135
- fn test_build_packages_queue ( ) {
136
- let _ = env_logger:: try_init ( ) ;
137
- let options = DocBuilderOptions :: from_prefix ( PathBuf :: from ( "../cratesfyi-prefix" ) ) ;
138
- let mut docbuilder = DocBuilder :: new ( options) ;
139
- assert ! ( docbuilder. build_packages_queue( ) . is_ok( ) ) ;
140
- }
141
97
}
0 commit comments