Subversion Repositories HelenOS

Rev

Rev 3912 | Rev 4192 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

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&nbsp;new packet aligned to the memory page size if none available.
113
 *  Creates a&nbsp;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&nbsp;new packet of dimensions at least as given.
125
/** Creates a&nbsp;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;