2 * Copyright (C) ST-Ericsson AB 2010
3 * Author: Sjur Brendeland/sjur.brandeland@stericsson.com
4 * License terms: GNU General Public License (GPL) version 2
7 #define pr_fmt(fmt) KBUILD_MODNAME ":%s(): " fmt, __func__
9 #include <linux/stddef.h>
10 #include <linux/spinlock.h>
11 #include <linux/slab.h>
12 #include <net/caif/caif_layer.h>
13 #include <net/caif/cfpkt.h>
14 #include <net/caif/cfctrl.h>
16 #define container_obj(layr) container_of(layr, struct cfctrl, serv.layer)
17 #define UTILITY_NAME_LENGTH 16
18 #define CFPKT_CTRL_PKT_LEN 20
22 static int handle_loop(struct cfctrl
*ctrl
,
23 int cmd
, struct cfpkt
*pkt
){
27 static int handle_loop(struct cfctrl
*ctrl
,
28 int cmd
, struct cfpkt
*pkt
);
30 static int cfctrl_recv(struct cflayer
*layr
, struct cfpkt
*pkt
);
31 static void cfctrl_ctrlcmd(struct cflayer
*layr
, enum caif_ctrlcmd ctrl
,
35 struct cflayer
*cfctrl_create(void)
37 struct dev_info dev_info
;
39 kmalloc(sizeof(struct cfctrl
), GFP_ATOMIC
);
41 pr_warn("Out of memory\n");
44 caif_assert(offsetof(struct cfctrl
, serv
.layer
) == 0);
45 memset(&dev_info
, 0, sizeof(dev_info
));
47 memset(this, 0, sizeof(*this));
48 cfsrvl_init(&this->serv
, 0, &dev_info
, false);
49 atomic_set(&this->req_seq_no
, 1);
50 atomic_set(&this->rsp_seq_no
, 1);
51 this->serv
.layer
.receive
= cfctrl_recv
;
52 sprintf(this->serv
.layer
.name
, "ctrl");
53 this->serv
.layer
.ctrlcmd
= cfctrl_ctrlcmd
;
54 spin_lock_init(&this->loop_linkid_lock
);
55 spin_lock_init(&this->info_list_lock
);
56 INIT_LIST_HEAD(&this->list
);
57 this->loop_linkid
= 1;
58 return &this->serv
.layer
;
61 static bool param_eq(struct cfctrl_link_param
*p1
, struct cfctrl_link_param
*p2
)
64 p1
->linktype
== p2
->linktype
&&
65 p1
->priority
== p2
->priority
&&
66 p1
->phyid
== p2
->phyid
&&
67 p1
->endpoint
== p2
->endpoint
&& p1
->chtype
== p2
->chtype
;
72 switch (p1
->linktype
) {
75 case CFCTRL_SRV_DATAGRAM
:
76 return p1
->u
.datagram
.connid
== p2
->u
.datagram
.connid
;
79 p1
->u
.rfm
.connid
== p2
->u
.rfm
.connid
&&
80 strcmp(p1
->u
.rfm
.volume
, p2
->u
.rfm
.volume
) == 0;
83 p1
->u
.utility
.fifosize_kb
== p2
->u
.utility
.fifosize_kb
84 && p1
->u
.utility
.fifosize_bufs
==
85 p2
->u
.utility
.fifosize_bufs
86 && strcmp(p1
->u
.utility
.name
, p2
->u
.utility
.name
) == 0
87 && p1
->u
.utility
.paramlen
== p2
->u
.utility
.paramlen
88 && memcmp(p1
->u
.utility
.params
, p2
->u
.utility
.params
,
89 p1
->u
.utility
.paramlen
) == 0;
91 case CFCTRL_SRV_VIDEO
:
92 return p1
->u
.video
.connid
== p2
->u
.video
.connid
;
103 bool cfctrl_req_eq(struct cfctrl_request_info
*r1
,
104 struct cfctrl_request_info
*r2
)
106 if (r1
->cmd
!= r2
->cmd
)
108 if (r1
->cmd
== CFCTRL_CMD_LINK_SETUP
)
109 return param_eq(&r1
->param
, &r2
->param
);
111 return r1
->channel_id
== r2
->channel_id
;
114 /* Insert request at the end */
115 void cfctrl_insert_req(struct cfctrl
*ctrl
,
116 struct cfctrl_request_info
*req
)
118 spin_lock(&ctrl
->info_list_lock
);
119 atomic_inc(&ctrl
->req_seq_no
);
120 req
->sequence_no
= atomic_read(&ctrl
->req_seq_no
);
121 list_add_tail(&req
->list
, &ctrl
->list
);
122 spin_unlock(&ctrl
->info_list_lock
);
125 /* Compare and remove request */
126 struct cfctrl_request_info
*cfctrl_remove_req(struct cfctrl
*ctrl
,
127 struct cfctrl_request_info
*req
)
129 struct cfctrl_request_info
*p
, *tmp
, *first
;
131 spin_lock(&ctrl
->info_list_lock
);
132 first
= list_first_entry(&ctrl
->list
, struct cfctrl_request_info
, list
);
134 list_for_each_entry_safe(p
, tmp
, &ctrl
->list
, list
) {
135 if (cfctrl_req_eq(req
, p
)) {
137 pr_warn("Requests are not received in order\n");
139 atomic_set(&ctrl
->rsp_seq_no
,
147 spin_unlock(&ctrl
->info_list_lock
);
151 struct cfctrl_rsp
*cfctrl_get_respfuncs(struct cflayer
*layer
)
153 struct cfctrl
*this = container_obj(layer
);
157 void cfctrl_set_dnlayer(struct cflayer
*this, struct cflayer
*dn
)
162 void cfctrl_set_uplayer(struct cflayer
*this, struct cflayer
*up
)
167 static void init_info(struct caif_payload_info
*info
, struct cfctrl
*cfctrl
)
170 info
->channel_id
= cfctrl
->serv
.layer
.id
;
171 info
->dev_info
= &cfctrl
->serv
.dev_info
;
174 void cfctrl_enum_req(struct cflayer
*layer
, u8 physlinkid
)
176 struct cfctrl
*cfctrl
= container_obj(layer
);
178 struct cfpkt
*pkt
= cfpkt_create(CFPKT_CTRL_PKT_LEN
);
180 pr_warn("Out of memory\n");
183 caif_assert(offsetof(struct cfctrl
, serv
.layer
) == 0);
184 init_info(cfpkt_info(pkt
), cfctrl
);
185 cfpkt_info(pkt
)->dev_info
->id
= physlinkid
;
186 cfctrl
->serv
.dev_info
.id
= physlinkid
;
187 cfpkt_addbdy(pkt
, CFCTRL_CMD_ENUM
);
188 cfpkt_addbdy(pkt
, physlinkid
);
190 cfctrl
->serv
.layer
.dn
->transmit(cfctrl
->serv
.layer
.dn
, pkt
);
192 pr_err("Could not transmit enum message\n");
197 int cfctrl_linkup_request(struct cflayer
*layer
,
198 struct cfctrl_link_param
*param
,
199 struct cflayer
*user_layer
)
201 struct cfctrl
*cfctrl
= container_obj(layer
);
205 struct cfctrl_request_info
*req
;
207 char utility_name
[16];
208 struct cfpkt
*pkt
= cfpkt_create(CFPKT_CTRL_PKT_LEN
);
210 pr_warn("Out of memory\n");
213 cfpkt_addbdy(pkt
, CFCTRL_CMD_LINK_SETUP
);
214 cfpkt_addbdy(pkt
, (param
->chtype
<< 4) + param
->linktype
);
215 cfpkt_addbdy(pkt
, (param
->priority
<< 3) + param
->phyid
);
216 cfpkt_addbdy(pkt
, param
->endpoint
& 0x03);
218 switch (param
->linktype
) {
221 case CFCTRL_SRV_VIDEO
:
222 cfpkt_addbdy(pkt
, (u8
) param
->u
.video
.connid
);
226 case CFCTRL_SRV_DATAGRAM
:
227 tmp32
= cpu_to_le32(param
->u
.datagram
.connid
);
228 cfpkt_add_body(pkt
, &tmp32
, 4);
231 /* Construct a frame, convert DatagramConnectionID to network
232 * format long and copy it out...
234 tmp32
= cpu_to_le32(param
->u
.rfm
.connid
);
235 cfpkt_add_body(pkt
, &tmp32
, 4);
236 /* Add volume name, including zero termination... */
237 cfpkt_add_body(pkt
, param
->u
.rfm
.volume
,
238 strlen(param
->u
.rfm
.volume
) + 1);
240 case CFCTRL_SRV_UTIL
:
241 tmp16
= cpu_to_le16(param
->u
.utility
.fifosize_kb
);
242 cfpkt_add_body(pkt
, &tmp16
, 2);
243 tmp16
= cpu_to_le16(param
->u
.utility
.fifosize_bufs
);
244 cfpkt_add_body(pkt
, &tmp16
, 2);
245 memset(utility_name
, 0, sizeof(utility_name
));
246 strncpy(utility_name
, param
->u
.utility
.name
,
247 UTILITY_NAME_LENGTH
- 1);
248 cfpkt_add_body(pkt
, utility_name
, UTILITY_NAME_LENGTH
);
249 tmp8
= param
->u
.utility
.paramlen
;
250 cfpkt_add_body(pkt
, &tmp8
, 1);
251 cfpkt_add_body(pkt
, param
->u
.utility
.params
,
252 param
->u
.utility
.paramlen
);
255 pr_warn("Request setup of bad link type = %d\n",
259 req
= kzalloc(sizeof(*req
), GFP_KERNEL
);
261 pr_warn("Out of memory\n");
264 req
->client_layer
= user_layer
;
265 req
->cmd
= CFCTRL_CMD_LINK_SETUP
;
267 cfctrl_insert_req(cfctrl
, req
);
268 init_info(cfpkt_info(pkt
), cfctrl
);
270 * NOTE:Always send linkup and linkdown request on the same
271 * device as the payload. Otherwise old queued up payload
272 * might arrive with the newly allocated channel ID.
274 cfpkt_info(pkt
)->dev_info
->id
= param
->phyid
;
276 cfctrl
->serv
.layer
.dn
->transmit(cfctrl
->serv
.layer
.dn
, pkt
);
278 pr_err("Could not transmit linksetup request\n");
285 int cfctrl_linkdown_req(struct cflayer
*layer
, u8 channelid
,
286 struct cflayer
*client
)
289 struct cfctrl
*cfctrl
= container_obj(layer
);
290 struct cfpkt
*pkt
= cfpkt_create(CFPKT_CTRL_PKT_LEN
);
292 pr_warn("Out of memory\n");
295 cfpkt_addbdy(pkt
, CFCTRL_CMD_LINK_DESTROY
);
296 cfpkt_addbdy(pkt
, channelid
);
297 init_info(cfpkt_info(pkt
), cfctrl
);
299 cfctrl
->serv
.layer
.dn
->transmit(cfctrl
->serv
.layer
.dn
, pkt
);
301 pr_err("Could not transmit link-down request\n");
307 void cfctrl_sleep_req(struct cflayer
*layer
)
310 struct cfctrl
*cfctrl
= container_obj(layer
);
311 struct cfpkt
*pkt
= cfpkt_create(CFPKT_CTRL_PKT_LEN
);
313 pr_warn("Out of memory\n");
316 cfpkt_addbdy(pkt
, CFCTRL_CMD_SLEEP
);
317 init_info(cfpkt_info(pkt
), cfctrl
);
319 cfctrl
->serv
.layer
.dn
->transmit(cfctrl
->serv
.layer
.dn
, pkt
);
324 void cfctrl_wake_req(struct cflayer
*layer
)
327 struct cfctrl
*cfctrl
= container_obj(layer
);
328 struct cfpkt
*pkt
= cfpkt_create(CFPKT_CTRL_PKT_LEN
);
330 pr_warn("Out of memory\n");
333 cfpkt_addbdy(pkt
, CFCTRL_CMD_WAKE
);
334 init_info(cfpkt_info(pkt
), cfctrl
);
336 cfctrl
->serv
.layer
.dn
->transmit(cfctrl
->serv
.layer
.dn
, pkt
);
341 void cfctrl_getstartreason_req(struct cflayer
*layer
)
344 struct cfctrl
*cfctrl
= container_obj(layer
);
345 struct cfpkt
*pkt
= cfpkt_create(CFPKT_CTRL_PKT_LEN
);
347 pr_warn("Out of memory\n");
350 cfpkt_addbdy(pkt
, CFCTRL_CMD_START_REASON
);
351 init_info(cfpkt_info(pkt
), cfctrl
);
353 cfctrl
->serv
.layer
.dn
->transmit(cfctrl
->serv
.layer
.dn
, pkt
);
359 void cfctrl_cancel_req(struct cflayer
*layr
, struct cflayer
*adap_layer
)
361 struct cfctrl_request_info
*p
, *tmp
;
362 struct cfctrl
*ctrl
= container_obj(layr
);
363 spin_lock(&ctrl
->info_list_lock
);
366 list_for_each_entry_safe(p
, tmp
, &ctrl
->list
, list
) {
367 if (p
->client_layer
== adap_layer
) {
368 pr_warn("cancel req :%d\n", p
->sequence_no
);
374 spin_unlock(&ctrl
->info_list_lock
);
377 static int cfctrl_recv(struct cflayer
*layer
, struct cfpkt
*pkt
)
386 struct cfctrl
*cfctrl
= container_obj(layer
);
387 struct cfctrl_request_info rsp
, *req
;
390 cfpkt_extr_head(pkt
, &cmdrsp
, 1);
391 cmd
= cmdrsp
& CFCTRL_CMD_MASK
;
392 if (cmd
!= CFCTRL_CMD_LINK_ERR
393 && CFCTRL_RSP_BIT
!= (CFCTRL_RSP_BIT
& cmdrsp
)) {
394 if (handle_loop(cfctrl
, cmd
, pkt
) != 0)
395 cmdrsp
|= CFCTRL_ERR_BIT
;
399 case CFCTRL_CMD_LINK_SETUP
:
401 enum cfctrl_srv serv
;
402 enum cfctrl_srv servtype
;
410 struct cfctrl_link_param linkparam
;
411 memset(&linkparam
, 0, sizeof(linkparam
));
413 cfpkt_extr_head(pkt
, &tmp
, 1);
415 serv
= tmp
& CFCTRL_SRV_MASK
;
416 linkparam
.linktype
= serv
;
419 linkparam
.chtype
= servtype
;
421 cfpkt_extr_head(pkt
, &tmp
, 1);
422 physlinkid
= tmp
& 0x07;
425 linkparam
.priority
= prio
;
426 linkparam
.phyid
= physlinkid
;
427 cfpkt_extr_head(pkt
, &endpoint
, 1);
428 linkparam
.endpoint
= endpoint
& 0x03;
433 if (CFCTRL_ERR_BIT
& cmdrsp
)
436 cfpkt_extr_head(pkt
, &linkid
, 1);
438 case CFCTRL_SRV_VIDEO
:
439 cfpkt_extr_head(pkt
, &tmp
, 1);
440 linkparam
.u
.video
.connid
= tmp
;
441 if (CFCTRL_ERR_BIT
& cmdrsp
)
444 cfpkt_extr_head(pkt
, &linkid
, 1);
447 case CFCTRL_SRV_DATAGRAM
:
448 cfpkt_extr_head(pkt
, &tmp32
, 4);
449 linkparam
.u
.datagram
.connid
=
451 if (CFCTRL_ERR_BIT
& cmdrsp
)
454 cfpkt_extr_head(pkt
, &linkid
, 1);
457 /* Construct a frame, convert
458 * DatagramConnectionID
459 * to network format long and copy it out...
461 cfpkt_extr_head(pkt
, &tmp32
, 4);
462 linkparam
.u
.rfm
.connid
=
464 cp
= (u8
*) linkparam
.u
.rfm
.volume
;
465 for (cfpkt_extr_head(pkt
, &tmp
, 1);
466 cfpkt_more(pkt
) && tmp
!= '\0';
467 cfpkt_extr_head(pkt
, &tmp
, 1))
471 if (CFCTRL_ERR_BIT
& cmdrsp
)
474 cfpkt_extr_head(pkt
, &linkid
, 1);
477 case CFCTRL_SRV_UTIL
:
478 /* Construct a frame, convert
479 * DatagramConnectionID
480 * to network format long and copy it out...
483 cfpkt_extr_head(pkt
, &tmp16
, 2);
484 linkparam
.u
.utility
.fifosize_kb
=
487 cfpkt_extr_head(pkt
, &tmp16
, 2);
488 linkparam
.u
.utility
.fifosize_bufs
=
491 cp
= (u8
*) linkparam
.u
.utility
.name
;
492 caif_assert(sizeof(linkparam
.u
.utility
.name
)
493 >= UTILITY_NAME_LENGTH
);
495 i
< UTILITY_NAME_LENGTH
496 && cfpkt_more(pkt
); i
++) {
497 cfpkt_extr_head(pkt
, &tmp
, 1);
501 cfpkt_extr_head(pkt
, &len
, 1);
502 linkparam
.u
.utility
.paramlen
= len
;
504 cp
= linkparam
.u
.utility
.params
;
505 while (cfpkt_more(pkt
) && len
--) {
506 cfpkt_extr_head(pkt
, &tmp
, 1);
509 if (CFCTRL_ERR_BIT
& cmdrsp
)
512 cfpkt_extr_head(pkt
, &linkid
, 1);
514 cfpkt_extr_head(pkt
, &len
, 1);
516 cfpkt_extr_head(pkt
, ¶m
, len
);
519 pr_warn("Request setup - invalid link type (%d)\n",
525 rsp
.param
= linkparam
;
526 req
= cfctrl_remove_req(cfctrl
, &rsp
);
528 if (CFCTRL_ERR_BIT
== (CFCTRL_ERR_BIT
& cmdrsp
) ||
529 cfpkt_erroneous(pkt
)) {
530 pr_err("Invalid O/E bit or parse error on CAIF control channel\n");
531 cfctrl
->res
.reject_rsp(cfctrl
->serv
.layer
.up
,
533 req
? req
->client_layer
536 cfctrl
->res
.linksetup_rsp(cfctrl
->serv
.
540 client_layer
: NULL
);
547 case CFCTRL_CMD_LINK_DESTROY
:
548 cfpkt_extr_head(pkt
, &linkid
, 1);
549 cfctrl
->res
.linkdestroy_rsp(cfctrl
->serv
.layer
.up
, linkid
);
551 case CFCTRL_CMD_LINK_ERR
:
552 pr_err("Frame Error Indication received\n");
553 cfctrl
->res
.linkerror_ind();
555 case CFCTRL_CMD_ENUM
:
556 cfctrl
->res
.enum_rsp();
558 case CFCTRL_CMD_SLEEP
:
559 cfctrl
->res
.sleep_rsp();
561 case CFCTRL_CMD_WAKE
:
562 cfctrl
->res
.wake_rsp();
564 case CFCTRL_CMD_LINK_RECONF
:
565 cfctrl
->res
.restart_rsp();
567 case CFCTRL_CMD_RADIO_SET
:
568 cfctrl
->res
.radioset_rsp();
571 pr_err("Unrecognized Control Frame\n");
581 static void cfctrl_ctrlcmd(struct cflayer
*layr
, enum caif_ctrlcmd ctrl
,
584 struct cfctrl
*this = container_obj(layr
);
586 case _CAIF_CTRLCMD_PHYIF_FLOW_OFF_IND
:
587 case CAIF_CTRLCMD_FLOW_OFF_IND
:
588 spin_lock(&this->info_list_lock
);
589 if (!list_empty(&this->list
)) {
590 pr_debug("Received flow off in control layer\n");
592 spin_unlock(&this->info_list_lock
);
600 static int handle_loop(struct cfctrl
*ctrl
, int cmd
, struct cfpkt
*pkt
)
602 static int last_linkid
;
603 u8 linkid
, linktype
, tmp
;
605 case CFCTRL_CMD_LINK_SETUP
:
606 spin_lock(&ctrl
->loop_linkid_lock
);
607 for (linkid
= last_linkid
+ 1; linkid
< 255; linkid
++)
608 if (!ctrl
->loop_linkused
[linkid
])
610 for (linkid
= last_linkid
- 1; linkid
> 0; linkid
--)
611 if (!ctrl
->loop_linkused
[linkid
])
613 spin_unlock(&ctrl
->loop_linkid_lock
);
614 pr_err("Out of link-ids\n");
617 if (!ctrl
->loop_linkused
[linkid
])
618 ctrl
->loop_linkused
[linkid
] = 1;
620 last_linkid
= linkid
;
622 cfpkt_add_trail(pkt
, &linkid
, 1);
623 spin_unlock(&ctrl
->loop_linkid_lock
);
624 cfpkt_peek_head(pkt
, &linktype
, 1);
625 if (linktype
== CFCTRL_SRV_UTIL
) {
627 cfpkt_add_trail(pkt
, &tmp
, 1);
628 cfpkt_add_trail(pkt
, &tmp
, 1);
632 case CFCTRL_CMD_LINK_DESTROY
:
633 spin_lock(&ctrl
->loop_linkid_lock
);
634 cfpkt_peek_head(pkt
, &linkid
, 1);
635 ctrl
->loop_linkused
[linkid
] = 0;
636 spin_unlock(&ctrl
->loop_linkid_lock
);