Search Options

Results per page
Sort
Preferred Languages
Advance

Results 121 - 130 of 276 for buf1 (0.07 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. src/main/java/org/codelibs/fess/job/PythonJob.java

            final StringBuilder buf = new StringBuilder(100);
            buf.append("WEB-INF");
            buf.append(File.separator);
            buf.append("env");
            buf.append(File.separator);
            buf.append(getExecuteType());
            buf.append(File.separator);
            buf.append("resources");
            buf.append(File.separator);
            buf.append(filename.replaceAll("\\.\\.+", ""));
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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)
  6. cmd/xl-storage-format-v2.go

    	}
    }
    
    func decodeXLHeaders(buf []byte) (versions int, headerV, metaV uint8, b []byte, err error) {
    	hdrVer, buf, err := msgp.ReadUint8Bytes(buf)
    	if err != nil {
    		return 0, 0, 0, buf, err
    	}
    	metaVer, buf, err := msgp.ReadUint8Bytes(buf)
    	if err != nil {
    		return 0, 0, 0, buf, err
    	}
    	if hdrVer > xlHeaderVersion {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 64K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/core/text/DecimalFormatUtil.java

            final StringBuilder buf = new StringBuilder(20);
            for (int i = 0; i < s.length(); ++i) {
                char c = s.charAt(i);
                if (c == groupingSep) {
                    continue;
                } else if (c == decimalSep) {
                    c = '.';
                }
                buf.append(c);
            }
            return buf.toString();
        }
    
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  8. internal/ringbuffer/README.md

    )
    
    func main() {
    	rb := ringbuffer.New(1024)
    
    	// write
    	rb.Write([]byte("abcd"))
    	fmt.Println(rb.Length())
    	fmt.Println(rb.Free())
    
    	// read
    	buf := make([]byte, 4)
    	rb.Read(buf)
    	fmt.Println(string(buf))
    }
    ```
    
    It is possible to use an existing buffer with by replacing `New` with `NewBuffer`.
    
    
    # Blocking vs Non-blocking
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  9. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/LookupInvoker.java

                    MessageBuilder buff = MessageUtils.builder();
                    buff.a("Message styles: ");
                    buff.trace("trace").a(' ');
                    buff.debug("debug").a(' ');
                    buff.info("info").a(' ');
                    buff.warning("warning").a(' ');
                    buff.error("error").a(' ');
                    buff.success("success").a(' ');
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 38K bytes
    - Viewed (0)
  10. internal/s3select/select.go

    			return err
    		}
    		if buf.Bytes()[buf.Len()-1] == '\n' {
    			buf.Truncate(buf.Len() - 1)
    		}
    		buf.WriteString(s3Select.Output.CSVArgs.RecordDelimiter)
    
    		return nil
    	case jsonFormat:
    		err := record.WriteJSON(buf)
    		if err != nil {
    			return err
    		}
    		// Trim trailing newline from non-simd output
    		if buf.Bytes()[buf.Len()-1] == '\n' {
    			buf.Truncate(buf.Len() - 1)
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 21.2K bytes
    - Viewed (0)
Back to top