tun2socks 0.0.1

High performance tun2socks
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
89
90
91
92
93
94
95
96

/*
 ============================================================================
 Name        : hev-task-channel-private.h
 Author      : Heiher <r@hev.cc>
 Copyright   : Copyright (c) 2019 everyone.
 Description : Channel
 ============================================================================
 */

#ifndef __HEV_TASK_CHANNEL_PRIVATE_H__
#define __HEV_TASK_CHANNEL_PRIVATE_H__

#include "lib/list/hev-list.h"
#include "kern/task/hev-task.h"

#include "hev-task-channel-select.h"

#ifdef __cplusplus
extern "C" {
#endif

typedef union _HevTaskChannelData HevTaskChannelData;
typedef struct _HevTaskChannelBuffer HevTaskChannelBuffer;

union _HevTaskChannelData
{
    char b[0];
    short h[0];
    int w[0];
    long long d[0];
};

struct _HevTaskChannelBuffer
{
    size_t size;
    HevTaskChannelData *data;
};

struct _HevTaskChannel
{
    HevTaskChannel *peer;

    struct
    {
        HevListNode node;
        int used;
    } read;
    struct
    {
        HevListNode node;
        int used;
    } write;
    HevListNode chan_node;

    HevTask *task;
    HevTaskChannelSelect *select;

    unsigned int rd_idx;
    unsigned int wr_idx;
    unsigned int max_size;
    unsigned int use_count;
    unsigned int max_count;
    unsigned int ref_count;

    HevTaskChannelBuffer buffers[0];
};

static inline int
hev_task_channel_is_active (HevTaskChannel *self)
{
    return READ_ONCE (self->peer) != NULL;
}

static inline int
hev_task_channel_is_readable (HevTaskChannel *self)
{
    return READ_ONCE (self->use_count) != 0;
}

static inline int
hev_task_channel_is_writable (HevTaskChannel *peer)
{
    return READ_ONCE (peer->use_count) < READ_ONCE (peer->max_count);
}

static inline int
hev_task_channel_is_select_writable (HevTaskChannel *peer)
{
    return READ_ONCE (peer->use_count) < (READ_ONCE (peer->max_count) - 1);
}

#ifdef __cplusplus
}
#endif

#endif /* __HEV_TASK_CHANNEL_PRIVATE_H__ */