| /linux-4.1.27/drivers/staging/lustre/lustre/obdclass/ |
| H A D | uuid.c | 47 static inline __u32 consume(int nob, __u8 **ptr) consume() argument
51 LASSERT(nob <= sizeof(value)); consume()
53 for (value = 0; nob > 0; --nob) consume()
|
| H A D | dt_object.c | 645 * \param nob - is the maximum number of bytes that should be copied
652 int nob, const struct dt_it_ops *iops, dt_index_page_build()
667 nob -= LIP_HDR_SIZE; dt_index_page_build()
692 if (nob < size) { dt_index_page_build()
724 nob -= size; dt_index_page_build()
764 unsigned int pageidx, nob, nlupgs = 0; dt_index_walk() local
770 nob = rdpg->rp_count; dt_index_walk()
771 if (nob <= 0) dt_index_walk()
805 for (pageidx = 0; rc == 0 && nob > 0; pageidx++) { dt_index_walk()
813 for (i = 0; i < LU_PAGE_COUNT; i++, lp++, nob -= LU_PAGE_SIZE) { dt_index_walk()
814 rc = filler(env, lp, min_t(int, nob, LU_PAGE_SIZE), dt_index_walk()
651 dt_index_page_build(const struct lu_env *env, union lu_page *lp, int nob, const struct dt_it_ops *iops, struct dt_it *it, __u32 attr, void *arg) dt_index_page_build() argument
|
| H A D | cl_io.c | 571 * Records that read or write io progressed \a nob bytes forward.
573 void cl_io_rw_advance(const struct lu_env *env, struct cl_io *io, size_t nob) cl_io_rw_advance() argument
578 nob == 0); cl_io_rw_advance()
582 io->u.ci_rw.crw_pos += nob; cl_io_rw_advance()
583 io->u.ci_rw.crw_count -= nob; cl_io_rw_advance()
589 nob); cl_io_for_each_reverse()
983 size_t nob; cl_io_loop() local
988 nob = io->ci_nob; cl_io_loop()
1007 cl_io_rw_advance(env, io, io->ci_nob - nob); cl_io_loop()
|
| /linux-4.1.27/drivers/staging/lustre/lustre/libcfs/linux/ |
| H A D | linux-tcpip.c | 81 int nob; libcfs_ipif_query() local
85 nob = strnlen(name, IFNAMSIZ); libcfs_ipif_query()
86 if (nob == IFNAMSIZ) { libcfs_ipif_query()
150 int nob; libcfs_ipif_enumerate() local
204 nob = strnlen (ifr[i].ifr_name, IFNAMSIZ); libcfs_ipif_enumerate()
205 if (nob == IFNAMSIZ) { libcfs_ipif_enumerate()
208 nob, ifr[i].ifr_name, IFNAMSIZ); libcfs_ipif_enumerate()
219 memcpy(names[i], ifr[i].ifr_name, nob); libcfs_ipif_enumerate()
220 names[i][nob] = 0; libcfs_ipif_enumerate()
253 libcfs_sock_write (struct socket *sock, void *buffer, int nob, int timeout) libcfs_sock_write() argument
260 LASSERT (nob > 0); libcfs_sock_write()
267 .iov_len = nob libcfs_sock_write()
289 rc = kernel_sendmsg(sock, &msg, &iov, 1, nob); libcfs_sock_write()
292 if (rc == nob) libcfs_sock_write()
307 nob -= rc; libcfs_sock_write()
315 libcfs_sock_read (struct socket *sock, void *buffer, int nob, int timeout) libcfs_sock_read() argument
322 LASSERT (nob > 0); libcfs_sock_read()
328 .iov_len = nob libcfs_sock_read()
348 rc = kernel_recvmsg(sock, &msg, &iov, 1, nob, 0); libcfs_sock_read()
358 nob -= rc; libcfs_sock_read()
360 if (nob == 0) libcfs_sock_read()
|
| /linux-4.1.27/drivers/staging/lustre/lnet/klnds/socklnd/ |
| H A D | socklnd_lib-linux.c | 81 int nob; ksocknal_lib_send_iov() local
105 for (nob = i = 0; i < niov; i++) { ksocknal_lib_send_iov()
107 nob += scratchiov[i].iov_len; ksocknal_lib_send_iov()
111 nob < tx->tx_resid) ksocknal_lib_send_iov()
114 rc = kernel_sendmsg(sock, &msg, scratchiov, niov, nob); ksocknal_lib_send_iov()
125 int nob; ksocknal_lib_send_kiov() local
169 for (nob = i = 0; i < niov; i++) { ksocknal_lib_send_kiov()
172 nob += scratchiov[i].iov_len = kiov[i].kiov_len; ksocknal_lib_send_kiov()
176 nob < tx->tx_resid) ksocknal_lib_send_kiov()
179 rc = kernel_sendmsg(sock, &msg, (struct kvec *)scratchiov, niov, nob); ksocknal_lib_send_kiov()
217 int nob; ksocknal_lib_recv_iov() local
228 for (nob = i = 0; i < niov; i++) { ksocknal_lib_recv_iov()
230 nob += scratchiov[i].iov_len; ksocknal_lib_recv_iov()
232 LASSERT(nob <= conn->ksnc_rx_nob_wanted); ksocknal_lib_recv_iov()
235 scratchiov, niov, nob, MSG_DONTWAIT); ksocknal_lib_recv_iov()
275 int nob; ksocknal_lib_kiov_vmap() local
287 for (nob = i = 0; i < niov; i++) { ksocknal_lib_kiov_vmap()
293 nob += kiov[i].kiov_len; ksocknal_lib_kiov_vmap()
301 iov->iov_len = nob; ksocknal_lib_kiov_vmap()
326 int nob; ksocknal_lib_recv_kiov() local
339 nob = scratchiov[0].iov_len; ksocknal_lib_recv_kiov()
343 for (nob = i = 0; i < niov; i++) { ksocknal_lib_recv_kiov()
344 nob += scratchiov[i].iov_len = kiov[i].kiov_len; ksocknal_lib_recv_kiov()
351 LASSERT(nob <= conn->ksnc_rx_nob_wanted); ksocknal_lib_recv_kiov()
354 (struct kvec *)scratchiov, n, nob, MSG_DONTWAIT); ksocknal_lib_recv_kiov()
|
| H A D | socklnd_cb.c | 114 int nob; ksocknal_send_iov() local
125 nob = rc; ksocknal_send_iov()
126 LASSERT (nob <= tx->tx_resid); ksocknal_send_iov()
127 tx->tx_resid -= nob; ksocknal_send_iov()
133 if (nob < (int) iov->iov_len) { ksocknal_send_iov()
134 iov->iov_base = (void *)((char *)iov->iov_base + nob); ksocknal_send_iov()
135 iov->iov_len -= nob; ksocknal_send_iov()
139 nob -= iov->iov_len; ksocknal_send_iov()
142 } while (nob != 0); ksocknal_send_iov()
151 int nob; ksocknal_send_kiov() local
163 nob = rc; ksocknal_send_kiov()
164 LASSERT (nob <= tx->tx_resid); ksocknal_send_kiov()
165 tx->tx_resid -= nob; ksocknal_send_kiov()
171 if (nob < (int)kiov->kiov_len) { ksocknal_send_kiov()
172 kiov->kiov_offset += nob; ksocknal_send_kiov()
173 kiov->kiov_len -= nob; ksocknal_send_kiov()
177 nob -= (int)kiov->kiov_len; ksocknal_send_kiov()
180 } while (nob != 0); ksocknal_send_kiov()
255 int nob; ksocknal_recv_iov() local
268 nob = rc; ksocknal_recv_iov()
276 conn->ksnc_rx_nob_wanted -= nob; ksocknal_recv_iov()
277 conn->ksnc_rx_nob_left -= nob; ksocknal_recv_iov()
282 if (nob < (int)iov->iov_len) { ksocknal_recv_iov()
283 iov->iov_len -= nob; ksocknal_recv_iov()
284 iov->iov_base += nob; ksocknal_recv_iov()
288 nob -= iov->iov_len; ksocknal_recv_iov()
291 } while (nob != 0); ksocknal_recv_iov()
300 int nob; ksocknal_recv_kiov() local
312 nob = rc; ksocknal_recv_kiov()
320 conn->ksnc_rx_nob_wanted -= nob; ksocknal_recv_kiov()
321 conn->ksnc_rx_nob_left -= nob; ksocknal_recv_kiov()
326 if (nob < (int) kiov->kiov_len) { ksocknal_recv_kiov()
327 kiov->kiov_offset += nob; ksocknal_recv_kiov()
328 kiov->kiov_len -= nob; ksocknal_recv_kiov()
332 nob -= kiov->kiov_len; ksocknal_recv_kiov()
335 } while (nob != 0); ksocknal_recv_kiov()
629 int nob = atomic_read(&c->ksnc_tx_nob) + ksocknal_find_conn_locked() local
646 if (typed == NULL || tnob > nob || ksocknal_find_conn_locked()
647 (tnob == nob && *ksocknal_tunables.ksnd_round_robin && ksocknal_find_conn_locked()
650 tnob = nob; ksocknal_find_conn_locked()
655 if (fallback == NULL || fnob > nob || ksocknal_find_conn_locked()
656 (fnob == nob && *ksocknal_tunables.ksnd_round_robin && ksocknal_find_conn_locked()
659 fnob = nob; ksocknal_find_conn_locked()
717 CDEBUG (D_NET, "Packet %p type %d, nob %d niov %d nkiov %d\n", ksocknal_queue_tx_locked()
1031 int nob; ksocknal_new_packet() local
1090 nob = min_t(int, nob_to_skip, sizeof(ksocknal_slop_buffer)); ksocknal_new_packet()
1093 conn->ksnc_rx_iov[niov].iov_len = nob; ksocknal_new_packet()
1095 skipped += nob; ksocknal_new_packet()
1096 nob_to_skip -=nob; ksocknal_new_packet()
|
| H A D | socklnd_proto.c | 276 int nob; ksocknal_match_tx() local
285 nob = offsetof(ksock_msg_t, ksm_u); ksocknal_match_tx()
287 nob = tx->tx_lnetmsg->msg_len + ksocknal_match_tx()
304 if (nob < *ksocknal_tunables.ksnd_min_bulk) ksocknal_match_tx()
310 if (nob >= *ksocknal_tunables.ksnd_min_bulk) ksocknal_match_tx()
320 int nob; ksocknal_match_tx_v3() local
323 nob = offsetof(ksock_msg_t, ksm_u); ksocknal_match_tx_v3()
325 nob = tx->tx_lnetmsg->msg_len + sizeof(ksock_msg_t); ksocknal_match_tx_v3()
345 else if (nob < *ksocknal_tunables.ksnd_min_bulk) ksocknal_match_tx_v3()
353 else if (nob >= *ksocknal_tunables.ksnd_min_bulk) ksocknal_match_tx_v3()
|
| /linux-4.1.27/drivers/staging/lustre/lustre/libcfs/ |
| H A D | nidstrings.c | 84 static int libcfs_lo_str2addr(const char *str, int nob, __u32 *addr) libcfs_lo_str2addr() argument
97 static int libcfs_ip_str2addr(const char *str, int nob, __u32 *addr) libcfs_ip_str2addr() argument
103 int n = nob; /* XscanfX */ libcfs_ip_str2addr()
107 n == nob && libcfs_ip_str2addr()
127 static int libcfs_num_str2addr(const char *str, int nob, __u32 *addr) libcfs_num_str2addr() argument
131 n = nob; libcfs_num_str2addr()
132 if (sscanf(str, "0x%x%n", addr, &n) >= 1 && n == nob) libcfs_num_str2addr()
135 n = nob; libcfs_num_str2addr()
136 if (sscanf(str, "0X%x%n", addr, &n) >= 1 && n == nob) libcfs_num_str2addr()
139 n = nob; libcfs_num_str2addr()
140 if (sscanf(str, "%u%n", addr, &n) >= 1 && n == nob) libcfs_num_str2addr()
189 int (*nf_str2addr)(const char *str, int nob, __u32 *addr);
412 int nob; libcfs_nid2str() local
424 nob = strlen(str); libcfs_nid2str()
426 snprintf(str + nob, LNET_NIDSTR_SIZE - nob, "@%s", libcfs_nid2str()
429 snprintf(str + nob, LNET_NIDSTR_SIZE - nob, "@%s%d", libcfs_nid2str()
441 int nob; libcfs_str2net_internal() local
455 nob = strlen(nf->nf_name); libcfs_str2net_internal()
457 if (strlen(str) == (unsigned int)nob) { libcfs_str2net_internal()
463 str += nob; libcfs_str2net_internal()
|
| H A D | module.c | 515 loff_t pos, void __user *buffer, int nob) __proc_dobitmasks()
535 rc = cfs_trace_copyout_string(buffer, nob, __proc_dobitmasks()
539 rc = cfs_trace_copyin_string(tmpstr, tmpstrlen, buffer, nob); __proc_dobitmasks()
566 loff_t pos, void __user *buffer, int nob) __proc_dump_kernel()
571 return cfs_trace_dump_debug_buffer_usrstr(buffer, nob); __proc_dump_kernel()
582 loff_t pos, void __user *buffer, int nob) __proc_daemon_file()
590 return cfs_trace_copyout_string(buffer, nob, __proc_daemon_file()
594 return cfs_trace_daemon_command_usrstr(buffer, nob); __proc_daemon_file()
605 loff_t pos, void __user *buffer, int nob) __proc_debug_mb()
615 return cfs_trace_copyout_string(buffer, nob, tmpstr + pos, __proc_debug_mb()
619 return cfs_trace_set_debug_mb_usrstr(buffer, nob); __proc_debug_mb()
746 loff_t pos, void __user *buffer, int nob) __proc_cpt_table()
779 rc = cfs_trace_copyout_string(buffer, nob, buf + pos, NULL); __proc_cpt_table()
514 __proc_dobitmasks(void *data, int write, loff_t pos, void __user *buffer, int nob) __proc_dobitmasks() argument
565 __proc_dump_kernel(void *data, int write, loff_t pos, void __user *buffer, int nob) __proc_dump_kernel() argument
581 __proc_daemon_file(void *data, int write, loff_t pos, void __user *buffer, int nob) __proc_daemon_file() argument
604 __proc_debug_mb(void *data, int write, loff_t pos, void __user *buffer, int nob) __proc_debug_mb() argument
745 __proc_cpt_table(void *data, int write, loff_t pos, void __user *buffer, int nob) __proc_cpt_table() argument
|
| H A D | tracefile.c | 758 int nob; cfs_trace_copyin_string() local
767 nob = strnlen(knl_buffer, usr_buffer_nob); cfs_trace_copyin_string()
768 while (nob-- >= 0) /* strip trailing whitespace */ cfs_trace_copyin_string()
769 if (!isspace(knl_buffer[nob])) cfs_trace_copyin_string()
772 if (nob < 0) /* empty string */ cfs_trace_copyin_string()
775 if (nob == knl_buffer_nob) /* no space to terminate */ cfs_trace_copyin_string()
778 knl_buffer[nob + 1] = 0; /* terminate */ cfs_trace_copyin_string()
789 int nob = strlen(knl_buffer); cfs_trace_copyout_string() local
791 if (nob > usr_buffer_nob) cfs_trace_copyout_string()
792 nob = usr_buffer_nob; cfs_trace_copyout_string()
794 if (copy_to_user(usr_buffer, knl_buffer, nob)) cfs_trace_copyout_string()
797 if (append != NULL && nob < usr_buffer_nob) { cfs_trace_copyout_string()
798 if (copy_to_user(usr_buffer + nob, append, 1)) cfs_trace_copyout_string()
801 nob++; cfs_trace_copyout_string()
804 return nob; cfs_trace_copyout_string()
808 int cfs_trace_allocate_string_buffer(char **str, int nob) cfs_trace_allocate_string_buffer() argument
810 if (nob > 2 * PAGE_CACHE_SIZE) /* string must be "sensible" */ cfs_trace_allocate_string_buffer()
813 *str = kmalloc(nob, GFP_IOFS | __GFP_ZERO); cfs_trace_allocate_string_buffer()
820 void cfs_trace_free_string_buffer(char *str, int nob) cfs_trace_free_string_buffer() argument
|
| H A D | libcfs_string.c | 223 * \retval 1 if first \a nob chars of \a str convert to decimal or
228 cfs_str2num_check(char *str, int nob, unsigned *num, cfs_str2num_check() argument
238 for (; endp < str + nob; endp++) { cfs_str2num_check()
|
| H A D | tracefile.h | 74 int cfs_trace_allocate_string_buffer(char **str, int nob);
75 void cfs_trace_free_string_buffer(char *str, int nob);
|
| /linux-4.1.27/drivers/staging/lustre/lnet/lnet/ |
| H A D | config.c | 372 int nob; lnet_new_text_buf() local
375 nob = offsetof(struct lnet_text_buf_t, ltb_text[str_len + 1]); lnet_new_text_buf()
376 if (nob > LNET_SINGLE_TEXTBUF_NOB) { lnet_new_text_buf()
382 if (lnet_tbnob + nob > LNET_MAX_TEXTBUF_NOB) { lnet_new_text_buf()
387 LIBCFS_ALLOC(ltb, nob); lnet_new_text_buf()
391 ltb->ltb_size = nob; lnet_new_text_buf()
393 lnet_tbnob += nob; lnet_new_text_buf()
422 int nob; lnet_str2tbs_sep() local
439 nob = (int)(sep - str); lnet_str2tbs_sep()
440 if (nob > 0) { lnet_str2tbs_sep()
441 ltb = lnet_new_text_buf(nob); lnet_str2tbs_sep()
447 for (i = 0; i < nob; i++) lnet_str2tbs_sep()
453 ltb->ltb_text[nob] = 0; lnet_str2tbs_sep()
513 int nob; lnet_str2tbs_expand() local
566 nob = strlen(num); lnet_str2tbs_expand()
567 if (nob + 1 == sizeof(num)) lnet_str2tbs_expand()
571 num, nob) != 0) lnet_str2tbs_expand()
588 int nob = len; lnet_parse_hops() local
590 return (sscanf(str, "%u%n", hops, &nob) >= 1 && lnet_parse_hops()
591 nob == len && lnet_parse_hops()
600 int nob; lnet_parse_priority() local
611 if ((sscanf((sep+1), "%u%n", priority, &nob) < 1) || (len != nob)) { lnet_parse_priority()
618 CDEBUG(D_NET, "gateway %s, priority %d, nob %d\n", str, *priority, nob); lnet_parse_priority()
|
| H A D | lib-move.c | 163 unsigned int nob = 0; lnet_iov_nob() local
166 nob += (iov++)->iov_len; lnet_iov_nob()
168 return nob; lnet_iov_nob()
175 unsigned int nob) lnet_copy_iov2iov()
180 if (nob == 0) lnet_copy_iov2iov()
206 this_nob = min(this_nob, nob); lnet_copy_iov2iov()
210 nob -= this_nob; lnet_copy_iov2iov()
227 } while (nob > 0); lnet_copy_iov2iov()
282 unsigned int nob = 0; lnet_kiov_nob() local
285 nob += (kiov++)->kiov_len; lnet_kiov_nob()
287 return nob; lnet_kiov_nob()
294 unsigned int nob) lnet_copy_kiov2kiov()
301 if (nob == 0) lnet_copy_kiov2kiov()
327 this_nob = min(this_nob, nob); lnet_copy_kiov2kiov()
341 nob -= this_nob; lnet_copy_kiov2kiov()
364 } while (nob > 0); lnet_copy_kiov2kiov()
376 unsigned int kiovoffset, unsigned int nob) lnet_copy_kiov2iov()
382 if (nob == 0) lnet_copy_kiov2iov()
408 this_nob = min(this_nob, nob); lnet_copy_kiov2iov()
415 nob -= this_nob; lnet_copy_kiov2iov()
436 } while (nob > 0); lnet_copy_kiov2iov()
447 unsigned int nob) lnet_copy_iov2kiov()
453 if (nob == 0) lnet_copy_iov2kiov()
479 this_nob = min(this_nob, nob); lnet_copy_iov2kiov()
486 nob -= this_nob; lnet_copy_iov2kiov()
506 } while (nob > 0); lnet_copy_iov2kiov()
1354 lnet_drop_message(lnet_ni_t *ni, int cpt, void *private, unsigned int nob) lnet_drop_message() argument
1358 the_lnet.ln_counters[cpt]->drop_length += nob; lnet_drop_message()
1361 lnet_ni_recv(ni, private, NULL, 0, 0, 0, nob); lnet_drop_message()
173 lnet_copy_iov2iov(unsigned int ndiov, struct kvec *diov, unsigned int doffset, unsigned int nsiov, struct kvec *siov, unsigned int soffset, unsigned int nob) lnet_copy_iov2iov() argument
292 lnet_copy_kiov2kiov(unsigned int ndiov, lnet_kiov_t *diov, unsigned int doffset, unsigned int nsiov, lnet_kiov_t *siov, unsigned int soffset, unsigned int nob) lnet_copy_kiov2kiov() argument
374 lnet_copy_kiov2iov(unsigned int niov, struct kvec *iov, unsigned int iovoffset, unsigned int nkiov, lnet_kiov_t *kiov, unsigned int kiovoffset, unsigned int nob) lnet_copy_kiov2iov() argument
444 lnet_copy_iov2kiov(unsigned int nkiov, lnet_kiov_t *kiov, unsigned int kiovoffset, unsigned int niov, struct kvec *iov, unsigned int iovoffset, unsigned int nob) lnet_copy_iov2kiov() argument
|
| H A D | router_proc.c | 113 loff_t pos, void __user *buffer, int nob) __proc_lnet_stats()
152 rc = cfs_trace_copyout_string(buffer, nob, __proc_lnet_stats()
596 loff_t pos, void __user *buffer, int nob) __proc_lnet_buffers()
646 rc = cfs_trace_copyout_string(buffer, nob,
816 loff_t pos, void __user *buffer, int nob) __proc_lnet_portal_rotor()
848 rc = cfs_trace_copyout_string(buffer, nob, __proc_lnet_portal_rotor()
854 rc = cfs_trace_copyin_string(buf, buf_len, buffer, nob); __proc_lnet_portal_rotor()
112 __proc_lnet_stats(void *data, int write, loff_t pos, void __user *buffer, int nob) __proc_lnet_stats() argument
595 __proc_lnet_buffers(void *data, int write, loff_t pos, void __user *buffer, int nob) __proc_lnet_buffers() argument
815 __proc_lnet_portal_rotor(void *data, int write, loff_t pos, void __user *buffer, int nob) __proc_lnet_portal_rotor() argument
|
| H A D | api-ni.c | 1774 int nob; lnet_ping() local
1879 nob = rc; lnet_ping()
1880 LASSERT(nob >= 0 && nob <= infosz); lnet_ping()
1884 if (nob < 8) { lnet_ping()
1887 libcfs_id2str(id), nob); lnet_ping()
1905 if (nob < offsetof(lnet_ping_info_t, pi_ni[0])) { lnet_ping()
1907 nob, (int)offsetof(lnet_ping_info_t, pi_ni[0])); lnet_ping()
1914 if (nob < offsetof(lnet_ping_info_t, pi_ni[n_ids])) { lnet_ping()
1916 nob, (int)offsetof(lnet_ping_info_t, pi_ni[n_ids])); lnet_ping()
|
| /linux-4.1.27/drivers/staging/lustre/lnet/klnds/o2iblnd/ |
| H A D | o2iblnd_cb.c | 457 kiblnd_rx_complete(kib_rx_t *rx, int status, int nob) kiblnd_rx_complete() argument
479 LASSERT(nob >= 0); kiblnd_rx_complete()
480 rx->rx_nob = nob; kiblnd_rx_complete()
551 kiblnd_fmr_map_tx(kib_net_t *net, kib_tx_t *tx, kib_rdma_desc_t *rd, int nob) kiblnd_fmr_map_tx() argument
589 rd->rd_frags[0].rf_nob = nob; kiblnd_fmr_map_tx()
596 kiblnd_pmr_map_tx(kib_net_t *net, kib_tx_t *tx, kib_rdma_desc_t *rd, int nob) kiblnd_pmr_map_tx() argument
626 rd->rd_frags[0].rf_nob = nob; kiblnd_pmr_map_tx()
661 __u32 nob; kiblnd_map_tx() local
673 for (i = 0, nob = 0; i < rd->rd_nfrags; i++) { kiblnd_map_tx()
678 nob += rd->rd_frags[i].rf_nob; kiblnd_map_tx()
690 return kiblnd_fmr_map_tx(net, tx, rd, nob); kiblnd_map_tx()
692 return kiblnd_pmr_map_tx(net, tx, rd, nob); kiblnd_map_tx()
700 unsigned int niov, struct kvec *iov, int offset, int nob) kiblnd_setup_rd_iov()
709 LASSERT(nob > 0); kiblnd_setup_rd_iov()
732 fragnob = min((int)(iov->iov_len - offset), nob); kiblnd_setup_rd_iov()
745 nob -= fragnob; kiblnd_setup_rd_iov()
746 } while (nob > 0); kiblnd_setup_rd_iov()
753 int nkiov, lnet_kiov_t *kiov, int offset, int nob) kiblnd_setup_rd_kiov()
759 CDEBUG(D_NET, "niov %d offset %d nob %d\n", nkiov, offset, nob); kiblnd_setup_rd_kiov()
761 LASSERT(nob > 0); kiblnd_setup_rd_kiov()
776 fragnob = min((int)(kiov->kiov_len - offset), nob); kiblnd_setup_rd_kiov()
785 nob -= fragnob; kiblnd_setup_rd_kiov()
786 } while (nob > 0); kiblnd_setup_rd_kiov()
1057 int nob = offsetof(kib_msg_t, ibm_u) + body_nob; kiblnd_init_tx_msg() local
1062 LASSERT(nob <= IBLND_MSG_SIZE); kiblnd_init_tx_msg()
1066 mr = kiblnd_find_dma_mr(hdev, tx->tx_msgaddr, nob); kiblnd_init_tx_msg()
1071 sge->length = nob; kiblnd_init_tx_msg()
1471 int nob; kiblnd_send() local
1501 nob = offsetof(kib_msg_t, ibm_u.immediate.ibim_payload[lntmsg->msg_md->md_length]); kiblnd_send()
1502 if (nob <= IBLND_MSG_SIZE) kiblnd_send()
1533 nob = offsetof(kib_get_msg_t, ibgm_rd.rd_frags[tx->tx_nfrags]); kiblnd_send()
1537 kiblnd_init_tx_msg(ni, tx, IBLND_MSG_GET_REQ, nob); kiblnd_send()
1555 nob = offsetof(kib_msg_t, ibm_u.immediate.ibim_payload[payload_nob]); kiblnd_send()
1556 if (nob <= IBLND_MSG_SIZE) kiblnd_send()
1619 nob = offsetof(kib_immediate_msg_t, ibim_payload[payload_nob]); kiblnd_send()
1620 kiblnd_init_tx_msg(ni, tx, IBLND_MSG_IMMEDIATE, nob); kiblnd_send()
1635 unsigned int nob = lntmsg->msg_len; kiblnd_reply() local
1646 if (nob == 0) kiblnd_reply()
1650 niov, iov, offset, nob); kiblnd_reply()
1653 niov, kiov, offset, nob); kiblnd_reply()
1662 IBLND_MSG_GET_DONE, nob, kiblnd_reply()
1671 if (nob == 0) { kiblnd_reply()
1699 int nob; kiblnd_recv() local
1713 nob = offsetof(kib_msg_t, ibm_u.immediate.ibim_payload[rlen]); kiblnd_recv()
1714 if (nob > rx->rx_nob) { kiblnd_recv()
1717 nob, rx->rx_nob); kiblnd_recv()
1771 nob = offsetof(kib_putack_msg_t, ibpam_rd.rd_frags[tx->tx_nfrags]); kiblnd_recv()
1775 kiblnd_init_tx_msg(ni, tx, IBLND_MSG_PUT_ACK, nob); kiblnd_recv()
699 kiblnd_setup_rd_iov(lnet_ni_t *ni, kib_tx_t *tx, kib_rdma_desc_t *rd, unsigned int niov, struct kvec *iov, int offset, int nob) kiblnd_setup_rd_iov() argument
752 kiblnd_setup_rd_kiov(lnet_ni_t *ni, kib_tx_t *tx, kib_rdma_desc_t *rd, int nkiov, lnet_kiov_t *kiov, int offset, int nob) kiblnd_setup_rd_kiov() argument
|
| H A D | o2iblnd.h | 867 kiblnd_rd_consume_frag(kib_rdma_desc_t *rd, int index, __u32 nob) kiblnd_rd_consume_frag() argument
869 if (nob < rd->rd_frags[index].rf_nob) { kiblnd_rd_consume_frag()
870 rd->rd_frags[index].rf_addr += nob; kiblnd_rd_consume_frag()
871 rd->rd_frags[index].rf_nob -= nob; kiblnd_rd_consume_frag()
1008 int nob, kib_rdma_desc_t *dstrd, __u64 dstcookie);
1024 int kiblnd_unpack_msg(kib_msg_t *msg, int nob);
|
| H A D | o2iblnd.c | 56 static __u32 kiblnd_cksum(void *ptr, int nob) kiblnd_cksum() argument
61 while (nob-- > 0) kiblnd_cksum()
142 int nob; kiblnd_unpack_rd() local
166 nob = offsetof(kib_msg_t, ibm_u) + kiblnd_unpack_rd()
169 if (msg->ibm_nob < nob) { kiblnd_unpack_rd()
171 kiblnd_msgtype2str(msg->ibm_type), msg->ibm_nob, nob); kiblnd_unpack_rd()
210 int kiblnd_unpack_msg(kib_msg_t *msg, int nob) kiblnd_unpack_msg() argument
219 if (nob < 6) { kiblnd_unpack_msg()
220 CERROR("Short message: %d\n", nob); kiblnd_unpack_msg()
240 if (nob < hdr_size) { kiblnd_unpack_msg()
241 CERROR("Short message: %d\n", nob); kiblnd_unpack_msg()
246 if (msg_nob > nob) { kiblnd_unpack_msg()
247 CERROR("Short message: got %d, wanted %d\n", nob, msg_nob); kiblnd_unpack_msg()
|
| /linux-4.1.27/drivers/staging/lustre/include/linux/lnet/ |
| H A D | lib-lnet.h | 769 unsigned int soffset, unsigned int nob);
773 unsigned int kiovoffset, unsigned int nob);
777 unsigned int iovoffset, unsigned int nob);
781 unsigned int soffset, unsigned int nob);
786 unsigned int nob) lnet_copy_iov2flat()
791 nsiov, siov, soffset, nob); lnet_copy_iov2flat()
797 unsigned int soffset, unsigned int nob) lnet_copy_kiov2flat()
802 nsiov, skiov, soffset, nob); lnet_copy_kiov2flat()
807 int slen, void *src, unsigned int soffset, unsigned int nob) lnet_copy_flat2iov()
812 1, &siov, soffset, nob); lnet_copy_flat2iov()
818 unsigned int soffset, unsigned int nob) lnet_copy_flat2kiov()
823 1, &siov, soffset, nob); lnet_copy_flat2kiov()
784 lnet_copy_iov2flat(int dlen, void *dest, unsigned int doffset, unsigned int nsiov, struct kvec *siov, unsigned int soffset, unsigned int nob) lnet_copy_iov2flat() argument
795 lnet_copy_kiov2flat(int dlen, void *dest, unsigned int doffset, unsigned int nsiov, lnet_kiov_t *skiov, unsigned int soffset, unsigned int nob) lnet_copy_kiov2flat() argument
806 lnet_copy_flat2iov(unsigned int ndiov, struct kvec *diov, unsigned int doffset, int slen, void *src, unsigned int soffset, unsigned int nob) lnet_copy_flat2iov() argument
816 lnet_copy_flat2kiov(unsigned int ndiov, lnet_kiov_t *dkiov, unsigned int doffset, int slen, void *src, unsigned int soffset, unsigned int nob) lnet_copy_flat2kiov() argument
|
| /linux-4.1.27/drivers/staging/lustre/include/linux/libcfs/ |
| H A D | libcfs.h | 104 int libcfs_sock_write(struct socket *sock, void *buffer, int nob, int timeout);
105 int libcfs_sock_read(struct socket *sock, void *buffer, int nob, int timeout);
|
| H A D | libcfs_string.h | 83 int cfs_str2num_check(char *str, int nob, unsigned *num,
|
| /linux-4.1.27/drivers/staging/lustre/lustre/ptlrpc/ |
| H A D | sec_plain.c | 338 int i, nob; plain_cli_unwrap_bulk() local
354 for (i = 0, nob = 0; i < desc->bd_iov_count; i++) { plain_cli_unwrap_bulk()
355 if (desc->bd_iov[i].kiov_len + nob > desc->bd_nob_transferred) { plain_cli_unwrap_bulk()
357 desc->bd_nob_transferred - nob; plain_cli_unwrap_bulk()
359 nob += desc->bd_iov[i].kiov_len; plain_cli_unwrap_bulk()
|
| H A D | sec.c | 2228 * return nob of actual plain text size received, or error code.
2232 int nob) sptlrpc_cli_unwrap_bulk_read()
2275 * if everything is going right, nob should equals to nob_transferred. sptlrpc_cli_unwrap_bulk_write()
2279 CERROR("nob %d doesn't match transferred nob %d", sptlrpc_cli_unwrap_bulk_write()
2230 sptlrpc_cli_unwrap_bulk_read(struct ptlrpc_request *req, struct ptlrpc_bulk_desc *desc, int nob) sptlrpc_cli_unwrap_bulk_read() argument
|
| /linux-4.1.27/drivers/staging/lustre/lnet/selftest/ |
| H A D | rpc.c | 91 srpc_add_bulk_page(srpc_bulk_t *bk, struct page *pg, int i, int nob) srpc_add_bulk_page() argument
93 nob = min(nob, (int)PAGE_CACHE_SIZE); srpc_add_bulk_page()
95 LASSERT(nob > 0); srpc_add_bulk_page()
100 bk->bk_iovs[i].kiov_len = nob; srpc_add_bulk_page()
101 return nob; srpc_add_bulk_page()
146 int nob; srpc_alloc_bulk() local
156 nob = srpc_add_bulk_page(bk, pg, i, bulk_len); srpc_alloc_bulk()
157 bulk_len -= nob; srpc_alloc_bulk()
|
| H A D | conrpc.c | 821 int nob = 0; lstcon_testrpc_prep() local
826 nob = (feats & LST_FEAT_BULK_LEN) == 0 ? lstcon_testrpc_prep()
831 rc = lstcon_rpc_prep(nd, SRPC_SERVICE_TEST, feats, npg, nob, crpc); lstcon_testrpc_prep()
851 LASSERT(nob > 0); lstcon_testrpc_prep()
854 PAGE_CACHE_SIZE : min_t(int, nob, PAGE_CACHE_SIZE); lstcon_testrpc_prep()
855 nob -= len; lstcon_testrpc_prep()
|
| /linux-4.1.27/drivers/mmc/host/ |
| H A D | pxamci.c | 178 unsigned int nob = data->blocks; pxamci_setup_data() local
188 nob = 0xffff; pxamci_setup_data()
190 writel(nob, host->base + MMC_NOB); pxamci_setup_data()
|
| H A D | mxcmmc.c | 303 unsigned int nob = data->blocks; mxcmci_setup_data() local
305 unsigned int datasize = nob * blksz; mxcmci_setup_data()
311 nob = 0xffff; mxcmci_setup_data()
316 mxcmci_writew(host, nob, MMC_REG_NOB); mxcmci_setup_data()
|
| /linux-4.1.27/drivers/staging/lustre/lustre/obdecho/ |
| H A D | echo_client.c | 1272 int nob, i; echo_copyout_lsm() local
1274 nob = offsetof(struct lov_stripe_md, lsm_oinfo[lsm->lsm_stripe_count]); echo_copyout_lsm()
1275 if (nob > ulsm_nob) echo_copyout_lsm()
1808 int mode, u64 offset, u64 nob) echo_client_enqueue()
1823 (nob & (~CFS_PAGE_MASK)) != 0) echo_client_enqueue()
1830 end = (nob == 0) ? ((u64) -1) : (offset + nob - 1); echo_client_enqueue()
1807 echo_client_enqueue(struct obd_export *exp, struct obdo *oa, int mode, u64 offset, u64 nob) echo_client_enqueue() argument
|
| /linux-4.1.27/drivers/staging/lustre/lustre/osc/ |
| H A D | osc_request.c | 1183 static u32 osc_checksum_bulk(int nob, u32 pg_count, osc_checksum_bulk() argument
1203 while (nob > 0 && pg_count > 0) { osc_checksum_bulk()
1204 int count = pga[i]->count > nob ? nob : pga[i]->count; osc_checksum_bulk()
1212 memcpy(ptr + off, "bad1", min(4, nob)); osc_checksum_bulk()
1225 nob -= pga[i]->count; osc_checksum_bulk()
1449 __u32 client_cksum, __u32 server_cksum, int nob, check_write_checksum()
1464 new_cksum = osc_checksum_bulk(nob, page_count, pga, OST_WRITE, check_write_checksum()
1448 check_write_checksum(struct obdo *oa, const lnet_process_id_t *peer, __u32 client_cksum, __u32 server_cksum, int nob, u32 page_count, struct brw_page **pga, cksum_type_t client_cksum_type) check_write_checksum() argument
|
| /linux-4.1.27/drivers/staging/lustre/lustre/include/ |
| H A D | lustre_sec.h | 476 * \return +ve nob of actual bulk data in clear text.
897 __u32 bsd_nob; /* nob of bulk data */
1114 int nob);
|
| H A D | lclient.h | 348 size_t nob);
|
| H A D | dt_object.h | 927 union lu_page *lp, int nob,
|
| H A D | cl_object.h | 2096 * iteration finished, with \a nob bytes transferred.
2100 size_t nob);
3070 size_t nob);
|
| /linux-4.1.27/drivers/staging/lustre/lustre/lclient/ |
| H A D | lcommon_cl.c | 758 size_t nob) ccc_io_advance()
769 iov_iter_reexpand(cio->cui_iter, cio->cui_tot_count -= nob); ccc_io_advance()
756 ccc_io_advance(const struct lu_env *env, const struct cl_io_slice *ios, size_t nob) ccc_io_advance() argument
|