Lines Matching defs:conn
242 struct iucv_connection *conn;
253 struct iucv_connection *conn;
535 struct iucv_connection *conn = path->private;
538 ev.conn = conn;
540 fsm_event(conn->fsm, CONN_EVENT_RX, &ev);
546 struct iucv_connection *conn = path->private;
549 ev.conn = conn;
551 fsm_event(conn->fsm, CONN_EVENT_TXDONE, &ev);
556 struct iucv_connection *conn = path->private;
558 fsm_event(conn->fsm, CONN_EVENT_CONN_ACK, conn);
564 struct iucv_connection *conn = path->private;
573 list_for_each_entry(conn, &iucv_connection_list, list) {
574 if (strncmp(ipvmid, conn->userid, 8))
577 conn->path = path;
578 ev.conn = conn;
580 fsm_event(conn->fsm, CONN_EVENT_CONN_REQ, &ev);
589 struct iucv_connection *conn = path->private;
591 fsm_event(conn->fsm, CONN_EVENT_CONN_REJ, conn);
596 struct iucv_connection *conn = path->private;
598 fsm_event(conn->fsm, CONN_EVENT_CONN_SUS, conn);
603 struct iucv_connection *conn = path->private;
605 fsm_event(conn->fsm, CONN_EVENT_CONN_RES, conn);
621 * @conn: The connection where this skb has been received.
627 static void netiucv_unpack_skb(struct iucv_connection *conn,
630 struct net_device *dev = conn->netdev;
685 struct iucv_connection *conn = ev->conn;
687 struct netiucv_priv *privptr = netdev_priv(conn->netdev);
692 if (!conn->netdev) {
693 iucv_message_reject(conn->path, msg);
698 if (msg->length > conn->max_buffsize) {
699 iucv_message_reject(conn->path, msg);
702 msg->length, conn->max_buffsize);
705 conn->rx_buff->data = conn->rx_buff->head;
706 skb_reset_tail_pointer(conn->rx_buff);
707 conn->rx_buff->len = 0;
708 rc = iucv_message_receive(conn->path, msg, 0, conn->rx_buff->data,
715 netiucv_unpack_skb(conn, conn->rx_buff);
721 struct iucv_connection *conn = ev->conn;
736 if (conn && conn->netdev)
737 privptr = netdev_priv(conn->netdev);
738 conn->prof.tx_pending--;
740 if ((skb = skb_dequeue(&conn->commit_queue))) {
751 conn->tx_buff->data = conn->tx_buff->head;
752 skb_reset_tail_pointer(conn->tx_buff);
753 conn->tx_buff->len = 0;
754 spin_lock_irqsave(&conn->collect_lock, saveflags);
755 while ((skb = skb_dequeue(&conn->collect_queue))) {
756 header.next = conn->tx_buff->len + skb->len + NETIUCV_HDRLEN;
757 memcpy(skb_put(conn->tx_buff, NETIUCV_HDRLEN), &header,
760 skb_put(conn->tx_buff, skb->len),
768 if (conn->collect_len > conn->prof.maxmulti)
769 conn->prof.maxmulti = conn->collect_len;
770 conn->collect_len = 0;
771 spin_unlock_irqrestore(&conn->collect_lock, saveflags);
772 if (conn->tx_buff->len == 0) {
778 memcpy(skb_put(conn->tx_buff, NETIUCV_HDRLEN), &header, NETIUCV_HDRLEN);
779 conn->prof.send_stamp = current_kernel_time();
782 rc = iucv_message_send(conn->path, &txmsg, 0, 0,
783 conn->tx_buff->data, conn->tx_buff->len);
784 conn->prof.doios_multi++;
785 conn->prof.txlen += conn->tx_buff->len;
786 conn->prof.tx_pending++;
787 if (conn->prof.tx_pending > conn->prof.tx_max_pending)
788 conn->prof.tx_max_pending = conn->prof.tx_pending;
790 conn->prof.tx_pending--;
800 if (stat_maxcq > conn->prof.maxcqueue)
801 conn->prof.maxcqueue = stat_maxcq;
808 struct iucv_connection *conn = ev->conn;
810 struct net_device *netdev = conn->netdev;
816 conn->path = path;
819 rc = iucv_path_accept(path, &netiucv_handler, NULL, conn);
825 netdev->tx_queue_len = conn->path->msglim;
840 struct iucv_connection *conn = arg;
841 struct net_device *netdev = conn->netdev;
845 fsm_deltimer(&conn->timer);
847 netdev->tx_queue_len = conn->path->msglim;
853 struct iucv_connection *conn = arg;
856 fsm_deltimer(&conn->timer);
857 iucv_path_sever(conn->path, NULL);
863 struct iucv_connection *conn = arg;
864 struct net_device *netdev = conn->netdev;
869 fsm_deltimer(&conn->timer);
870 iucv_path_sever(conn->path, NULL);
881 struct iucv_connection *conn = arg;
882 struct net_device *netdev = conn->netdev;
890 netdev->name, conn->userid);
899 conn->path = iucv_path_alloc(NETIUCV_QUEUELEN_DEFAULT, 0, GFP_KERNEL);
900 rc = iucv_path_connect(conn->path, &netiucv_handler, conn->userid,
901 NULL, iucvMagic, conn);
904 netdev->tx_queue_len = conn->path->msglim;
905 fsm_addtimer(&conn->timer, NETIUCV_TIMEOUT_5SEC,
906 CONN_EVENT_TIMER, conn);
911 netiucv_printname(conn->userid));
917 " guest %s\n", netiucv_printname(conn->userid));
930 netiucv_printname(conn->userid));
947 kfree(conn->path);
948 conn->path = NULL;
964 struct iucv_connection *conn = ev->conn;
965 struct net_device *netdev = conn->netdev;
970 fsm_deltimer(&conn->timer);
972 netiucv_purge_skb_queue(&conn->collect_queue);
973 if (conn->path) {
975 iucv_path_sever(conn->path, iucvMagic);
976 kfree(conn->path);
977 conn->path = NULL;
979 netiucv_purge_skb_queue(&conn->commit_queue);
985 struct iucv_connection *conn = arg;
986 struct net_device *netdev = conn->netdev;
989 netdev->name, conn->userid);
1047 fsm_event(privptr->conn->fsm, CONN_EVENT_START, privptr->conn);
1066 ev.conn = privptr->conn;
1069 fsm_event(privptr->conn->fsm, CONN_EVENT_STOP, &ev);
1093 " successfully to %s\n", privptr->conn->userid);
1148 * @param conn Connection to be used for sending.
1155 static int netiucv_transmit_skb(struct iucv_connection *conn,
1163 if (fsm_getstate(conn->fsm) != CONN_STATE_IDLE) {
1166 spin_lock_irqsave(&conn->collect_lock, saveflags);
1167 if (conn->collect_len + l >
1168 (conn->max_buffsize - NETIUCV_HDRLEN)) {
1174 skb_queue_tail(&conn->collect_queue, skb);
1175 conn->collect_len += l;
1178 spin_unlock_irqrestore(&conn->collect_lock, saveflags);
1210 fsm_newstate(conn->fsm, CONN_STATE_TX);
1211 conn->prof.send_stamp = current_kernel_time();
1215 rc = iucv_message_send(conn->path, &msg, 0, 0,
1217 conn->prof.doios_single++;
1218 conn->prof.txlen += skb->len;
1219 conn->prof.tx_pending++;
1220 if (conn->prof.tx_pending > conn->prof.tx_max_pending)
1221 conn->prof.tx_max_pending = conn->prof.tx_pending;
1224 fsm_newstate(conn->fsm, CONN_STATE_IDLE);
1225 conn->prof.tx_pending--;
1226 privptr = netdev_priv(conn->netdev);
1244 skb_queue_tail(&conn->commit_queue, nskb);
1312 if (priv && priv->conn)
1313 ndev = priv->conn->netdev;
1336 if (priv && priv->conn)
1337 ndev = priv->conn->netdev;
1403 rc = netiucv_transmit_skb(privptr->conn, skb);
1455 return sprintf(buf, "%s\n", netiucv_printname(priv->conn->userid));
1462 struct net_device *ndev = priv->conn->netdev;
1494 if (memcmp(username, priv->conn->userid, 9) &&
1510 memcpy(priv->conn->userid, username, 9);
1522 return sprintf(buf, "%d\n", priv->conn->max_buffsize);
1529 struct net_device *ndev = priv->conn->netdev;
1563 priv->conn->max_buffsize = bs1;
1590 return sprintf(buf, "%s\n", fsm_getstate_str(priv->conn->fsm));
1601 return sprintf(buf, "%ld\n", priv->conn->prof.maxmulti);
1611 priv->conn->prof.maxmulti = 0;
1623 return sprintf(buf, "%ld\n", priv->conn->prof.maxcqueue);
1632 priv->conn->prof.maxcqueue = 0;
1644 return sprintf(buf, "%ld\n", priv->conn->prof.doios_single);
1653 priv->conn->prof.doios_single = 0;
1665 return sprintf(buf, "%ld\n", priv->conn->prof.doios_multi);
1674 priv->conn->prof.doios_multi = 0;
1686 return sprintf(buf, "%ld\n", priv->conn->prof.txlen);
1695 priv->conn->prof.txlen = 0;
1707 return sprintf(buf, "%ld\n", priv->conn->prof.tx_time);
1716 priv->conn->prof.tx_time = 0;
1728 return sprintf(buf, "%ld\n", priv->conn->prof.tx_pending);
1737 priv->conn->prof.tx_pending = 0;
1749 return sprintf(buf, "%ld\n", priv->conn->prof.tx_max_pending);
1758 priv->conn->prof.tx_max_pending = 0;
1869 struct iucv_connection *conn;
1871 conn = kzalloc(sizeof(*conn), GFP_KERNEL);
1872 if (!conn)
1874 skb_queue_head_init(&conn->collect_queue);
1875 skb_queue_head_init(&conn->commit_queue);
1876 spin_lock_init(&conn->collect_lock);
1877 conn->max_buffsize = NETIUCV_BUFSIZE_DEFAULT;
1878 conn->netdev = dev;
1880 conn->rx_buff = alloc_skb(conn->max_buffsize, GFP_KERNEL | GFP_DMA);
1881 if (!conn->rx_buff)
1883 conn->tx_buff = alloc_skb(conn->max_buffsize, GFP_KERNEL | GFP_DMA);
1884 if (!conn->tx_buff)
1886 conn->fsm = init_fsm("netiucvconn", conn_state_names,
1890 if (!conn->fsm)
1893 fsm_settimer(conn->fsm, &conn->timer);
1894 fsm_newstate(conn->fsm, CONN_STATE_INVALID);
1897 memcpy(conn->userid, username, 9);
1898 fsm_newstate(conn->fsm, CONN_STATE_STOPPED);
1902 list_add_tail(&conn->list, &iucv_connection_list);
1904 return conn;
1907 kfree_skb(conn->tx_buff);
1909 kfree_skb(conn->rx_buff);
1911 kfree(conn);
1920 static void netiucv_remove_connection(struct iucv_connection *conn)
1924 list_del_init(&conn->list);
1926 fsm_deltimer(&conn->timer);
1927 netiucv_purge_skb_queue(&conn->collect_queue);
1928 if (conn->path) {
1929 iucv_path_sever(conn->path, iucvMagic);
1930 kfree(conn->path);
1931 conn->path = NULL;
1933 netiucv_purge_skb_queue(&conn->commit_queue);
1934 kfree_fsm(conn->fsm);
1935 kfree_skb(conn->rx_buff);
1936 kfree_skb(conn->tx_buff);
1952 if (privptr->conn)
1953 netiucv_remove_connection(privptr->conn);
1956 privptr->conn = NULL; privptr->fsm = NULL;
2007 privptr->conn = netiucv_new_connection(dev, username);
2008 if (!privptr->conn) {
2135 priv->conn->userid);