// This file written mostly by Tim Johnson (Tim@TimMUD) // broadcast the mudlist when a mud just now got changed... static void validate(); static mapping BroadcastQueue = ([]); varargs void broadcast_mudlist(string mudname, int remote, string single){ //string targ_mudname; string *audience = ({}); mixed *packet1; // for muds that use protocol 1 or 2 mixed *packet3; // for muds that use protocol 3 int mudstat; validate(); mudinfo_update_counter++; if(BroadcastQueue[mudname]) map_delete(BroadcastQueue, mudname); if(single && sizeof(single) && connected_muds[single]){ audience = ({ single }); } else audience = keys(connected_muds); //trr("audience: "+identify(audience),"white"); //trr("mud: "+mudname); if(mudinfo[mudname]){ if(!connected_muds[mudname] && mudinfo[mudname]){ //trr("disconnect time for "+mudname+": "+mudinfo[mudname]["disconnect_time"]); if(!mudinfo[mudname]["disconnect_time"] && mudinfo[mudname]["connect_time"]) mudstat = -1; else mudstat = 0; } else { //trr("evidently i think we are connected."); mudstat = -1; } if(!mapp(mudinfo[mudname])){ //trr("WTF. NOT A MAPPING: "+get_stack(),"red"); return; } //trr("mudstat: "+mudstat,"white"); //trr("mud: "+identify(mudinfo[mudname]),"green"); //trr("broadcasting mudlist to let them know about "+mudname,"red"); packet1 = ({ "mudlist", 5, router_name, 0, 0, 0, mudinfo_update_counter,([ mudname:({ mudstat, // -1=up, 0=down, n=down for n secs mudinfo[mudname]["ip"], // ip_addr mudinfo[mudname]["player_port"], // player_port mudinfo[mudname]["imud_tcp_port"], // imud_tcp_port mudinfo[mudname]["imud_udp_port"], // imud_udp_port mudinfo[mudname]["mudlib"], // mudlib mudinfo[mudname]["base_mudlib"], // base_mudlib mudinfo[mudname]["driver"], // driver mudinfo[mudname]["mud_type"], // mud_type mudinfo[mudname]["open_status"], // open_status mudinfo[mudname]["services"], // services }) ]) }); packet3 = ({ "mudlist", 5, router_name, 0, 0, 0, mudinfo_update_counter,([ mudname:({ mudstat, // -1=up, 0=down, n=down for n secs mudinfo[mudname]["ip"], // ip_addr mudinfo[mudname]["player_port"], // player_port mudinfo[mudname]["imud_tcp_port"], // imud_tcp_port mudinfo[mudname]["imud_udp_port"], // imud_udp_port mudinfo[mudname]["mudlib"], // mudlib mudinfo[mudname]["base_mudlib"], // base_mudlib mudinfo[mudname]["driver"], // driver mudinfo[mudname]["mud_type"], // mud_type mudinfo[mudname]["open_status"], // open_status mudinfo[mudname]["admin_email"], // admin_email mudinfo[mudname]["services"], // services mudinfo[mudname]["other_data"], // other_data }) ]) }); } if(!mudinfo[mudname]){ // deleted mud... trr("%^B_RED%^%^BLACK%^No mudinfo for "+mudname); // just send a 0 to everyone foreach(string targ_mudname in audience){ write_data(connected_muds[targ_mudname], ({ "mudlist", 5, router_name, 0, targ_mudname, 0, mudinfo_update_counter, ([mudname:0]) }) ); } return; } if(!remote){ if(!single){ //trr("%^RESET%^%^B_MAGENTA%^sending IRN mudstat for "+mudname+": "+identify(mudinfo[mudname])); trr("%^RESET%^%^B_MAGENTA%^sending IRN mudstat for "+mudname); this_object()->SendList( ([ mudname : mudinfo[mudname] ]) ); } } foreach(string targ_mudname in audience){ int womble; if(!sizeof(mudinfo) || !mudinfo[targ_mudname]) continue; switch(mudinfo[targ_mudname]["protocol"]){ case 1: case 2: packet1[4]=targ_mudname; //write_data(connected_muds[targ_mudname], packet1); call_out( (: write_data :), 1, connected_muds[targ_mudname], packet1); break; case 3: //trr("I want to write to "+targ_mudname+": "+identify(packet3)); womble = connected_muds[targ_mudname]; packet3[4]=targ_mudname; //trr("I want to write to "+targ_mudname+": "+identify(packet3)); //trr("connected_muds["+targ_mudname+"] is: "+womble); //trr("this_object()->query_connected_fds()["+womble+"] is: "+ //this_object()->query_connected_fds()[womble]); //write_data(connected_muds[targ_mudname], packet3); call_out( (: write_data :), 1, connected_muds[targ_mudname], copy(packet3), womble); break; } } } varargs void schedule_broadcast(string mudname, int remote, string single){ validate(); if(!BroadcastQueue) BroadcastQueue = ([]); if(BroadcastQueue[mudname]) return; else { BroadcastQueue[mudname] =([]); if(remote) BroadcastQueue[mudname]["remote"] = remote; else BroadcastQueue[mudname]["remote"] = 0; if(single) BroadcastQueue[mudname]["single"] = single; else BroadcastQueue[mudname]["single"] = 0; call_out( (: broadcast_mudlist :), 10, mudname, BroadcastQueue[mudname]["remote"], BroadcastQueue[mudname]["single"] ); } }