Wiselib
|
00001 #ifndef MESSAGEQUEUE_H_ 00002 #define MESSAGEQUEUE_H_ 00003 00004 #include "algorithms/bgu_clustering/Message.h" 00005 #include "algorithms/bgu_clustering/utils.h" 00006 #include "util/pstl/queue_static.h" 00007 00008 namespace wiselib{ 00009 00010 00013 class MessageQueue 00014 { 00015 public: 00016 MessageQueue(); 00017 virtual ~MessageQueue(); 00018 00024 void receiveBuffer( Radio::node_id_t from, Radio::size_t len, Radio::block_data_t *buf ); 00025 00030 Message* nextMessage(); 00031 00032 private: 00033 static const size_t MAX_MQUEUE_SIZE=10; 00034 00035 queue_static<Os,Message*, MAX_MQUEUE_SIZE> _mqueue; 00036 00037 }; 00038 00039 } 00040 #endif /* MESSAGEQUEUE_H_ */