$time)) {
// file is non-existant or expired, must redo, or wait for someone else to
if (!file_exists($filename)) {
@touch($filename);
}
// open file. If this does not work, wait one second and try cycle again
//if ($rfh=@fopen($filename,'r')) { Lutz was hast Du nur hier gebaut?
if ($rfh=@fopen($filename,'w')) {
// obtain a blocking write lock, else wait 1 second and try again
if(flock($rfh,2)) {
// open file for writing. if this does not work, something is broken.
if (!$wfh = @fopen($filename,'w')) {
return "Unable to open cache file for writing after obtaining lock.";
}
// have successful locks and opens now
$return=cache_get_new_data($back_url,$entries);
fwrite($wfh,$return); //write the file
fclose($wfh); //close the file
flock($rfh,3); //release lock
fclose($rfh); //close the lock
return $return;
} else { // unable to obtain flock
fclose($rfh); //close the lock
sleep(1);
unlink($filename);
}
} else { // unable to open for reading
sleep(1);
unlink($filename);
}
}
// file is now good, use it for return value
if (!$rfh = fopen($filename,'r')) { //bad filename
return cache_get_new_data($back_url,$entries);
}
while(!flock($rfh,1+4) && ($counter < 30)) { // obtained non blocking shared lock
usleep(250000); // wait 0.25 seconds for the lock to become available
$counter++;
}
$result = "";
$i = 0;
while (!feof ($rfh) && $i < $entries) {
$result .= fgets($rfh, 4096);
$i++;
}
flock($rfh,3); // cancel read lock
fclose($rfh);
return $result;
}
function cache_get_new_data($back_url,$entries) {
$rdf = parse_url($back_url);
$fp = fsockopen($rdf['host'], 80, $errno, $errstr, 15);
if (!$fp) {
rssfail("Can't connect to host.");
} else {
// print("