Lines Matching refs:endpoint

86     var endpoint = new InterfaceEndpoint(this, id);
87     this.endpoints_.set(id, endpoint);
89       this.updateEndpointStateMayRemove(endpoint,
92     endpoint.handleCreated = true;
97       this.updateEndpointStateMayRemove(endpoint,
112     var endpoint = this.endpoints_.get(interfaceEndpointHandle.id());
113     check(endpoint);
114     check(!endpoint.client);
115     check(!endpoint.closed);
116     endpoint.client = interfaceEndpointClient;
118     if (endpoint.peerClosed) {
119       setTimeout(endpoint.client.notifyError.bind(endpoint.client), 0);
137           var ok = endpoint.client.handleIncomingMessage(message,
148     return endpoint;
154     var endpoint = this.endpoints_.get(interfaceEndpointHandle.id());
155     check(endpoint);
156     check(endpoint.client);
157     check(!endpoint.closed);
159     endpoint.client = null;
177     var endpoint = this.endpoints_.get(interfaceId);
179     if (!endpoint) {
180       endpoint = new InterfaceEndpoint(this, interfaceId);
181       this.endpoints_.set(interfaceId, endpoint);
183       check(!endpoint.handleCreated);
186         this.updateEndpointStateMayRemove(endpoint,
192       check(!endpoint.closed);
193       check(endpoint.peerClosed);
195       if (endpoint.handleCreated) {
200     endpoint.handleCreated = true;
216         var endpoint = this.endpoints_.get(interfaceId);
217         if (!endpoint || endpoint.closed) {
221         if (!endpoint.client) {
229         ok = endpoint.client.handleIncomingMessage(message, messageValidator);
245     var endpoint = this.endpoints_.get(interfaceId);
246     if (!endpoint) {
247       endpoint = new InterfaceEndpoint(this, interfaceId);
248       this.endpoints_.set(interfaceId, endpoint);
252       endpoint.disconnectReason = reason;
255     if (!endpoint.peerClosed) {
256       if (endpoint.client) {
257         setTimeout(endpoint.client.notifyError.bind(endpoint.client, reason),
260       this.updateEndpointStateMayRemove(endpoint,
269     for (var endpoint of this.endpoints_.values()) {
270       if (endpoint.client) {
272             endpoint.client.notifyError.bind(
273                 endpoint.client, endpoint.disconnectReason),
276       this.updateEndpointStateMayRemove(endpoint,
285     var endpoint = this.endpoints_.get(interfaceId);
286     check(endpoint);
287     check(!endpoint.client);
288     check(!endpoint.closed);
290     this.updateEndpointStateMayRemove(endpoint,
304   Router.prototype.updateEndpointStateMayRemove = function(endpoint,  argument
307       endpoint.closed = true;
309       endpoint.peerClosed = true;
311     if (endpoint.closed && endpoint.peerClosed) {
312       this.endpoints_.delete(endpoint.id);