/dports/net/rclone/rclone-1.57.0/vendor/storj.io/drpc/internal/integration/customservice/ |
H A D | service_drpc.pb.go | 89 if err := x.MsgRecv(m, drpcEncoding_File_service_proto{}); err != nil { 99 return x.MsgRecv(m, drpcEncoding_File_service_proto{}) 128 if err := x.MsgRecv(m, drpcEncoding_File_service_proto{}); err != nil { 135 return x.MsgRecv(m, drpcEncoding_File_service_proto{}) 163 if err := x.MsgRecv(m, drpcEncoding_File_service_proto{}); err != nil { 170 return x.MsgRecv(m, drpcEncoding_File_service_proto{}) 282 if err := x.MsgRecv(m, drpcEncoding_File_service_proto{}); err != nil { 289 return x.MsgRecv(m, drpcEncoding_File_service_proto{}) 321 if err := x.MsgRecv(m, drpcEncoding_File_service_proto{}); err != nil { 328 return x.MsgRecv(m, drpcEncoding_File_service_proto{})
|
/dports/net/storj/storj-1.45.3/vendor/storj.io/drpc/internal/integration/customservice/ |
H A D | service_drpc.pb.go | 89 if err := x.MsgRecv(m, drpcEncoding_File_service_proto{}); err != nil { 99 return x.MsgRecv(m, drpcEncoding_File_service_proto{}) 128 if err := x.MsgRecv(m, drpcEncoding_File_service_proto{}); err != nil { 135 return x.MsgRecv(m, drpcEncoding_File_service_proto{}) 163 if err := x.MsgRecv(m, drpcEncoding_File_service_proto{}); err != nil { 170 return x.MsgRecv(m, drpcEncoding_File_service_proto{}) 282 if err := x.MsgRecv(m, drpcEncoding_File_service_proto{}); err != nil { 289 return x.MsgRecv(m, drpcEncoding_File_service_proto{}) 321 if err := x.MsgRecv(m, drpcEncoding_File_service_proto{}); err != nil { 328 return x.MsgRecv(m, drpcEncoding_File_service_proto{})
|
/dports/net/rclone/rclone-1.57.0/vendor/storj.io/drpc/internal/integration/service/ |
H A D | service_drpc.pb.go | 94 if err := x.MsgRecv(m, drpcEncoding_File_service_proto{}); err != nil { 104 return x.MsgRecv(m, drpcEncoding_File_service_proto{}) 133 if err := x.MsgRecv(m, drpcEncoding_File_service_proto{}); err != nil { 140 return x.MsgRecv(m, drpcEncoding_File_service_proto{}) 168 if err := x.MsgRecv(m, drpcEncoding_File_service_proto{}); err != nil { 175 return x.MsgRecv(m, drpcEncoding_File_service_proto{}) 287 if err := x.MsgRecv(m, drpcEncoding_File_service_proto{}); err != nil { 294 return x.MsgRecv(m, drpcEncoding_File_service_proto{}) 326 if err := x.MsgRecv(m, drpcEncoding_File_service_proto{}); err != nil { 333 return x.MsgRecv(m, drpcEncoding_File_service_proto{})
|
/dports/net/rclone/rclone-1.57.0/vendor/storj.io/drpc/internal/backcompat/newservicedefs/ |
H A D | servicedefs_drpc.pb.go | 94 if err := x.MsgRecv(m, drpcEncoding_File_servicedefs_proto{}); err != nil { 104 return x.MsgRecv(m, drpcEncoding_File_servicedefs_proto{}) 133 if err := x.MsgRecv(m, drpcEncoding_File_servicedefs_proto{}); err != nil { 140 return x.MsgRecv(m, drpcEncoding_File_servicedefs_proto{}) 168 if err := x.MsgRecv(m, drpcEncoding_File_servicedefs_proto{}); err != nil { 175 return x.MsgRecv(m, drpcEncoding_File_servicedefs_proto{}) 287 if err := x.MsgRecv(m, drpcEncoding_File_servicedefs_proto{}); err != nil { 294 return x.MsgRecv(m, drpcEncoding_File_servicedefs_proto{}) 326 if err := x.MsgRecv(m, drpcEncoding_File_servicedefs_proto{}); err != nil { 333 return x.MsgRecv(m, drpcEncoding_File_servicedefs_proto{})
|
/dports/net/rclone/rclone-1.57.0/vendor/storj.io/drpc/internal/grpccompat/ |
H A D | service_drpc.pb.go | 94 if err := x.MsgRecv(m, drpcEncoding_File_service_proto{}); err != nil { 104 return x.MsgRecv(m, drpcEncoding_File_service_proto{}) 133 if err := x.MsgRecv(m, drpcEncoding_File_service_proto{}); err != nil { 140 return x.MsgRecv(m, drpcEncoding_File_service_proto{}) 168 if err := x.MsgRecv(m, drpcEncoding_File_service_proto{}); err != nil { 175 return x.MsgRecv(m, drpcEncoding_File_service_proto{}) 287 if err := x.MsgRecv(m, drpcEncoding_File_service_proto{}); err != nil { 294 return x.MsgRecv(m, drpcEncoding_File_service_proto{}) 326 if err := x.MsgRecv(m, drpcEncoding_File_service_proto{}); err != nil { 333 return x.MsgRecv(m, drpcEncoding_File_service_proto{})
|
/dports/net/rclone/rclone-1.57.0/vendor/storj.io/drpc/internal/integration/gogoservice/ |
H A D | service_drpc.pb.go | 96 if err := x.MsgRecv(m, drpcEncoding_File_service_proto{}); err != nil { 106 return x.MsgRecv(m, drpcEncoding_File_service_proto{}) 135 if err := x.MsgRecv(m, drpcEncoding_File_service_proto{}); err != nil { 142 return x.MsgRecv(m, drpcEncoding_File_service_proto{}) 170 if err := x.MsgRecv(m, drpcEncoding_File_service_proto{}); err != nil { 177 return x.MsgRecv(m, drpcEncoding_File_service_proto{}) 289 if err := x.MsgRecv(m, drpcEncoding_File_service_proto{}); err != nil { 296 return x.MsgRecv(m, drpcEncoding_File_service_proto{}) 328 if err := x.MsgRecv(m, drpcEncoding_File_service_proto{}); err != nil { 335 return x.MsgRecv(m, drpcEncoding_File_service_proto{})
|
/dports/net/storj/storj-1.45.3/vendor/storj.io/drpc/internal/backcompat/newservicedefs/ |
H A D | servicedefs_drpc.pb.go | 94 if err := x.MsgRecv(m, drpcEncoding_File_servicedefs_proto{}); err != nil { 104 return x.MsgRecv(m, drpcEncoding_File_servicedefs_proto{}) 133 if err := x.MsgRecv(m, drpcEncoding_File_servicedefs_proto{}); err != nil { 140 return x.MsgRecv(m, drpcEncoding_File_servicedefs_proto{}) 168 if err := x.MsgRecv(m, drpcEncoding_File_servicedefs_proto{}); err != nil { 175 return x.MsgRecv(m, drpcEncoding_File_servicedefs_proto{}) 287 if err := x.MsgRecv(m, drpcEncoding_File_servicedefs_proto{}); err != nil { 294 return x.MsgRecv(m, drpcEncoding_File_servicedefs_proto{}) 326 if err := x.MsgRecv(m, drpcEncoding_File_servicedefs_proto{}); err != nil { 333 return x.MsgRecv(m, drpcEncoding_File_servicedefs_proto{})
|
/dports/net/storj/storj-1.45.3/vendor/storj.io/drpc/internal/integration/gogoservice/ |
H A D | service_drpc.pb.go | 96 if err := x.MsgRecv(m, drpcEncoding_File_service_proto{}); err != nil { 106 return x.MsgRecv(m, drpcEncoding_File_service_proto{}) 135 if err := x.MsgRecv(m, drpcEncoding_File_service_proto{}); err != nil { 142 return x.MsgRecv(m, drpcEncoding_File_service_proto{}) 170 if err := x.MsgRecv(m, drpcEncoding_File_service_proto{}); err != nil { 177 return x.MsgRecv(m, drpcEncoding_File_service_proto{}) 289 if err := x.MsgRecv(m, drpcEncoding_File_service_proto{}); err != nil { 296 return x.MsgRecv(m, drpcEncoding_File_service_proto{}) 328 if err := x.MsgRecv(m, drpcEncoding_File_service_proto{}); err != nil { 335 return x.MsgRecv(m, drpcEncoding_File_service_proto{})
|
/dports/net/storj/storj-1.45.3/vendor/storj.io/drpc/internal/integration/service/ |
H A D | service_drpc.pb.go | 94 if err := x.MsgRecv(m, drpcEncoding_File_service_proto{}); err != nil { 104 return x.MsgRecv(m, drpcEncoding_File_service_proto{}) 133 if err := x.MsgRecv(m, drpcEncoding_File_service_proto{}); err != nil { 140 return x.MsgRecv(m, drpcEncoding_File_service_proto{}) 168 if err := x.MsgRecv(m, drpcEncoding_File_service_proto{}); err != nil { 175 return x.MsgRecv(m, drpcEncoding_File_service_proto{}) 287 if err := x.MsgRecv(m, drpcEncoding_File_service_proto{}); err != nil { 294 return x.MsgRecv(m, drpcEncoding_File_service_proto{}) 326 if err := x.MsgRecv(m, drpcEncoding_File_service_proto{}); err != nil { 333 return x.MsgRecv(m, drpcEncoding_File_service_proto{})
|
/dports/net/storj/storj-1.45.3/vendor/storj.io/drpc/internal/grpccompat/ |
H A D | service_drpc.pb.go | 94 if err := x.MsgRecv(m, drpcEncoding_File_service_proto{}); err != nil { 104 return x.MsgRecv(m, drpcEncoding_File_service_proto{}) 133 if err := x.MsgRecv(m, drpcEncoding_File_service_proto{}); err != nil { 140 return x.MsgRecv(m, drpcEncoding_File_service_proto{}) 168 if err := x.MsgRecv(m, drpcEncoding_File_service_proto{}); err != nil { 175 return x.MsgRecv(m, drpcEncoding_File_service_proto{}) 287 if err := x.MsgRecv(m, drpcEncoding_File_service_proto{}); err != nil { 294 return x.MsgRecv(m, drpcEncoding_File_service_proto{}) 326 if err := x.MsgRecv(m, drpcEncoding_File_service_proto{}); err != nil { 333 return x.MsgRecv(m, drpcEncoding_File_service_proto{})
|
/dports/net-im/libsignal-client/libsignal-client-0.9.6/cargo-crates/loom-0.4.0/src/rt/ |
H A D | mpsc.rs | 47 MsgRecv, enumerator 99 self.state.branch_disable(Action::MsgRecv, self.is_empty()); in recv() 118 && operation.action() == object::Action::Channel(Action::MsgRecv) in recv() 146 Action::MsgRecv => self.last_recv_access.as_ref(), in last_dependent_access() 153 Action::MsgRecv => Access::set_or_create(&mut self.last_recv_access, path_id, version), in set_last_access()
|
/dports/misc/xd-rust/delan-xd-4bdbb191ed6d/cargo-crates/loom-0.3.6/src/rt/ |
H A D | mpsc.rs | 47 MsgRecv, enumerator 99 self.state.branch_disable(Action::MsgRecv, self.is_empty()); in recv() 118 && operation.action() == object::Action::Channel(Action::MsgRecv) in recv() 146 Action::MsgRecv => self.last_recv_access.as_ref(), in last_dependent_access() 153 Action::MsgRecv => Access::set_or_create(&mut self.last_recv_access, path_id, version), in set_last_access()
|
/dports/net/storj/storj-1.45.3/vendor/storj.io/common/pb/ |
H A D | piecestore2_drpc.pb.go | 91 if err := x.MsgRecv(m, drpcEncoding_File_piecestore2_proto{}); err != nil { 101 return x.MsgRecv(m, drpcEncoding_File_piecestore2_proto{}) 129 if err := x.MsgRecv(m, drpcEncoding_File_piecestore2_proto{}); err != nil { 136 return x.MsgRecv(m, drpcEncoding_File_piecestore2_proto{}) 296 if err := x.MsgRecv(m, drpcEncoding_File_piecestore2_proto{}); err != nil { 303 return x.MsgRecv(m, drpcEncoding_File_piecestore2_proto{}) 322 if err := x.MsgRecv(m, drpcEncoding_File_piecestore2_proto{}); err != nil { 329 return x.MsgRecv(m, drpcEncoding_File_piecestore2_proto{})
|
H A D | orders_drpc.pb.go | 86 if err := x.MsgRecv(m, drpcEncoding_File_orders_proto{}); err != nil { 96 return x.MsgRecv(m, drpcEncoding_File_orders_proto{}) 151 if err := x.MsgRecv(m, drpcEncoding_File_orders_proto{}); err != nil { 158 return x.MsgRecv(m, drpcEncoding_File_orders_proto{})
|
H A D | gracefulexit_drpc.pb.go | 84 if err := x.MsgRecv(m, drpcEncoding_File_gracefulexit_proto{}); err != nil { 91 return x.MsgRecv(m, drpcEncoding_File_gracefulexit_proto{}) 166 if err := x.MsgRecv(m, drpcEncoding_File_gracefulexit_proto{}); err != nil { 173 return x.MsgRecv(m, drpcEncoding_File_gracefulexit_proto{})
|
/dports/net/rclone/rclone-1.57.0/vendor/storj.io/drpc/internal/backcompat/oldservicedefs/ |
H A D | servicedefs.pb.go | 184 if err := x.MsgRecv(m); err != nil { 216 if err := x.MsgRecv(m); err != nil { 247 if err := x.MsgRecv(m); err != nil { 362 if err := x.MsgRecv(m); err != nil { 397 if err := x.MsgRecv(m); err != nil {
|
/dports/net/storj/storj-1.45.3/vendor/storj.io/drpc/internal/backcompat/oldservicedefs/ |
H A D | servicedefs.pb.go | 184 if err := x.MsgRecv(m); err != nil { 216 if err := x.MsgRecv(m); err != nil { 247 if err := x.MsgRecv(m); err != nil { 362 if err := x.MsgRecv(m); err != nil { 397 if err := x.MsgRecv(m); err != nil {
|
/dports/net/rclone/rclone-1.57.0/vendor/storj.io/drpc/drpcstream/ |
H A D | state.dot | 7 open -> open [label="{MsgSend, MsgRecv}"]; 12 "send-closed" -> "send-closed" [label="{MsgRecv}"];
|
/dports/net/storj/storj-1.45.3/vendor/storj.io/drpc/drpcstream/ |
H A D | state.dot | 7 open -> open [label="{MsgSend, MsgRecv}"]; 12 "send-closed" -> "send-closed" [label="{MsgRecv}"];
|
/dports/net/rclone/rclone-1.57.0/vendor/storj.io/drpc/internal/integration/ |
H A D | transport_test.go | 89 errs <- stream.MsgRecv(nil, Encoding) 99 errs <- stream.MsgRecv(nil, Encoding)
|
/dports/net/storj/storj-1.45.3/vendor/storj.io/drpc/internal/integration/ |
H A D | transport_test.go | 89 errs <- stream.MsgRecv(nil, Encoding) 99 errs <- stream.MsgRecv(nil, Encoding)
|
/dports/audio/wavplay/wavplay-1.4/ |
H A D | wavplay.h | 486 extern int MsgRecv(int ipcid,SVRMSG *msg,int flags,long msgtype); 495 #define MsgFromClient(ipcid,msg,flags) MsgRecv(ipcid,msg,flags,MSGNO_SRVR) 496 #define MsgFromServer(ipcid,msg,flags) MsgRecv(ipcid,msg,flags,MSGNO_CLNT)
|
/dports/net/storj/storj-1.45.3/vendor/storj.io/common/rpc/rpctest/ |
H A D | wrappers.go | 95 func (d *interceptedStream) MsgRecv(msg drpc.Message, enc drpc.Encoding) error { func 96 err := d.delegate.MsgRecv(msg, enc)
|
/dports/net/rclone/rclone-1.57.0/vendor/storj.io/common/pb/ |
H A D | piecestore2_drpc.pb.go | 91 if err := x.MsgRecv(m, drpcEncoding_File_piecestore2_proto{}); err != nil { 122 if err := x.MsgRecv(m, drpcEncoding_File_piecestore2_proto{}); err != nil { 285 if err := x.MsgRecv(m, drpcEncoding_File_piecestore2_proto{}); err != nil { 307 if err := x.MsgRecv(m, drpcEncoding_File_piecestore2_proto{}); err != nil {
|
H A D | orders_drpc.pb.go | 86 if err := x.MsgRecv(m, drpcEncoding_File_orders_proto{}); err != nil { 144 if err := x.MsgRecv(m, drpcEncoding_File_orders_proto{}); err != nil {
|