| | @@ -162,34 +162,34 @@ |
| 162 | 162 | Bag seen; |
| 163 | 163 | PQueue queue; |
| 164 | 164 | Stmt ins; |
| 165 | 165 | Stmt q; |
| 166 | 166 | bag_init(&seen); |
| 167 | | - pqueue_init(&queue); |
| 167 | + pqueuex_init(&queue); |
| 168 | 168 | bag_insert(&seen, rid); |
| 169 | | - pqueue_insert(&queue, rid, 0.0, 0); |
| 169 | + pqueuex_insert(&queue, rid, 0.0, 0); |
| 170 | 170 | db_prepare(&ins, "INSERT OR IGNORE INTO ok VALUES(:rid)"); |
| 171 | 171 | db_prepare(&q, |
| 172 | 172 | "SELECT a.pid, b.mtime FROM plink a LEFT JOIN plink b ON b.cid=a.pid" |
| 173 | 173 | " WHERE a.cid=:rid" |
| 174 | 174 | ); |
| 175 | | - while( (N--)>0 && (rid = pqueue_extract(&queue, 0))!=0 ){ |
| 175 | + while( (N--)>0 && (rid = pqueuex_extract(&queue, 0))!=0 ){ |
| 176 | 176 | db_bind_int(&ins, ":rid", rid); |
| 177 | 177 | db_step(&ins); |
| 178 | 178 | db_reset(&ins); |
| 179 | 179 | db_bind_int(&q, ":rid", rid); |
| 180 | 180 | while( db_step(&q)==SQLITE_ROW ){ |
| 181 | 181 | int pid = db_column_int(&q, 0); |
| 182 | 182 | double mtime = db_column_double(&q, 1); |
| 183 | 183 | if( bag_insert(&seen, pid) ){ |
| 184 | | - pqueue_insert(&queue, pid, -mtime, 0); |
| 184 | + pqueuex_insert(&queue, pid, -mtime, 0); |
| 185 | 185 | } |
| 186 | 186 | } |
| 187 | 187 | db_reset(&q); |
| 188 | 188 | } |
| 189 | 189 | bag_clear(&seen); |
| 190 | | - pqueue_clear(&queue); |
| 190 | + pqueuex_clear(&queue); |
| 191 | 191 | db_finalize(&ins); |
| 192 | 192 | db_finalize(&q); |
| 193 | 193 | } |
| 194 | 194 | |
| 195 | 195 | /* |
| | @@ -237,31 +237,31 @@ |
| 237 | 237 | PQueue queue; |
| 238 | 238 | Stmt ins; |
| 239 | 239 | Stmt q; |
| 240 | 240 | |
| 241 | 241 | bag_init(&seen); |
| 242 | | - pqueue_init(&queue); |
| 242 | + pqueuex_init(&queue); |
| 243 | 243 | bag_insert(&seen, rid); |
| 244 | | - pqueue_insert(&queue, rid, 0.0, 0); |
| 244 | + pqueuex_insert(&queue, rid, 0.0, 0); |
| 245 | 245 | db_prepare(&ins, "INSERT OR IGNORE INTO ok VALUES(:rid)"); |
| 246 | 246 | db_prepare(&q, "SELECT cid, mtime FROM plink WHERE pid=:rid"); |
| 247 | | - while( (N--)>0 && (rid = pqueue_extract(&queue, 0))!=0 ){ |
| 247 | + while( (N--)>0 && (rid = pqueuex_extract(&queue, 0))!=0 ){ |
| 248 | 248 | db_bind_int(&ins, ":rid", rid); |
| 249 | 249 | db_step(&ins); |
| 250 | 250 | db_reset(&ins); |
| 251 | 251 | db_bind_int(&q, ":rid", rid); |
| 252 | 252 | while( db_step(&q)==SQLITE_ROW ){ |
| 253 | 253 | int pid = db_column_int(&q, 0); |
| 254 | 254 | double mtime = db_column_double(&q, 1); |
| 255 | 255 | if( bag_insert(&seen, pid) ){ |
| 256 | | - pqueue_insert(&queue, pid, mtime, 0); |
| 256 | + pqueuex_insert(&queue, pid, mtime, 0); |
| 257 | 257 | } |
| 258 | 258 | } |
| 259 | 259 | db_reset(&q); |
| 260 | 260 | } |
| 261 | 261 | bag_clear(&seen); |
| 262 | | - pqueue_clear(&queue); |
| 262 | + pqueuex_clear(&queue); |
| 263 | 263 | db_finalize(&ins); |
| 264 | 264 | db_finalize(&q); |
| 265 | 265 | } |
| 266 | 266 | |
| 267 | 267 | /* |
| 268 | 268 | |