- Sort Score
- Result 10 results
- Languages All
Results 41 - 47 of 47 for GetResponse (0.14 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 25 10:26:38 UTC 2023 - 18.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/store_test.go
} type clientRecorder struct { reads uint64 clientv3.KV } func (r *clientRecorder) Get(ctx context.Context, key string, opts ...clientv3.OpOption) (*clientv3.GetResponse, error) { atomic.AddUint64(&r.reads, 1) return r.KV.Get(ctx, key, opts...) } func (r *clientRecorder) GetReadsAndReset() uint64 { return atomic.SwapUint64(&r.reads, 0) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 12:45:33 UTC 2024 - 26.5K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbFile.java
cur.chain(closeReq); Smb2CreateResponse createResp = th.send(cr); Smb2CloseResponse closeResp = closeReq.getResponse(); SmbBasicFileInfo info; if ( ( closeResp.getCloseFlags() & Smb2CloseResponse.SMB2_CLOSE_FLAG_POSTQUERY_ATTIB ) != 0 ) { info = closeResp; }
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Thu May 23 01:50:13 UTC 2024 - 82.3K bytes - Viewed (1) -
pkg/config/validation/validation.go
errs = appendErrors(errs, ValidateHTTPHeaderOperationName(name)) } for name, val := range weight.Headers.GetResponse().GetAdd() { errs = appendErrors(errs, ValidateHTTPHeaderOperationName(name)) errs = appendErrors(errs, ValidateHTTPHeaderValue(val)) } for name, val := range weight.Headers.GetResponse().GetSet() { errs = appendErrors(errs, ValidateHTTPHeaderOperationName(name))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 04:03:33 UTC 2024 - 107.2K bytes - Viewed (0) -
pilot/pkg/networking/core/route/route.go
} return result } // TranslateHeadersOperations translates headers operations func TranslateHeadersOperations(headers *networking.Headers) HeadersOperations { req := headers.GetRequest() resp := headers.GetResponse() requestHeadersToAdd, setAuthority := translateAppendHeaders(req.GetSet(), false) reqAdd, addAuthority := translateAppendHeaders(req.GetAdd(), true) requestHeadersToAdd = append(requestHeadersToAdd, reqAdd...)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 14:12:39 UTC 2024 - 56.1K bytes - Viewed (0) -
src/test/java/jcifs/tests/OplockTests.java
SmbComNTCreateAndX req = new SmbComNTCreateAndX(sess.getConfig(), uncPath, flags, access, sharing, attrs, options, null); req.addFlags0(0x2); // REQUEST_OPLOCK req.setResponse(resp); try { resp = tree.send(req); SmbComNTCreateAndXResponse resp2 = new SmbComNTCreateAndXResponse(sess.getConfig());
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Thu Jan 05 13:09:03 UTC 2023 - 6.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/rank/fusion/RankFusionProcessor.java
responseOpt.ifPresent(externalContext::setResponse); } return searcher.search(query, reqParams, userBean); } finally { if (externalContext != null) { externalContext.setRequest(null); externalContext.setResponse(null); } } }));
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 16.5K bytes - Viewed (0)