WebSVN – HelenOS – Diff – /branches/network/uspace/srv/net/structures/packet/packet_server.c



 
/** @file
 *  Packet server implementation.
 */
 
 
#include <align.h>
#include <async.h>
#include <errno.h>
#include <futex.h>
//#include <stdio.h>
#include <unistd.h>
 
#include <ipc/ipc.h>
#include <ipc/services.h>

#define FREE_QUEUES_COUNT   7
 
/** Packet server global data.
 */
static struct{
    /** Safety lock.
     */
    futex_t lock;
    /** Free packet queues.
     */
    packet_t free[ FREE_QUEUES_COUNT ];
    /** Packet length upper bounds of the free packet queues.
     *  The maximal lengths of packets in each queue in the ascending order.

    int sizes[ FREE_QUEUES_COUNT ];
    /** Total packets allocated.
     */
    unsigned int count;
} ps_globals = {
    { 1 },
    { NULL, NULL, NULL, NULL, NULL, NULL, NULL },
    { PAGE_SIZE, PAGE_SIZE * 2, PAGE_SIZE * 4, PAGE_SIZE * 8, PAGE_SIZE * 16, PAGE_SIZE * 32, PAGE_SIZE * 64 },
    0
};
 
/** Releases the packet and returns it to the appropriate free packet queue.
 *  Should be used only when the global data are locked.
 *  @param packet The packet to be released. Input parameter.
 */
void packet_release( packet_t packet );
 
/** Returns the packet of dimensions at least as given.
 *  Tries to reuse free packets first.
 *  Creates a&nbsp;new packet aligned to the memory page size if none available.
 *  Locks the global data during its processing.
 *  @param owner The new owner of the packet. Input parameter.
 *  @param addr_len The source and destination addresses maximal length in bytes. Input parameter.
 *  @param max_prefix The maximal prefix length in bytes. Input parameter.
 *  @param max_content The maximal content length in bytes. Input parameter.
 *  @param max_suffix The maximal suffix length in bytes. Input parameter.

 *  @returns NULL if there is not enough memory left.
 */
packet_t packet_get( services_t owner, size_t addr_len, size_t max_prefix, size_t max_content, size_t max_suffix );
 
