- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 63 for GetResponse (0.16 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/etcd3/store.go
clientv3.OpGet(key), ).Commit() metrics.RecordEtcdRequest("delete", s.groupResourceString, err, startTime) if err != nil { return err } if !txnResp.Succeeded { getResp := (*clientv3.GetResponse)(txnResp.Responses[0].GetResponseRange()) klog.V(4).Infof("deletion of %s failed because of a conflict, going to retry", key) origState, err = s.getState(ctx, getResp, key, v, false) if err != nil { return err
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 11:56:42 UTC 2024 - 35.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/sso/oic/OpenIdConnectAuthenticator.java
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 11.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/api/json/SearchApiManager.java
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 02:17:23 UTC 2024 - 50.3K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/proxy/upgradeaware.go
h.Responder.Error(w, req, err) return true } defer backendConn.Close() // determine the http response code from the backend by reading from rawResponse+backendConn backendHTTPResponse, headerBytes, err := getResponse(io.MultiReader(bytes.NewReader(rawResponse), backendConn)) if err != nil { klog.V(6).Infof("Proxy connection error: %v", err) h.Responder.Error(w, req, err) return true }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 19:10:30 UTC 2024 - 19.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher_test.go
return &etcdClientKVWrapper{ KV: kv, getCallCounter: 0, } } func (ecw *etcdClientKVWrapper) Get(ctx context.Context, key string, opts ...clientv3.OpOption) (*clientv3.GetResponse, error) { resp, err := ecw.KV.Get(ctx, key, opts...) ecw.getCallCounter++ if err != nil { return nil, err } if len(ecw.getReactors) > 0 { reactor := ecw.getReactors[0]
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 12.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/client/SearchEngineClient.java
final SearchResult<T, GetRequestBuilder, GetResponse> searchResult) { final SystemHelper systemHelper = ComponentUtil.getSystemHelper(); final long startTime = systemHelper.getCurrentTimeAsLong(); GetResponse response = null; final GetRequestBuilder requestBuilder = client.prepareGet(index, id);
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 84.1K bytes - Viewed (0) -
src/net/rpc/server.go
// contains an error when it is used. var invalidRequest = struct{}{} func (server *Server) sendResponse(sending *sync.Mutex, req *Request, reply any, codec ServerCodec, errmsg string) { resp := server.getResponse() // Encode the response header resp.ServiceMethod = req.ServiceMethod if errmsg != "" { resp.Error = errmsg reply = invalidRequest } resp.Seq = req.Seq sending.Lock()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 21.6K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbCopyUtil.java
ooff += r.getTotalBytesWritten(); } catch ( SmbException e ) { Smb2IoctlResponse response = copy.getResponse(); if ( !retry && response.isReceived() && !response.isError() && response.getStatus() == NtStatus.NT_STATUS_INVALID_PARAMETER ) {
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Tue Jul 07 10:52:42 UTC 2020 - 17.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/taglib/FessFunctions.java
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 16.9K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb1/AndXServerMessageBlock.java
dstIndex += writeAndXWireFormat(dst, dstIndex); this.length = dstIndex - start; if ( this.digest != null ) { this.digest.sign(dst, this.headerStart, this.length, this, this.getResponse()); } return this.length; } /* * We overload this because we want readAndXWireFormat to * read the parameter words and bytes. This is so when
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Mon Nov 28 10:56:27 UTC 2022 - 14.3K bytes - Viewed (0)