include/native/pipe.h

Go to the documentation of this file.

#ifndef _XENO_PIPE_H
#define _XENO_PIPE_H

#include <nucleus/pipe.h>
#include <nucleus/heap.h>
#include <native/types.h>

/* Operation flags. */
#define P_NORMAL  XNPIPE_NORMAL
#define P_URGENT  XNPIPE_URGENT

#define P_MINOR_AUTO    XNPIPE_MINOR_AUTO

#define P_EVENT_INPUT   1
#define P_EVENT_OUTPUT  2
#define P_EVENT_CLOSE   3
#define P_EVENT_NOBUF   4

typedef struct rt_pipe_placeholder {
    xnhandle_t opaque;
} RT_PIPE_PLACEHOLDER;

#ifdef __KERNEL__

#include <native/ppd.h>

#define XENO_PIPE_MAGIC  0x55550202

#define P_SYNCWAIT  0
#define P_ATOMIC    1

typedef xnpipe_mh_t RT_PIPE_MSG;

#define P_MSGPTR(msg)  xnpipe_m_data(msg)
#define P_MSGSIZE(msg) xnpipe_m_size(msg)

typedef struct rt_pipe {

    unsigned magic;             /* !< Magic code -- must be first. */

    xnholder_t link;            /* !< Link in flush queue. */

#define link2rtpipe(ln) container_of(ln, RT_PIPE, link)

    int minor;                  /* !< Device minor number.  */

    RT_PIPE_MSG *buffer;        /* !< Buffer used in byte stream mode. */

    xnheap_t *bufpool;         /* !< Current buffer pool. */

    int (*monitor)(struct rt_pipe *pipe, int event, long arg);

    xnheap_t privpool;         /* !< Private buffer pool. */

    size_t fillsz;              /* !< Bytes written to the buffer.  */

    u_long status;              /* !< Status information. */

    xnhandle_t handle;          /* !< Handle in registry -- zero if unregistered. */

    char name[XNOBJECT_NAME_LEN]; /* !< Symbolic name. */

#ifdef CONFIG_XENO_OPT_PERVASIVE
    pid_t cpid;                 /* !< Creator's pid. */
#endif /* CONFIG_XENO_OPT_PERVASIVE */

    xnholder_t rlink;           /* !< Link in resource queue. */

#define rlink2pipe(ln)          container_of(ln, RT_PIPE, rlink)

    xnqueue_t *rqueue;          /* !< Backpointer to resource queue. */

} RT_PIPE;

#else /* !__KERNEL__ */

typedef RT_PIPE_PLACEHOLDER RT_PIPE;

#endif /* __KERNEL__ */

#ifdef __cplusplus
extern "C" {
#endif

/* Public interface. */

int rt_pipe_create(RT_PIPE *pipe,
                   const char *name,
                   int minor,
                   size_t poolsize);

int rt_pipe_delete(RT_PIPE *pipe);

ssize_t rt_pipe_read(RT_PIPE *pipe,
                     void *buf,
                     size_t size,
                     RTIME timeout);

ssize_t rt_pipe_write(RT_PIPE *pipe,
                      const void *buf,
                      size_t size,
                      int mode);

ssize_t rt_pipe_stream(RT_PIPE *pipe,
                       const void *buf,
                       size_t size);

#ifdef __KERNEL__

ssize_t rt_pipe_receive(RT_PIPE *pipe,
                        RT_PIPE_MSG **msg,
                        RTIME timeout);

ssize_t rt_pipe_send(RT_PIPE *pipe,
                     RT_PIPE_MSG *msg,
                     size_t size,
                     int mode);

RT_PIPE_MSG *rt_pipe_alloc(RT_PIPE *pipe,
                           size_t size);

int rt_pipe_free(RT_PIPE *pipe,
                 RT_PIPE_MSG *msg);

int rt_pipe_flush(RT_PIPE *pipe,
                  int mode);

int rt_pipe_monitor(RT_PIPE *pipe,
                    int (*fn)(RT_PIPE *pipe, int event, long arg));

#else /* !__KERNEL__ */

int rt_pipe_bind(RT_PIPE *pipe,
                 const char *name,
                 RTIME timeout);

static inline int rt_pipe_unbind(RT_PIPE *pipe)
{
    pipe->opaque = XN_NO_HANDLE;
    return 0;
}

#endif /* __KERNEL__ */

#ifdef CONFIG_XENO_OPT_NATIVE_PIPE

int __native_pipe_pkg_init(void);

void __native_pipe_pkg_cleanup(void);

static inline void __native_pipe_flush_rq(xnqueue_t *rq)
{
        xeno_flush_rq_norelease(RT_PIPE, rq, pipe);
}

#else /* !CONFIG_XENO_OPT_NATIVE_PIPE */

#define __native_pipe_pkg_init()                ({ 0; })
#define __native_pipe_pkg_cleanup()             do { } while(0)
#define __native_pipe_flush_rq(rq)              do { } while(0)

#endif /* !CONFIG_XENO_OPT_NATIVE_PIPE */

#ifdef __cplusplus
}
#endif

#endif /* !_XENO_PIPE_H */