/** Creates a&nbsp;new packet of dimensions at least as given.
 *  Should be used only when the global data are locked.
 *  @param length The total length of the packet, including the header, the addresses and the data of the packet. Input parameter.
 *  @param owner The new owner of the packet. Input parameter.
 *  @param addr_len The source and destination addresses maximal length in bytes. Input parameter.
 *  @param max_prefix The maximal prefix length in bytes. Input parameter.
 *  @param max_content The maximal content length in bytes. Input parameter.

            IPC_SET_ARG1( * answer, packet->length );
            return EOK;
        case NET_PACKET_RELEASE:
            packet = pm_find( IPC_GET_ID( call ));
            if( ! packet_is_valid( packet )) return ENOENT;
            futex_down( & ps_globals.lock );
            pq_destroy( packet, packet_release );
            futex_up( & ps_globals.lock );
            return EOK;
    }
    return ENOTSUP;
}
 

    int index;
    packet_t packet;
    size_t length;
 
    length = ALIGN_UP( sizeof( struct packet ) + 2 * addr_len + max_prefix + max_content + max_suffix, PAGE_SIZE );
    futex_down( & ps_globals.lock );
    for( index = 0; index < FREE_QUEUES_COUNT - 1; ++ index ){
        if( length <= ps_globals.sizes[ index ] ){
            packet = ps_globals.free[ index ];
            while( packet_is_valid( packet ) && ( packet->length < length )){
                packet = pm_find( packet->next );
            }
            if( packet ){
                packet_init( packet, owner, addr_len, max_prefix, max_content, max_suffix );
                futex_up( & ps_globals.lock );
                return packet;
            }
        }
    }
    packet = packet_create( length, owner, addr_len, max_prefix, max_content, max_suffix );
    futex_up( & ps_globals.lock );
    return packet;
}
 
packet_t packet_create( size_t length, services_t owner, size_t addr_len, size_t max_prefix, size_t max_content, size_t max_suffix ){
    ERROR_DECLARE;
 
    packet_t    packet;
 
    // already locked
    packet = ( packet_t ) mmap( NULL, length, PROTO_READ | PROTO_WRITE, MAP_SHARED | MAP_ANONYMOUS, 0, 0 );
    if( packet == MAP_FAILED ) return NULL;
    ++ ps_globals.count;
    packet->packet_id = ps_globals.count;
    packet->mode = PM_ONE_WAY;

Rev 3912	Rev 3914
Line 32...	Line 32...
32		32
33	/** @file	33	/** @file
34	* Packet server implementation.	34	* Packet server implementation.
35	*/	35	*/
36		36
37	#include <async.h>	-
38	#include <align.h>	37	#include <align.h>
-		38	#include <async.h>
39	#include <errno.h>	39	#include <errno.h>
-		40	#include <futex.h>
40	//#include <stdio.h>	41	//#include <stdio.h>
41	#include <unistd.h>	42	#include <unistd.h>
42		43
43	#include <ipc/ipc.h>	44	#include <ipc/ipc.h>
44	#include <ipc/services.h>	45	#include <ipc/services.h>
Line 78...	Line 79...
78	#define FREE_QUEUES_COUNT 7	79	#define FREE_QUEUES_COUNT 7
79		80
80	/** Packet server global data.	81	/** Packet server global data.
81	*/	82	*/
82	static struct{	83	static struct{
-		84	/** Safety lock.
-		85	*/
-		86	futex_t lock;
83	/** Free packet queues.	87	/** Free packet queues.
84	*/	88	*/
85	packet_t free[ FREE_QUEUES_COUNT ];	89	packet_t free[ FREE_QUEUES_COUNT ];
86	/** Packet length upper bounds of the free packet queues.	90	/** Packet length upper bounds of the free packet queues.
87	* The maximal lengths of packets in each queue in the ascending order.	91	* The maximal lengths of packets in each queue in the ascending order.
Line 90...	Line 94...
90	int sizes[ FREE_QUEUES_COUNT ];	94	int sizes[ FREE_QUEUES_COUNT ];
91	/** Total packets allocated.	95	/** Total packets allocated.
92	*/	96	*/
93	unsigned int count;	97	unsigned int count;
94	} ps_globals = {	98	} ps_globals = {
-		99	{ 1 },
95	{ NULL, NULL, NULL, NULL, NULL, NULL, NULL },	100	{ NULL, NULL, NULL, NULL, NULL, NULL, NULL },
96	{ PAGE_SIZE, PAGE_SIZE * 2, PAGE_SIZE * 4, PAGE_SIZE * 8, PAGE_SIZE * 16, PAGE_SIZE * 32, PAGE_SIZE * 64 },	101	{ PAGE_SIZE, PAGE_SIZE * 2, PAGE_SIZE * 4, PAGE_SIZE * 8, PAGE_SIZE * 16, PAGE_SIZE * 32, PAGE_SIZE * 64 },
97	0	102	0
98	};	103	};
99		104
100	/** Releases the packet and returns it to the appropriate free packet queue.	105	/** Releases the packet and returns it to the appropriate free packet queue.
-		106	* Should be used only when the global data are locked.
101	* @param packet The packet to be released. Input parameter.	107	* @param packet The packet to be released. Input parameter.
102	*/	108	*/
103	void packet_release( packet_t packet );	109	void packet_release( packet_t packet );
104		110
105	/** Returns the packet of dimensions at least as given.	111	/** Returns the packet of dimensions at least as given.
106	* Tries to reuse free packets first.	112	* Tries to reuse free packets first.
107	* Creates a new packet aligned to the memory page size if none available.	113	* Creates a new packet aligned to the memory page size if none available.
-		114	* Locks the global data during its processing.
108	* @param owner The new owner of the packet. Input parameter.	115	* @param owner The new owner of the packet. Input parameter.
109	* @param addr_len The source and destination addresses maximal length in bytes. Input parameter.	116	* @param addr_len The source and destination addresses maximal length in bytes. Input parameter.
110	* @param max_prefix The maximal prefix length in bytes. Input parameter.	117	* @param max_prefix The maximal prefix length in bytes. Input parameter.
111	* @param max_content The maximal content length in bytes. Input parameter.	118	* @param max_content The maximal content length in bytes. Input parameter.
112	* @param max_suffix The maximal suffix length in bytes. Input parameter.	119	* @param max_suffix The maximal suffix length in bytes. Input parameter.
Line 114...	Line 121...
114	* @returns NULL if there is not enough memory left.	121	* @returns NULL if there is not enough memory left.
115	*/	122	*/
116	packet_t packet_get( services_t owner, size_t addr_len, size_t max_prefix, size_t max_content, size_t max_suffix );	123	packet_t packet_get( services_t owner, size_t addr_len, size_t max_prefix, size_t max_content, size_t max_suffix );
117		124
118	/** Creates a new packet of dimensions at least as given.	125	/** Creates a new packet of dimensions at least as given.
-		126	* Should be used only when the global data are locked.
119	* @param length The total length of the packet, including the header, the addresses and the data of the packet. Input parameter.	127	* @param length The total length of the packet, including the header, the addresses and the data of the packet. Input parameter.
120	* @param owner The new owner of the packet. Input parameter.	128	* @param owner The new owner of the packet. Input parameter.
121	* @param addr_len The source and destination addresses maximal length in bytes. Input parameter.	129	* @param addr_len The source and destination addresses maximal length in bytes. Input parameter.
122	* @param max_prefix The maximal prefix length in bytes. Input parameter.	130	* @param max_prefix The maximal prefix length in bytes. Input parameter.
123	* @param max_content The maximal content length in bytes. Input parameter.	131	* @param max_content The maximal content length in bytes. Input parameter.
Line 179...	Line 187...
179	IPC_SET_ARG1( * answer, packet->length );	187	IPC_SET_ARG1( * answer, packet->length );
180	return EOK;	188	return EOK;
181	case NET_PACKET_RELEASE:	189	case NET_PACKET_RELEASE:
182	packet = pm_find( IPC_GET_ID( call ));	190	packet = pm_find( IPC_GET_ID( call ));
183	if( ! packet_is_valid( packet )) return ENOENT;	191	if( ! packet_is_valid( packet )) return ENOENT;
-		192	futex_down( & ps_globals.lock );
184	pq_destroy( packet, packet_release );	193	pq_destroy( packet, packet_release );
-		194	futex_up( & ps_globals.lock );
185	return EOK;	195	return EOK;
186	}	196	}
187	return ENOTSUP;	197	return ENOTSUP;
188	}	198	}
189		199
Line 198...	Line 208...
198	int index;	208	int index;
199	packet_t packet;	209	packet_t packet;
200	size_t length;	210	size_t length;
201		211
202	length = ALIGN_UP( sizeof( struct packet ) + 2 * addr_len + max_prefix + max_content + max_suffix, PAGE_SIZE );	212	length = ALIGN_UP( sizeof( struct packet ) + 2 * addr_len + max_prefix + max_content + max_suffix, PAGE_SIZE );
-		213	futex_down( & ps_globals.lock );
203	for( index = 0; index < FREE_QUEUES_COUNT - 1; ++ index ){	214	for( index = 0; index < FREE_QUEUES_COUNT - 1; ++ index ){
204	if( length <= ps_globals.sizes[ index ] ){	215	if( length <= ps_globals.sizes[ index ] ){
205	packet = ps_globals.free[ index ];	216	packet = ps_globals.free[ index ];
206	while( packet_is_valid( packet ) && ( packet->length < length )){	217	while( packet_is_valid( packet ) && ( packet->length < length )){
207	packet = pm_find( packet->next );	218	packet = pm_find( packet->next );
208	}	219	}
209	if( packet ){	220	if( packet ){
210	packet_init( packet, owner, addr_len, max_prefix, max_content, max_suffix );	221	packet_init( packet, owner, addr_len, max_prefix, max_content, max_suffix );
-		222	futex_up( & ps_globals.lock );
211	return packet;	223	return packet;
212	}	224	}
213	}	225	}
214	}	226	}
215	return packet_create( length, owner, addr_len, max_prefix, max_content, max_suffix );	227	packet = packet_create( length, owner, addr_len, max_prefix, max_content, max_suffix );
-		228	futex_up( & ps_globals.lock );
-		229	return packet;
216	}	230	}
217		231
218	packet_t packet_create( size_t length, services_t owner, size_t addr_len, size_t max_prefix, size_t max_content, size_t max_suffix ){	232	packet_t packet_create( size_t length, services_t owner, size_t addr_len, size_t max_prefix, size_t max_content, size_t max_suffix ){
219	ERROR_DECLARE;	233	ERROR_DECLARE;
220		234
221	packet_t packet;	235	packet_t packet;
222		236
-		237	// already locked
223	packet = ( packet_t ) mmap( NULL, length, PROTO_READ \| PROTO_WRITE, MAP_SHARED \| MAP_ANONYMOUS, 0, 0 );	238	packet = ( packet_t ) mmap( NULL, length, PROTO_READ \| PROTO_WRITE, MAP_SHARED \| MAP_ANONYMOUS, 0, 0 );
224	if( packet == MAP_FAILED ) return NULL;	239	if( packet == MAP_FAILED ) return NULL;
225	++ ps_globals.count;	240	++ ps_globals.count;
226	packet->packet_id = ps_globals.count;	241	packet->packet_id = ps_globals.count;
227	packet->mode = PM_ONE_WAY;	242	packet->mode = PM_ONE_WAY;

Subversion Repositories HelenOS

(root)/branches/network/uspace/srv/net/structures/packet/packet_server.c – Rev 3912 → 3914