Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 41 - 50 of 305 for resMap (0.04 seconds)

  1. src/main/java/jcifs/smb/SmbTransportImpl.java

            final ServerMessageBlock2Response resp = (ServerMessageBlock2Response) response;
            synchronized (resp) {
                if (resp.isAsync() && !resp.isAsyncHandled() && resp.getStatus() == NtStatus.NT_STATUS_PENDING && resp.getAsyncId() != 0) {
                    resp.setAsyncHandled(true);
                    final boolean first = !req.isAsync();
                    req.setAsyncId(resp.getAsyncId());
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 69.8K bytes
    - Click Count (0)
  2. internal/config/identity/plugin/config.go

    	}
    
    	reqStartTime := time.Now()
    	resp, err := o.client.Do(req)
    	if err != nil {
    		o.serviceMetrics.accumRequestRTT(reqStartTime, 0, false)
    		return AuthNResponse{}, err
    	}
    	defer o.args.CloseRespFn(resp.Body)
    	reqDurNanos := time.Since(reqStartTime).Nanoseconds()
    	o.serviceMetrics.accumRequestRTT(reqStartTime, float64(reqDurNanos)/1e6, true)
    
    	switch resp.StatusCode {
    	case 200:
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 13.3K bytes
    - Click Count (0)
  3. docs/en/docs/tutorial/body-updates.md

    Like `stored_item_model.model_copy(update=update_data)`:
    
    {* ../../docs_src/body_updates/tutorial002_py310.py hl[33] *}
    
    ### Partial updates recap { #partial-updates-recap }
    
    In summary, to apply partial updates you would:
    
    * (Optionally) use `PATCH` instead of `PUT`.
    * Retrieve the stored data.
    * Put that data in a Pydantic model.
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sat Dec 20 15:55:38 GMT 2025
    - 4.1K bytes
    - Click Count (0)
  4. cmd/kms-handlers.go

    		response.DecryptionErr = "The generated and the decrypted data key do not match"
    		resp, err := json.Marshal(response)
    		if err != nil {
    			writeCustomErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrInternalError), err.Error(), r.URL)
    			return
    		}
    		writeSuccessResponseJSON(w, resp)
    		return
    	}
    
    	resp, err := json.Marshal(response)
    	if err != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Aug 18 06:43:03 GMT 2024
    - 10.1K bytes
    - Click Count (0)
  5. src/main/java/jcifs/smb/SmbPipeHandleImpl.java

                    final Smb2IoctlResponse resp = th.send(req, RequestParam.NO_RETRY);
                    return resp.getOutputLength();
                }
                if (this.transact) {
                    final TransTransactNamedPipe req = new TransTransactNamedPipe(th.getConfig(), fh.getFid(), buf, off, length);
                    final TransTransactNamedPipeResponse resp = new TransTransactNamedPipeResponse(th.getConfig(), inB);
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 10.2K bytes
    - Click Count (0)
  6. cmd/lock-rest-server.go

    	ctx, cancel := context.WithTimeout(context.Background(), dsync.DefaultTimeouts.RefreshCall)
    	defer cancel()
    
    	resp := lockRPCRefresh.NewResponse()
    	refreshed, err := l.ll.Refresh(ctx, *args)
    	if err != nil {
    		return l.makeResp(resp, err)
    	}
    	if !refreshed {
    		return l.makeResp(resp, errLockNotFound)
    	}
    	return l.makeResp(resp, err)
    }
    
    // LockHandler - Acquires a lock.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Jan 31 19:54:34 GMT 2025
    - 6.3K bytes
    - Click Count (0)
  7. cmd/storage-rest-client.go

    	})
    	if err != nil {
    		return cache, toStorageErr(err)
    	}
    	var final *dataUsageCache
    	err = st.Results(func(resp *nsScannerResp) error {
    		if resp.Update != nil {
    			select {
    			case <-ctx.Done():
    			case updates <- *resp.Update:
    			}
    		}
    		if resp.Final != nil {
    			final = resp.Final
    		}
    		// We can't reuse the response since it is sent upstream.
    		return nil
    	})
    	if err != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 08 02:38:41 GMT 2025
    - 30.4K bytes
    - Click Count (0)
  8. src/test/java/jcifs/smb/SmbTreeConnectionTest.java

            CommonServerMessageBlockResponse resp = mock(CommonServerMessageBlockResponse.class);
    
            // Configure the tree to throw transport error on first call, succeed on second
            when(tree.send(eq(req), eq(resp), anySet()))
                    .thenThrow(new SmbException("transport error", new jcifs.util.transport.TransportException()))
                    .thenReturn(resp);
    
            setTree(c, tree);
    
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 07:14:38 GMT 2025
    - 13K bytes
    - Click Count (0)
  9. docs/en/docs/tutorial/body-fields.md

    As these keys may not necessarily be part of the OpenAPI specification, some OpenAPI tools, for example [the OpenAPI validator](https://validator.swagger.io/), may not work with your generated schema.
    
    ///
    
    ## Recap { #recap }
    
    You can use Pydantic's `Field` to declare extra validations and metadata for model attributes.
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sun Aug 31 09:15:41 GMT 2025
    - 2.3K bytes
    - Click Count (0)
  10. internal/grid/stream.go

    				return err
    			}
    			// Fall through to be sure we have returned all responses.
    			doneCh = nil
    		case resp, ok := <-s.responses:
    			if !ok {
    				done = true
    				return nil
    			}
    			if resp.Err != nil {
    				s.cancel(resp.Err)
    				return resp.Err
    			}
    			err = next(resp.Msg)
    			if err != nil {
    				s.cancel(err)
    				return err
    			}
    		}
    	}
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Jun 07 15:51:52 GMT 2024
    - 3.1K bytes
    - Click Count (0)
Back to Top