Changeset bb322a0 in rtems
- Timestamp:
- 08/22/95 15:37:59 (28 years ago)
- Branches:
- 4.10, 4.11, 4.8, 4.9, 5, master
- Children:
- da6375b
- Parents:
- b2c491a0
- Files:
-
- 5 edited
Legend:
- Unmodified
- Added
- Removed
-
c/src/exec/rtems/macros/message.inl
rb2c491a0 rbb322a0 23 23 */ 24 24 25 #define _Message_queue_Copy_buffer( _source, _destination ) \25 #define _Message_queue_Copy_buffer( _source, _destination, _size ) \ 26 26 memcpy( _destination, _source, _size) 27 27 … … 32 32 */ 33 33 34 #define _Message_queue_Allocate_message_buffer( ) \35 36 _Chain_Get( &_Message_queue_Inactive_messages )34 #define _Message_queue_Allocate_message_buffer( _the_message_queue ) \ 35 (Message_queue_Buffer_control *) \ 36 _Chain_Get( &(_the_message_queue)->Inactive_messages ) 37 37 38 38 /*PAGE … … 42 42 */ 43 43 44 #define _Message_queue_Free_message_buffer( _the_message ) \ 45 _Chain_Append( &_Message_queue_Inactive_messages, &(_the_message)->Node ) 44 #define _Message_queue_Free_message_buffer( _the_message_queue, _the_message ) \ 45 _Chain_Append( \ 46 &(_the_message_queue)->Inactive_messages, \ 47 &(_the_message)->Node \ 48 ) 46 49 47 50 /*PAGE … … 93 96 do { \ 94 97 \ 95 if ( (_the_mess sage_queue)->message_buffers ) { \98 if ( (_the_message_queue)->message_buffers ) { \ 96 99 _Workspace_Free((void *) (_the_message_queue)->message_buffers); \ 97 100 (_the_message_queue)->message_buffers = 0; \ 98 } 101 } \ 99 102 \ 100 103 _Objects_Free( \ -
c/src/exec/rtems/macros/rtems/rtems/message.inl
rb2c491a0 rbb322a0 23 23 */ 24 24 25 #define _Message_queue_Copy_buffer( _source, _destination ) \25 #define _Message_queue_Copy_buffer( _source, _destination, _size ) \ 26 26 memcpy( _destination, _source, _size) 27 27 … … 32 32 */ 33 33 34 #define _Message_queue_Allocate_message_buffer( ) \35 36 _Chain_Get( &_Message_queue_Inactive_messages )34 #define _Message_queue_Allocate_message_buffer( _the_message_queue ) \ 35 (Message_queue_Buffer_control *) \ 36 _Chain_Get( &(_the_message_queue)->Inactive_messages ) 37 37 38 38 /*PAGE … … 42 42 */ 43 43 44 #define _Message_queue_Free_message_buffer( _the_message ) \ 45 _Chain_Append( &_Message_queue_Inactive_messages, &(_the_message)->Node ) 44 #define _Message_queue_Free_message_buffer( _the_message_queue, _the_message ) \ 45 _Chain_Append( \ 46 &(_the_message_queue)->Inactive_messages, \ 47 &(_the_message)->Node \ 48 ) 46 49 47 50 /*PAGE … … 93 96 do { \ 94 97 \ 95 if ( (_the_mess sage_queue)->message_buffers ) { \98 if ( (_the_message_queue)->message_buffers ) { \ 96 99 _Workspace_Free((void *) (_the_message_queue)->message_buffers); \ 97 100 (_the_message_queue)->message_buffers = 0; \ 98 } 101 } \ 99 102 \ 100 103 _Objects_Free( \ -
c/src/exec/rtems/src/msg.c
rb2c491a0 rbb322a0 69 69 unsigned32 allocated_message_size; 70 70 71 mq = (Message_queue_Control *)_Objects_Allocate(&_Message_queue_Information); 71 mq = \ 72 (Message_queue_Control *)_Objects_Allocate(&_Message_queue_Information); 73 72 74 if (mq == 0) 73 75 goto failed; … … 80 82 81 83 allocated_message_size = max_message_size; 82 if (allocated_message_size & (sizeof(unsigned32) - 1)) 83 { 84 if (allocated_message_size & (sizeof(unsigned32) - 1)) { 84 85 allocated_message_size += sizeof(unsigned32); 85 86 allocated_message_size &= ~(sizeof(unsigned32) - 1); 86 87 } 87 88 88 message_buffering_required = count * (allocated_message_size + sizeof(Message_queue_Buffer_control)); 89 message_buffering_required = 90 count * (allocated_message_size + sizeof(Message_queue_Buffer_control)); 89 91 90 mq->message_buffers = (Message_queue_Buffer *) _Workspace_Allocate(message_buffering_required); 92 mq->message_buffers = 93 (Message_queue_Buffer *) _Workspace_Allocate(message_buffering_required); 94 91 95 if (mq->message_buffers == 0) 92 96 goto failed; 93 97 94 _Chain_Initialize(&mq->Inactive_messages, 95 mq->message_buffers, 96 count, 97 allocated_message_size + sizeof(Message_queue_Buffer_control)); 98 _Chain_Initialize 99 (&mq->Inactive_messages, 100 mq->message_buffers, 101 count, 102 allocated_message_size + sizeof(Message_queue_Buffer_control) 103 ); 98 104 return mq; 99 105 -
cpukit/rtems/macros/rtems/rtems/message.inl
rb2c491a0 rbb322a0 23 23 */ 24 24 25 #define _Message_queue_Copy_buffer( _source, _destination ) \25 #define _Message_queue_Copy_buffer( _source, _destination, _size ) \ 26 26 memcpy( _destination, _source, _size) 27 27 … … 32 32 */ 33 33 34 #define _Message_queue_Allocate_message_buffer( ) \35 36 _Chain_Get( &_Message_queue_Inactive_messages )34 #define _Message_queue_Allocate_message_buffer( _the_message_queue ) \ 35 (Message_queue_Buffer_control *) \ 36 _Chain_Get( &(_the_message_queue)->Inactive_messages ) 37 37 38 38 /*PAGE … … 42 42 */ 43 43 44 #define _Message_queue_Free_message_buffer( _the_message ) \ 45 _Chain_Append( &_Message_queue_Inactive_messages, &(_the_message)->Node ) 44 #define _Message_queue_Free_message_buffer( _the_message_queue, _the_message ) \ 45 _Chain_Append( \ 46 &(_the_message_queue)->Inactive_messages, \ 47 &(_the_message)->Node \ 48 ) 46 49 47 50 /*PAGE … … 93 96 do { \ 94 97 \ 95 if ( (_the_mess sage_queue)->message_buffers ) { \98 if ( (_the_message_queue)->message_buffers ) { \ 96 99 _Workspace_Free((void *) (_the_message_queue)->message_buffers); \ 97 100 (_the_message_queue)->message_buffers = 0; \ 98 } 101 } \ 99 102 \ 100 103 _Objects_Free( \ -
cpukit/rtems/src/msg.c
rb2c491a0 rbb322a0 69 69 unsigned32 allocated_message_size; 70 70 71 mq = (Message_queue_Control *)_Objects_Allocate(&_Message_queue_Information); 71 mq = \ 72 (Message_queue_Control *)_Objects_Allocate(&_Message_queue_Information); 73 72 74 if (mq == 0) 73 75 goto failed; … … 80 82 81 83 allocated_message_size = max_message_size; 82 if (allocated_message_size & (sizeof(unsigned32) - 1)) 83 { 84 if (allocated_message_size & (sizeof(unsigned32) - 1)) { 84 85 allocated_message_size += sizeof(unsigned32); 85 86 allocated_message_size &= ~(sizeof(unsigned32) - 1); 86 87 } 87 88 88 message_buffering_required = count * (allocated_message_size + sizeof(Message_queue_Buffer_control)); 89 message_buffering_required = 90 count * (allocated_message_size + sizeof(Message_queue_Buffer_control)); 89 91 90 mq->message_buffers = (Message_queue_Buffer *) _Workspace_Allocate(message_buffering_required); 92 mq->message_buffers = 93 (Message_queue_Buffer *) _Workspace_Allocate(message_buffering_required); 94 91 95 if (mq->message_buffers == 0) 92 96 goto failed; 93 97 94 _Chain_Initialize(&mq->Inactive_messages, 95 mq->message_buffers, 96 count, 97 allocated_message_size + sizeof(Message_queue_Buffer_control)); 98 _Chain_Initialize 99 (&mq->Inactive_messages, 100 mq->message_buffers, 101 count, 102 allocated_message_size + sizeof(Message_queue_Buffer_control) 103 ); 98 104 return mq; 99 105
Note: See TracChangeset
for help on using the changeset viewer.