Search Options

Results per page
Sort
Preferred Languages
Advance

Results 741 - 750 of 1,168 for lose (0.02 sec)

  1. internal/config/lambda/parse.go

    		return err
    	}
    
    	targetList, err := fetchSubSysTargets(ctx, cfg, subSys, transport)
    	if err != nil {
    		return err
    	}
    
    	for _, target := range targetList {
    		defer target.Close()
    	}
    
    	for _, target := range targetList {
    		yes, err := target.IsActive()
    		if err == nil && !yes {
    			err = ErrTargetsOffline
    		}
    		if err != nil {
    			return fmt.Errorf("error (%s): %w", target.ID(), err)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6K bytes
    - Viewed (0)
  2. internal/http/response-recorder.go

    	if lrw.Header().Get("Content-Encoding") == "gzip" {
    		if lrw.body.Len() > 1<<20 {
    			return gzippedBody
    		}
    		r, err := gzip.NewReader(&lrw.body)
    		if err != nil {
    			return gzippedBody
    		}
    		defer r.Close()
    		b, _ := io.ReadAll(io.LimitReader(r, 10<<20))
    		return b
    	}
    	// If there was an error response or body logging is enabled
    	// then we return the body contents
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java

             * InterruptibleChannel and JavaLangAccess.blockedOn(Thread, Interruptible), it isn't
             * predictable what work might be done. (e.g., close a file and flush buffers to disk). To
             * protect ourselves from this, we park ourselves and tell our interrupter that we did so.
             */
            if (state == PARKED || compareAndSet(state, PARKED)) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  4. docs/pt/docs/tutorial/request-files.md

        * Por exemplo, `await myfile.seek(0)` irá para o início do arquivo.
        * Isso é especialmente útil se você executar `await myfile.read()` uma vez e precisar ler o conteúdo novamente.
    * `close()`: Fecha o arquivo.
    
    Como todos esses métodos são métodos `assíncronos`, você precisa "aguardar" por eles.
    
    Por exemplo, dentro de uma função de *operação de rota* `assíncrona`, você pode obter o conteúdo com:
    
    ```Python
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Wed Oct 30 19:52:32 UTC 2024
    - 7.8K bytes
    - Viewed (0)
  5. callbacks/update.go

    					dest := db.Statement.Dest
    					db.Statement.Dest = db.Statement.ReflectValue.Addr().Interface()
    					gorm.Scan(rows, db, mode)
    					db.Statement.Dest = dest
    					db.AddError(rows.Close())
    				}
    			} else {
    				result, err := db.Statement.ConnPool.ExecContext(db.Statement.Context, db.Statement.SQL.String(), db.Statement.Vars...)
    
    				if db.AddError(err) == nil {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Mar 18 05:44:55 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  6. cmd/object-lambda-handlers.go

    		return
    	}
    
    	resp, err := target.Send(eventData)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    	defer resp.Body.Close()
    
    	if eventData.GetObjectContext.OutputRoute != resp.Header.Get(xhttp.AmzRequestRoute) {
    		tokenErr := errorCodes.ToAPIErr(ErrInvalidRequest)
    		tokenErr.Description = "The request route included in the request is invalid"
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 22 07:04:48 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  7. cmd/veeam-sos-api.go

    }
    
    func veeamSOSAPIHeadObject(ctx context.Context, bucket, object string, opts ObjectOptions) (ObjectInfo, error) {
    	gr, err := veeamSOSAPIGetObject(ctx, bucket, object, nil, opts)
    	if gr != nil {
    		gr.Close()
    		return gr.ObjInfo, nil
    	}
    	return ObjectInfo{}, err
    }
    
    func veeamSOSAPIGetObject(ctx context.Context, bucket, object string, rs *HTTPRangeSpec, opts ObjectOptions) (gr *GetObjectReader, err error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 00:34:56 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  8. build-logic-commons/gradle-plugin/src/main/kotlin/gradlebuild/testcleanup/TestFilesCleanupService.kt

        private
        fun getExecutedTaskPaths(projectPath: String) = projectPathToExecutedTaskPaths.getOrDefault(projectPath, emptyList())
    
        override fun close() {
            val projectPathToLeftoverFiles = mutableMapOf<String, LeftoverFiles>()
            // First run: delete any temporary directories used to extract resources from jars
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Fri Jul 28 16:19:47 UTC 2023
    - 12.5K bytes
    - Viewed (0)
  9. src/main/webapp/js/admin/adminlte.min.js.map

    is._config.title))\n    }\n\n    if (this._config.subtitle != null) {\n      toastHeader.append($('<small />').html(this._config.subtitle))\n    }\n\n    if (this._config.close == true) {\n      const toastClose = $('<button data-dismiss=\"toast\" />').attr('type', 'button').addClass('ml-2 mb-1 close').attr('aria-label', 'Close').append('<span aria-hidden=\"true\">&times;</span>')\n\n      if (this._config.title == null) {\n        toastClose.toggleClass('ml-2 ml-auto')\n      }\n\n      toastHe...
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sat Oct 26 01:49:09 UTC 2024
    - 132.4K bytes
    - Viewed (0)
  10. docs/sts/assume-role.go

    	if sessionPolicyFile != "" {
    		var policy string
    		if f, err := os.Open(sessionPolicyFile); err != nil {
    			log.Fatalf("Unable to open session policy file: %v", err)
    		} else {
    			defer f.Close()
    			bs, err := io.ReadAll(f)
    			if err != nil {
    				log.Fatalf("Error reading session policy file: %v", err)
    			}
    			policy = string(bs)
    		}
    		stsOpts.Policy = policy
    	}
    	if expiryDuration != 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Aug 17 01:24:54 UTC 2024
    - 4.4K bytes
    - Viewed (0)
Back to top