+++ /dev/null
-// ------------------------------------------------
-// File : servmgr.h
-// Date: 4-apr-2002
-// Author: giles
-// Desc:
-//
-// (c) 2002 peercast.org
-// ------------------------------------------------
-// This program is free software; you can redistribute it and/or modify
-// it under the terms of the GNU General Public License as published by
-// the Free Software Foundation; either version 2 of the License, or
-// (at your option) any later version.
-
-// This program is distributed in the hope that it will be useful,
-// but WITHOUT ANY WARRANTY; without even the implied warranty of
-// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
-// GNU General Public License for more details.
-// ------------------------------------------------
-
-#ifndef _SERVMGR_H
-#define _SERVMGR_H
-
-#include "servent.h"
-
-// ----------------------------------
-
-const int MIN_YP_RETRY = 20;
-const int MIN_TRACKER_RETRY = 10;
-const int MIN_RELAY_RETRY = 5;
-
-// ----------------------------------
-class BCID
-{
-public:
- BCID()
- :next(0),valid(true)
- {}
-
- bool writeVariable(Stream &, const String &);
-
- GnuID id;
- String name,email,url;
- bool valid;
- BCID *next;
-};
-
-
-// ----------------------------------
-class ServHost
-{
-public:
- enum TYPE
- {
- T_NONE,
- T_STREAM,
- T_CHANNEL,
- T_SERVENT,
- T_TRACKER
- };
-
- ServHost() {init();}
- void init()
- {
- host.init();
- time = 0;
- type = T_NONE;
- }
- void init(Host &h, TYPE tp, unsigned int tim)
- {
- init();
- host = h;
- type = tp;
- if (tim)
- time = tim;
- else
- time = sys->getTime();
- }
-
- static const char *getTypeStr(TYPE);
- static TYPE getTypeFromStr(const char *);
-
- TYPE type;
- Host host;
- unsigned int time;
-};
-// ----------------------------------
-class ServFilter
-{
-public:
- enum
- {
- F_PRIVATE = 0x01,
- F_BAN = 0x02,
- F_NETWORK = 0x04,
- F_DIRECT = 0x08
- };
-
- ServFilter() {init();}
- void init()
- {
- flags = 0;
- host.init();
- }
-
- bool writeVariable(Stream &, const String &);
-
- Host host;
- unsigned int flags;
-};
-
-// ----------------------------------
-// ServMgr keeps track of Servents
-class ServMgr
-{
-
-
-
-public:
-
- enum NOTIFY_TYPE
- {
- NT_UPGRADE = 0x0001,
- NT_PEERCAST = 0x0002,
- NT_BROADCASTERS = 0x0004,
- NT_TRACKINFO = 0x0008,
- NT_APPLAUSE = 0x0010 //JP-MOD
- };
-
- enum FW_STATE
- {
- FW_OFF,
- FW_ON,
- FW_UNKNOWN
- };
- enum {
-
- MAX_HOSTCACHE = 100, // max. amount of hosts in cache
- MIN_HOSTS = 3, // min. amount of hosts that should be kept in cache
-
- MAX_OUTGOING = 3, // max. number of outgoing servents to use
- MAX_INCOMING = 6, // max. number of public incoming servents to use
- MAX_TRYOUT = 10, // max. number of outgoing servents to try connect
- MIN_CONNECTED = 3, // min. amount of connected hosts that should be kept
-
- MIN_RELAYS = 1,
-
- MAX_FILTERS = 50,
-
- MAX_VERSIONS = 16,
-
- MAX_PREVIEWTIME = 300, // max. seconds preview per channel available (direct connections)
- MAX_PREVIEWWAIT = 300, // max. seconds wait between previews
-
- };
-
- enum AUTH_TYPE
- {
- AUTH_COOKIE,
- AUTH_HTTPBASIC
- };
-
-
-
- ServMgr();
-
- bool start();
-
- Servent *findServent(unsigned int,unsigned short,GnuID &);
- Servent *findServent(Servent::TYPE);
- Servent *findServent(Servent::TYPE,Host &,GnuID &);
- Servent *findOldestServent(Servent::TYPE,bool);
- Servent *findServentByIndex(int);
- Servent *findServentByServentID(int);
-
- bool writeVariable(Stream &, const String &);
- Servent *allocServent();
- unsigned int numUsed(int);
- unsigned int numStreams(GnuID &, Servent::TYPE,bool);
- unsigned int numStreams(Servent::TYPE,bool);
- unsigned int numConnected(int,bool,unsigned int);
- unsigned int numConnected(int t,int tim = 0)
- {
- return numConnected(t,false,tim)+numConnected(t,true,tim);
- }
- unsigned int numConnected();
- unsigned int numServents();
-
- unsigned int totalConnected()
- {
- //return numConnected(Servent::T_OUTGOING) + numConnected(Servent::T_INCOMING);
- return numConnected();
- }
- unsigned int numOutgoing();
- bool isFiltered(int,Host &h);
- bool addOutgoing(Host,GnuID &,bool);
- Servent *findConnection(Servent::TYPE,GnuID &);
-
-
- static THREAD_PROC serverProc(ThreadInfo *);
- static THREAD_PROC clientProc(ThreadInfo *);
- static THREAD_PROC trackerProc(ThreadInfo *);
- static THREAD_PROC idleProc(ThreadInfo *);
-
- int broadcast(GnuPacket &,Servent * = NULL);
- int route(GnuPacket &, GnuID &, Servent * = NULL);
-
- XML::Node *createServentXML();
-
- void connectBroadcaster();
- void procConnectArgs(char *,ChanInfo &);
-
- void quit();
- void closeConnections(Servent::TYPE);
-
- void checkFirewall();
-
- // host cache
- void addHost(Host &,ServHost::TYPE,unsigned int);
- int getNewestServents(Host *,int, Host &);
- ServHost getOutgoingServent(GnuID &);
- void deadHost(Host &,ServHost::TYPE);
- unsigned int numHosts(ServHost::TYPE);
- void clearHostCache(ServHost::TYPE);
- bool seenHost(Host &,ServHost::TYPE,unsigned int);
-
- void setMaxRelays(int);
- void setFirewall(FW_STATE);
- bool checkForceIP();
- FW_STATE getFirewall() {return firewalled;}
- void saveSettings(const char *);
- void loadSettings(const char *);
- void setPassiveSearch(unsigned int);
- int findChannel(ChanInfo &);
- bool getChannel(char *,ChanInfo &,bool);
- void setFilterDefaults();
-
- bool acceptGIV(ClientSocket *);
- void addVersion(unsigned int);
-
- void broadcastRootSettings(bool);
- int broadcastPushRequest(ChanHit &, Host &, GnuID &, Servent::TYPE);
- void writeRootAtoms(AtomStream &,bool);
-
- int broadcastPacket(ChanPacket &,GnuID &,GnuID &,GnuID &,Servent::TYPE type);
-
- void addValidBCID(BCID *);
- void removeValidBCID(GnuID &);
- BCID *findValidBCID(GnuID &);
- BCID *findValidBCID(int);
-
- unsigned int getUptime()
- {
- return sys->getTime()-startTime;
- }
-
- bool seenPacket(GnuPacket &);
-
-
- bool needHosts()
- {
- return false;
- //return numHosts(ServHost::T_SERVENT) < maxTryout;
- }
-
- unsigned int numActiveOnPort(int);
- unsigned int numActive(Servent::TYPE);
-
- bool needConnections()
- {
- return numConnected(Servent::T_PGNU,60) < minGnuIncoming;
- }
- bool tryFull()
- {
- return false;
- //return maxTryout ? numUsed(Servent::T_OUTGOING) > maxTryout: false;
- }
-
- bool pubInOver()
- {
- return numConnected(Servent::T_PGNU) > maxGnuIncoming;
-// return maxIncoming ? numConnected(Servent::T_INCOMING,false) > maxIncoming : false;
- }
- bool pubInFull()
- {
- return numConnected(Servent::T_PGNU) >= maxGnuIncoming;
-// return maxIncoming ? numConnected(Servent::T_INCOMING,false) >= maxIncoming : false;
- }
-
- bool outUsedFull()
- {
- return false;
-// return maxOutgoing ? numUsed(Servent::T_OUTGOING) >= maxOutgoing: false;
- }
- bool outOver()
- {
- return false;
-// return maxOutgoing ? numConnected(Servent::T_OUTGOING) > maxOutgoing : false;
- }
-
- bool controlInFull()
- {
- return numConnected(Servent::T_CIN)>=maxControl;
- }
-
- bool outFull()
- {
- return false;
-// return maxOutgoing ? numConnected(Servent::T_OUTGOING) >= maxOutgoing : false;
- }
-
- bool relaysFull()
- {
- return numStreams(Servent::T_RELAY,false) >= maxRelays;
- }
- bool directFull()
- {
- return numStreams(Servent::T_DIRECT,false) >= maxDirect;
- }
-
- bool bitrateFull(unsigned int br)
- {
- return maxBitrateOut ? (BYTES_TO_KBPS(totalOutput(false))+br) > maxBitrateOut : false;
- }
-
- unsigned int totalOutput(bool);
- unsigned int totalInput(bool);
-
- static ThreadInfo serverThread,idleThread;
-
-
- Servent *servents;
- WLock lock;
-
- ServHost hostCache[MAX_HOSTCACHE];
-
- char password[64];
-
- bool allowGnutella;
-
- unsigned int maxBitrateOut,maxControl,maxRelays,maxDirect;
- unsigned int minGnuIncoming,maxGnuIncoming;
- unsigned int maxServIn;
-
- bool isDisabled;
- bool isRoot;
- int totalStreams;
-
- Host serverHost;
- String rootHost;
- String rootHost2;
-
- char downloadURL[128];
- String rootMsg;
- String forceIP;
- char connectHost[128];
- GnuID networkID;
- unsigned int firewallTimeout;
- int showLog;
- int shutdownTimer;
- bool pauseLog;
- bool forceNormal;
- bool useFlowControl;
- unsigned int lastIncoming;
-
- bool restartServer;
- bool allowDirect;
- bool autoConnect,autoServe,forceLookup;
- int queryTTL;
-
- unsigned int allowServer1,allowServer2;
- unsigned int startTime;
- unsigned int tryoutDelay;
- unsigned int refreshHTML;
- unsigned int relayBroadcast;
-
- unsigned int notifyMask;
-
- BCID *validBCID;
- GnuID sessionID;
-
- ServFilter filters[MAX_FILTERS];
- int numFilters;
-
-
- CookieList cookieList;
- AUTH_TYPE authType;
-
- char htmlPath[128];
- unsigned int clientVersions[MAX_VERSIONS],clientCounts[MAX_VERSIONS];
- int numVersions;
-
- int serventNum;
- String chanLog;
-
- char modulePath[256]; //JP-EX
- int enableGetName; //JP-EX
- int allowConnectPCST; //JP-EX
- int autoRelayKeep; //JP-EX
- unsigned int autoMaxRelaySetting; //JP-EX
- unsigned int autoBumpSkipCount;//JP-EX
- unsigned int kickPushStartRelays; //JP-EX
- unsigned int kickPushInterval; //JP-EX
- unsigned int kickPushTime;
- bool isCheckPushStream(); //JP-EX
- void banFirewalledHost(); //JP-EX
- int kickUnrelayableHost(GnuID &, ChanHit &);
-
- bool getModulePath; //JP-EX
- bool clearPLS; //JP-EX
- bool writeLogFile; //JP-EX
-
- bool autoPort0Kick;
- bool allowOnlyVP;
- unsigned int kickKeepTime;
- bool vpDebug;
- bool saveIniChannel;
- bool saveGuiPos;
- bool keepDownstreams;
-
- bool topmostGui; // \8dÅ\91O\96Ê
- bool startWithGui; // \8bN\93®\8e\9e\82ÉGUI
- bool preventSS; // \83X\83N\83\8a\81[\83\93\83Z\81[\83o\81[\82ð\97}\8e~
- bool noVersionCheck; // bcstAtom\82É\82æ\82é\83o\81[\83W\83\87\83\93\83`\83F\83b\83N\82ð\8ds\82í\82È\82¢
-
- int versionDNS; // DNS\82©\82ç\8eæ\93¾\82µ\82½\8dÅ\90V\83o\81[\83W\83\87\83\93\82Ì\94Ô\8d\86
-
- int maxRelaysIndexTxt; // for PCRaw (relay)
-
-#ifdef WIN32 //JP-MOD
- bool guiSimpleChannelList;
- bool guiSimpleConnectionList;
- bool guiTopMost;
-
- int guiChanListDisplays;
- int guiConnListDisplays;
- bool guiTitleModify;
- String guiTitleModifyNormal;
- String guiTitleModifyMinimized;
-
- bool guiAntennaNotifyIcon;
-
- bool ppClapSound;
- String ppClapSoundPath;
-#endif
-
- int disableAutoBumpIfDirect;
- int asxDetailedMode;
-
- enum PPBCSTFLAG //JP-MOD
- {
- bcstNone = 0x00000000,
- bcstClap = 0x00000001
- };
-
- // PCP broadcast flood
- GnuID lastPCPFromID;
- time_t lastPCPBcstTime;
-
-private:
- FW_STATE firewalled;
-};
-
-// ----------------------------------
-extern ServMgr *servMgr;
-
-
-#endif
OSDN Git Service
