Home
last modified time | relevance | path

Searched refs:MsgRecv (Results 1 – 25 of 43) sorted by relevance

12

/dports/net/rclone/rclone-1.57.0/vendor/storj.io/drpc/internal/integration/customservice/
H A Dservice_drpc.pb.go89 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 Dservice_drpc.pb.go89 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 Dservice_drpc.pb.go94 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 Dservicedefs_drpc.pb.go94 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 Dservice_drpc.pb.go94 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 Dservice_drpc.pb.go96 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 Dservicedefs_drpc.pb.go94 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 Dservice_drpc.pb.go96 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 Dservice_drpc.pb.go94 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 Dservice_drpc.pb.go94 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 Dmpsc.rs47 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 Dmpsc.rs47 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 Dpiecestore2_drpc.pb.go91 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 Dorders_drpc.pb.go86 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 Dgracefulexit_drpc.pb.go84 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 Dservicedefs.pb.go184 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 Dservicedefs.pb.go184 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 Dstate.dot7 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 Dstate.dot7 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 Dtransport_test.go89 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 Dtransport_test.go89 errs <- stream.MsgRecv(nil, Encoding)
99 errs <- stream.MsgRecv(nil, Encoding)
/dports/audio/wavplay/wavplay-1.4/
H A Dwavplay.h486 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 Dwrappers.go95 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 Dpiecestore2_drpc.pb.go91 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 Dorders_drpc.pb.go86 if err := x.MsgRecv(m, drpcEncoding_File_orders_proto{}); err != nil {
144 if err := x.MsgRecv(m, drpcEncoding_File_orders_proto{}); err != nil {

12