Page MenuHomePhabricator
Files F15396533

D11073.id26586.diff
No OneTemporary
Actions

D11073.id26586.diff
View Options

diff --git a/support/aphlict/server/aphlict_server.js b/support/aphlict/server/aphlict_server.js
--- a/support/aphlict/server/aphlict_server.js
+++ b/support/aphlict/server/aphlict_server.js
@@ -12,17 +12,6 @@
JX.require('lib/AphlictListenerList', __dirname);
JX.require('lib/AphlictLog', __dirname);
-var debug = new JX.AphlictLog()
- .addConsole(console);
-
-var clients = new JX.AphlictListenerList();
-
-var config = parse_command_line_arguments(process.argv);
-
-if (config.logfile) {
- debug.addLogfile(config.logfile);
-}
-
function parse_command_line_arguments(argv) {
var config = {
port: 22280,
@@ -50,6 +39,17 @@
return config;
}
+var debug = new JX.AphlictLog()
+ .addConsole(console);
+
+var clients = new JX.AphlictListenerList();
+
+var config = parse_command_line_arguments(process.argv);
+
+if (config.logfile) {
+ debug.addLogfile(config.logfile);
+}
+
if (process.getuid() !== 0) {
console.log(
"ERROR: " +
@@ -161,6 +161,26 @@
var messages_in = 0;
var start_time = new Date().getTime();
+function transmit(msg) {
+ var listeners = clients.getListeners().filter(function(client) {
+ return client.isSubscribedToAny(msg.subscribers);
+ });
+
+ for (var i = 0; i < listeners.length; i++) {
+ var listener = listeners[i];
+
+ try {
+ listener.writeMessage(msg);
+
+ ++messages_out;
+ debug.log('<%s> Wrote Message', listener.getDescription());
+ } catch (error) {
+ clients.removeListener(listener);
+ debug.log('<%s> Write Error: %s', listener.getDescription(), error);
+ }
+ }
+}
+
http.createServer(function(request, response) {
// Publishing a notification.
if (request.url == '/') {
@@ -233,26 +253,6 @@
}
}).listen(config.admin, config.host);
-function transmit(msg) {
- var listeners = clients.getListeners().filter(function(client) {
- return client.isSubscribedToAny(msg.subscribers);
- });
-
- for (var i = 0; i < listeners.length; i++) {
- var listener = listeners[i];
-
- try {
- listener.writeMessage(msg);
-
- ++messages_out;
- debug.log('<%s> Wrote Message', listener.getDescription());
- } catch (error) {
- clients.removeListener(listener);
- debug.log('<%s> Write Error: %s', listener.getDescription(), error);
- }
- }
-}
-
// If we're configured to drop permissions, get rid of them now that we've
// bound to the ports we need and opened logfiles.
if (config.user) {

File Metadata

Mime Type
text/plain
Expires
Mon, Mar 17, 2:56 PM (1 w, 3 d ago)
Storage Engine
blob
Storage Format
Encrypted (AES-256-CBC)
Storage Handle
7229473
Default Alt Text
D11073.id26586.diff (2 KB)

Event Timeline

Phabricator · Built by Phacility