orbbec-sdk-sys 0.1.2+2.5.5

Low-level Rust bindings for https://github.com/orbbec/OrbbecSDK_v2
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88

// Copyright (c) Orbbec Inc. All Rights Reserved.
// Licensed under the MIT License.

#include "ObUsageEnvironment.hpp"

#include "logger/Logger.hpp"

namespace libobsensor {

ObUsageEnvironment::ObUsageEnvironment(TaskScheduler &taskScheduler) : BasicUsageEnvironment(taskScheduler), destroy_(false), newLog_(false) {
    outputLogThread_ = std::thread(&ObUsageEnvironment::outputLog, this);
}

ObUsageEnvironment::~ObUsageEnvironment() {
    destroy_ = true;
    newLogCv_.notify_all();
    outputLogThread_.join();
}

ObUsageEnvironment *ObUsageEnvironment::createNew(TaskScheduler &taskScheduler) {
    return new ObUsageEnvironment(taskScheduler);
}

void ObUsageEnvironment::outputLog() {
    while(!destroy_) {
        std::unique_lock<std::mutex> lk(mutex_);
        newLogCv_.wait(lk, [&]() { return newLog_ || destroy_; });
        newLogCv_.wait_for(lk, std::chrono::microseconds(100), [&]() {
            bool exit = !newLog_ || destroy_;
            newLog_   = false;
            return exit;
        });

        if(logMsg_.length() && !destroy_) {
            LOG_DEBUG(logMsg_);
            logMsg_.clear();
        }
    }
}

UsageEnvironment &ObUsageEnvironment::operator<<(char const *str) {
    std::unique_lock<std::mutex> lk(mutex_);
    if(str == nullptr) {
        logMsg_ += "(NULL)";  // sanity check
    }
    else {
        logMsg_ += str;
    }
    newLog_ = true;
    newLogCv_.notify_all();
    return dynamic_cast<UsageEnvironment &>(*this);
}

UsageEnvironment &ObUsageEnvironment::operator<<(int i) {
    std::unique_lock<std::mutex> lk(mutex_);
    logMsg_ += std::to_string(i);
    newLog_ = true;
    newLogCv_.notify_all();
    return dynamic_cast<UsageEnvironment &>(*this);
}

UsageEnvironment &ObUsageEnvironment::operator<<(unsigned u) {
    std::unique_lock<std::mutex> lk(mutex_);
    logMsg_ += std::to_string(u);
    newLog_ = true;
    newLogCv_.notify_all();
    return dynamic_cast<UsageEnvironment &>(*this);
}

UsageEnvironment &ObUsageEnvironment::operator<<(double d) {
    std::unique_lock<std::mutex> lk(mutex_);
    logMsg_ += std::to_string(d);
    newLog_ = true;
    newLogCv_.notify_all();
    return dynamic_cast<UsageEnvironment &>(*this);
}

UsageEnvironment &ObUsageEnvironment::operator<<(void *p) {
    std::unique_lock<std::mutex> lk(mutex_);
    logMsg_ += std::to_string((uint64_t)p);
    newLog_ = true;
    newLogCv_.notify_all();
    return dynamic_cast<UsageEnvironment &>(*this);
}


}  // namespace libobsensor