package com.cn.test.chapter2.websocket;

import org.eclipse.jetty.websocket.WebSocket;

import java.util.Queue;
import java.util.concurrent.ConcurrentLinkedQueue;

/**
 * @author Mathieu Carbou (mathieu.carbou@gmail.com)
 */
final class Endpoints {
	
    private final Queue<Endpoint> endpoints = new ConcurrentLinkedQueue<Endpoint>();

    /**
     * 广播
     * @param fromEndpoint  消息来源
     * @param data
     */
    void broadcast(Endpoint fromEndpoint, String data) {
    	System.out.println("endpoints.size  : " + endpoints.size());
        for (Endpoint endpoint : endpoints) {
        	//不给自己发信息广播，如果是clientId=0为系统广播
        	if(endpoint != fromEndpoint){
        		endpoint.sendMessage(fromEndpoint,data);
        	}
        }
    }
    

    void offer(Endpoint endpoint) {
        endpoints.offer(endpoint);
    }

    void remove(Endpoint endpoint) {
        endpoints.remove(endpoint);
    }

    public WebSocket newEndpoint() {
        return new Endpoint(this);
    }
}