Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 304 for buf1 (0.03 sec)

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

        SmbFileHandle ensureOpen () throws CIFSException;
    
    
        /**
         * @param buf
         * @param off
         * @param length
         * @param direct
         * @return received bytes
         * @throws CIFSException
         * @throws IOException
         */
        int recv ( byte[] buf, int off, int length ) throws IOException;
    
    
        /**
         * @param buf
         * @param off
         * @param length
         * @param direct
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 2.5K bytes
    - Viewed (0)
  2. internal/grid/grid.go

    	return d
    }
    
    type writerWrapper struct {
    	ch  chan<- []byte
    	ctx context.Context
    }
    
    func (w *writerWrapper) Write(p []byte) (n int, err error) {
    	buf := GetByteBufferCap(len(p))
    	buf = buf[:len(p)]
    	copy(buf, p)
    	select {
    	case w.ch <- buf:
    		return len(p), nil
    	case <-w.ctx.Done():
    		return 0, context.Cause(w.ctx)
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  3. fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/LhaExtractor.java

                                final Map<String, String> map = new HashMap<>();
                                map.put(ExtractData.RESOURCE_NAME_KEY, filename);
                                buf.append(extractor.getText(new IgnoreCloseInputStream(is), map).getContent());
                                buf.append('\n');
                            } catch (final Exception e) {
                                if (logger.isDebugEnabled()) {
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  4. internal/ringbuffer/ring_buffer_test.go

    			n, err = rb.WriteString(string(buf[:writeRng.Intn(len(buf))]))
    			if err != nil {
    				t.Fatalf("write failed: %v", err)
    			}
    			wroteBytes += n
    			wrote.Write(buf[:n])
    			debugln("WRITE 2\t", writeRng.Intn(len(buf)), wroteBytes)
    
    			// WriteByte
    			err = rb.WriteByte(buf[0])
    			if err != nil {
    				t.Fatalf("write failed: %v", err)
    			}
    			wroteBytes++
    			wrote.Write(buf[:1])
    			debugln("WRITE 3\t", 1, wroteBytes)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/timer/MonitorTarget.java

                tempBuf.append("null");
            }
            buf.append(tempBuf.toString());
            return buf;
        }
    
        protected StringBuilder appendTimestamp(final StringBuilder buf) {
            final SystemHelper systemHelper = ComponentUtil.getSystemHelper();
            append(buf, "timestamp", () -> FessFunctions.formatDate(systemHelper.getCurrentTime()));
            return buf;
        }
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:11:58 UTC 2024
    - 3K bytes
    - Viewed (0)
  6. cmd/veeam-sos-api.go

    		} else {
    			ci.Capacity = quotaSize
    		}
    		ci.Available = ci.Capacity - ci.Used
    
    		buf = encodeResponse(&ci)
    	default:
    		return nil, errFileNotFound
    	}
    
    	etag := getMD5Hash(buf)
    	r := bytes.NewReader(buf)
    
    	off, length := int64(0), r.Size()
    	if rs != nil {
    		off, length, err = rs.GetOffsetLength(r.Size())
    		if err != nil {
    			return nil, err
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 00:34:56 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  7. tensorflow/c/eager/dlpack.cc

      auto tf_dlm_type = GetDlDataType(data_type, status);
      if (!status->status.ok()) {
        return nullptr;
      }
    
      TensorReference tensor_ref(*tensor);  // This will call buf_->Ref()
      auto* tf_dlm_tensor_ctx = new TfDlManagedTensorCtx(tensor_ref);
      tf_dlm_tensor_ctx->reference = tensor_ref;
    
      DLManagedTensor* dlm_tensor = &tf_dlm_tensor_ctx->tensor;
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 05:11:17 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  8. internal/pubsub/pubsub.go

    		// Read from subChT and write to subCh
    		var buf bytes.Buffer
    		enc := json.NewEncoder(&buf)
    		for {
    			select {
    			case <-doneCh:
    				return
    			case v, ok := <-subChT:
    				if !ok {
    					return
    				}
    				buf.Reset()
    				err := enc.Encode(v)
    				if err != nil {
    					return
    				}
    
    				select {
    				case subCh <- append(GetByteBuffer()[:0], buf.Bytes()...):
    					continue
    				case <-doneCh:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Feb 06 16:57:30 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  9. cmd/erasure-multipart.go

    		// Add input readahead.
    		// We use 2 buffers, so we always have a full buffer of input.
    		pool := globalBytePoolCap.Load()
    		bufA := pool.Get()
    		bufB := pool.Get()
    		defer pool.Put(bufA)
    		defer pool.Put(bufB)
    		ra, err := readahead.NewReaderBuffer(data, [][]byte{bufA[:fi.Erasure.BlockSize], bufB[:fi.Erasure.BlockSize]})
    		if err == nil {
    			toEncode = ra
    			defer ra.Close()
    		}
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 44.7K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/suggest/index/contents/DefaultContentsParser.java

            final List<AnalyzeToken> tokens = new ArrayList<>();
            final StringBuilder buf = new StringBuilder(maxAnalyzedContentLength);
            for (final String t : text.split("\\s")) {
                buf.append(t).append(' ');
                if (buf.length() > maxAnalyzedContentLength) {
                    try {
                        tokens.addAll(analyzer.analyze(buf.toString().trim(), field, lang));
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:54 UTC 2024
    - 13.7K bytes
    - Viewed (0)
Back to top