void onClientConnected(String identifier, GOInternalClient gOInternalClient) throws InterruptedException {
        WfdLog.d(TAG, "New client connected id : " + identifier);
        NineBus.get().post(new GOConnectionEvent(GOConnectionEvent.CONNECTED, identifier));
        connectionSemaphore.acquire();
        Set<String> clients = new HashSet<>(goInternalClients.keySet());
        clients.add(super.myIdentifier);
        GOInternalClient c = goInternalClients.put(identifier, gOInternalClient);
        signalNewInstanceToGroup(identifier);
        signalGroupToNewClient(gOInternalClient, clients);
        connectionSemaphore.release();
        if (c != null) {
            c.recycle();
        }
    }
void onClientConnected(String identifier, GOInternalClient gOInternalClient) throws InterruptedException {
        WfdLog.d(TAG, "New client connected id : " + identifier);
        NineBus.get().post(new GOConnectionEvent(GOConnectionEvent.CONNECTED, identifier));
        connectionSemaphore.acquire();
        Set<String> clients = new HashSet<>(goInternalClients.keySet());
        clients.add(super.myIdentifier);
        GOInternalClient c = goInternalClients.put(identifier, gOInternalClient);
        signalNewInstanceToGroup(identifier);
        signalGroupToNewClient(gOInternalClient, clients);
        connectionSemaphore.release();
        if (c != null) {
            c.recycle();
        }
    }
void onClientConnected ( String identifier , GOInternalClient gOInternalClient ) throws InterruptedException { WfdLog . d ( TAG , "New client connected id : " + identifier ) ; NineBus . get ( ) . post ( new GOConnectionEvent ( GOConnectionEvent . CONNECTED , identifier ) ) ; connectionSemaphore . acquire ( ) ; Set < String > clients = new HashSet <> ( goInternalClients . keySet ( ) ) ; clients . add ( super . myIdentifier ) ; GOInternalClient c = goInternalClients . put ( identifier , gOInternalClient ) ; signalNewInstanceToGroup ( identifier ) ; signalGroupToNewClient ( gOInternalClient , clients ) ; connectionSemaphore . release ( ) ; if ( c != null ) { c . recycle ( ) ; } }
called from GoInternalClient
called from GoInternalClient