bluetooth/btpand/channel.c

62 	channel_t *chan;
64 	chan = malloc(sizeof(channel_t));
65 	if (chan == NULL) {
70 	memset(chan, 0, sizeof(channel_t));
71 	STAILQ_INIT(&chan->pktlist);
72 	chan->state = CHANNEL_CLOSED;
73 	LIST_INSERT_HEAD(&channel_list, chan, next);
77 	return chan;
81 channel_open(channel_t *chan, int fd)
85 	assert(chan->refcnt == 0);
86 	assert(chan->state != CHANNEL_CLOSED);
88 	if (chan->mtu > 0) {
89 		chan->sendbuf = malloc(chan->mtu);
90 		if (chan->sendbuf == NULL) {
102 	event_set(&chan->rd_ev, fd, EV_READ | EV_PERSIST, channel_read, chan);
103 	if (event_add(&chan->rd_ev, NULL) == -1) {
108 	event_set(&chan->wr_ev, fd, EV_WRITE, channel_start, chan);
110 	chan->refcnt++;
111 	chan->fd = fd;
113 	log_debug("(fd#%d)", chan->fd);
119 channel_close(channel_t *chan)
123 	assert(chan->state != CHANNEL_CLOSED);
125 	log_debug("(fd#%d)", chan->fd);
127 	chan->state = CHANNEL_CLOSED;
128 	event_del(&chan->rd_ev);
129 	event_del(&chan->wr_ev);
130 	close(chan->fd);
131 	chan->refcnt--;
132 	chan->tick = 0;
134 	while ((ph = STAILQ_FIRST(&chan->pktlist)) != NULL) {
135 		STAILQ_REMOVE_HEAD(&chan->pktlist, next);
137 		chan->qlen--;
140 	if (chan->pfh != NULL) {
141 		pidfile_remove(chan->pfh);
142 		chan->pfh = NULL;
145 	if (chan->refcnt == 0)
146 		channel_free(chan);
150 channel_free(channel_t *chan)
153 	assert(chan->refcnt == 0);
154 	assert(chan->state == CHANNEL_CLOSED);
155 	assert(chan->qlen == 0);
156 	assert(STAILQ_EMPTY(&chan->pktlist));
158 	LIST_REMOVE(chan, next);
159 	free(chan->pfilter);
160 	free(chan->mfilter);
161 	free(chan->sendbuf);
162 	free(chan);
175 	channel_t *chan = arg;
178 	chan->oactive = true;
180 	while (chan->qlen > 0) {
181 		ph = STAILQ_FIRST(&chan->pktlist);
183 		channel_timeout(chan, 10);
184 		if (chan->send(chan, ph->data) == false) {
185 			if (event_add(&chan->wr_ev, NULL) == -1) {
187 				channel_close(chan);
192 		STAILQ_REMOVE_HEAD(&chan->pktlist, next);
194 		chan->qlen--;
197 	channel_timeout(chan, 0);
198 	chan->oactive = false;
204 	channel_t *chan = arg;
208 	pkt = packet_alloc(chan);
210 		channel_close(chan);
214 	nr = read(fd, pkt->buf, chan->mru);
218 		channel_close(chan);
224 		channel_close(chan);
229 	if (chan->recv(pkt) == true)
238 	channel_t *chan;
247 		LIST_FOREACH(chan, &channel_list, next) {
248 			if (chan == pkt->chan
249 			    || chan->state != CHANNEL_OPEN)
252 			if (memcmp(pkt->dst, chan->raddr, ETHER_ADDR_LEN) == 0) {
253 				if (chan->qlen > CHANNEL_MAXQLEN)
256 					channel_put(chan, pkt);
263 	LIST_FOREACH(chan, &channel_list, next) {
264 		if (chan == pkt->chan
265 		    || chan->state != CHANNEL_OPEN)
268 		if (chan->qlen > CHANNEL_MAXQLEN) {
273 		channel_put(chan, pkt);
278 channel_put(channel_t *chan, packet_t *pkt)
286 	chan->qlen++;
287 	STAILQ_INSERT_TAIL(&chan->pktlist, ph, next);
289 	if (!chan->oactive)
290 		channel_start(chan->fd, EV_WRITE, chan);
298 channel_timeout(channel_t *chan, int to)
303 		chan->tick = 0;
305 		chan->tick = (channel_tick + to) % 60;
317 	channel_t *chan, *next;
324 	while ((chan = next) != NULL) {
325 		next = LIST_NEXT(chan, next);
327 		if (chan->tick == tick)
328 			channel_close(chan);
329 		else if (chan->tick != 0)