This directory contains network protocols that are part of
the TinyOS core distribution. They are:
-ctp: Collection Tree Protocol (TEP 123)
-dip: DIssemination Protocol (TEP 1xx)
-rstp: Root Sequenced Tree Protocol (TEP 124)
+ctp: Collection Tree Protocol (TEP 123), a collection (TEP 119) protocol
+drip: Drip, a dissemination (TEP 118) protocol
+le: Link Estimation Exchange Protocol (TEP 124)
+lqi: MultihopLQI, a collection (TEP 119) protocol
--- /dev/null
+#include <DisseminationEngine.h>
+
+/*
+ * Copyright (c) 2006 Arch Rock Corporation
+ * All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions
+ * are met:
+ * - Redistributions of source code must retain the above copyright
+ * notice, this list of conditions and the following disclaimer.
+ * - Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the
+ * distribution.
+ * - Neither the name of the Arch Rock Corporation nor the names of
+ * its contributors may be used to endorse or promote products derived
+ * from this software without specific prior written permission.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS
+ * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE
+ * ARCHED ROCK OR ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT,
+ * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
+ * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
+ * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
+ * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT,
+ * STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
+ * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED
+ * OF THE POSSIBILITY OF SUCH DAMAGE
+ *
+ */
+
+/**
+ * The DisseminationC component is the top-level interface to the
+ * dissemination protocol. StdControl controls all of the trickle
+ * timers used for all of the keys.
+ *
+ * See TEP118 - Dissemination for details.
+ *
+ * @author Gilman Tolle <gtolle@archrock.com>
+ * @version $Revision$
+ */
+
+configuration DisseminationC {
+ provides interface StdControl;
+}
+implementation {
+ components DisseminationEngineP;
+ StdControl = DisseminationEngineP;
+}
--- /dev/null
+
+/*
+ * Copyright (c) 2006 Arch Rock Corporation
+ * All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions
+ * are met:
+ * - Redistributions of source code must retain the above copyright
+ * notice, this list of conditions and the following disclaimer.
+ * - Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the
+ * distribution.
+ * - Neither the name of the Arch Rock Corporation nor the names of
+ * its contributors may be used to endorse or promote products derived
+ * from this software without specific prior written permission.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS
+ * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE
+ * ARCHED ROCK OR ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT,
+ * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
+ * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
+ * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
+ * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT,
+ * STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
+ * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED
+ * OF THE POSSIBILITY OF SUCH DAMAGE
+ *
+ */
+
+/**
+ * The DisseminationCache interface connects each DisseminatorC
+ * component to the DisseminationEngineC component.
+ *
+ * See TEP118 - Dissemination for details.
+ *
+ * @author Gilman Tolle <gtolle@archrock.com>
+ * @version $Revision$ $Date$
+ */
+
+interface DisseminationCache {
+ event error_t start();
+ event error_t stop();
+ command void* requestData( uint8_t* size );
+ command void storeData( void* data, uint8_t size, uint32_t seqno );
+ command uint32_t requestSeqno();
+ event void newData();
+}
--- /dev/null
+#ifndef DISSEMINATION_ENGINE_H
+#define DISSEMINATION_ENGINE_H
+
+/*
+ * Copyright (c) 2006 Arched Rock Corporation
+ * All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions
+ * are met:
+ * - Redistributions of source code must retain the above copyright
+ * notice, this list of conditions and the following disclaimer.
+ * - Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the
+ * distribution.
+ * - Neither the name of the Arched Rock Corporation nor the names of
+ * its contributors may be used to endorse or promote products derived
+ * from this software without specific prior written permission.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS
+ * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE
+ * ARCHED ROCK OR ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT,
+ * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
+ * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
+ * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
+ * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT,
+ * STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
+ * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED
+ * OF THE POSSIBILITY OF SUCH DAMAGE
+ *
+ */
+
+/*
+ * TODO: Add a tiebreaker and an application GUID to the header
+ */
+
+enum {
+ AM_DISSEMINATION_MESSAGE = 13,
+ AM_DISSEMINATION_PROBE_MESSAGE = 14,
+ DISSEMINATION_SEQNO_UNKNOWN = 0,
+};
+
+typedef nx_struct dissemination_message {
+ nx_uint16_t key;
+ nx_uint32_t seqno;
+ nx_uint8_t data[0];
+} dissemination_message_t;
+
+typedef nx_struct dissemination_probe_message {
+ nx_uint16_t key;
+} dissemination_probe_message_t;
+
+#endif
+
--- /dev/null
+#include <DisseminationEngine.h>
+
+/*
+ * Copyright (c) 2006 Arch Rock Corporation
+ * All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions
+ * are met:
+ * - Redistributions of source code must retain the above copyright
+ * notice, this list of conditions and the following disclaimer.
+ * - Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the
+ * distribution.
+ * - Neither the name of the Arch Rock Corporation nor the names of
+ * its contributors may be used to endorse or promote products derived
+ * from this software without specific prior written permission.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS
+ * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE
+ * ARCHED ROCK OR ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT,
+ * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
+ * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
+ * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
+ * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT,
+ * STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
+ * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED
+ * OF THE POSSIBILITY OF SUCH DAMAGE
+ *
+ */
+
+/**
+ * The DisseminationEngineImplP component implements the dissemination
+ * logic.
+ *
+ * See TEP118 - Dissemination for details.
+ *
+ * @author Gilman Tolle <gtolle@archrock.com>
+ * @version $Revision$ $Date$
+ */
+
+module DisseminationEngineImplP {
+ provides interface StdControl;
+
+ uses {
+ interface DisseminationCache[uint16_t key];
+ interface TrickleTimer[uint16_t key];
+ interface StdControl as DisseminatorControl[uint16_t id];
+
+ interface AMSend;
+ interface Receive;
+
+ interface AMSend as ProbeAMSend;
+ interface Receive as ProbeReceive;
+
+ interface Leds;
+ }
+}
+implementation {
+
+ enum { NUM_DISSEMINATORS = uniqueCount("DisseminationTimerC.TrickleTimer") };
+
+ message_t m_buf;
+ bool m_running;
+ bool m_bufBusy;
+
+ void sendProbe( uint16_t key );
+ void sendObject( uint16_t key );
+
+ command error_t StdControl.start() {
+ uint8_t i;
+ for ( i = 0; i < NUM_DISSEMINATORS; i++ ) {
+ call DisseminatorControl.start[ i ]();
+ }
+ m_running = TRUE;
+ return SUCCESS;
+ }
+
+ command error_t StdControl.stop() {
+ uint8_t i;
+ for ( i = 0; i < NUM_DISSEMINATORS; i++ ) {
+ call DisseminatorControl.stop[ i ]();
+ }
+ m_running = FALSE;
+ return SUCCESS;
+ }
+
+ event error_t DisseminationCache.start[ uint16_t key ]() {
+ error_t result = call TrickleTimer.start[ key ]();
+ call TrickleTimer.reset[ key ]();
+ return result;
+ }
+
+ event error_t DisseminationCache.stop[ uint16_t key ]() {
+ call TrickleTimer.stop[ key ]();
+ return SUCCESS;
+ }
+
+ event void DisseminationCache.newData[ uint16_t key ]() {
+
+ if ( !m_running || m_bufBusy ) { return; }
+
+ sendObject( key );
+ call TrickleTimer.reset[ key ]();
+ }
+
+ event void TrickleTimer.fired[ uint16_t key ]() {
+
+ if ( !m_running || m_bufBusy ) { return; }
+
+ sendObject( key );
+ }
+
+ void sendProbe( uint16_t key ) {
+ dissemination_probe_message_t* dpMsg =
+ (dissemination_probe_message_t*) call ProbeAMSend.getPayload( &m_buf, sizeof(dissemination_probe_message_t));
+ if (dpMsg != NULL) {
+ m_bufBusy = TRUE;
+
+ dpMsg->key = key;
+
+ call ProbeAMSend.send( AM_BROADCAST_ADDR, &m_buf,
+ sizeof( dissemination_probe_message_t ) );
+ }
+ }
+
+ void sendObject( uint16_t key ) {
+ void* object;
+ uint8_t objectSize = 0;
+
+ dissemination_message_t* dMsg =
+ (dissemination_message_t*) call AMSend.getPayload( &m_buf, sizeof(dissemination_message_t) );
+ if (dMsg != NULL) {
+ m_bufBusy = TRUE;
+
+ dMsg->key = key;
+ dMsg->seqno = call DisseminationCache.requestSeqno[ key ]();
+
+ if ( dMsg->seqno != DISSEMINATION_SEQNO_UNKNOWN ) {
+ object = call DisseminationCache.requestData[ key ]( &objectSize );
+ if ((objectSize + sizeof(dissemination_message_t)) >
+ call AMSend.maxPayloadLength()) {
+ objectSize = call AMSend.maxPayloadLength() - sizeof(dissemination_message_t);
+ }
+ memcpy( dMsg->data, object, objectSize );
+ }
+ call AMSend.send( AM_BROADCAST_ADDR,
+ &m_buf, sizeof( dissemination_message_t ) + objectSize );
+ }
+ }
+
+ event void ProbeAMSend.sendDone( message_t* msg, error_t error ) {
+ m_bufBusy = FALSE;
+ }
+
+ event void AMSend.sendDone( message_t* msg, error_t error ) {
+ m_bufBusy = FALSE;
+ }
+
+ event message_t* Receive.receive( message_t* msg,
+ void* payload,
+ uint8_t len ) {
+
+ dissemination_message_t* dMsg =
+ (dissemination_message_t*) payload;
+
+ uint16_t key = dMsg->key;
+ uint32_t incomingSeqno = dMsg->seqno;
+ uint32_t currentSeqno = call DisseminationCache.requestSeqno[ key ]();
+
+ if ( !m_running ) { return msg; }
+
+ if ( currentSeqno == DISSEMINATION_SEQNO_UNKNOWN &&
+ incomingSeqno != DISSEMINATION_SEQNO_UNKNOWN ) {
+
+ call DisseminationCache.storeData[ key ]
+ ( dMsg->data,
+ len - sizeof( dissemination_message_t ),
+ incomingSeqno );
+
+ call TrickleTimer.reset[ key ]();
+ return msg;
+ }
+
+ if ( incomingSeqno == DISSEMINATION_SEQNO_UNKNOWN &&
+ currentSeqno != DISSEMINATION_SEQNO_UNKNOWN ) {
+
+ call TrickleTimer.reset[ key ]();
+ return msg;
+ }
+
+ if ( (int32_t)( incomingSeqno - currentSeqno ) > 0 ) {
+
+ call DisseminationCache.storeData[key]
+ ( dMsg->data,
+ len - sizeof(dissemination_message_t),
+ incomingSeqno );
+ dbg("Dissemination", "Received dissemination value 0x%08x,0x%08x @ %s\n", (int)key, (int)incomingSeqno, sim_time_string());
+ call TrickleTimer.reset[ key ]();
+
+ } else if ( (int32_t)( incomingSeqno - currentSeqno ) == 0 ) {
+
+ call TrickleTimer.incrementCounter[ key ]();
+
+ } else {
+
+ // Still not sure which of these is the best. Immediate send for now.
+ sendObject( key );
+ // call TrickleTimer.reset[ key ]();
+
+ }
+
+ return msg;
+ }
+
+ event message_t* ProbeReceive.receive( message_t* msg,
+ void* payload,
+ uint8_t len) {
+
+ dissemination_probe_message_t* dpMsg =
+ (dissemination_probe_message_t*) payload;
+
+ if ( !m_running ) { return msg; }
+
+ if ( call DisseminationCache.requestSeqno[ dpMsg->key ]() !=
+ DISSEMINATION_SEQNO_UNKNOWN ) {
+ sendObject( dpMsg->key );
+ }
+
+ return msg;
+ }
+
+ default command void*
+ DisseminationCache.requestData[uint16_t key]( uint8_t* size ) { return NULL; }
+
+ default command void
+ DisseminationCache.storeData[uint16_t key]( void* data,
+ uint8_t size,
+ uint32_t seqno ) {}
+
+ default command uint32_t
+ DisseminationCache.requestSeqno[uint16_t key]() { return DISSEMINATION_SEQNO_UNKNOWN; }
+
+ default command error_t TrickleTimer.start[uint16_t key]() { return FAIL; }
+
+ default command void TrickleTimer.stop[uint16_t key]() { }
+
+ default command void TrickleTimer.reset[uint16_t key]() { }
+
+ default command void TrickleTimer.incrementCounter[uint16_t key]() { }
+
+ default command error_t DisseminatorControl.start[uint16_t id]() { return FAIL; }
+ default command error_t DisseminatorControl.stop[uint16_t id]() { return FAIL; }
+}
--- /dev/null
+#include <DisseminationEngine.h>
+
+/*
+ * Copyright (c) 2006 Arch Rock Corporation
+ * All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions
+ * are met:
+ * - Redistributions of source code must retain the above copyright
+ * notice, this list of conditions and the following disclaimer.
+ * - Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the
+ * distribution.
+ * - Neither the name of the Arch Rock Corporation nor the names of
+ * its contributors may be used to endorse or promote products derived
+ * from this software without specific prior written permission.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS
+ * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE
+ * ARCHED ROCK OR ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT,
+ * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
+ * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
+ * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
+ * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT,
+ * STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
+ * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED
+ * OF THE POSSIBILITY OF SUCH DAMAGE
+ *
+ */
+
+/**
+ * The DisseminationEngineP component retrieves values from the
+ * DisseminatorP components and disseminates them over the radio.
+ *
+ * TODO: Hook DisseminationProbe up to the serial instead of the radio.
+ *
+ * See TEP118 - Dissemination for details.
+ *
+ * @author Gilman Tolle <gtolle@archrock.com>
+ * @version $Revision$ $Date$
+ */
+
+configuration DisseminationEngineP {
+ provides interface StdControl;
+
+ uses {
+ interface DisseminationCache[uint16_t key];
+ interface TrickleTimer[uint16_t key];
+ interface StdControl as DisseminatorControl[uint16_t id];
+ }
+}
+implementation {
+ components DisseminationEngineImplP;
+ StdControl = DisseminationEngineImplP;
+ DisseminationCache = DisseminationEngineImplP;
+ TrickleTimer = DisseminationEngineImplP;
+ DisseminatorControl = DisseminationEngineImplP;
+
+ components new AMSenderC(AM_DISSEMINATION_MESSAGE) as DisseminationSendC;
+ DisseminationEngineImplP.AMSend -> DisseminationSendC.AMSend;
+
+ components new AMReceiverC(AM_DISSEMINATION_MESSAGE) as DisseminationReceiveC;
+ DisseminationEngineImplP.Receive -> DisseminationReceiveC.Receive;
+
+ components new AMSenderC(AM_DISSEMINATION_PROBE_MESSAGE) as DisseminationProbeSendC;
+ DisseminationEngineImplP.ProbeAMSend -> DisseminationProbeSendC.AMSend;
+
+ components new AMReceiverC(AM_DISSEMINATION_PROBE_MESSAGE)
+ as DisseminationProbeReceiveC;
+ DisseminationEngineImplP.ProbeReceive -> DisseminationProbeReceiveC.Receive;
+
+ components NoLedsC;
+ DisseminationEngineImplP.Leds -> NoLedsC;
+}
--- /dev/null
+
+/*
+ * Copyright (c) 2006 Arch Rock Corporation
+ * All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions
+ * are met:
+ * - Redistributions of source code must retain the above copyright
+ * notice, this list of conditions and the following disclaimer.
+ * - Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the
+ * distribution.
+ * - Neither the name of the Arch Rock Corporation nor the names of
+ * its contributors may be used to endorse or promote products derived
+ * from this software without specific prior written permission.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS
+ * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE
+ * ARCHED ROCK OR ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT,
+ * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
+ * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
+ * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
+ * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT,
+ * STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
+ * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED
+ * OF THE POSSIBILITY OF SUCH DAMAGE
+ *
+ */
+
+/*
+ * The DisseminationTimerP component maintains a set of Trickle timers
+ * and is wired to DisseminationEngineC once for each DisseminatorC.
+ *
+ * See TEP118 - Dissemination for details.
+ *
+ * @author Gilman Tolle <gtolle@archrock.com>
+ * @version $Revision$ $Date$
+ */
+
+configuration DisseminationTimerP {
+ provides interface TrickleTimer[uint8_t id];
+}
+implementation {
+ components new TrickleTimerMilliC(1, 1024, 1,
+ uniqueCount("DisseminationTimerC.TrickleTimer"));
+ TrickleTimer = TrickleTimerMilliC;
+}
--- /dev/null
+#include <DisseminationEngine.h>
+
+/*
+ * Copyright (c) 2006 Arch Rock Corporation
+ * All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions
+ * are met:
+ * - Redistributions of source code must retain the above copyright
+ * notice, this list of conditions and the following disclaimer.
+ * - Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the
+ * distribution.
+ * - Neither the name of the Arch Rock Corporation nor the names of
+ * its contributors may be used to endorse or promote products derived
+ * from this software without specific prior written permission.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS
+ * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE
+ * ARCHED ROCK OR ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT,
+ * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
+ * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
+ * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
+ * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT,
+ * STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
+ * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED
+ * OF THE POSSIBILITY OF SUCH DAMAGE
+ *
+ */
+
+/**
+ * The DisseminatorC component holds and synchronizes a single value
+ * of a chosen type, and identifies that value by a chosen 16-bit key.
+ * Different nodes should use the same key for the same value.
+ *
+ * See TEP118 - Dissemination for details.
+ *
+ * @param t the type of the object that will be disseminated
+ * @param key the 16-bit identifier of the disseminated object
+ *
+ * @author Gilman Tolle <gtolle@archrock.com>
+ * @version $Revision$ $Date$
+ */
+
+generic configuration DisseminatorC(typedef t, uint16_t key) {
+ provides interface DisseminationValue<t>;
+ provides interface DisseminationUpdate<t>;
+}
+implementation {
+ enum {
+ TIMER_ID = unique("DisseminationTimerC.TrickleTimer")
+ };
+
+ components new DisseminatorP(t);
+ DisseminationValue = DisseminatorP;
+ DisseminationUpdate = DisseminatorP;
+
+ components DisseminationEngineP;
+ DisseminationEngineP.DisseminationCache[key] -> DisseminatorP;
+ DisseminationEngineP.DisseminatorControl[TIMER_ID] -> DisseminatorP;
+
+ components DisseminationTimerP;
+ DisseminationEngineP.TrickleTimer[key] ->
+ DisseminationTimerP.TrickleTimer[TIMER_ID];
+
+ components LedsC;
+ DisseminatorP.Leds -> LedsC;
+}
--- /dev/null
+/*
+ * Copyright (c) 2006 Arch Rock Corporation
+ * All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions
+ * are met:
+ * - Redistributions of source code must retain the above copyright
+ * notice, this list of conditions and the following disclaimer.
+ * - Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the
+ * distribution.
+ * - Neither the name of the Arch Rock Corporation nor the names of
+ * its contributors may be used to endorse or promote products derived
+ * from this software without specific prior written permission.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS
+ * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE
+ * ARCHED ROCK OR ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT,
+ * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
+ * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
+ * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
+ * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT,
+ * STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
+ * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED
+ * OF THE POSSIBILITY OF SUCH DAMAGE
+ *
+ */
+
+/**
+ * The DisseminatorP module holds and synchronizes a single value of a
+ * chosen type.
+ *
+ * See TEP118 - Dissemination for details.
+ *
+ * @param t the type of the object that will be disseminated
+ *
+ * @author Gilman Tolle <gtolle@archrock.com>
+ * @version $Revision$ $Date$
+ */
+
+generic module DisseminatorP(typedef t) {
+ provides interface StdControl;
+
+ provides interface DisseminationValue<t>;
+ provides interface DisseminationUpdate<t>;
+ provides interface DisseminationCache;
+
+ uses interface Leds;
+}
+implementation {
+ t valueCache;
+ bool m_running;
+
+ // A sequence number is 32 bits. The top 16 bits are an incrementing
+ // counter, while the bottom 16 bits are a unique node identifier.
+ uint32_t seqno = DISSEMINATION_SEQNO_UNKNOWN;
+
+ command error_t StdControl.start() {
+ error_t result = signal DisseminationCache.start();
+ if ( result == SUCCESS ) { m_running = TRUE; }
+ return result;
+ }
+
+ command error_t StdControl.stop() {
+ if ( !m_running ) { return EOFF; }
+ m_running = FALSE;
+ return signal DisseminationCache.stop();
+ }
+
+ command const t* DisseminationValue.get() {
+ return &valueCache;
+ }
+
+ command void DisseminationValue.set( const t* val ) {
+ valueCache = *val;
+ }
+
+ command void DisseminationUpdate.change( t* newVal ) {
+ if ( !m_running ) { return; }
+ memcpy( &valueCache, newVal, sizeof(t) );
+ /* Increment the counter and append the local node ID. */
+ seqno = seqno >> 16;
+ seqno++;
+ if ( seqno == DISSEMINATION_SEQNO_UNKNOWN ) { seqno++; }
+ seqno = seqno << 16;
+ seqno += TOS_NODE_ID;
+ signal DisseminationCache.newData();
+ }
+
+ command void* DisseminationCache.requestData( uint8_t* size ) {
+ *size = sizeof(t);
+ return &valueCache;
+ }
+
+ command void DisseminationCache.storeData( void* data, uint8_t size,
+ uint32_t newSeqno ) {
+ memcpy( &valueCache, data, size < sizeof(t) ? size : sizeof(t) );
+ seqno = newSeqno;
+ signal DisseminationValue.changed();
+ }
+
+ command uint32_t DisseminationCache.requestSeqno() {
+ return seqno;
+ }
+
+ default event void DisseminationValue.changed() { }
+}
projects / tinyos-2.x.git / commitdiff