message->param.disconnectinfo.cause = cause;
message->param.disconnectinfo.location = LOCATION_PRIVATE_LOCAL;
message_put(message);
+ ea_endpoint->free_portlist(portlist);
/* destroy endpoint */
ea_endpoint->ep_use = 0;
/* port MESSAGE_RELEASE */
void EndpointAppBridge::port_release(struct port_list *portlist, int message_type, union parameter *param)
{
- unsigned int remote;
+ struct port_list *remote;
PDEBUG(DEBUG_EPOINT, "EPOINT(%d) epoint received release from port\n");
if (!ea_endpoint->ep_portlist || !ea_endpoint->ep_portlist->next)
goto out;
if (ea_endpoint->ep_portlist->port_id == portlist->port_id)
- remote = ea_endpoint->ep_portlist->next->port_id;
+ remote = ea_endpoint->ep_portlist->next;
else
- remote = ea_endpoint->ep_portlist->port_id;
+ remote = ea_endpoint->ep_portlist;
/* forward release */
- message_forward(ea_endpoint->ep_serial, remote, EPOINT_TO_PORT, param);
+ message_forward(ea_endpoint->ep_serial, remote->port_id, EPOINT_TO_PORT, param);
+
+ /* remove relations to in and out port */
+ ea_endpoint->free_portlist(portlist);
+ ea_endpoint->free_portlist(remote);
out:
/* destroy endpoint */
portlist = ep_portlist;
while(portlist) {
if (portlist->port_id) {
- PERROR("warning: still relation to port (portlist list)\n");
+ PERROR("Endpoint(%d) warning: still relation to port %d (portlist list)\n", ep_serial, portlist->port_id);
}
mtemp = portlist;
portlist = portlist->next;
/* portlist structure */
portlist = (struct port_list *)MALLOC(sizeof(struct port_list));
ememuse++;
- PDEBUG(DEBUG_EPOINT, "EPOINT(%d) allocating port_list.\n", ep_serial);
+ PDEBUG(DEBUG_EPOINT, "EPOINT(%d) allocating port_list, attaching to port %d\n", ep_serial, port_id);
/* add port_list to chain */
portlist->next = NULL;
*tempp=portlist->next;
/* free */
- PDEBUG(DEBUG_EPOINT, "EPOINT(%d) removed port_list from endpoint\n", ep_serial);
+ PDEBUG(DEBUG_EPOINT, "EPOINT(%d) removed port %d from port_list of endpoint\n", ep_serial, portlist->port_id);
FREE(portlist, sizeof(struct port_list));
ememuse--;
}