Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 109 for recycle (0.07 sec)

  1. src/main/webapp/WEB-INF/view/admin/design/admin_design.jsp

                                                name="editAsUseDefault"
                                                value="<la:message key="labels.design_use_default_button" />">
                                            <em class="fa fa-recycle">
                                            <la:message key="labels.design_use_default_button"/>
                                        </button>
                                    </div>
                                </la:form>
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Wed Feb 12 20:25:27 UTC 2020
    - 11.1K bytes
    - Viewed (0)
  2. cmd/peer-s3-client.go

    	}
    	buckets := make([]BucketInfo, 0, len(bi.Value()))
    	for _, b := range bi.Value() {
    		if b != nil {
    			buckets = append(buckets, *b)
    		}
    	}
    	bi.Recycle() // BucketInfo has no internal pointers, so it's safe to recycle.
    	return buckets, nil
    }
    
    func (client *remotePeerS3Client) HealBucket(ctx context.Context, bucket string, opts madmin.HealOpts) (madmin.HealResultItem, error) {
    	conn := client.gridConn()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 15.6K bytes
    - Viewed (0)
  3. cmd/storage-datatypes.go

    	buf := grid.GetByteBufferCap(32 + 16<<10)
    	return &RenameDataInlineHandlerParams{RenameDataHandlerParams{FI: FileInfo{Data: buf[:0]}}}
    }
    
    // Recycle will reuse the memory allocated for the FileInfo data.
    func (r *RenameDataInlineHandlerParams) Recycle() {
    	if r == nil {
    		return
    	}
    	if cap(r.FI.Data) >= xioutil.SmallBlock {
    		grid.PutByteBuffer(r.FI.Data)
    		r.FI.Data = nil
    	}
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 25 05:41:04 UTC 2025
    - 17.4K bytes
    - Viewed (0)
  4. cmd/bitrot-streaming.go

    	// Hence an immediate Read() on the file can return incorrect data.
    	if b.canClose != nil {
    		b.canClose.Wait()
    	}
    
    	// Recycle the buffer.
    	if b.byteBuf != nil {
    		globalBytePoolCap.Load().Put(b.byteBuf)
    		b.byteBuf = nil
    	}
    	return err
    }
    
    // newStreamingBitrotWriterBuffer returns streaming bitrot writer implementation.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jan 17 19:19:30 UTC 2025
    - 6.2K bytes
    - Viewed (0)
  5. cmd/peer-rest-client.go

    	if err != nil {
    		return
    	}
    	st.Results(func(b []byte) error {
    		select {
    		case traceCh <- b:
    		default:
    			// Do not block on slow receivers.
    			// Just recycle the buffer.
    			grid.PutByteBuffer(b)
    		}
    		return nil
    	})
    }
    
    func (client *peerRESTClient) doListen(ctx context.Context, listenCh chan<- []byte, v url.Values) {
    	conn := client.gridConn()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  6. cmd/storage-rest-server.go

    }
    
    // RenameDataInlineHandler - renames a meta object and data dir to destination.
    func (s *storageRESTServer) RenameDataInlineHandler(p *RenameDataInlineHandlerParams) (*RenameDataResp, *grid.RemoteErr) {
    	defer p.Recycle()
    	return s.RenameDataHandler(&p.RenameDataHandlerParams)
    }
    
    // RenameFileHandler - rename a file from source to destination
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 45.7K bytes
    - Viewed (0)
  7. cmd/peer-rest-server.go

    // ListenHandler sends http trace messages back to peer rest client
    func (s *peerRESTServer) ListenHandler(ctx context.Context, v *grid.URLValues, out chan<- *grid.Bytes) *grid.RemoteErr {
    	values := v.Values()
    	defer v.Recycle()
    	var prefix string
    	if len(values[peerRESTListenPrefix]) > 1 {
    		return grid.NewRemoteErrString("invalid request (peerRESTListenPrefix)")
    	}
    	globalAPIConfig.getRequestsPoolCapacity()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 53.4K bytes
    - Viewed (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/OkHttpClient.kt

         */
        fun dispatcher(dispatcher: Dispatcher) =
          apply {
            this.dispatcher = dispatcher
          }
    
        /**
         * Sets the connection pool used to recycle HTTP and HTTPS connections.
         *
         * If unset, a new connection pool will be used.
         */
        fun connectionPool(connectionPool: ConnectionPool) =
          apply {
            this.connectionPool = connectionPool
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon May 05 16:01:00 UTC 2025
    - 51.7K bytes
    - Viewed (0)
  9. cmd/data-scanner-metric.go

    	p.cycleInfoMu.Lock()
    	defer p.cycleInfoMu.Unlock()
    	if p.cycleInfo == nil {
    		return nil
    	}
    	c := p.cycleInfo.clone()
    	return &c
    }
    
    func (p *scannerMetrics) report() madmin.ScannerMetrics {
    	var m madmin.ScannerMetrics
    	cycle := p.getCycle()
    	if cycle != nil {
    		m.CurrentCycle = cycle.current
    		m.CyclesCompletedAt = cycle.cycleCompleted
    		m.CurrentStarted = cycle.started
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 9.4K bytes
    - Viewed (0)
  10. src/main/java/jcifs/smb1/smb1/SmbFile.java

            sid = resp.sid;
            req = new Trans2FindNext2(sid, resp.resumeKey, resp.lastName);
    
            /* The only difference between first2 and next2 responses is subCommand
             * so let's recycle the response object.
             */
            resp.subCommand = SmbComTransaction.TRANS2_FIND_NEXT2;
    
            for (;;) {
                for (int i = 0; i < resp.numEntries; i++) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 112.2K bytes
    - Viewed (0)
Back to top