Pipe API¶

Oasis Pipe는 프로세스간 통신(IPC)를 지원합니다.

oasis 네임스페이스를 사용합니다.

영상이나 오디오 데이터 전송에 특화되어 있습니다. 영상 데이터를 v4l2loopback 장치에 쓸 때 유용합니다.

Oasis Pipe는 다른 Oasis 컴포넌트에 의존적이지 않고, oasis::initialize 없이도 사용가능하므로 Oasis를 사용하지 않는 응용프로그램에서도 liboasis_pipe.so 라이브러리를 링크하며 사용할 수 있습니다.

헤더 파일¶

OasisPipe.h

형정의¶

Oasis Pipe가 지원하는 데이터 포맷은 아래와 같습니다. 영상의 경우, V4L2 포맷과 호환됩니다.

enum {
  kOasisPipeDataTypeUserData = 0,
  kOasisPipeDataTypeVideoBGRA,
  kOasisPipeDataTypeVideoARGB,
  kOasisPipeDataTypeVideoYUYV,
  kOasisPipeDataTypeVideoYVYU,
  kOasisPipeDataTypeVideoYUV420,
  kOasisPipeDataTypeVideoYVU420,
  kOasisPipeDataTypeVideoNV12,
  kOasisPipeDataTypeVideoNV21,
  kOasisPipeDataTypeAudioPCM16LE,
  kOasisPipeDataTypeAudioPCM16BE,

  //in case of the following types, width_or_sampling_rate, height_or_channels, stride_or_bits_per_sample are ignored.
  kOasisPipeDataTypeVideoH264,
  kOasisPipeDataTypeVideoH265,
  kOasisPipeDataTypeVideoVP8,
  kOasisPipeDataTypeVideoVP9,
  kOasisPipeDataTypeVideoMJPEG,
};

아래와 같이 변환됩니다.

아래와 같이 변환됩니다.

Writer¶

에러 이벤트 콜백 함수는 아래와 같습니다.

Reader¶

읽기 콜백 함수 형정의는 아래와 같습니다.

예제¶

아래는 한 프로세스에서 다른 프로세스에 OFFS 포맷을 파이프로 요청하고 그 응답을 파이프로 받는 예입니다.

JSON 처리를 위해 JsonCpp 라이브러리를 사용합니다.

명령 요청 프로세스¶

읽기 쓰기 파이프를 생성하고 각각 콜백을 등록합니다.

OasisPipeReaderRef pipe_reader_ = pipeReaderOpen("/tmp/oasis-mon-res");
pipeReaderSetCallback(pipe_reader_, std::bind(&onPipeCommandCompleted, _1, _2, _3, _4, _5, _6, _7));

OasisPipeWriterRef pipe_writer_ = pipeWriterOpen("/tmp/oasis-mon-req");
pipeWriterSetErrorCallback(pipe_writer_, std::bind(&onPipeCommandWriteError, _1, _2, _3, _4), nullptr);

읽기 콜백 함수입니다.

void onPipeCommandCompleted(const void *data, size_t length, int32_t width, int32_t height, int32_t stride, int32_t data_type, uint32_t flags)
{
  std::string reply((const char*)data, (const char*)data+length);

  Json::Value json_reply;
  Json::Reader reader;
  bool parsing_ok = reader.parse(reply.c_str(), json_reply);
  if(!parsing_ok) {
    return;
  }

  if(json_reply.isMember("result")) {
    //결과를 확인합니다.
    int32_t result = std::stoi(json_reply["result"].asString());
  }
}

쓰기 오류 이벤트 콜백 함수입니다.

void DashApp::onPipeCommandWriteError(int32_t error, const void *data, size_t length, void *user)
{
}

명령 수행 프로세스에 OFFS format 명령을 전달합니다.

Json::Value json_req;
json_req["cmd"] = "format";

Json::FastWriter fastWriter;
std::string json_string = fastWriter.write(json_req);

pipeWriterWrite(pipe_writer_, json_string.c_str(), json_string.length(), 0, 0, 0, 0, 0);

명령 수행 프로세스¶

읽기 쓰기 파이프를 생성하고 각각 콜백을 등록합니다. 명령 요청 프로세스에서 사용하는 경로가 각각 바뀌어서 사용됩니다.

// 명령을 수행하고 결과를 명령 요청 프로세스에게 전달합니다.
OasisPipeWriterRef writer = pipeWriterOpen("/tmp/oasis-mon-res");

// 명령 요청 프로세스로 부터 명령 요청 메세지를 읽습니다.
OasisPipeReaderRef reader = pipeReaderOpen("/tmp/oasis-mon-req");
pipeReaderSetCallback(reader, std::bind(&onCommand, _1, _2, _3, _4, _5, _6, _7));

명령 읽는 콜백 함수입니다.

static void onCommand(const void *data, size_t length, int32_t width, int32_t height, int32_t stride, int32_t data_type, uint32_t flags)
{
  if(length == 0) {
    //nothing to do
    return;
  }

  std::string cmd((const char *)data, (const char *)data+length);

  Json::Value json_req;
  Json::Reader reader;
  bool parsing_ok = reader.parse(cmd.c_str(), json_req);
  if(!parsing_ok) {
    fprintf(stdout, "pipe req: json parsing error: %s\n", cmd.c_str());
    continue;
  }

  if(json_req.isMember("cmd") == false) {
    fprintf(stdout, "pipe req: \"cmd\" not found!: %s\n", cmd.c_str());
    continue;
  }

  std::string req_cmd = json_req["cmd"].asString();
  if(req_cmd == "format") {
    //파일 시스템 포맷을 진행합니다.
    char shell_cmd[PATH_MAX];
    int32_t req_cmd_result = 0;
    sprintf(shell_cmd, "/usr/sbin/mkfs.offs /dev/mmcblk0p1 /etc/offs-format.cfg 32GB_DRV");
    err = runCommand(shell_cmd);
    if(err) {
      req_cmd_result = -err;
    }

    Json::Value json_reply;

    json_reply["result"] = std::to_string(req_cmd_result);
    json_reply["cmd"] = req_cmd;

    Json::FastWriter fastWriter;
    std::string json_string = fastWriter.write(json_reply);

    pipeWriterWrite(writer, json_string.c_str(), json_string.length(), 0, 0, 0, 0, 0);
  }
}

popen 함수를 이용하여 명령을 수행하는 함수입니다.

#define MAXLINE 4096

static int32_t runCommand(const char *shell_cmd)
{
    char buff[MAXLINE];
    FILE *fp;

    fp = popen(shell_cmd, "r");
    if(fp == NULL) {
        fprintf(stderr, "\"%s\" popen error: %d(%s)\n", shell_cmd, errno, strerror(errno));
        return -errno;
    }

    while(fgets(buff, MAXLINE, fp) != NULL) {
        fprintf(stdout, "%s", buff);
        fflush(stdout);
    }

    return (int32_t)(int8_t)pclose(fp);
}