Lines Matching defs:sock_id

409 	int sock_id;
413 if ((sock_id = so_check_fd(s, &errno)) == -1)
417 if (sockets[sock_id].type != INETBOOT_STREAM) {
422 if (!(sockets[sock_id].so_state & SS_ISCONNECTED)) {
429 sockets[sock_id].so_state |= SS_CANTRCVMORE;
432 sockets[sock_id].so_state |= SS_CANTSENDMORE;
435 sockets[sock_id].so_state |= (SS_CANTRCVMORE | SS_CANTSENDMORE);
442 switch (sockets[sock_id].so_state &
447 if (sockets[sock_id].close[i] != NULL) {
448 (void) sockets[sock_id].close[i](sock_id);
451 nuke_grams(&sockets[sock_id].inq);
454 nuke_grams(&sockets[sock_id].inq);
458 if (tcp_shutdown(sock_id) < 0)
475 int sock_id, i;
478 if ((sock_id = so_check_fd(s, &errno)) == -1)
483 if (sockets[sock_id].close[i] != NULL) {
493 (void) sockets[sock_id].close[i](sock_id);
502 nuke_grams(&sockets[sock_id].inq);
504 bzero((caddr_t)&sockets[sock_id], sizeof (struct inetboot_socket));
505 sockets[sock_id].type = INETBOOT_UNUSED;
553 bind_check(int sock_id, const struct sockaddr *addr)
559 if (! (sockets[sock_id].so_opt & SO_REUSEADDR)) {
562 sockets[k].proto == sockets[sock_id].proto &&
635 quickbind(int sock_id)
650 if (bind_check(sock_id, (struct sockaddr *)&addr) == 0)
657 bcopy((caddr_t)&addr, (caddr_t)&sockets[sock_id].bind,
659 sockets[sock_id].bound = B_TRUE;
662 inet_ntoa(sockets[sock_id].bind.sin_addr),
663 ntohs(sockets[sock_id].bind.sin_port));
674 int sock_id;
677 if ((sock_id = so_check_fd(fd, &errno)) == -1)
680 if (sockets[sock_id].type != INETBOOT_STREAM) {
684 if (sockets[sock_id].so_error != 0) {
685 errno = sockets[sock_id].so_error;
688 return (tcp_listen(sock_id, backlog));
694 int sock_id;
698 if ((sock_id = so_check_fd(fd, &errno)) == -1)
701 if (sockets[sock_id].type != INETBOOT_STREAM) {
705 if (sockets[sock_id].so_error != 0) {
706 errno = sockets[sock_id].so_error;
709 if ((new_sd = tcp_accept(sock_id, addr, addr_len)) == -1)
711 sock_id = so_check_fd(new_sd, &errno);
712 sockets[sock_id].so_state |= SS_ISCONNECTED;
719 int sock_id;
723 if ((sock_id = so_check_fd(fd, &errno)) == -1)
726 so_type = sockets[sock_id].type;
738 if (sockets[sock_id].so_state & SS_ISCONNECTED) {
743 if (sockets[sock_id].so_error != 0) {
744 errno = sockets[sock_id].so_error;
749 if (!sockets[sock_id].bound) {
752 if (tcp_bind(sock_id) < 0)
755 if (quickbind(sock_id) < 0) {
762 bcopy((caddr_t)addr, &sockets[sock_id].remote,
765 if (sockets[sock_id].type == INETBOOT_STREAM) {
767 if (tcp_connect(sock_id) == 0)
768 sockets[sock_id].so_state |= SS_ISCONNECTED;
770 if (sockets[sock_id].so_error != 0)
771 errno = sockets[sock_id].so_error;
775 sockets[sock_id].so_state |= SS_ISCONNECTED;
797 int sock_id, i;
806 if ((sock_id = so_check_fd(s, &errno)) == -1) {
811 if (sockets[sock_id].type == INETBOOT_STREAM &&
812 !(sockets[sock_id].so_state & SS_ISCONNECTED)) {
828 if (sockets[sock_id].inq == NULL) {
831 if (sockets[sock_id].input[i] != NULL) {
832 if (sockets[sock_id].input[i](sock_id) < 0) {
833 if (sockets[sock_id].so_error != 0) {
835 sockets[sock_id].so_error;
843 so_type = sockets[sock_id].type;
846 while ((icp = sockets[sock_id].inq) != NULL) {
854 del_gram(&sockets[sock_id].inq, icp, B_TRUE);
868 if (sockets[sock_id].so_state & SS_CANTRCVMORE) {
869 if (sockets[sock_id].so_error != 0) {
870 errno = sockets[sock_id].so_error;
889 bcopy(&(sockets[sock_id].remote), from, MIN(*fromlen,
911 del_gram(&sockets[sock_id].inq, icp, B_TRUE);
912 tcp_rcv_drain_sock(sock_id);
930 del_gram(&sockets[sock_id].inq, icp, B_TRUE);
936 while ((icp = sockets[sock_id].inq) != NULL) {
939 del_gram(&sockets[sock_id].inq, icp,
948 sockets[sock_id].so_rcvbuf += (int32_t)bytes;
957 del_gram(&sockets[sock_id].inq, icp, B_TRUE);
967 del_gram(&sockets[sock_id].inq, icp, B_TRUE);
972 printf("recvfrom(%d): data: (0x%x,%d)\n", sock_id,
996 int sock_id;
1001 if ((sock_id = so_check_fd(s, &errno)) == -1) {
1008 so_type = sockets[sock_id].type;
1013 if (sockets[sock_id].so_error != 0) {
1014 errno = sockets[sock_id].so_error;
1025 if (!(sockets[sock_id].so_state & SS_ISCONNECTED) &&
1030 bytes = dgram_sendto(sock_id, msg, len, flags, to, tolen);
1033 if (!((sockets[sock_id].so_state & SS_ISCONNECTED) ||
1034 (sockets[sock_id].so_state & SS_ISCONNECTING))) {
1038 if (sockets[sock_id].so_state & SS_CANTSENDMORE) {
1042 bytes = stream_sendto(sock_id, msg, len, flags);