added max-age and content-format
Fork of mbedConnectorInterface by
api/ThreadedResourceObserver.cpp
- Committer:
- ansond
- Date:
- 2015-04-07
- Revision:
- 30:113c2a1d8db2
- Child:
- 31:bacc63106754
File content as of revision 30:113c2a1d8db2:
/** * @file ThreadedResourceObserver.cpp * @brief mbed CoAP DynamicResource Thread-based observer (implementation) * @author Doug Anson/Chris Paola * @version 1.0 * @see * * Copyright (c) 2014 * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ #include "ThreadedResourceObserver.h" // constructor ThreadedResourceObserver::ThreadedResourceObserver(DynamicResource *resource,int sleep_time_ms) : ResourceObserver(resource), m_begin_observation(false), m_observation_thread(&ThreadedResourceObserver::_observation_notifier,this), m_sleep_time_ms(sleep_time_ms) { } // destructor ThreadedResourceObserver::~ThreadedResourceObserver() { this->m_observation_thread.terminate(); } // notifier void ThreadedResourceObserver::_observation_notifier(void const *args) { ThreadedResourceObserver *me = (ThreadedResourceObserver *)args; while(true) { Thread::wait(me->m_sleep_time_ms); if (me->m_begin_observation == true && me->m_resource != NULL) { me->m_resource->observe(); } } } // begin observing... void ThreadedResourceObserver::beginObservation() { this->m_begin_observation = true; }