Lines Matching defs:serv
73 * Queue up an idle server thread. Must have serv->sv_lock held.
79 svc_serv_enqueue(struct svc_serv *serv, struct svc_rqst *rqstp)
81 list_add(&rqstp->rq_list, &serv->sv_threads);
85 * Dequeue an nfsd thread. Must have serv->sv_lock held.
88 svc_serv_dequeue(struct svc_serv *serv, struct svc_rqst *rqstp)
117 struct svc_serv *serv = svsk->sk_server;
124 spin_lock_bh(&serv->sv_lock);
126 if (!list_empty(&serv->sv_threads) &&
127 !list_empty(&serv->sv_sockets))
137 if (((svsk->sk_reserved + serv->sv_bufsz)*2
143 svsk->sk_sk, svsk->sk_reserved+serv->sv_bufsz,
154 if (!list_empty(&serv->sv_threads)) {
155 rqstp = list_entry(serv->sv_threads.next,
160 svc_serv_dequeue(serv, rqstp);
167 rqstp->rq_reserved = serv->sv_bufsz;
172 list_add_tail(&svsk->sk_ready, &serv->sv_sockets);
177 spin_unlock_bh(&serv->sv_lock);
181 * Dequeue the first socket. Must be called with the serv->sv_lock held.
184 svc_sock_dequeue(struct svc_serv *serv)
188 if (list_empty(&serv->sv_sockets))
191 svsk = list_entry(serv->sv_sockets.next,
247 struct svc_serv *serv = svsk->sk_server;
249 spin_lock_bh(&serv->sv_lock);
251 spin_unlock_bh(&serv->sv_lock);
257 spin_unlock_bh(&serv->sv_lock);
289 svc_wake_up(struct svc_serv *serv)
293 spin_lock_bh(&serv->sv_lock);
294 if (!list_empty(&serv->sv_threads)) {
295 rqstp = list_entry(serv->sv_threads.next,
300 svc_serv_dequeue(serv, rqstp);
305 spin_unlock_bh(&serv->sv_lock);
465 struct svc_serv *serv = svsk->sk_server;
477 (serv->sv_nrthreads+3)* serv->sv_bufsz,
478 (serv->sv_nrthreads+3)* serv->sv_bufsz);
523 if (serv->sv_stats)
524 serv->sv_stats->netudpcnt++;
648 struct svc_serv *serv = svsk->sk_server;
660 printk(KERN_WARNING "%s: no more sockets!\n", serv->sv_name);
672 serv->sv_name, -err);
683 serv->sv_name, -err);
694 serv->sv_name,
698 dprintk("%s: connect from %u.%u.%u.%u:%04x\n", serv->sv_name,
701 if (!(newsvsk = svc_setup_socket(serv, newsock, &err, 0)))
720 if (serv->sv_tmpcnt > (serv->sv_nrthreads+3)*10) {
722 spin_lock_bh(&serv->sv_lock);
723 if (!list_empty(&serv->sv_tempsocks)) {
725 svsk = list_entry(serv->sv_tempsocks.prev,
729 svsk = list_entry(serv->sv_tempsocks.next,
735 spin_unlock_bh(&serv->sv_lock);
744 if (serv->sv_stats)
745 serv->sv_stats->nettcpconn++;
761 struct svc_serv *serv = svsk->sk_server;
790 (serv->sv_nrthreads+3) *
791 serv->sv_bufsz,
792 3 * serv->sv_bufsz);
866 if (serv->sv_stats)
867 serv->sv_stats->nettcpcnt++;
951 svc_sock_update_bufs(struct svc_serv *serv)
962 spin_lock_bh(&serv->sv_lock);
963 list_for_each(le, &serv->sv_permsocks) {
968 list_for_each(le, &serv->sv_tempsocks) {
973 spin_unlock_bh(&serv->sv_lock);
980 svc_recv(struct svc_serv *serv, struct svc_rqst *rqstp, long timeout)
1005 spin_lock_bh(&serv->sv_lock);
1006 if (!list_empty(&serv->sv_tempsocks)) {
1007 svsk = list_entry(serv->sv_tempsocks.next,
1023 } else if ((svsk = svc_sock_dequeue(serv)) != NULL) {
1026 rqstp->rq_reserved = serv->sv_bufsz;
1030 svc_serv_enqueue(serv, rqstp);
1038 spin_unlock_bh(&serv->sv_lock);
1042 spin_lock_bh(&serv->sv_lock);
1046 svc_serv_dequeue(serv, rqstp);
1047 spin_unlock_bh(&serv->sv_lock);
1052 spin_unlock_bh(&serv->sv_lock);
1067 spin_lock_bh(&serv->sv_lock);
1069 list_add_tail(&svsk->sk_list, &serv->sv_tempsocks);
1070 spin_unlock_bh(&serv->sv_lock);
1083 if (serv->sv_stats)
1084 serv->sv_stats->netcnt++;
1125 svc_setup_socket(struct svc_serv *serv, struct socket *sock,
1145 svsk->sk_server = serv;
1158 *errp = svc_register(serv, inet->protocol, ntohs(inet->sport));
1167 spin_lock_bh(&serv->sv_lock);
1170 list_add(&svsk->sk_list, &serv->sv_tempsocks);
1171 serv->sv_tmpcnt++;
1174 list_add(&svsk->sk_list, &serv->sv_permsocks);
1176 spin_unlock_bh(&serv->sv_lock);
1187 svc_create_socket(struct svc_serv *serv, int protocol, struct sockaddr_in *sin)
1195 serv->sv_program->pg_name, protocol,
1222 if ((svsk = svc_setup_socket(serv, sock, &error, 1)) != NULL)
1237 struct svc_serv *serv;
1242 serv = svsk->sk_server;
1249 spin_lock_bh(&serv->sv_lock);
1253 serv->sv_tmpcnt--;
1261 spin_unlock_bh(&serv->sv_lock);
1265 spin_unlock_bh(&serv->sv_lock);
1275 svc_makesock(struct svc_serv *serv, int protocol, unsigned short port)
1283 return svc_create_socket(serv, protocol, &sin);