Index: uspace/lib/net/generic/generic.c =================================================================== --- uspace/lib/net/generic/generic.c (revision 79ae36ddc409577eb0da3750b3a7280e034566a2) +++ uspace/lib/net/generic/generic.c (revision b366a6f4b86cb7fe82fcf415965c5a7de1a59638) @@ -37,5 +37,4 @@ #include #include -#include #include #include @@ -45,18 +44,19 @@ /** Notify the module about the device state change. * - * @param[in] phone The service module phone. - * @param[in] message The service specific message. - * @param[in] device_id The device identifier. - * @param[in] state The new device state. - * @param[in] target The target module service. - * @return EOK on success. - * - */ -int -generic_device_state_msg_remote(int phone, int message, device_id_t device_id, - int state, services_t target) -{ - async_obsolete_msg_3(phone, (sysarg_t) message, (sysarg_t) device_id, - (sysarg_t) state, target); + * @param[in] sess Service module session. + * @param[in] message Service specific message. + * @param[in] device_id Device identifier. + * @param[in] state New device state. + * @param[in] target Target module service. + * + * @return EOK on success. + * + */ +int generic_device_state_msg_remote(async_sess_t *sess, sysarg_t message, + device_id_t device_id, sysarg_t state, services_t target) +{ + async_exch_t *exch = async_exchange_begin(sess); + async_msg_3(exch, message, (sysarg_t) device_id, state, target); + async_exchange_end(exch); return EOK; @@ -65,54 +65,59 @@ /** Notify a module about the device. * - * @param[in] phone The service module phone. - * @param[in] message The service specific message. - * @param[in] device_id The device identifier. - * @param[in] arg2 The second argument of the message. - * @param[in] service The device module service. - * @return EOK on success. - * @return Other error codes as defined for the specific service - * message. - * - */ -int -generic_device_req_remote(int phone, int message, device_id_t device_id, - int arg2, services_t service) -{ - return (int) async_obsolete_req_3_0(phone, (sysarg_t) message, - (sysarg_t) device_id, (sysarg_t) arg2, (sysarg_t) service); + * @param[in] sess Service module session. + * @param[in] message Service specific message. + * @param[in] device_id Device identifier. + * @param[in] arg2 Second argument of the message. + * @param[in] service Device module service. + * + * @return EOK on success. + * @return Other error codes as defined for the specific service + * message. + * + */ +int generic_device_req_remote(async_sess_t *sess, sysarg_t message, + device_id_t device_id, sysarg_t arg2, services_t service) +{ + async_exch_t *exch = async_exchange_begin(sess); + int rc = async_req_3_0(exch, message, (sysarg_t) device_id, + arg2, (sysarg_t) service); + async_exchange_end(exch); + + return rc; } /** Returns the address. * - * @param[in] phone The service module phone. - * @param[in] message The service specific message. - * @param[in] device_id The device identifier. - * @param[out] address The desired address. - * @param[out] data The address data container. - * @return EOK on success. - * @return EBADMEM if the address parameter and/or the data - * parameter is NULL. - * @return Other error codes as defined for the specific service - * message. - */ -int -generic_get_addr_req(int phone, int message, device_id_t device_id, - measured_string_t **address, uint8_t **data) -{ - aid_t message_id; + * @param[in] sess Service module session. + * @param[in] message Service specific message. + * @param[in] device_id Device identifier. + * @param[out] address Desired address. + * @param[out] data Address data container. + * + * @return EOK on success. + * @return EBADMEM if the address parameter and/or the data + * parameter is NULL. + * @return Other error codes as defined for the specific service + * message. + * + */ +int generic_get_addr_req(async_sess_t *sess, sysarg_t message, + device_id_t device_id, measured_string_t **address, uint8_t **data) +{ + if ((!address) || (!data)) + return EBADMEM; + + /* Request the address */ + async_exch_t *exch = async_exchange_begin(sess); + aid_t message_id = async_send_1(exch, message, (sysarg_t) device_id, + NULL); + int rc = measured_strings_return(exch, address, data, 1); + async_exchange_end(exch); + sysarg_t result; - int string; - - if (!address || !data) - return EBADMEM; - - /* Request the address */ - message_id = async_obsolete_send_1(phone, (sysarg_t) message, - (sysarg_t) device_id, NULL); - string = measured_strings_return(phone, address, data, 1); async_wait_for(message_id, &result); - + /* If not successful */ - if ((string == EOK) && (result != EOK)) { + if ((rc == EOK) && (result != EOK)) { /* Clear the data */ free(*address); @@ -125,16 +130,17 @@ /** Return the device packet dimension for sending. * - * @param[in] phone The service module phone. - * @param[in] message The service specific message. - * @param[in] device_id The device identifier. - * @param[out] packet_dimension The packet dimension. - * @return EOK on success. - * @return EBADMEM if the packet_dimension parameter is NULL. - * @return Other error codes as defined for the specific service - * message. - */ -int -generic_packet_size_req_remote(int phone, int message, device_id_t device_id, - packet_dimension_t *packet_dimension) + * @param[in] sess Service module session. + * @param[in] message Service specific message. + * @param[in] device_id Device identifier. + * @param[out] packet_dimension Packet dimension. + * + * @return EOK on success. + * @return EBADMEM if the packet_dimension parameter is NULL. + * @return Other error codes as defined for the specific service + * message. + * + */ +int generic_packet_size_req_remote(async_sess_t *sess, sysarg_t message, + device_id_t device_id, packet_dimension_t *packet_dimension) { if (!packet_dimension) @@ -146,6 +152,8 @@ sysarg_t suffix; - sysarg_t result = async_obsolete_req_1_4(phone, (sysarg_t) message, - (sysarg_t) device_id, &addr_len, &prefix, &content, &suffix); + async_exch_t *exch = async_exchange_begin(sess); + sysarg_t result = async_req_1_4(exch, message, (sysarg_t) device_id, + &addr_len, &prefix, &content, &suffix); + async_exchange_end(exch); packet_dimension->prefix = (size_t) prefix; @@ -159,25 +167,31 @@ /** Pass the packet queue to the module. * - * @param[in] phone The service module phone. - * @param[in] message The service specific message. - * @param[in] device_id The device identifier. - * @param[in] packet_id The received packet or the received packet queue - * identifier. - * @param[in] target The target module service. - * @param[in] error The error module service. - * @return EOK on success. - */ -int -generic_received_msg_remote(int phone, int message, device_id_t device_id, - packet_id_t packet_id, services_t target, services_t error) -{ + * @param[in] sess Service module session. + * @param[in] message Service specific message. + * @param[in] device_id Device identifier. + * @param[in] packet_id Received packet or the received packet queue + * identifier. + * @param[in] target Target module service. + * @param[in] error Error module service. + * + * @return EOK on success. + * + */ +int generic_received_msg_remote(async_sess_t *sess, sysarg_t message, + device_id_t device_id, packet_id_t packet_id, services_t target, + services_t error) +{ + async_exch_t *exch = async_exchange_begin(sess); + if (error) { - async_obsolete_msg_4(phone, (sysarg_t) message, (sysarg_t) device_id, + async_msg_4(exch, message, (sysarg_t) device_id, (sysarg_t) packet_id, (sysarg_t) target, (sysarg_t) error); } else { - async_obsolete_msg_3(phone, (sysarg_t) message, (sysarg_t) device_id, + async_msg_3(exch, message, (sysarg_t) device_id, (sysarg_t) packet_id, (sysarg_t) target); } + async_exchange_end(exch); + return EOK; } @@ -185,25 +199,30 @@ /** Send the packet queue. * - * @param[in] phone The service module phone. - * @param[in] message The service specific message. - * @param[in] device_id The device identifier. - * @param[in] packet_id The packet or the packet queue identifier. - * @param[in] sender The sending module service. - * @param[in] error The error module service. - * @return EOK on success. - * - */ -int -generic_send_msg_remote(int phone, int message, device_id_t device_id, - packet_id_t packet_id, services_t sender, services_t error) -{ + * @param[in] sess Service module session. + * @param[in] message Service specific message. + * @param[in] device_id Device identifier. + * @param[in] packet_id Packet or the packet queue identifier. + * @param[in] sender Sending module service. + * @param[in] error Error module service. + * + * @return EOK on success. + * + */ +int generic_send_msg_remote(async_sess_t *sess, sysarg_t message, + device_id_t device_id, packet_id_t packet_id, services_t sender, + services_t error) +{ + async_exch_t *exch = async_exchange_begin(sess); + if (error) { - async_obsolete_msg_4(phone, (sysarg_t) message, (sysarg_t) device_id, + async_msg_4(exch, message, (sysarg_t) device_id, (sysarg_t) packet_id, (sysarg_t) sender, (sysarg_t) error); } else { - async_obsolete_msg_3(phone, (sysarg_t) message, (sysarg_t) device_id, + async_msg_3(exch, message, (sysarg_t) device_id, (sysarg_t) packet_id, (sysarg_t) sender); } + async_exchange_end(exch); + return EOK; } @@ -213,48 +232,51 @@ * Allocates and returns the needed memory block as the data parameter. * - * @param[in] phone The service module phone. - * @param[in] message The service specific message. - * @param[in] device_id The device identifier. - * @param[in] service The module service. - * @param[in] configuration The key strings. - * @param[in] count The number of configuration keys. - * @param[out] translation The translated values. - * @param[out] data The translation data container. - * @return EOK on success. - * @return EINVAL if the configuration parameter is NULL. - * @return EINVAL if the count parameter is zero. - * @return EBADMEM if the translation or the data parameters are - * NULL. - * @return Other error codes as defined for the specific service - * message. - */ -int -generic_translate_req(int phone, int message, device_id_t device_id, - services_t service, measured_string_t *configuration, size_t count, + * @param[in] sess Service module session. + * @param[in] message Service specific message. + * @param[in] device_id Device identifier. + * @param[in] service Module service. + * @param[in] configuration Key strings. + * @param[in] count Number of configuration keys. + * @param[out] translation Translated values. + * @param[out] data Translation data container. + * + * @return EOK on success. + * @return EINVAL if the configuration parameter is NULL. + * @return EINVAL if the count parameter is zero. + * @return EBADMEM if the translation or the data parameters are + * NULL. + * @return Other error codes as defined for the specific service + * message. + * + */ +int generic_translate_req(async_sess_t *sess, sysarg_t message, + device_id_t device_id, services_t service, + measured_string_t *configuration, size_t count, measured_string_t **translation, uint8_t **data) { - aid_t message_id; + if ((!configuration) || (count == 0)) + return EINVAL; + + if ((!translation) || (!data)) + return EBADMEM; + + /* Request the translation */ + async_exch_t *exch = async_exchange_begin(sess); + aid_t message_id = async_send_3(exch, message, (sysarg_t) device_id, + (sysarg_t) count, (sysarg_t) service, NULL); + measured_strings_send(exch, configuration, count); + int rc = measured_strings_return(exch, translation, data, count); + async_exchange_end(exch); + sysarg_t result; - int string; - - if (!configuration || (count == 0)) - return EINVAL; - if (!translation || !data) - return EBADMEM; - - /* Request the translation */ - message_id = async_obsolete_send_3(phone, (sysarg_t) message, - (sysarg_t) device_id, (sysarg_t) count, (sysarg_t) service, NULL); - measured_strings_send(phone, configuration, count); - string = measured_strings_return(phone, translation, data, count); async_wait_for(message_id, &result); - + /* If not successful */ - if ((string == EOK) && (result != EOK)) { + if ((rc == EOK) && (result != EOK)) { /* Clear the data */ free(*translation); free(*data); } - + return (int) result; } Index: uspace/lib/net/generic/net_remote.c =================================================================== --- uspace/lib/net/generic/net_remote.c (revision 79ae36ddc409577eb0da3750b3a7280e034566a2) +++ uspace/lib/net/generic/net_remote.c (revision b366a6f4b86cb7fe82fcf415965c5a7de1a59638) @@ -47,19 +47,22 @@ #include -/** Connects to the networking module. +/** Connect to the networking module. * - * @return The networking module phone on success. + * @return Networking module session on success. + * */ -int net_connect_module(void) +async_sess_t *net_connect_module(void) { return connect_to_service(SERVICE_NETWORKING); } -/** Frees the received settings. +/** Free the received settings. * - * @param[in] settings The received settings. - * @param[in] data The received settings data. - * @see net_get_device_conf_req() + * @param[in] settings Received settings. + * @param[in] data Received settings data. + * + * @see net_get_device_conf_req() * @see net_get_conf_req() + * */ void net_free_settings(measured_string_t *settings, uint8_t *data) @@ -71,5 +74,5 @@ } -/** Returns the global configuration. +/** Return the global configuration. * * The configuration names are read and the appropriate settings are set @@ -77,48 +80,52 @@ * configuration. * - * @param[in] net_phone The networking module phone. - * @param[in,out] configuration The requested configuration. The names are read - * and the appropriate settings are set instead. + * @param[in] sess Networking module session. + * @param[in,out] configuration Requested configuration. The names are + * read and the appropriate settings are set + * instead. * - * @param[in] count The configuration entries count. - * @param[in,out] data The configuration and settings data. - * @return EOK on success. - * @return EINVAL if the configuration is NULL. - * @return EINVAL if the count is zero. - * @return Other error codes as defined for the - * generic_translate_req() function. + * @param[in] count Configuration entries count. + * @param[in,out] data Configuration and settings data. + * + * @return EOK on success. + * @return EINVAL if the configuration is NULL. + * @return EINVAL if the count is zero. + * @return Other error codes as defined for the + * generic_translate_req() function. + * */ -int -net_get_conf_req(int net_phone, measured_string_t **configuration, +int net_get_conf_req(async_sess_t *sess, measured_string_t **configuration, size_t count, uint8_t **data) { - return generic_translate_req(net_phone, NET_NET_GET_DEVICE_CONF, 0, 0, + return generic_translate_req(sess, NET_NET_GET_DEVICE_CONF, 0, 0, *configuration, count, configuration, data); } -/** Returns the device specific configuration. +/** Return the device specific configuration. * - * Returns the global configuration if the device specific is not found. + * Return the global configuration if the device specific is not found. * The configuration names are read and the appropriate settings are set * instead. Call net_free_settings() function to release the returned * configuration. * - * @param[in] net_phone The networking module phone. - * @param[in] device_id The device identifier. - * @param[in,out] configuration The requested device configuration. The names - * are read and the appropriate settings are set instead. - * @param[in] count The configuration entries count. - * @param[in,out] data The configuration and settings data. - * @return EOK on success. - * @return EINVAL if the configuration is NULL. - * @return EINVAL if the count is zero. - * @return Other error codes as defined for the - * generic_translate_req() function. + * @param[in] sess The networking module session. + * @param[in] device_id Device identifier. + * @param[in,out] configuration Requested device configuration. The names + * are read and the appropriate settings are + * set instead. + * @param[in] count Configuration entries count. + * @param[in,out] data Configuration and settings data. + * + * @return EOK on success. + * @return EINVAL if the configuration is NULL. + * @return EINVAL if the count is zero. + * @return Other error codes as defined for the + * generic_translate_req() function. + * */ -int -net_get_device_conf_req(int net_phone, device_id_t device_id, +int net_get_device_conf_req(async_sess_t *sess, device_id_t device_id, measured_string_t **configuration, size_t count, uint8_t **data) { - return generic_translate_req(net_phone, NET_NET_GET_DEVICE_CONF, + return generic_translate_req(sess, NET_NET_GET_DEVICE_CONF, device_id, 0, *configuration, count, configuration, data); } Index: uspace/lib/net/generic/packet_client.c =================================================================== --- uspace/lib/net/generic/packet_client.c (revision 79ae36ddc409577eb0da3750b3a7280e034566a2) +++ uspace/lib/net/generic/packet_client.c (revision b366a6f4b86cb7fe82fcf415965c5a7de1a59638) @@ -247,33 +247,34 @@ } -/** Returns the packet copy. - * - * Copies the addresses, data, order and metric values. - * Does not copy the queue placement. - * - * @param[in] phone The packet server module phone. - * @param[in] packet The original packet. - * @return The packet copy. - * @return NULL on error. - */ -packet_t *packet_get_copy(int phone, packet_t *packet) -{ - packet_t *copy; - uint8_t * src = NULL; - uint8_t * dest = NULL; - size_t addrlen; - - if (!packet_is_valid(packet)) - return NULL; - +/** Return the packet copy. + * + * Copy the addresses, data, order and metric values. + * Queue placement is not copied. + * + * @param[in] sess Packet server module session. + * @param[in] packet Original packet. + * + * @return Packet copy. + * @return NULL on error. + * + */ +packet_t *packet_get_copy(async_sess_t *sess, packet_t *packet) +{ + if (!packet_is_valid(packet)) + return NULL; + /* Get a new packet */ - copy = packet_get_4_remote(phone, PACKET_DATA_LENGTH(packet), + packet_t *copy = packet_get_4_remote(sess, PACKET_DATA_LENGTH(packet), PACKET_MAX_ADDRESS_LENGTH(packet), packet->max_prefix, PACKET_MIN_SUFFIX(packet)); + if (!copy) return NULL; - + /* Get addresses */ - addrlen = packet_get_addr(packet, &src, &dest); + uint8_t *src = NULL; + uint8_t *dest = NULL; + size_t addrlen = packet_get_addr(packet, &src, &dest); + /* Copy data */ if ((packet_copy_data(copy, packet_get_data(packet), @@ -286,5 +287,5 @@ return copy; } else { - pq_release_remote(phone, copy->packet_id); + pq_release_remote(sess, copy->packet_id); return NULL; } Index: uspace/lib/net/generic/packet_remote.c =================================================================== --- uspace/lib/net/generic/packet_remote.c (revision 79ae36ddc409577eb0da3750b3a7280e034566a2) +++ uspace/lib/net/generic/packet_remote.c (revision b366a6f4b86cb7fe82fcf415965c5a7de1a59638) @@ -37,5 +37,4 @@ #include -#include #include #include @@ -52,63 +51,64 @@ * Create the local packet mapping as well. * - * @param[in] phone The packet server module phone. - * @param[out] packet The packet reference pointer to store the received + * @param[in] sess Packet server module session. + * @param[out] packet Packet reference pointer to store the received * packet reference. - * @param[in] packet_id The packet identifier. - * @param[in] size The packet total size in bytes. + * @param[in] packet_id Packet identifier. + * @param[in] size Packet total size in bytes. * * @return EOK on success. * @return Other error codes as defined for the pm_add() function. - * @return Other error codes as defined for the async_obsolete_share_in_start() function. - * - */ -static int -packet_return(int phone, packet_t **packet, packet_id_t packet_id, size_t size) -{ + * @return Other error codes as defined for the async_share_in_start() + * function. + * + */ +static int packet_return(async_sess_t *sess, packet_t **packet, + packet_id_t packet_id, size_t size) +{ + *packet = (packet_t *) as_get_mappable_page(size); + + async_exch_t *exch = async_exchange_begin(sess); ipc_call_t answer; - aid_t message; - int rc; - - message = async_obsolete_send_1(phone, NET_PACKET_GET, packet_id, &answer); - - *packet = (packet_t *) as_get_mappable_page(size); - rc = async_obsolete_share_in_start_0_0(phone, *packet, size); + aid_t message = async_send_1(exch, NET_PACKET_GET, packet_id, &answer); + int rc = async_share_in_start_0_0(exch, *packet, size); + async_exchange_end(exch); + + sysarg_t result; + async_wait_for(message, &result); + if (rc != EOK) { munmap(*packet, size); - async_wait_for(message, NULL); return rc; } + rc = pm_add(*packet); if (rc != EOK) { munmap(*packet, size); - async_wait_for(message, NULL); return rc; } - sysarg_t result; - async_wait_for(message, &result); - return result; } -/** Translates the packet identifier to the packet reference. - * - * Tries to find mapping first. - * Contacts the packet server to share the packet if the mapping is not present. - * - * @param[in] phone The packet server module phone. - * @param[out] packet The packet reference. - * @param[in] packet_id The packet identifier. - * @return EOK on success. - * @return EINVAL if the packet parameter is NULL. - * @return Other error codes as defined for the NET_PACKET_GET_SIZE - * message. - * @return Other error codes as defined for the packet_return() - * function. - */ -int packet_translate_remote(int phone, packet_t **packet, packet_id_t packet_id) -{ - int rc; - +/** Translate the packet identifier to the packet reference. + * + * Try to find mapping first. The packet server is asked to share + * the packet if the mapping is not present. + * + * @param[in] sess Packet server module session. + * @param[out] packet Packet reference. + * @param[in] packet_id Packet identifier. + * + * @return EOK on success. + * @return EINVAL if the packet parameter is NULL. + * @return Other error codes as defined for the NET_PACKET_GET_SIZE + * message. + * @return Other error codes as defined for the packet_return() + * function. + * + */ +int packet_translate_remote(async_sess_t *sess, packet_t **packet, + packet_id_t packet_id) +{ if (!packet) return EINVAL; @@ -116,18 +116,21 @@ *packet = pm_find(packet_id); if (!*packet) { + async_exch_t *exch = async_exchange_begin(sess); sysarg_t size; + int rc = async_req_1_1(exch, NET_PACKET_GET_SIZE, packet_id, + &size); + async_exchange_end(exch); - rc = async_obsolete_req_1_1(phone, NET_PACKET_GET_SIZE, packet_id, - &size); if (rc != EOK) return rc; - rc = packet_return(phone, packet, packet_id, size); + + rc = packet_return(sess, packet, packet_id, size); if (rc != EOK) return rc; } + if ((*packet)->next) { packet_t *next; - - return packet_translate_remote(phone, &next, (*packet)->next); + return packet_translate_remote(sess, &next, (*packet)->next); } @@ -135,33 +138,35 @@ } -/** Obtains the packet of the given dimensions. - * - * Contacts the packet server to return the appropriate packet. - * - * @param[in] phone The packet server module phone. - * @param[in] addr_len The source and destination addresses maximal length in - * bytes. - * @param[in] max_prefix The maximal prefix length in bytes. - * @param[in] max_content The maximal content length in bytes. - * @param[in] max_suffix The maximal suffix length in bytes. - * @return The packet reference. - * @return NULL on error. - */ -packet_t *packet_get_4_remote(int phone, size_t max_content, size_t addr_len, - size_t max_prefix, size_t max_suffix) -{ +/** Obtain the packet of given dimensions. + * + * Contact the packet server to return the appropriate packet. + * + * @param[in] sess Packet server module session. + * @param[in] addr_len Source and destination addresses maximal length + * in bytes. + * @param[in] max_prefix Maximal prefix length in bytes. + * @param[in] max_content Maximal content length in bytes. + * @param[in] max_suffix Maximal suffix length in bytes. + * + * @return The packet reference. + * @return NULL on error. + * + */ +packet_t *packet_get_4_remote(async_sess_t *sess, size_t max_content, + size_t addr_len, size_t max_prefix, size_t max_suffix) +{ + async_exch_t *exch = async_exchange_begin(sess); sysarg_t packet_id; sysarg_t size; - int rc; - - rc = async_obsolete_req_4_2(phone, NET_PACKET_CREATE_4, max_content, addr_len, + int rc = async_req_4_2(exch, NET_PACKET_CREATE_4, max_content, addr_len, max_prefix, max_suffix, &packet_id, &size); + async_exchange_end(exch); + if (rc != EOK) return NULL; - packet_t *packet = pm_find(packet_id); if (!packet) { - rc = packet_return(phone, &packet, packet_id, size); + rc = packet_return(sess, &packet, packet_id, size); if (rc != EOK) return NULL; @@ -171,21 +176,24 @@ } -/** Obtains the packet of the given content size. - * - * Contacts the packet server to return the appropriate packet. - * - * @param[in] phone The packet server module phone. - * @param[in] content The maximal content length in bytes. - * @return The packet reference. - * @return NULL on error. - */ -packet_t *packet_get_1_remote(int phone, size_t content) -{ +/** Obtain the packet of given content size. + * + * Contact the packet server to return the appropriate packet. + * + * @param[in] sess Packet server module session. + * @param[in] content Maximal content length in bytes. + * + * @return The packet reference. + * @return NULL on error. + * + */ +packet_t *packet_get_1_remote(async_sess_t *sess, size_t content) +{ + async_exch_t *exch = async_exchange_begin(sess); sysarg_t packet_id; sysarg_t size; - int rc; - - rc = async_obsolete_req_1_2(phone, NET_PACKET_CREATE_1, content, &packet_id, + int rc = async_req_1_2(exch, NET_PACKET_CREATE_1, content, &packet_id, &size); + async_exchange_end(exch); + if (rc != EOK) return NULL; @@ -193,5 +201,5 @@ packet_t *packet = pm_find(packet_id); if (!packet) { - rc = packet_return(phone, &packet, packet_id, size); + rc = packet_return(sess, &packet, packet_id, size); if (rc != EOK) return NULL; @@ -201,5 +209,5 @@ } -/** Releases the packet queue. +/** Release the packet queue. * * All packets in the queue are marked as free for use. @@ -208,10 +216,13 @@ * received or obtained again. * - * @param[in] phone The packet server module phone. - * @param[in] packet_id The packet identifier. - */ -void pq_release_remote(int phone, packet_id_t packet_id) -{ - async_obsolete_msg_1(phone, NET_PACKET_RELEASE, packet_id); + * @param[in] sess Packet server module session. + * @param[in] packet_id Packet identifier. + * + */ +void pq_release_remote(async_sess_t *sess, packet_id_t packet_id) +{ + async_exch_t *exch = async_exchange_begin(sess); + async_msg_1(exch, NET_PACKET_RELEASE, packet_id); + async_exchange_end(exch); }