The database data replicator periodically tries to send the data contained in the current DPD to all other nodes in the DPD network. This is the part of the DPD that will make sure that all the databases (the other DPD nodes in the network) will contain the most up-to-date data. Whenever new data is entered into the database, a timestamp is also inserted which lets the data replicator judge if the new data is more recent than the one already stored in the database. The script takes only one parameter:

integer DATA_REPLICATION_TIME=10;

where:

• DATA_REPLICATION_TIME represents the interval in seconds between which the current DPD node will attempt to replicate its own data to all the other nodes in the DPD network.

The data replicator, distributes the data in the database to all the nodes in the DPD network. It takes one configurable parameter, the DATA_REPLICATION_TIME parameter which represents the interval of seconds between which the current DPD node will attempt to send its data to all other DPD nodes.

database_data_replicator.lsl

///////////////////////////////////////////////////////////////////////////
//  Copyright (C) Wizardry and Steamworks 2011 - License: GNU GPLv3      //
//  Please see: http://www.gnu.org/licenses/gpl.html for legal details,  //
//  rights of fair usage, the disclaimer and warranty conditions.        //
///////////////////////////////////////////////////////////////////////////
 
// DPD: DATABASE DATA REPLICATOR
 
//////////////////////////////////////////////////////////
//------------------- CONFIGURATION --------------------//
//////////////////////////////////////////////////////////
 
// Time in seconds between the Distributed Primitive 
// Database (DPD) data address replication attempts.
// This determines how fast the current prim/DPD will
// attempt to connect to other prims/DPDs in your 
// network and replicate the data it contains. 
// Keep this at a sensible value, way beyond a setting of 
// 1. Do NOT be greedy and go too low on this or you will 
// overclock the script till it breaks. Sensible values 
// are well beyond 60s and it should be that way for slow 
// to moderate storage.
integer DATA_REPLICATION_TIME=5;
 
//////////////////////////////////////////////////////////
//--------------------- INTERNALS ----------------------//
//////////////////////////////////////////////////////////
 
// pragma inline
integer isValidURL(string URL) {
    if(~llSubStringIndex(URL, "http://") &&
        ~llSubStringIndex(URL, "lindenlab.com") &&
        ~llSubStringIndex(URL, "cap")) return 1;
    return 0;
}
 
list beaconQueue = [];
list messageQueue = [];
integer gitra = 0;
 
default
{
    state_entry() {
        llSetTimerEvent(DATA_REPLICATION_TIME);
    }
 
    link_message(integer sender_num, integer num, string str, key id) {
        if(num != 2) return;
        list dbData = llParseString2List(id, ["@"], [""]);
        string reqData = llList2String(dbData, 0);
        if(!isValidURL(reqData)) return;
        dbData = llParseString2List(llList2String(dbData, 1), ["="], [""]);
        if(llList2String(dbData, 0) != "db_COMMIT") return;
        list newBeacons = llCSV2List(str);
        if(!llGetListLength(newBeacons)) return;
        integer itra;
        string cBeacon;
        for(itra=0, cBeacon = llList2String(newBeacons, itra); itra<llGetListLength(newBeacons); cBeacon = llList2String(newBeacons, ++itra)) {
            if(~llListFindList(beaconQueue, [ cBeacon ])) jump next_beacon; 
            if(isValidURL(llList2String(newBeacons, itra))) beaconQueue += [ cBeacon ];
@next_beacon;
        }
        if(~llListFindList(messageQueue, [ (reqData + "@db_REPLACE=" + llList2String(dbData, 1)) ])) return;
        messageQueue += [ (reqData + "@db_REPLACE=" + llList2String(dbData, 1)) ];
    }
 
    timer() {
        llSetTimerEvent(0);
        if(gitra >= llGetListLength(beaconQueue)) {
            messageQueue = llDeleteSubList((messageQueue = []) + messageQueue, 0, 0);
            gitra = 0;
        }
        if(isValidURL(llList2String(beaconQueue, gitra))) {
            llHTTPRequest(llList2String(beaconQueue, gitra), [HTTP_METHOD, "PUT"], llList2String(messageQueue, 0));
            jump next_beacon;
        }
        beaconQueue = llDeleteSubList((beaconQueue = []) + beaconQueue, gitra, gitra);
@next_beacon;
        ++gitra;
        llSetTimerEvent(DATA_REPLICATION_TIME);    
    }
}