mirror of
git://git.psyced.org/git/psyced
synced 2024-08-15 03:25:10 +00:00
96 lines
2.7 KiB
C
96 lines
2.7 KiB
C
// vim:foldmethod=marker:syntax=lpc:noexpandtab
|
|
// $Id: active.c,v 1.41 2008/06/17 09:35:45 lynx Exp $
|
|
//
|
|
#include "common.h"
|
|
#include <net.h>
|
|
#include <services.h>
|
|
|
|
inherit PSYC_PATH "circuit";
|
|
inherit NET_PATH "circuit";
|
|
|
|
volatile object super;
|
|
|
|
void takeover() {
|
|
super = previous_object();
|
|
if (super == ME) /* TODO: prevent elsewhere */ {
|
|
super = 0;
|
|
}
|
|
unless (interactive(ME)) runQ();
|
|
}
|
|
|
|
// we love multiple inheritance.. rock'n'roll!
|
|
int logon(int failure) {
|
|
int ret;
|
|
|
|
P2(("%O logon kriegt %O, prev: %O\n", ME, failure, previous_object()))
|
|
ret = NET_PATH "circuit"::logon(failure);
|
|
if (failure >= 0 && ret > 0) {
|
|
#if 0 // apparently wrong
|
|
emit(".\n"); // should we do the greeting?
|
|
PSYC_PATH "circuit"::logon(failure);
|
|
|
|
peeraddr = peerhost = host;
|
|
if (port && port != PSYC_SERVICE) peeraddr += ":"+port;
|
|
#else // probably better
|
|
peeraddr = peerhost = host;
|
|
peerport = port;
|
|
if (port && port != PSYC_SERVICE) peeraddr += ":"+port;
|
|
// circuit::logon now also implies a full greeting
|
|
// therefore it needs peeraddr, and the emit is redundant
|
|
PSYC_PATH "circuit"::logon(failure);
|
|
#endif
|
|
return 1;
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
int msg(string source, string method, string data,
|
|
mapping vars, int showingLog, string target) {
|
|
P3(("active.c:msg(%O, %O, %O) in %O%s\n", source, method, data, ME,
|
|
(interactive()) ? "(connected)" : "(not connected)"))
|
|
|
|
unless (interactive())
|
|
#ifdef FORK // {{{
|
|
{
|
|
if (!member(vars, "_source"))
|
|
vars["_source"] = UNIFORM(source);
|
|
unless (super)
|
|
return enqueue(source, method, data, vars, showingLog, target);
|
|
return super->msg(source, method, data, vars, showingLog, target);
|
|
}
|
|
return ::msg(source, method, data, vars, showingLog, target);
|
|
#else // }}}
|
|
{
|
|
P2(("%O ist nicht interactive\n", ME))
|
|
if (!member(vars, "_source"))
|
|
vars["_source"] = UNIFORM(source);
|
|
// this stuff is causing loops and i don't know how to fix it right now
|
|
// unless (super)
|
|
# ifdef SPYC
|
|
// NOTE: SPYC uses a per-host verification and therefore
|
|
// may not send certain packets before verification
|
|
// is done (those packets usually have source and target)
|
|
// for now, this check works most of the time
|
|
# endif
|
|
return enqueue(source, method, data, vars, showingLog, target);
|
|
// return super->msg(source, method, data, vars, showingLog, target);
|
|
}
|
|
return ::msg(source, method, data, vars, showingLog, target);
|
|
#endif // !FORK
|
|
}
|
|
|
|
#if 0
|
|
connect(host, port) {
|
|
if (host) {
|
|
// funky but who needs this?
|
|
if (interactive()) {
|
|
if (ahost == host && aport == port) return -8;
|
|
else remove_interactive(ME);
|
|
}
|
|
...
|
|
|
|
P1(("PSYC/TCP %O * net_connect(%O, %O) = %O\n",
|
|
ME, host, port, rc))
|
|
return rc;
|
|
}
|
|
#endif
|