/dports/net/mpich2/mpich2-1.5/src/mpid/pamid/src/ |
H A D | mpid_request.h | 48 #define MPIDI_Request_getCA(_req) ({ (_req)->mpid.ca; … argument 49 #define MPIDI_Request_getPeerRank_pami(_req) ({ (_req)->mpid.peer_pami; … argument 50 #define MPIDI_Request_getPeerRank_comm(_req) ({ (_req)->mpid.peer_comm; … argument 51 #define MPIDI_Request_getPType(_req) ({ (_req)->mpid.ptype; … argument 52 #define MPIDI_Request_getControl(_req) ({ (_req)->mpid.envelope.msginfo.control; … argument 53 #define MPIDI_Request_isSync(_req) ({ (_req)->mpid.envelope.msginfo.isSync; … argument 54 #define MPIDI_Request_isRzv(_req) ({ (_req)->mpid.envelope.msginfo.isRzv; … argument 55 #define MPIDI_Request_getMatchTag(_req) ({ (_req)->mpid.envelope.msginfo.MPItag; … argument 56 #define MPIDI_Request_getMatchRank(_req) ({ (_req)->mpid.envelope.msginfo.MPIrank; … argument 57 #define MPIDI_Request_getMatchCtxt(_req) ({ (_req)->mpid.envelope.msginfo.MPIctxt; … argument [all …]
|
/dports/www/p5-WebDriver-Tiny/WebDriver-Tiny-0.105/lib/WebDriver/ |
H A D | Tiny.pm | 87 my $reply = $self->_req( 109 sub html($self) { $self->_req( GET => '/source' ) } 110 sub title($self) { $self->_req( GET => '/title' ) } 121 $_[0]->_req( GET => '/status' ); 145 $self->_req( POST => '/cookie', 156 $self->_req( DELETE => '/cookie' ); 189 my $reply = $self->_req( 223 $self->_req( 235 $self->_req( GET => '/screenshot' ) 269 $self->_req( POST => '/window/rect', \%args ); [all …]
|
/dports/www/p5-WebDriver-Tiny/WebDriver-Tiny-0.105/lib/WebDriver/Tiny/ |
H A D | Elements.pm | 26 sub clear($self) { $self->_req( POST => '/clear' ); $self } 27 sub click($self) { $self->_req( POST => '/click' ); $self } 28 sub tap($self) { $self->_req( POST => '/tap' ); $self } 30 sub enabled($self) { $self->_req( GET => '/enabled' ) } 31 sub rect($self) { $self->_req( GET => '/rect' ) } 32 sub selected($self) { $self->_req( GET => '/selected' ) } 33 sub tag($self) { $self->_req( GET => '/name' ) } 34 sub visible($self) { $self->_req( GET => '/displayed' ) } 44 $self->_req( GET => '/screenshot' ) 59 $self->_req( POST => '/value', { text => "$keys" } ); [all …]
|
/dports/sysutils/fusefs-sandboxfs/sandboxfs-sandboxfs-0.2.0/cargo-crates/fuse-0.3.1/src/ |
H A D | lib.rs | 101 fn init(&mut self, _req: &Request) -> Result<(), c_int> { in init() 107 fn destroy(&mut self, _req: &Request) {} in destroy() 121 fn forget(&mut self, _req: &Request, _ino: u64, _nlookup: u64) {} in forget() 124 fn getattr(&mut self, _req: &Request, _ino: u64, reply: ReplyAttr) { in getattr() 134 fn readlink(&mut self, _req: &Request, _ino: u64, reply: ReplyData) { in readlink() 182 fn open(&mut self, _req: &Request, _ino: u64, _flags: u32, reply: ReplyOpen) { in open() 247 fn opendir(&mut self, _req: &Request, _ino: u64, _flags: u32, reply: ReplyOpen) { in opendir() 277 fn statfs(&mut self, _req: &Request, _ino: u64, reply: ReplyStatfs) { in statfs() 311 fn access(&mut self, _req: &Request, _ino: u64, _mask: u32, reply: ReplyEmpty) { in access() 355 fn setvolname(&mut self, _req: &Request, _name: &OsStr, reply: ReplyEmpty) { in setvolname() [all …]
|
/dports/sysutils/fusefs-xfuse/xfuse-9c8824/cargo-crates/fuse-0.3.1/src/ |
H A D | lib.rs | 101 fn init(&mut self, _req: &Request) -> Result<(), c_int> { in init() 107 fn destroy(&mut self, _req: &Request) {} in destroy() 121 fn forget(&mut self, _req: &Request, _ino: u64, _nlookup: u64) {} in forget() 124 fn getattr(&mut self, _req: &Request, _ino: u64, reply: ReplyAttr) { in getattr() 134 fn readlink(&mut self, _req: &Request, _ino: u64, reply: ReplyData) { in readlink() 182 fn open(&mut self, _req: &Request, _ino: u64, _flags: u32, reply: ReplyOpen) { in open() 247 fn opendir(&mut self, _req: &Request, _ino: u64, _flags: u32, reply: ReplyOpen) { in opendir() 277 fn statfs(&mut self, _req: &Request, _ino: u64, reply: ReplyStatfs) { in statfs() 311 fn access(&mut self, _req: &Request, _ino: u64, _mask: u32, reply: ReplyEmpty) { in access() 355 fn setvolname(&mut self, _req: &Request, _name: &OsStr, reply: ReplyEmpty) { in setvolname() [all …]
|
/dports/audio/ardour6/Ardour-6.8.0/libs/pbd/ |
H A D | file_archive.cc | 157 : _req (url) in FileArchive() 161 if (!_req.url) { in FileArchive() 166 if (_req.is_remote ()) { in FileArchive() 169 _req.mp.progress = 0; in FileArchive() 192 if (_req.is_remote ()) { in inflate() 205 if (_req.is_remote ()) { in contents() 287 _req.mp.length = -1; in contents_file() 299 _req.mp.reset (); in contents_url() 318 _req.mp.length = -1; in extract_file() 330 _req.mp.reset (); in extract_url() [all …]
|
/dports/net/openmpi/openmpi-4.1.1/orte/orted/pmix/ |
H A D | pmix_server_internal.h | 115 pmix_server_req_t *_req; \ 116 _req = OBJ_NEW(pmix_server_req_t); \ 118 _req->target = (p); \ 119 _req->mdxcbfunc = (ocf); \ 120 _req->cbdata = (ocd); \ 121 opal_event_set(orte_event_base, &(_req->ev), \ 122 -1, OPAL_EV_WRITE, (cf), _req); \ 123 opal_event_set_priority(&(_req->ev), ORTE_MSG_PRI); \ 124 ORTE_POST_OBJECT(_req); \ 125 opal_event_active(&(_req->ev), OPAL_EV_WRITE, 1); \ [all …]
|
/dports/net/openmpi3/openmpi-3.1.6/orte/orted/pmix/ |
H A D | pmix_server_internal.h | 115 pmix_server_req_t *_req; \ 116 _req = OBJ_NEW(pmix_server_req_t); \ 118 _req->target = (p); \ 119 _req->mdxcbfunc = (ocf); \ 120 _req->cbdata = (ocd); \ 121 opal_event_set(orte_event_base, &(_req->ev), \ 122 -1, OPAL_EV_WRITE, (cf), _req); \ 123 opal_event_set_priority(&(_req->ev), ORTE_MSG_PRI); \ 124 ORTE_POST_OBJECT(_req); \ 125 opal_event_active(&(_req->ev), OPAL_EV_WRITE, 1); \ [all …]
|
/dports/devel/hadoop2/jetty-6.1.14/contrib/j2se6/src/main/java/org/mortbay/jetty/j2se6/ |
H A D | JettyHttpExchange.java | 46 private HttpServletRequest _req; field in JettyHttpExchange 65 this._req = req; in JettyHttpExchange() 82 Enumeration en = _req.getHeaderNames(); in getRequestHeaders() 107 String uriAsString = _req.getRequestURI(); in getRequestURI() 108 if (_req.getQueryString() != null) in getRequestURI() 122 return _req.getMethod(); in getRequestMethod() 182 return new InetSocketAddress(_req.getRemoteAddr(), _req.getRemotePort()); in getRemoteAddress() 194 return new InetSocketAddress(_req.getLocalAddr(), _req.getLocalPort()); in getLocalAddress() 200 return _req.getProtocol(); in getProtocol() 206 return _req.getAttribute(name); in getAttribute() [all …]
|
/dports/devel/hadoop/jetty-6.1.14/contrib/j2se6/src/main/java/org/mortbay/jetty/j2se6/ |
H A D | JettyHttpExchange.java | 46 private HttpServletRequest _req; field in JettyHttpExchange 65 this._req = req; in JettyHttpExchange() 82 Enumeration en = _req.getHeaderNames(); in getRequestHeaders() 107 String uriAsString = _req.getRequestURI(); in getRequestURI() 108 if (_req.getQueryString() != null) in getRequestURI() 122 return _req.getMethod(); in getRequestMethod() 182 return new InetSocketAddress(_req.getRemoteAddr(), _req.getRemotePort()); in getRemoteAddress() 194 return new InetSocketAddress(_req.getLocalAddr(), _req.getLocalPort()); in getLocalAddress() 200 return _req.getProtocol(); in getProtocol() 206 return _req.getAttribute(name); in getAttribute() [all …]
|
/dports/devel/dulwich/dulwich-0.19.16/dulwich/tests/ |
H A D | test_web.py | 184 self.assertFalse(self._req.cached) 191 self.assertFalse(self._req.cached) 200 self.assertFalse(self._req.cached) 210 self.assertTrue(self._req.cached) 240 self.assertTrue(self._req.cached) 250 self.assertTrue(self._req.cached) 278 self.assertFalse(self._req.cached) 323 self.assertFalse(self._req.cached) 351 self.assertFalse(self._req.cached) 457 self._req.respond() [all …]
|
/dports/devel/etcd31/etcd-3.1.20/etcdserver/api/v3rpc/ |
H A D | interceptor.go | 89 _req, ok := req.(*pb.RangeRequest) 92 reqSize = _req.Size() 93 reqContent = _req.String() 100 _req, ok := req.(*pb.PutRequest) 103 reqSize = _req.Size() 112 _req, ok := req.(*pb.DeleteRangeRequest) 115 reqSize = _req.Size() 116 reqContent = _req.String() 123 _req, ok := req.(*pb.TxnRequest) 128 for _, r := range _req.GetSuccess() { [all …]
|
/dports/net/kamailio/kamailio-5.4.5/src/modules/tm/ |
H A D | uac.h | 56 #define set_uac_req(_req, \ argument 59 memset((_req), 0, sizeof(uac_req_t)); \ 60 (_req)->method = (_m); \ 61 (_req)->headers = (_h); \ 62 (_req)->body = (_b); \ 63 (_req)->dialog = (_dlg); \ 64 (_req)->cb_flags = (_cb_flags); \ 65 (_req)->cb = (_cb); \ 66 (_req)->cbp = (_cbp); \
|
/dports/www/py-wfuzz/wfuzz-3.1.0/src/wfuzz/ |
H A D | fuzzrequest.py | 28 self._req = req 34 if self._req.response 44 self._req._headers.update(values_dict) 59 self._req = req 63 if self._req.response: 74 if "Cookie" in self._req._headers: 98 self._req = req 120 self._req.setVariablePOST( 124 self._req._non_parsed_post = self._req._variablesPOST.urlEncoded() 127 self._req.setPostData(pp) [all …]
|
/dports/java/openjdk8/jdk8u-jdk8u312-b07.1/corba/src/share/classes/com/sun/corba/se/impl/corba/ |
H A D | AsynchInvoke.java | 49 private RequestImpl _req; field in AsynchInvoke 56 _req = reqToInvokeOn; in AsynchInvoke() 72 _req.doInvocation(); in run() 76 synchronized (_req) in run() 79 _req.gotResponse = true; in run() 82 _req.notify(); in run()
|
/dports/java/openjdk8-jre/jdk8u-jdk8u312-b07.1/corba/src/share/classes/com/sun/corba/se/impl/corba/ |
H A D | AsynchInvoke.java | 49 private RequestImpl _req; field in AsynchInvoke 56 _req = reqToInvokeOn; in AsynchInvoke() 72 _req.doInvocation(); in run() 76 synchronized (_req) in run() 79 _req.gotResponse = true; in run() 82 _req.notify(); in run()
|
/dports/sysutils/istio/istio-1.6.7/vendor/github.com/coreos/etcd/etcdserver/api/v3rpc/ |
H A D | interceptor.go | 85 _req, ok := req.(*pb.RangeRequest) 88 reqSize = _req.Size() 89 reqContent = _req.String() 96 _req, ok := req.(*pb.PutRequest) 99 reqSize = _req.Size() 108 _req, ok := req.(*pb.DeleteRangeRequest) 111 reqSize = _req.Size() 112 reqContent = _req.String() 119 _req, ok := req.(*pb.TxnRequest) 124 for _, r := range _req.GetSuccess() { [all …]
|
/dports/devel/etcd32/etcd-3.2.32/etcdserver/api/v3rpc/ |
H A D | interceptor.go | 95 _req, ok := req.(*pb.RangeRequest) 98 reqSize = _req.Size() 99 reqContent = _req.String() 106 _req, ok := req.(*pb.PutRequest) 109 reqSize = _req.Size() 118 _req, ok := req.(*pb.DeleteRangeRequest) 121 reqSize = _req.Size() 122 reqContent = _req.String() 129 _req, ok := req.(*pb.TxnRequest) 134 for _, r := range _req.GetSuccess() { [all …]
|
/dports/sysutils/sensu-go/sensu-go-5.11.1/vendor/github.com/coreos/etcd/etcdserver/api/v3rpc/ |
H A D | interceptor.go | 85 _req, ok := req.(*pb.RangeRequest) 88 reqSize = _req.Size() 89 reqContent = _req.String() 96 _req, ok := req.(*pb.PutRequest) 99 reqSize = _req.Size() 108 _req, ok := req.(*pb.DeleteRangeRequest) 111 reqSize = _req.Size() 112 reqContent = _req.String() 119 _req, ok := req.(*pb.TxnRequest) 124 for _, r := range _req.GetSuccess() { [all …]
|
/dports/security/vault/vault-1.8.2/vendor/go.etcd.io/etcd/etcdserver/api/v3rpc/ |
H A D | interceptor.go | 98 _req, ok := req.(*pb.RangeRequest) 101 reqSize = _req.Size() 102 reqContent = _req.String() 109 _req, ok := req.(*pb.PutRequest) 112 reqSize = _req.Size() 121 _req, ok := req.(*pb.DeleteRangeRequest) 124 reqSize = _req.Size() 125 reqContent = _req.String() 132 _req, ok := req.(*pb.TxnRequest) 137 for _, r := range _req.GetSuccess() { [all …]
|
/dports/devel/etcd33/etcd-3.3.23/etcdserver/api/v3rpc/ |
H A D | interceptor.go | 91 _req, ok := req.(*pb.RangeRequest) 94 reqSize = _req.Size() 95 reqContent = _req.String() 102 _req, ok := req.(*pb.PutRequest) 105 reqSize = _req.Size() 114 _req, ok := req.(*pb.DeleteRangeRequest) 117 reqSize = _req.Size() 118 reqContent = _req.String() 125 _req, ok := req.(*pb.TxnRequest) 130 for _, r := range _req.GetSuccess() { [all …]
|
/dports/devel/etcd33/etcd-3.3.23/vendor/github.com/coreos/etcd/etcdserver/api/v3rpc/ |
H A D | interceptor.go | 91 _req, ok := req.(*pb.RangeRequest) 94 reqSize = _req.Size() 95 reqContent = _req.String() 102 _req, ok := req.(*pb.PutRequest) 105 reqSize = _req.Size() 114 _req, ok := req.(*pb.DeleteRangeRequest) 117 reqSize = _req.Size() 118 reqContent = _req.String() 125 _req, ok := req.(*pb.TxnRequest) 130 for _, r := range _req.GetSuccess() { [all …]
|
/dports/net-im/nextcloud-spreed-signaling/nextcloud-spreed-signaling-0.2.0/vendor/src/go.etcd.io/etcd/etcdserver/api/v3rpc/ |
H A D | interceptor.go | 100 _req, ok := req.(*pb.RangeRequest) 103 reqSize = _req.Size() 104 reqContent = _req.String() 111 _req, ok := req.(*pb.PutRequest) 114 reqSize = _req.Size() 123 _req, ok := req.(*pb.DeleteRangeRequest) 126 reqSize = _req.Size() 127 reqContent = _req.String() 134 _req, ok := req.(*pb.TxnRequest) 139 for _, r := range _req.GetSuccess() { [all …]
|
/dports/devel/etcd34/etcd-3.4.18/etcdserver/api/v3rpc/ |
H A D | interceptor.go | 100 _req, ok := req.(*pb.RangeRequest) 103 reqSize = _req.Size() 104 reqContent = _req.String() 111 _req, ok := req.(*pb.PutRequest) 114 reqSize = _req.Size() 123 _req, ok := req.(*pb.DeleteRangeRequest) 126 reqSize = _req.Size() 127 reqContent = _req.String() 134 _req, ok := req.(*pb.TxnRequest) 139 for _, r := range _req.GetSuccess() { [all …]
|
/dports/sysutils/terraform/terraform-1.0.11/vendor/go.etcd.io/etcd/etcdserver/api/v3rpc/ |
H A D | interceptor.go | 100 _req, ok := req.(*pb.RangeRequest) 103 reqSize = _req.Size() 104 reqContent = _req.String() 111 _req, ok := req.(*pb.PutRequest) 114 reqSize = _req.Size() 123 _req, ok := req.(*pb.DeleteRangeRequest) 126 reqSize = _req.Size() 127 reqContent = _req.String() 134 _req, ok := req.(*pb.TxnRequest) 139 for _, r := range _req.GetSuccess() { [all …]
|