Lines Matching refs:srv
57 static void server_accept_client (server_p srv, int32_t fd);
58 static int32_t server_process_request (server_p srv, int32_t fd);
59 static int32_t server_send_error_response (server_p srv, int32_t fd,
61 static void server_close_fd (server_p srv, int32_t fd);
68 server_init(server_p srv, char const *control)
76 assert(srv != NULL);
79 memset(srv, 0, sizeof(*srv));
162 srv->imtu = (imtu > SDP_LOCAL_MTU)? imtu : SDP_LOCAL_MTU;
163 srv->req = (uint8_t *) calloc(srv->imtu, sizeof(srv->req[0]));
164 if (srv->req == NULL) {
172 srv->fdidx = (fd_idx_p) calloc(FD_SETSIZE, sizeof(srv->fdidx[0]));
173 if (srv->fdidx == NULL) {
175 free(srv->req);
184 free(srv->fdidx);
185 free(srv->req);
196 FD_ZERO(&srv->fdset);
197 srv->maxfd = (unsock > l2sock)? unsock : l2sock;
199 FD_SET(unsock, &srv->fdset);
200 srv->fdidx[unsock].valid = 1;
201 srv->fdidx[unsock].server = 1;
202 srv->fdidx[unsock].control = 1;
203 srv->fdidx[unsock].priv = 0;
204 srv->fdidx[unsock].rsp_cs = 0;
205 srv->fdidx[unsock].rsp_size = 0;
206 srv->fdidx[unsock].rsp_limit = 0;
207 srv->fdidx[unsock].omtu = SDP_LOCAL_MTU;
208 srv->fdidx[unsock].rsp = NULL;
210 FD_SET(l2sock, &srv->fdset);
211 srv->fdidx[l2sock].valid = 1;
212 srv->fdidx[l2sock].server = 1;
213 srv->fdidx[l2sock].control = 0;
214 srv->fdidx[l2sock].priv = 0;
215 srv->fdidx[l2sock].rsp_cs = 0;
216 srv->fdidx[l2sock].rsp_size = 0;
217 srv->fdidx[l2sock].rsp_limit = 0;
218 srv->fdidx[l2sock].omtu = 0; /* unknown */
219 srv->fdidx[l2sock].rsp = NULL;
229 server_shutdown(server_p srv)
233 assert(srv != NULL);
235 for (fd = 0; fd < srv->maxfd + 1; fd ++)
236 if (srv->fdidx[fd].valid)
237 server_close_fd(srv, fd);
239 free(srv->req);
240 free(srv->fdidx);
242 memset(srv, 0, sizeof(*srv));
250 server_do(server_p srv)
255 assert(srv != NULL);
258 memcpy(&fdset, &srv->fdset, sizeof(fdset));
259 n = select(srv->maxfd + 1, &fdset, NULL, NULL, NULL);
265 srv->maxfd + 1, &fdset, strerror(errno), errno);
271 for (fd = 0; fd < srv->maxfd + 1 && n > 0; fd ++) {
275 assert(srv->fdidx[fd].valid);
278 if (srv->fdidx[fd].server)
279 server_accept_client(srv, fd);
280 else if (server_process_request(srv, fd) != 0)
281 server_close_fd(srv, fd);
293 server_accept_client(server_p srv, int32_t fd)
306 srv->fdidx[fd].control? "control" : "L2CAP",
311 assert(!FD_ISSET(cfd, &srv->fdset));
312 assert(!srv->fdidx[cfd].valid);
316 if (!srv->fdidx[fd].control) {
318 size = sizeof(srv->req_sa);
319 if (getsockname(cfd,(struct sockaddr*)&srv->req_sa,&size) < 0) {
371 memcpy(&srv->req_sa.l2cap_bdaddr, NG_HCI_BDADDR_ANY,
372 sizeof(srv->req_sa.l2cap_bdaddr));
374 omtu = srv->fdidx[fd].omtu;
390 FD_SET(cfd, &srv->fdset);
391 if (srv->maxfd < cfd)
392 srv->maxfd = cfd;
393 srv->fdidx[cfd].valid = 1;
394 srv->fdidx[cfd].server = 0;
395 srv->fdidx[cfd].control = srv->fdidx[fd].control;
396 srv->fdidx[cfd].priv = priv;
397 srv->fdidx[cfd].rsp_cs = 0;
398 srv->fdidx[cfd].rsp_size = 0;
399 srv->fdidx[cfd].rsp_limit = 0;
400 srv->fdidx[cfd].omtu = omtu;
401 srv->fdidx[cfd].rsp = rsp;
409 server_process_request(server_p srv, int32_t fd)
411 sdp_pdu_p pdu = (sdp_pdu_p) srv->req;
414 assert(srv->imtu > 0);
415 assert(srv->req != NULL);
416 assert(FD_ISSET(fd, &srv->fdset));
417 assert(srv->fdidx[fd].valid);
418 assert(!srv->fdidx[fd].server);
419 assert(srv->fdidx[fd].rsp != NULL);
420 assert(srv->fdidx[fd].omtu >= NG_L2CAP_MTU_MINIMUM);
423 len = read(fd, srv->req, srv->imtu);
428 srv->fdidx[fd].control? "control" : "L2CAP",
434 srv->fdidx[fd].control? "control" : "L2CAP");
442 error = server_prepare_service_search_response(srv, fd);
446 error = server_prepare_service_attribute_response(srv, fd);
450 error = server_prepare_service_search_attribute_response(srv, fd);
454 error = server_prepare_service_register_response(srv, fd);
458 error = server_prepare_service_unregister_response(srv, fd);
462 error = server_prepare_service_change_response(srv, fd);
475 error = server_send_service_search_response(srv, fd);
479 error = server_send_service_attribute_response(srv, fd);
483 error = server_send_service_search_attribute_response(srv, fd);
487 error = server_send_service_register_response(srv, fd);
491 error = server_send_service_unregister_response(srv, fd);
495 error = server_send_service_change_response(srv, fd);
506 srv->fdidx[fd].control? "control" : "L2CAP",
512 srv->fdidx[fd].control? "control" : "L2CAP",
515 error = server_send_error_response(srv, fd, error);
519 srv->fdidx[fd].control? "control" : "L2CAP",
525 srv->fdidx[fd].rsp_cs = 0;
526 srv->fdidx[fd].rsp_size = 0;
527 srv->fdidx[fd].rsp_limit = 0;
538 server_send_error_response(server_p srv, int32_t fd, uint16_t error)
549 rsp.pdu.tid = ((sdp_pdu_p)(srv->req))->tid;
565 server_close_fd(server_p srv, int32_t fd)
569 assert(FD_ISSET(fd, &srv->fdset));
570 assert(srv->fdidx[fd].valid);
574 FD_CLR(fd, &srv->fdset);
575 if (fd == srv->maxfd)
576 srv->maxfd --;
578 if (srv->fdidx[fd].rsp != NULL)
579 free(srv->fdidx[fd].rsp);
581 memset(&srv->fdidx[fd], 0, sizeof(srv->fdidx[fd]));