Cross Reference: /src/usr.sbin/btpand/channel.c

Lines Matching refs:chan
55 	channel_t *chan;
57 	chan = malloc(sizeof(channel_t));
58 	if (chan == NULL) {
63 	memset(chan, 0, sizeof(channel_t));
64 	STAILQ_INIT(&chan->pktlist);
65 	chan->state = CHANNEL_CLOSED;
66 	LIST_INSERT_HEAD(&channel_list, chan, next);
68 	return chan;
72 channel_open(channel_t *chan, int fd)
76 	assert(chan->refcnt == 0);
77 	assert(chan->state != CHANNEL_CLOSED);
78 	assert(chan->send != NULL);
79 	assert(chan->recv != NULL);
80 	assert(chan->down != NULL);
82 	if (chan->mtu > 0) {
83 		chan->sendbuf = malloc(chan->mtu);
84 		if (chan->sendbuf == NULL) {
96 	event_set(&chan->rd_ev, fd, EV_READ | EV_PERSIST, channel_read, chan);
97 	if (event_add(&chan->rd_ev, NULL) == -1) {
102 	event_set(&chan->wr_ev, fd, EV_WRITE, channel_start, chan);
104 	chan->refcnt++;
105 	chan->fd = fd;
107 	log_debug("(fd#%d)", chan->fd);
113 channel_close(channel_t *chan)
117 	assert(chan->state != CHANNEL_CLOSED);
119 	log_debug("(fd#%d)", chan->fd);
121 	chan->state = CHANNEL_CLOSED;
122 	event_del(&chan->rd_ev);
123 	event_del(&chan->wr_ev);
124 	close(chan->fd);
125 	chan->refcnt--;
126 	chan->tick = 0;
128 	while ((ph = STAILQ_FIRST(&chan->pktlist)) != NULL) {
129 		STAILQ_REMOVE_HEAD(&chan->pktlist, next);
131 		chan->qlen--;
134 	if (chan->refcnt == 0)
135 		channel_free(chan);
139 channel_free(channel_t *chan)
142 	assert(chan->refcnt == 0);
143 	assert(chan->state == CHANNEL_CLOSED);
144 	assert(chan->qlen == 0);
145 	assert(STAILQ_EMPTY(&chan->pktlist));
147 	LIST_REMOVE(chan, next);
148 	free(chan->pfilter);
149 	free(chan->mfilter);
150 	free(chan->sendbuf);
151 	free(chan);
157 	channel_t *chan = arg;
160 	chan->oactive = true;
162 	while (chan->qlen > 0) {
163 		ph = STAILQ_FIRST(&chan->pktlist);
165 		channel_timeout(chan, 10);
166 		if (chan->send(chan, ph->data) == false) {
167 			if (event_add(&chan->wr_ev, NULL) == -1) {
169 				chan->down(chan);
174 		STAILQ_REMOVE_HEAD(&chan->pktlist, next);
176 		chan->qlen--;
179 	channel_timeout(chan, 0);
180 	chan->oactive = false;
186 	channel_t *chan = arg;
190 	pkt = packet_alloc(chan);
192 		chan->down(chan);
196 	nr = read(fd, pkt->buf, chan->mru);
200 		chan->down(chan);
206 		chan->down(chan);
211 	if (chan->recv(pkt) == true)
220 	channel_t *chan;
229 		LIST_FOREACH(chan, &channel_list, next) {
230 			if (chan == pkt->chan
231 			    || chan->state != CHANNEL_OPEN)
234 			if (memcmp(pkt->dst, chan->raddr, ETHER_ADDR_LEN) == 0) {
235 				if (chan->qlen > CHANNEL_MAXQLEN)
238 					channel_put(chan, pkt);
245 	LIST_FOREACH(chan, &channel_list, next) {
246 		if (chan == pkt->chan
247 		    || chan->state != CHANNEL_OPEN)
250 		if (chan->qlen > CHANNEL_MAXQLEN) {
255 		channel_put(chan, pkt);
260 channel_put(channel_t *chan, packet_t *pkt)
268 	chan->qlen++;
269 	STAILQ_INSERT_TAIL(&chan->pktlist, ph, next);
271 	if (!chan->oactive)
272 		channel_start(chan->fd, EV_WRITE, chan);
280 channel_timeout(channel_t *chan, int to)
285 		chan->tick = 0;
287 		chan->tick = (channel_tick + to) % 60;
299 	channel_t *chan, *next;
306 	while ((chan = next) != NULL) {
307 		next = LIST_NEXT(chan, next);
309 		if (chan->tick == tick)
310 			chan->down(chan);
311 		else if (chan->tick != 0)
OpenGrok
