Clean up comments

This commit is contained in:
James E. Blair 2019-02-11 07:47:26 -08:00
parent 5a36c4a3eb
commit 12e8291698
1 changed files with 26 additions and 22 deletions

View File

@ -17,6 +17,12 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
/*
* This program reads one line at a time on standard input, expecting
* a specially formatted hostname from Apache's RewriteMap and uses
* that to look up a build URL which it emits on standard output.
*/
#include <config.h>
#include <pthread.h>
#include <boost/optional.hpp>
@ -36,6 +42,7 @@ vector<string> split(const string &in)
return parts;
}
// An LRU cache of hostname->URL mappings.
class Cache {
// A queue of hostname, URL pairs. The head of the queue is always
// the most recently accessed entry, the tail is the least.
@ -64,7 +71,6 @@ public:
auto val = *(location->second);
queue.erase(location->second);
queue.push_front(val);
//cout << "get push " << val.second << endl;
return val.second;
}
@ -78,12 +84,10 @@ public:
if (queue.size() == size) {
auto last = queue.back();
//cout << "put pop " << last.second << endl;
queue.pop_back();
map.erase(last.first);
}
//cout << "put push " << value << endl;
queue.push_front(make_pair(key, value));
map[key] = queue.begin();
}
@ -96,52 +100,52 @@ int main(int, char**)
string hostname;
Cache cache{1024};
while (getline(cin, hostname)) {
// Expected hostname:
// site.75031cad206c4014ad7a3387091d15ab.openstack.preview.opendev.org
// Apache will drop "preview.opendev.org", so our expected input will be:
// site.75031cad206c4014ad7a3387091d15ab.openstack
// site.7c16d914db5a4c4b91cd9a31d119dd48.openstack
// site.688b70499b9a41a08f498ed6e932960c.openstack
// site.dbefc23dcc594577a8bfa4db4f9b0a8f.openstack
// For each request apache receieves, it sends us the HTTP host name
// on standard input. We use that to look up the build URL and emit
// it on standard output. Apache will send us one request at a time
// (protected by an internal mutex) and expect exactly one line of
// output for each.
// Expected input:
// site.926bb0aaddad4bc3853269451e115dcb.openstack.preview.opendev.org
while (getline(cin, hostname)) {
// If we have the value in the cache, return it.
if (auto val = cache.get(hostname)) {
cout << val.value() << endl;
continue;
}
// We use the first three parts of the hostname to look up the
// build url.
auto parts = split(hostname);
if (parts.size() < 3) {
cout << "not enough args" << endl;
cout << "Not enough args" << endl;
continue;
}
auto artifact = parts[0];
auto buildid = parts[1];
auto tenant = parts[2];
/*
cout << artifact << endl
<< buildid << endl
<< tenant << endl;
*/
// 75031cad206c4014ad7a3387091d15ab
try {
// Use the Zuul API to look up the artifact URL.
auto uri = web::uri_builder("/api/tenant/" + tenant + "/build");
uri.append_path(buildid);
auto response = client.request(
web::http::methods::GET, uri.to_string()).get();
// body is a web::json::value
// cout << response.status_code() << endl;
auto body = response.extract_json().get();
//cout << body.serialize() << endl;
// TODO: use artifact
// TODO: use artifact instead of log_url
// body["log_url"].as_string() returns a const std::string&
cout << body["log_url"].as_string() << endl;
cache.put(hostname, body["log_url"].as_string());
} catch (...) {
cout << "error" << endl;
// If anything goes wrong, we still need to return only a single
// string to apache, and recover for the next request, so we
// have a general exception handler here.
cout << "Error" << endl;
}
}
}