// This file written in great part by Tim Johnson (Tim@TimMUD)

static void close_callback(int fd){
    string mudname;
    trr("close_callback: fd="+fd+"\n");
    foreach(mudname in keys(muds_on_this_fd(fd))){
	trr("Removing mud from connected_muds list: "+mudname);
	mudinfo[mudname]["disconnect_time"] = time();
	map_delete(connected_muds, mudname);
	broadcast_mudlist(mudname);
    }
    close_connection(fd);
}

static void listen_callback(int fd){
    int fdstat;
    if ((fdstat = socket_accept(fd, "read_callback", "write_callback")) < 0) {
	return;
    }
}

void write_callback(int fd){
    if (sockets[fd]["write_status"] == EEALREADY) {
	write_data(fd, sockets[fd]["pending"]);
	map_delete(sockets[fd], "pending");
    } 
    else {
	sockets[fd]["write_status"] = EESUCCESS;
    }
}

static void write_data_retry(int fd, mixed data, int counter){
    int rc;
    if (counter == MAXIMUM_RETRIES) {
	close_connection(fd);
	return;
    }
    rc = socket_write(fd, data);
    if(!sockets[fd]) sockets[fd]=([]); // Tim
    sockets[fd]["write_status"] = rc;
    switch (rc) {
    case EESUCCESS:
	break;
    case EEALREADY:
	sockets[fd]["pending"] = data;
	break;
    case EECALLBACK:
	break;
    case EESEND:
	if (counter < MAXIMUM_RETRIES) {
	    trr("retry hit");
	    call_out("retry_write", 2, ({fd, data, counter + 1}));
	    return;
	}
    default:
	trr("write_data_retry: " + socket_error(rc));
	close_connection(fd);
	break;
    }
}

static void close_connection(int fd){
    int sockerr;
    map_delete(sockets, fd);
    sockerr = socket_close(fd);
    trr("closing sockerr:"+sockerr);
}

static void write_data(int fd, mixed data){
    write_data_retry(fd, data, 0);
}

static void broadcast_data(mapping targets, mixed data){
    foreach(int *arr in unique_array(values(targets), (: $1 :))){
	write_data(arr[0], data);
    }
}