pipe.h

Go to the documentation of this file.

/*
 * Copyright (c) 2022 Trackunit Corporation
 *
 * SPDX-License-Identifier: Apache-2.0
 */
 
#include <zephyr/types.h>
#include <zephyr/kernel.h>
 
#ifndef ZEPHYR_MODEM_PIPE_
#define ZEPHYR_MODEM_PIPE_
 
#ifdef __cplusplus
extern "C" {
#endif


enum modem_pipe_event {
        MODEM_PIPE_EVENT_OPENED = 0,
        MODEM_PIPE_EVENT_RECEIVE_READY,
        MODEM_PIPE_EVENT_TRANSMIT_IDLE,
        MODEM_PIPE_EVENT_CLOSED,
};

 
struct modem_pipe;

 
typedef void (*modem_pipe_api_callback)(struct modem_pipe *pipe, enum modem_pipe_event event,
                                        void *user_data);

 
typedef int (*modem_pipe_api_open)(void *data);
 
typedef int (*modem_pipe_api_transmit)(void *data, const uint8_t *buf, size_t size);
 
typedef int (*modem_pipe_api_receive)(void *data, uint8_t *buf, size_t size);
 
typedef int (*modem_pipe_api_close)(void *data);
 
struct modem_pipe_api {
        modem_pipe_api_open open;
        modem_pipe_api_transmit transmit;
        modem_pipe_api_receive receive;
        modem_pipe_api_close close;
};
 
struct modem_pipe {
        void *data;
        const struct modem_pipe_api *api;
        modem_pipe_api_callback callback;
        void *user_data;
        struct k_spinlock spinlock;
        struct k_event event;
};

void modem_pipe_init(struct modem_pipe *pipe, void *data, const struct modem_pipe_api *api);


int modem_pipe_open(struct modem_pipe *pipe, k_timeout_t timeout);

int modem_pipe_open_async(struct modem_pipe *pipe);

void modem_pipe_attach(struct modem_pipe *pipe, modem_pipe_api_callback callback, void *user_data);

int modem_pipe_transmit(struct modem_pipe *pipe, const uint8_t *buf, size_t size);

int modem_pipe_receive(struct modem_pipe *pipe, uint8_t *buf, size_t size);

void modem_pipe_release(struct modem_pipe *pipe);

int modem_pipe_close(struct modem_pipe *pipe, k_timeout_t timeout);

int modem_pipe_close_async(struct modem_pipe *pipe);


void modem_pipe_notify_opened(struct modem_pipe *pipe);

void modem_pipe_notify_closed(struct modem_pipe *pipe);

void modem_pipe_notify_receive_ready(struct modem_pipe *pipe);

void modem_pipe_notify_transmit_idle(struct modem_pipe *pipe);


 
#ifdef __cplusplus
}
#endif
 
#endif /* ZEPHYR_MODEM_PIPE_ */