#include "../common/try_malloc.h" /* try_malloc() */
#include "cleanup.h" /* set_cleanup_flag() */
#include "hardcoded_strings.h" /* s */
+#include "run.h" /* send_to_outfile() */
#include "things.h" /* Thing, ThingType, ThingInMemory, ThingAction,
* get_thing_type(), get_player()
*/
dur.tv_nsec = 33333333;
while (1)
{
- if (read_file_into_queue(world.file_in, &world.queue,&world.queue_size))
+ if (read_file_into_queue(world.file_in, &world.queue))
{
return;
}
extern char * io_round()
{
- if (0 < world.queue_size)
+ if (world.queue && strlen(world.queue))
{
- return get_message_from_queue(&world.queue, &world.queue_size);
+ return get_message_from_queue(&world.queue);
}
if (world.do_update)
{
update_worldstate_file();
+ send_to_outfile("WORLD_UPDATED\n", 1);
world.do_update = 0;
}
try_growing_queue();
- return get_message_from_queue(&world.queue, &world.queue_size);
+ return get_message_from_queue(&world.queue);
}