blob: f3e8e6065f7bb4f184c528cdea3e5fa75b4fa035 [file] [log] [blame]
/*
* Copyright (C) 2019 The Android Open Source Project
*
* 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.
*/
#pragma once
#include <android-base/macros.h>
#include <android-base/unique_fd.h>
#include <linux/can.h>
#include <atomic>
#include <chrono>
#include <functional>
#include <thread>
namespace android::hardware::automotive::can::V1_0::implementation {
/** Wrapper around SocketCAN socket. */
struct CanSocket {
using ReadCallback = std::function<void(const struct canfd_frame&, std::chrono::nanoseconds)>;
using ErrorCallback = std::function<void(int errnoVal)>;
/**
* Open and bind SocketCAN socket.
*
* \param ifname SocketCAN network interface name (such as can0)
* \param rdcb Callback on received messages
* \param errcb Callback on socket failure
* \return Socket instance, or nullptr if it wasn't possible to open one
*/
static std::unique_ptr<CanSocket> open(const std::string& ifname, ReadCallback rdcb,
ErrorCallback errcb);
virtual ~CanSocket();
/**
* Send CAN frame.
*
* \param frame Frame to send
* \return true in case of success, false otherwise
*/
bool send(const struct canfd_frame& frame);
private:
CanSocket(base::unique_fd socket, ReadCallback rdcb, ErrorCallback errcb);
void readerThread();
ReadCallback mReadCallback;
ErrorCallback mErrorCallback;
const base::unique_fd mSocket;
std::thread mReaderThread;
std::atomic<bool> mStopReaderThread = false;
std::atomic<bool> mReaderThreadFinished = false;
DISALLOW_COPY_AND_ASSIGN(CanSocket);
};
} // namespace android::hardware::automotive::can::V1_0::implementation