Mercurial > hg > pnewss

comparison fetchnews.php @ 11:e0807e0b1a67

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Added common.php, updated server synchronization to continue after a connection failure
author Ivo Smits <Ivo@UCIS.nl>
date Sat, 18 Jun 2011 15:59:11 +0200
parents ae0c67d72670
children 7917bd536187
comparison
equal deleted inserted replaced
10:ca88deec5352 11:e0807e0b1a67
28 chdir(__DIR__); 28 chdir(__DIR__);
29 require_once './common.php'; 29 require_once './common.php';
30 30
31 foreach ($db->evalAllAssoc('SELECT * FROM `peers`') as $peer) { 31 foreach ($db->evalAllAssoc('SELECT * FROM `peers`') as $peer) {
32 $socket = stream_socket_client($peer['address']); 32 $socket = stream_socket_client($peer['address']);
33 if ($socket === FALSE) die("Could not connect to peer $peer[address]\n"); 33 if ($socket === FALSE) {
34 print("Could not connect to peer $peer[address]\n");
35 continue;
36 }
34 $line = nntp_readline($socket); 37 $line = nntp_readline($socket);
35 $code = strtok($line, " \t"); 38 $code = strtok($line, " \t");
36 if ($code == 200) { 39 if ($code == 200) {
37 } else if ($code == 201) { 40 } else if ($code == 201) {
38 $peer['post'] = 0; 41 $peer['post'] = 0;