| /dports/databases/tile38/tile38-1.12.0/vendor/github.com/streadway/amqp/ |
| H A D | channel.go | 27 type Channel struct { struct
28 destructor sync.Once
36 consumers *consumers
38 id uint16
41 closed int32
44 noNotify bool
47 closes []chan *Error
51 flows []chan bool
63 confirming bool
66 errors chan *Error
[all …]
|
| /dports/irc/ergo/ergo-2.8.0/irc/ |
| H A D | channel.go | 30 type Channel struct { struct
33 key string
34 forward string
37 name string
38 nameCasefolded string
41 registeredFounder string
43 transferPendingTo string
44 topic string
45 topicSetBy string
47 userLimit int
[all …]
|
| /dports/net/nsq/nsq-1.2.1/nsqd/ |
| H A D | channel.go | 37 type Channel struct { struct
39 requeueCount uint64
40 messageCount uint64
41 timeoutCount uint64
43 sync.RWMutex
45 topicName string
46 name string
47 nsqd *NSQD
49 backend BackendQueue
52 exitFlag int32
[all …]
|
| /dports/net-im/matterbridge/matterbridge-1.22.3/vendor/layeh.com/gumble/gumble/ |
| H A D | channel.go | 9 type Channel struct { struct
11 ID uint32
13 Name string
15 Parent *Channel
17 Children Channels
19 Links Channels
21 Users Users
31 MaxUsers uint32
33 Position int32
35 Temporary bool
[all …]
|
| /dports/www/beehive/beehive-0.4.0/vendor/layeh.com/gumble/gumble/ |
| H A D | channel.go | 9 type Channel struct { struct
11 ID uint32
13 Name string
15 Parent *Channel
17 Children Channels
19 Links Channels
21 Users Users
31 MaxUsers uint32
33 Position int32
35 Temporary bool
[all …]
|
| /dports/www/beehive/beehive-0.4.0/vendor/github.com/muesli/go-pkg-rss/ |
| H A D | channel.go | 3 type Channel struct { struct
4 Title string
5 Links []Link
6 Description string
7 Language string
8 Copyright string
16 TTL int
27 Id string
28 Rights string
29 Author Author
[all …]
|
| /dports/audio/zrythm/zrythm-1.0.0-alpha.26.0.13/inc/audio/ |
| H A D | channel.h | 79 typedef struct Channel struct
103 ChannelSend * sends[STRIP_SIZE]; argument
112 * if \ref Channel.all_midi_ins is not enabled. argument
117 int num_ext_midi_ins;
121 int all_midi_ins;
140 int all_stereo_l_ins;
176 Fader * fader;
183 Fader * prefader;
213 /** Channel widget width - reserved for future argument
221 ChannelWidget * widget; argument
[all …]
|
| /dports/devel/pecl-swoole/swoole-4.8.5/include/ |
| H A D | swoole_channel.h | 33 struct Channel { struct
34 off_t head;
35 off_t tail;
36 size_t size;
39 int num;
40 int max_num;
45 int flags;
46 int maxlen;
50 void *mem;
51 Lock *lock;
[all …]
|
| /dports/irc/komanda-cli/komanda-cli-b5ba03b/komanda/client/ |
| H A D | channel.go | 50 type Channel struct { struct
51 Status bool
52 Ready bool
53 Unread bool
54 Highlight bool
55 Name string
57 MaxX int
58 MaxY int
63 NickListReady bool
65 Private bool
[all …]
|
| /dports/security/ncrack/ncrack-0.7/opensshlib/ |
| H A D | channels.h | 95 struct Channel { struct
123 Buffer extended;
124 char *path;
131 u_int remote_window;
133 u_int local_window;
135 u_int local_consumed;
146 int detach_close;
152 void *filter_ctx;
156 int datagram;
163 void *mux_ctx;
[all …]
|
| /dports/security/gnome-ssh-askpass/openssh-6.6p1/ |
| H A D | channels.h | 93 struct Channel { struct
121 Buffer extended;
122 char *path;
129 u_int remote_window;
131 u_int local_window;
133 u_int local_consumed;
144 int detach_close;
150 void *filter_ctx;
154 int datagram;
161 void *mux_ctx;
[all …]
|
| /dports/security/openssh-portable/openssh-8.8p1/ |
| H A D | channels.h | 125 struct Channel { struct
159 char *path;
166 u_int remote_window;
168 u_int local_window;
170 u_int local_consumed;
171 u_int local_maxpacket;
181 int detach_close;
187 void *filter_ctx;
191 int datagram;
199 void *mux_ctx;
[all …]
|
| /dports/security/dropbear/dropbear-2020.81/ |
| H A D | channel.h | 51 struct Channel { struct
53 unsigned int index; /* the local channel index */
54 unsigned int remotechan;
55 unsigned int recvwindow, transwindow;
56 unsigned int recvdonelen;
57 unsigned int recvmaxpacket, transmaxpacket;
58 void* typedata; /* a pointer to type specific data */
59 int writefd; /* read from wire, written to insecure side */
83 void (*read_mangler)(const struct Channel*, const unsigned char* bytes, int *len); argument
95 int (*inithandler)(struct Channel*); argument
|
| /dports/games/libretro-scummvm/scummvm-7b1e929/engines/kyra/sound/drivers/ |
| H A D | adlib.h | 104 struct Channel { struct
105 bool lock; // New to ScummVM
106 uint8 opExtraLevel2;
107 const uint8 *dataptr;
108 uint8 duration;
109 uint8 repeatCounter;
133 typedef void (AdLibDriver::*Callback)(Channel&); argument
157 void primaryEffect1(Channel &channel); argument
|
| /dports/net-im/matterbridge/matterbridge-1.22.3/vendor/github.com/yaegashi/msgraph.go/beta/ |
| H A D | ModelChannel.go | 6 type Channel struct { struct
8 Entity
10 DisplayName *string `json:"displayName,omitempty"`
12 Description *string `json:"description,omitempty"`
14 IsFavoriteByDefault *bool `json:"isFavoriteByDefault,omitempty"`
16 Email *string `json:"email,omitempty"`
18 WebURL *string `json:"webUrl,omitempty"`
22 Messages []ChatMessage `json:"messages,omitempty"`
24 Tabs []TeamsTab `json:"tabs,omitempty"`
26 Members []ConversationMember `json:"members,omitempty"`
[all …]
|
| /dports/audio/giada/giada-0.17.1/src/core/ |
| H A D | patch.h | 61 struct Channel struct
64 ChannelType type; argument
65 int height;
66 std::string name;
67 ID columnId;
68 int key;
69 bool mute;
70 bool solo;
74 bool armed;
75 bool midiIn;
[all …]
|
| /dports/games/libretro-scummvm/scummvm-7b1e929/engines/bladerunner/ |
| H A D | audio_mixer.h | 47 struct Channel { struct
65 Channel _channels[kChannels]; argument
|
| /dports/games/scummvm/scummvm-2.5.1/engines/bladerunner/ |
| H A D | audio_mixer.h | 56 struct Channel { struct
77 Channel _channels[kChannels]; argument
|
| /dports/security/xray-core/Xray-core-1.5.0/app/stats/ |
| H A D | channel.go | 11 type Channel struct { struct
35 // Subscribers implements stats.Channel.
42 // Subscribe implements stats.Channel.
54 // Unsubscribe implements stats.Channel.
70 // Publish implements stats.Channel.
71 func (c *Channel) Publish(ctx context.Context, msg interface{}) {
86 func (c *Channel) Running() bool {
98 func (c *Channel) Start() error {
128 func (c *Channel) Close() error {
|
| /dports/net/v2ray/v2ray-core-4.36.2/app/stats/ |
| H A D | channel.go | 13 type Channel struct { struct
37 // Subscribers implements stats.Channel.
44 // Subscribe implements stats.Channel.
56 // Unsubscribe implements stats.Channel.
72 // Publish implements stats.Channel.
73 func (c *Channel) Publish(ctx context.Context, msg interface{}) {
88 func (c *Channel) Running() bool {
100 func (c *Channel) Start() error {
130 func (c *Channel) Close() error {
|
| /dports/www/libdatachannel/libdatachannel-0.16.1/src/impl/ |
| H A D | channel.hpp | 30 struct Channel { struct
45 synchronized_stored_callback<> openCallback;
46 synchronized_stored_callback<> closedCallback;
47 synchronized_stored_callback<string> errorCallback;
48 synchronized_stored_callback<> availableCallback;
49 synchronized_stored_callback<> bufferedAmountLowCallback;
51 synchronized_callback<message_variant> messageCallback;
53 std::atomic<size_t> bufferedAmount = 0;
54 std::atomic<size_t> bufferedAmountLowThreshold = 0;
57 std::atomic<bool> mOpenTriggered = false;
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/cortexproject/cortex/vendor/github.com/prometheus/alertmanager/cluster/ |
| H A D | channel.go | 30 type Channel struct { struct
31 key string
32 send func([]byte)
33 peers func() []*memberlist.Node
34 sendOversize func(*memberlist.Node, []byte) error
36 msgc chan []byte
37 logger log.Logger
39 oversizeGossipMessageFailureTotal prometheus.Counter
40 oversizeGossipMessageDroppedTotal prometheus.Counter
41 oversizeGossipMessageSentTotal prometheus.Counter
[all …]
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/vendor/github.com/prometheus/alertmanager/cluster/ |
| H A D | channel.go | 30 type Channel struct { struct
31 key string
32 send func([]byte)
33 peers func() []*memberlist.Node
34 sendOversize func(*memberlist.Node, []byte) error
36 msgc chan []byte
37 logger log.Logger
39 oversizeGossipMessageFailureTotal prometheus.Counter
40 oversizeGossipMessageDroppedTotal prometheus.Counter
41 oversizeGossipMessageSentTotal prometheus.Counter
[all …]
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/prometheus/alertmanager/cluster/ |
| H A D | channel.go | 30 type Channel struct { struct
31 key string
32 send func([]byte)
33 peers func() []*memberlist.Node
34 sendOversize func(*memberlist.Node, []byte) error
36 msgc chan []byte
37 logger log.Logger
39 oversizeGossipMessageFailureTotal prometheus.Counter
40 oversizeGossipMessageDroppedTotal prometheus.Counter
41 oversizeGossipMessageSentTotal prometheus.Counter
[all …]
|
| /dports/net-mgmt/thanos/thanos-0.11.0/vendor/github.com/prometheus/alertmanager/cluster/ |
| H A D | channel.go | 30 type Channel struct { struct
31 key string
32 send func([]byte)
33 peers func() []*memberlist.Node
34 sendOversize func(*memberlist.Node, []byte) error
36 msgc chan []byte
37 logger log.Logger
39 oversizeGossipMessageFailureTotal prometheus.Counter
40 oversizeGossipMessageDroppedTotal prometheus.Counter
41 oversizeGossipMessageSentTotal prometheus.Counter
[all …]
|