X-Git-Url: https://code.citadel.org/?p=citadel.git;a=blobdiff_plain;f=citadel%2Fmodules%2Fnetwork%2Fnetspool.h;h=e62e8cfb3f9d58f259694356e81c5e7ef15936a6;hp=0fcb1808ba1f9319aef3ffa07212ee2cfb856053;hb=baa76dc30501a088c025fa10408ac50b4f452cba;hpb=cccc01dc3c5b9f774156b199bc1fe11f6aa9d319 diff --git a/citadel/modules/network/netspool.h b/citadel/modules/network/netspool.h index 0fcb1808b..e62e8cfb3 100644 --- a/citadel/modules/network/netspool.h +++ b/citadel/modules/network/netspool.h @@ -31,20 +31,33 @@ typedef struct SpoolControl SpoolControl; struct SpoolControl { OneRoomNetCfg *RNCfg; + struct ctdlroom room; + StrBuf *Users[maxRoomNetCfg]; FILE *digestfp; int num_msgs_spooled; long lastsent; HashList *working_ignetcfg; HashList *the_netmap; + + SpoolControl *next; }; -void network_spoolout_room(RoomProcList *room_to_spool, - HashList *working_ignetcfg, - HashList *the_netmap); +void network_spoolout_room(SpoolControl *sc); + +void InspectQueuedRoom(SpoolControl **pSC, + RoomProcList *room_to_spool, + HashList *working_ignetcfg, + HashList *the_netmap); + +int HaveSpoolConfig(OneRoomNetCfg* RNCfg); + + void network_do_spoolin(HashList *working_ignetcfg, HashList *the_netmap, int *netmap_changed); void network_consolidate_spoolout(HashList *working_ignetcfg, HashList *the_netmap); void free_spoolcontrol_struct(SpoolControl **scc); int writenfree_spoolcontrol_file(SpoolControl **scc, char *filename); int read_spoolcontrol_file(SpoolControl **scc, char *filename); + +void aggregate_recipients(StrBuf **recps, RoomNetCfg Which, OneRoomNetCfg *OneRNCfg);