code: 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();
          }
      }
docs: called from GoInternalClient