Home
last modified time | relevance | path

Searched refs:proc_send (Results 1 – 25 of 62) sorted by relevance

123

/dports/sysutils/tmate-ssh-server/tmate-ssh-server-97d2024/
H A Dclient.c368 proc_send(client_peer, msg, -1, NULL, 0); in client_main()
413 proc_send(client_peer, MSG_IDENTIFY_TMATE_READONLY, in client_send_identify()
528 proc_send(client_peer, MSG_EXITING, -1, NULL, 0); in client_signal()
536 proc_send(client_peer, MSG_RESIZE, -1, NULL, 0); in client_signal()
545 proc_send(client_peer, MSG_WAKEUP, -1, NULL, 0); in client_signal()
613 proc_send(client_peer, MSG_RESIZE, -1, NULL, 0); in client_dispatch_wait()
660 proc_send(client_peer, MSG_EXITING, -1, NULL, 0); in client_dispatch_wait()
693 proc_send(client_peer, MSG_EXITING, -1, NULL, 0); in client_dispatch_attached()
699 proc_send(client_peer, MSG_EXITING, -1, NULL, 0); in client_dispatch_attached()
712 proc_send(client_peer, MSG_EXITING, -1, NULL, 0); in client_dispatch_attached()
[all …]
H A Dproc.c122 proc_send(peer, MSG_VERSION, -1, NULL, 0); in peer_check_version()
146 proc_send(struct tmuxpeer *peer, enum msgtype type, int fd, const void *buf, in proc_send() function
167 return (proc_send(peer, type, -1, s, strlen(s) + 1)); in proc_send_s()
/dports/sysutils/tmux/tmux-3.2a/
H A Dclient.c390 proc_send(client_peer, msg, -1, NULL, 0); in client_main()
464 proc_send(client_peer, MSG_IDENTIFY_TERMINFO, -1, in client_send_identify()
546 proc_send(client_peer, MSG_RESIZE, -1, NULL, 0); in client_signal()
555 proc_send(client_peer, MSG_WAKEUP, -1, NULL, 0); in client_signal()
654 proc_send(client_peer, MSG_RESIZE, -1, NULL, 0); in client_dispatch_wait()
682 proc_send(client_peer, MSG_EXITING, -1, NULL, 0); in client_dispatch_wait()
743 proc_send(client_peer, MSG_EXITING, -1, NULL, 0); in client_dispatch_attached()
753 proc_send(client_peer, MSG_EXITING, -1, NULL, 0); in client_dispatch_attached()
759 proc_send(client_peer, MSG_EXITING, -1, NULL, 0); in client_dispatch_attached()
771 proc_send(client_peer, MSG_EXITING, -1, NULL, 0); in client_dispatch_attached()
[all …]
H A Dfile.c214 proc_send(c->peer, MSG_WRITE_OPEN, -1, &msg, sizeof msg); in file_vprint()
241 proc_send(c->peer, MSG_WRITE_OPEN, -1, &msg, sizeof msg); in file_print_buffer()
271 proc_send(c->peer, MSG_WRITE_OPEN, -1, &msg, sizeof msg); in file_error()
342 if (proc_send(cf->peer, MSG_WRITE_OPEN, -1, msg, msglen) != 0) { in file_write()
417 if (proc_send(cf->peer, MSG_READ_OPEN, -1, msg, msglen) != 0) { in file_read()
459 if (proc_send(cf->peer, MSG_WRITE, -1, msg, msglen) != 0) in file_push()
471 proc_send(cf->peer, MSG_WRITE_CLOSE, -1, &close, sizeof close); in file_push()
594 proc_send(peer, MSG_WRITE_READY, -1, &reply, sizeof reply); in file_write_open()
654 proc_send(cf->peer, MSG_READ_DONE, -1, &msg, sizeof msg); in file_read_error_callback()
687 proc_send(cf->peer, MSG_READ, -1, msg, msglen); in file_read_callback()
[all …]
/dports/sysutils/tmux23/tmux-2.3/
H A Dclient.c359 proc_send(client_peer, msg, -1, NULL, 0); in client_main()
502 proc_send(client_peer, MSG_EXITING, -1, NULL, 0); in client_signal()
507 proc_send(client_peer, MSG_EXITING, -1, NULL, 0); in client_signal()
510 proc_send(client_peer, MSG_RESIZE, -1, NULL, 0); in client_signal()
519 proc_send(client_peer, MSG_WAKEUP, -1, NULL, 0); in client_signal()
587 proc_send(client_peer, MSG_RESIZE, -1, NULL, 0); in client_dispatch_wait()
630 proc_send(client_peer, MSG_EXITING, -1, NULL, 0); in client_dispatch_wait()
661 proc_send(client_peer, MSG_EXITING, -1, NULL, 0); in client_dispatch_attached()
667 proc_send(client_peer, MSG_EXITING, -1, NULL, 0); in client_dispatch_attached()
680 proc_send(client_peer, MSG_EXITING, -1, NULL, 0); in client_dispatch_attached()
[all …]
H A Dproc.c120 proc_send(peer, MSG_VERSION, -1, NULL, 0); in peer_check_version()
144 proc_send(struct tmuxpeer *peer, enum msgtype type, int fd, const void *buf, in proc_send() function
165 return (proc_send(peer, type, -1, s, strlen(s) + 1)); in proc_send_s()
/dports/sysutils/tmate/tmate-2.4.0/
H A Dclient.c453 proc_send(client_peer, msg, -1, NULL, 0); in client_main()
596 proc_send(client_peer, MSG_EXITING, -1, NULL, 0); in client_signal()
601 proc_send(client_peer, MSG_EXITING, -1, NULL, 0); in client_signal()
604 proc_send(client_peer, MSG_RESIZE, -1, NULL, 0); in client_signal()
613 proc_send(client_peer, MSG_WAKEUP, -1, NULL, 0); in client_signal()
681 proc_send(client_peer, MSG_RESIZE, -1, NULL, 0); in client_dispatch_wait()
724 proc_send(client_peer, MSG_EXITING, -1, NULL, 0); in client_dispatch_wait()
755 proc_send(client_peer, MSG_EXITING, -1, NULL, 0); in client_dispatch_attached()
761 proc_send(client_peer, MSG_EXITING, -1, NULL, 0); in client_dispatch_attached()
774 proc_send(client_peer, MSG_EXITING, -1, NULL, 0); in client_dispatch_attached()
[all …]
H A Dproc.c120 proc_send(peer, MSG_VERSION, -1, NULL, 0); in peer_check_version()
144 proc_send(struct tmuxpeer *peer, enum msgtype type, int fd, const void *buf, in proc_send() function
165 return (proc_send(peer, type, -1, s, strlen(s) + 1)); in proc_send_s()
/dports/science/cp2k/cp2k-2e995eec7fd208c8a72d9544807bd8b8ba8cd1cc/src/
H A Dmp2_ri_gpw.F279 send_ij_index = num_ij_pairs(proc_send)
340 CALL mp_sendrecv(null_mat_send, proc_send, &
580 send_ij_index = num_ij_pairs(proc_send)
1769 CALL mp_sendrecv(send_ab, proc_send, &
2045 send_L_size = sizes_array(proc_send)
2115 CALL mp_sendrecv(BI_C_send, proc_send, &
2189 CALL mp_sendrecv(BI_C_send, proc_send, &
2230 CALL mp_sendrecv(null_mat_send, proc_send, &
2303 CALL mp_sendrecv(null_mat_send, proc_send, &
2504 send_ijk_index = num_ijk(proc_send)
[all …]
H A Dmp2_ri_grad_util.F150 CALL mp_sendrecv(B_ia_Q, proc_send, &
515 map_send_size(proc_send) = map_send_size(proc_send) + 1
592 IF (map_send_size(proc_send) > 0) THEN
609 IF (map_send_size(proc_send) > 0) THEN
686 IF (map_send_size(proc_send) > 0) THEN
949 map_send_size(proc_send) = map_send_size(proc_send) + 1
991 IF (map_send_size(proc_send) > 0) THEN
1010 IF (map_send_size(proc_send) > 0) THEN
1106 IF (map_send_size(proc_send) > 0) THEN
1294 map_send_size(proc_send) = map_send_size(proc_send) + 1
[all …]
H A Drpa_communication.F166 map_send_size(proc_send) = map_send_size(proc_send) + 1
190 IF (map_send_size(proc_send) > 0) THEN
205 size_send_buffer = map_send_size(proc_send)
207 IF (map_send_size(proc_send) > 0) THEN
213 proc2counter(proc_send) = send_counter
450 size_send_buffer = map_send_size(proc_send)
452 IF (map_send_size(proc_send) > 0) THEN
706 map_send_size(proc_send) = map_send_size(proc_send) + 1
743 IF (map_send_size(proc_send) > 0) THEN
757 IF (map_send_size(proc_send) > 0) THEN
[all …]
H A Dmp2_ri_grad.F1455 proc_send_sub = pos_info(proc_send)
1471 proc_send_sub = pos_info(proc_send)
1487 IF (map_send_size(proc_send) > 0) THEN
1499 IF (map_send_size(proc_send) > 0) THEN
1524 proc_send_sub = pos_info(proc_send)
1545 proc_send_sub = pos_info(proc_send)
1592 IF (map_send_size(proc_send) > 0) THEN
1922 send_prow = mepos_2_grid(proc_send, 1)
1923 send_pcol = mepos_2_grid(proc_send, 2)
1925 send_row_size = sizes(1, proc_send)
[all …]
H A Dmp2_direct_method.F124 primitive_counter, proc_num, proc_receive, proc_send, R_offset_rec, Rsize_rec, & local
697 proc_send = proc_map(para_env%mepos + index_proc_shift)
700 case_send_receive = (proc_send /= para_env%mepos)
724 DO index_proc_ij = proc_send + 1, multiple, para_env%num_pe
980 index_proc_shift, j, n, proc_receive, proc_send, r, R_global, R_offset, R_offset_rec, & local
1001 proc_send = proc_map(para_env%mepos + index_proc_shift)
1004 case_send_receive = (proc_send /= para_env%mepos)
1024 DO index_proc_ij = proc_send + 1, multiple, para_env%num_pe
1172 proc_send = proc_map(para_env%mepos + index_proc_shift)
1175 case_send_receive = (proc_send /= para_env%mepos)
[all …]
H A Dmp2_ri_2c.F723 nsgf, potential_type, proc_receive, proc_receive_static, proc_send, proc_send_static, & local
894 proc_send = proc_map(para_env_exchange%mepos + proc_shift)
1147 proc_send, send_pcol, send_prow local
1190 proc_send = fm_matrix_L%matrix_struct%context%blacs2mpi(send_prow, send_pcol)
1192 num_entries_send(proc_send) = num_entries_send(proc_send) + 1
1272 proc_send = fm_matrix_L%matrix_struct%context%blacs2mpi(send_prow, send_pcol)
1274 entry_counter(proc_send) = entry_counter(proc_send) + 1
1276 buffer_send(proc_send)%msg(entry_counter(proc_send)) = &
1279 buffer_send(proc_send)%indx(entry_counter(proc_send), 1) = LLL
1280 buffer_send(proc_send)%indx(entry_counter(proc_send), 2) = MMM
/dports/science/cp2k-data/cp2k-7.1.0/src/
H A Dmp2_ri_gpw.F279 send_ij_index = num_ij_pairs(proc_send)
340 CALL mp_sendrecv(null_mat_send, proc_send, &
580 send_ij_index = num_ij_pairs(proc_send)
1769 CALL mp_sendrecv(send_ab, proc_send, &
2045 send_L_size = sizes_array(proc_send)
2115 CALL mp_sendrecv(BI_C_send, proc_send, &
2189 CALL mp_sendrecv(BI_C_send, proc_send, &
2230 CALL mp_sendrecv(null_mat_send, proc_send, &
2303 CALL mp_sendrecv(null_mat_send, proc_send, &
2504 send_ijk_index = num_ijk(proc_send)
[all …]
H A Dmp2_ri_grad_util.F150 CALL mp_sendrecv(B_ia_Q, proc_send, &
515 map_send_size(proc_send) = map_send_size(proc_send) + 1
592 IF (map_send_size(proc_send) > 0) THEN
609 IF (map_send_size(proc_send) > 0) THEN
686 IF (map_send_size(proc_send) > 0) THEN
949 map_send_size(proc_send) = map_send_size(proc_send) + 1
991 IF (map_send_size(proc_send) > 0) THEN
1010 IF (map_send_size(proc_send) > 0) THEN
1106 IF (map_send_size(proc_send) > 0) THEN
1294 map_send_size(proc_send) = map_send_size(proc_send) + 1
[all …]
H A Drpa_communication.F166 map_send_size(proc_send) = map_send_size(proc_send) + 1
190 IF (map_send_size(proc_send) > 0) THEN
205 size_send_buffer = map_send_size(proc_send)
207 IF (map_send_size(proc_send) > 0) THEN
213 proc2counter(proc_send) = send_counter
450 size_send_buffer = map_send_size(proc_send)
452 IF (map_send_size(proc_send) > 0) THEN
706 map_send_size(proc_send) = map_send_size(proc_send) + 1
743 IF (map_send_size(proc_send) > 0) THEN
757 IF (map_send_size(proc_send) > 0) THEN
[all …]
H A Dmp2_ri_grad.F1448 proc_send_sub = pos_info(proc_send)
1464 proc_send_sub = pos_info(proc_send)
1480 IF (map_send_size(proc_send) > 0) THEN
1492 IF (map_send_size(proc_send) > 0) THEN
1517 proc_send_sub = pos_info(proc_send)
1538 proc_send_sub = pos_info(proc_send)
1585 IF (map_send_size(proc_send) > 0) THEN
1915 send_prow = mepos_2_grid(proc_send, 1)
1916 send_pcol = mepos_2_grid(proc_send, 2)
1918 send_row_size = sizes(1, proc_send)
[all …]
H A Dmp2_direct_method.F124 primitive_counter, proc_num, proc_receive, proc_send, R_offset_rec, Rsize_rec, & local
697 proc_send = proc_map(para_env%mepos + index_proc_shift)
700 case_send_receive = (proc_send /= para_env%mepos)
724 DO index_proc_ij = proc_send + 1, multiple, para_env%num_pe
980 index_proc_shift, j, n, proc_receive, proc_send, r, R_global, R_offset, R_offset_rec, & local
1001 proc_send = proc_map(para_env%mepos + index_proc_shift)
1004 case_send_receive = (proc_send /= para_env%mepos)
1024 DO index_proc_ij = proc_send + 1, multiple, para_env%num_pe
1172 proc_send = proc_map(para_env%mepos + index_proc_shift)
1175 case_send_receive = (proc_send /= para_env%mepos)
[all …]
H A Dmp2_ri_2c.F725 nsgf, potential_type, proc_receive, proc_receive_static, proc_send, proc_send_static, & local
896 proc_send = proc_map(para_env_exchange%mepos + proc_shift)
1149 proc_send, send_pcol, send_prow local
1192 proc_send = fm_matrix_L%matrix_struct%context%blacs2mpi(send_prow, send_pcol)
1194 num_entries_send(proc_send) = num_entries_send(proc_send) + 1
1274 proc_send = fm_matrix_L%matrix_struct%context%blacs2mpi(send_prow, send_pcol)
1276 entry_counter(proc_send) = entry_counter(proc_send) + 1
1278 buffer_send(proc_send)%msg(entry_counter(proc_send)) = &
1281 buffer_send(proc_send)%indx(entry_counter(proc_send), 1) = LLL
1282 buffer_send(proc_send)%indx(entry_counter(proc_send), 2) = MMM
/dports/science/liggghts/LIGGGHTS-PUBLIC-3.8.0-26-g6e873439/src/
H A Dirregular.cpp323 int *proc_send = new int[nsend]; in create_atom() local
342 proc_send[isend] = iproc; in create_atom()
410 aplan->proc_send = proc_send; in create_atom()
467 aplan->proc_send[isend],0,world); in exchange_atom()
485 delete [] aplan->proc_send; in destroy_atom()
546 int *proc_send = new int[nsend]; in create_data() local
567 proc_send[isend] = iproc; in create_data()
599 MPI_Send(&num_send[i],1,MPI_INT,proc_send[i],0,world); in create_data()
632 dplan->proc_send = proc_send; in create_data()
686 dplan->proc_send[isend],0,world); in exchange_data()
[all …]
H A Dirregular.h85 int *proc_send; // procs to send to member
103 int *proc_send; // procs to send to member
/dports/science/sparta/sparta-20Oct2021/src/
H A Dirregular.cpp47 memory->create(proc_send,nprocs,"irregular:proc_send"); in Irregular()
80 memory->destroy(proc_send); in ~Irregular()
160 proc_send[isend] = iproc; in create_procs()
170 MPI_Send(&m,0,MPI_INT,proc_send[i],0,world); in create_procs()
294 proc_send[isend] = iproc; in create_data_uniform()
326 MPI_Send(&num_send[i],1,MPI_INT,proc_send[i],0,world); in create_data_uniform()
463 proc_send[isend] = iproc; in create_data_uniform_grouped()
498 MPI_Send(&num_send[i],1,MPI_INT,proc_send[i],0,world); in create_data_uniform_grouped()
635 MPI_Send(&size_send[i],1,MPI_INT,proc_send[i],1,world); in create_data_variable()
676 for (i = 0; i < nsend; i++) work2[proc_send[i]] = 0; in augment_data_uniform()
[all …]
/dports/science/lammps/lammps-stable_29Sep2021/src/
H A Dirregular.cpp356 proc_send = new int[nsend_proc]; in create_atom()
375 proc_send[isend] = iproc; in create_atom()
561 delete [] proc_send; in destroy_atom()
631 proc_send = new int[nsend_proc]; in create_data()
653 proc_send[isend] = iproc; in create_data()
686 MPI_Isend(&num_send[i],1,MPI_INT,proc_send[i],0,world,&tmpReq); in create_data()
802 proc_send = new int[nsend_proc]; in create_data_grouped()
824 proc_send[isend] = iproc; in create_data_grouped()
860 MPI_Isend(&num_send[i],1,MPI_INT,proc_send[i],0,world,&tmpReq); in create_data_grouped()
961 MPI_Send(buf,count*nbytes,MPI_CHAR,proc_send[isend],0,world); in exchange_data()
[all …]
/dports/science/sparta/sparta-20Oct2021/src/KOKKOS/
H A Dirregular_kokkos.cpp148 proc_send[isend] = iproc; in create_data_uniform()
180 MPI_Send(&num_send[i],1,MPI_INT,proc_send[i],0,world); in create_data_uniform()
253 for (i = 0; i < nsend; i++) work2[proc_send[i]] = 0; in augment_data_uniform()
256 for (i = 0; i < nsend; i++) num_send[i] = work2[proc_send[i]]; in augment_data_uniform()
308 MPI_Send(&num_send[i],1,MPI_INT,proc_send[i],0,world); in augment_data_uniform()
416 MPI_Send(d_buf.data(),count*nbytes,MPI_CHAR,proc_send[isend],0,world); in exchange_uniform()
419 MPI_Send(h_buf.data(),count*nbytes,MPI_CHAR,proc_send[isend],0,world); in exchange_uniform()

123