Lines Matching refs:server

33 change_conf(struct TCP_Server_Info *server)  in change_conf()  argument
35 server->credits += server->echo_credits + server->oplock_credits; in change_conf()
36 server->oplock_credits = server->echo_credits = 0; in change_conf()
37 switch (server->credits) { in change_conf()
41 server->echoes = false; in change_conf()
42 server->oplocks = false; in change_conf()
46 server->echoes = true; in change_conf()
47 server->oplocks = false; in change_conf()
48 server->echo_credits = 1; in change_conf()
52 server->echoes = true; in change_conf()
54 server->oplocks = true; in change_conf()
55 server->oplock_credits = 1; in change_conf()
57 server->oplocks = false; in change_conf()
59 server->echo_credits = 1; in change_conf()
61 server->credits -= server->echo_credits + server->oplock_credits; in change_conf()
66 smb2_add_credits(struct TCP_Server_Info *server, const unsigned int add, in smb2_add_credits() argument
70 spin_lock(&server->req_lock); in smb2_add_credits()
71 val = server->ops->get_credits_field(server, optype); in smb2_add_credits()
73 server->in_flight--; in smb2_add_credits()
74 if (server->in_flight == 0 && (optype & CIFS_OP_MASK) != CIFS_NEG_OP) in smb2_add_credits()
75 rc = change_conf(server); in smb2_add_credits()
80 else if (server->in_flight > 0 && server->oplock_credits == 0 && in smb2_add_credits()
81 server->oplocks) { in smb2_add_credits()
82 if (server->credits > 1) { in smb2_add_credits()
83 server->credits--; in smb2_add_credits()
84 server->oplock_credits++; in smb2_add_credits()
87 spin_unlock(&server->req_lock); in smb2_add_credits()
88 wake_up(&server->request_q); in smb2_add_credits()
90 cifs_reconnect(server); in smb2_add_credits()
94 smb2_set_credits(struct TCP_Server_Info *server, const int val) in smb2_set_credits() argument
96 spin_lock(&server->req_lock); in smb2_set_credits()
97 server->credits = val; in smb2_set_credits()
98 spin_unlock(&server->req_lock); in smb2_set_credits()
102 smb2_get_credits_field(struct TCP_Server_Info *server, const int optype) in smb2_get_credits_field() argument
106 return &server->echo_credits; in smb2_get_credits_field()
108 return &server->oplock_credits; in smb2_get_credits_field()
110 return &server->credits; in smb2_get_credits_field()
121 smb2_wait_mtu_credits(struct TCP_Server_Info *server, unsigned int size, in smb2_wait_mtu_credits() argument
127 spin_lock(&server->req_lock); in smb2_wait_mtu_credits()
129 if (server->credits <= 0) { in smb2_wait_mtu_credits()
130 spin_unlock(&server->req_lock); in smb2_wait_mtu_credits()
131 cifs_num_waiters_inc(server); in smb2_wait_mtu_credits()
132 rc = wait_event_killable(server->request_q, in smb2_wait_mtu_credits()
133 has_credits(server, &server->credits)); in smb2_wait_mtu_credits()
134 cifs_num_waiters_dec(server); in smb2_wait_mtu_credits()
137 spin_lock(&server->req_lock); in smb2_wait_mtu_credits()
139 if (server->tcpStatus == CifsExiting) { in smb2_wait_mtu_credits()
140 spin_unlock(&server->req_lock); in smb2_wait_mtu_credits()
144 scredits = server->credits; in smb2_wait_mtu_credits()
158 server->credits -= *credits; in smb2_wait_mtu_credits()
159 server->in_flight++; in smb2_wait_mtu_credits()
163 spin_unlock(&server->req_lock); in smb2_wait_mtu_credits()
168 smb2_get_next_mid(struct TCP_Server_Info *server) in smb2_get_next_mid() argument
173 mid = server->CurrentMid++; in smb2_get_next_mid()
179 smb2_find_mid(struct TCP_Server_Info *server, char *buf) in smb2_find_mid() argument
186 list_for_each_entry(mid, &server->pending_mid_q, qhead) { in smb2_find_mid()
212 smb2_need_neg(struct TCP_Server_Info *server) in smb2_need_neg() argument
214 return server->max_read == 0; in smb2_need_neg()
221 ses->server->CurrentMid = 0; in smb2_negotiate()
232 struct TCP_Server_Info *server = tcon->ses->server; in smb2_negotiate_wsize() local
237 wsize = min_t(unsigned int, wsize, server->max_write); in smb2_negotiate_wsize()
239 if (!(server->capabilities & SMB2_GLOBAL_CAP_LARGE_MTU)) in smb2_negotiate_wsize()
248 struct TCP_Server_Info *server = tcon->ses->server; in smb2_negotiate_rsize() local
253 rsize = min_t(unsigned int, rsize, server->max_read); in smb2_negotiate_rsize()
255 if (!(server->capabilities & SMB2_GLOBAL_CAP_LARGE_MTU)) in smb2_negotiate_rsize()
414 smb2_can_echo(struct TCP_Server_Info *server) in smb2_can_echo() argument
416 return server->echoes; in smb2_can_echo()
532 struct TCP_Server_Info *server = tlink_tcon(cfile->tlink)->ses->server; in smb2_set_fid() local
536 server->ops->set_oplock_level(cinode, oplock, fid->epoch, in smb2_set_fid()
949 smb2_is_status_pending(char *buf, struct TCP_Server_Info *server, int length) in smb2_is_status_pending() argument
957 spin_lock(&server->req_lock); in smb2_is_status_pending()
958 server->credits += le16_to_cpu(hdr->CreditRequest); in smb2_is_status_pending()
959 spin_unlock(&server->req_lock); in smb2_is_status_pending()
960 wake_up(&server->request_q); in smb2_is_status_pending()
970 if (tcon->ses->server->capabilities & SMB2_GLOBAL_CAP_LEASING) in smb2_oplock_response()
1254 smb2_downgrade_oplock(struct TCP_Server_Info *server, in smb2_downgrade_oplock() argument
1258 server->ops->set_oplock_level(cinode, SMB2_OPLOCK_LEVEL_II, in smb2_downgrade_oplock()
1261 server->ops->set_oplock_level(cinode, 0, 0, NULL); in smb2_downgrade_oplock()