Search Options

Results per page
Sort
Preferred Languages
Advance

Results 151 - 160 of 873 for Breaks (0.06 sec)

  1. internal/ioutil/hardlimitreader.go

    	"io"
    )
    
    // ErrOverread is returned to the reader when the hard limit of HardLimitReader is exceeded.
    var ErrOverread = errors.New("input provided more bytes than specified")
    
    // HardLimitReader returns a Reader that reads from r
    // but returns an error if the source provides more data than allowed.
    // This means the source *will* be overread unless EOF is returned prior.
    // The underlying implementation is a *HardLimitedReader.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat May 06 02:53:12 UTC 2023
    - 2K bytes
    - Viewed (0)
  2. internal/s3select/csv/recordtransform.go

    		for idx := 0; idx < len(p); {
    			i := bytes.Index(p[idx:], rr.recordDelimiter)
    			if i < 0 {
    				break
    			}
    			idx += i
    			p[idx] = '\n'
    		}
    		return n, nil
    	}
    
    	// 2 characters...
    	for idx := 0; idx < len(p); {
    		i := bytes.Index(p[idx:], rr.recordDelimiter)
    		if i < 0 {
    			break
    		}
    		idx += i
    
    		p[idx] = '\n'
    		p = append(p[:idx+1], p[idx+2:]...)
    		n--
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 2.1K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/api/json/SearchApiManager.java

                break;
            case LABEL:
                processLabelRequest(request, response, chain);
                break;
            case POPULARWORD:
                processPopularWordRequest(request, response, chain);
                break;
            case FAVORITE:
                processFavoriteRequest(request, response, chain);
                break;
            case FAVORITES:
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sat Oct 12 01:54:46 UTC 2024
    - 50.3K bytes
    - Viewed (0)
  4. src/main/java/jcifs/smb1/smb1/NtlmContext.java

                ri += 4;
                if (id == 0 || (ri + len) > type2token.length) {
                    break;
                } else if (id == id0) {
                    try {
                        return new String(type2token, ri, len, SmbConstants.UNI_ENCODING);
                    } catch (java.io.UnsupportedEncodingException uee) {
                        break;
                    }
                }
                ri += len;
            }
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 5.9K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/util/concurrent/AtomicDoubleArrayTest.java

        assertEquals(Arrays.toString(VALUES), aa.toString());
        assertEquals("[]", new AtomicDoubleArray(0).toString());
        assertEquals("[]", new AtomicDoubleArray(new double[0]).toString());
      }
    
      /** compareAndSet treats +0.0 and -0.0 as distinct values */
      public void testDistinctZeros() {
        AtomicDoubleArray aa = new AtomicDoubleArray(SIZE);
        for (int i : new int[] {0, SIZE - 1}) {
          assertFalse(aa.compareAndSet(i, -0.0, 7.0));
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 14.6K bytes
    - Viewed (0)
  6. src/main/java/jcifs/smb/SmbTransportImpl.java

                checkReferral(resp, path, ( (RequestWithPath) req ));
                // checkReferral always throws and exception but put break here for clarity
                break;
            case NtStatus.NT_STATUS_BUFFER_OVERFLOW:
                if ( resp instanceof Smb2ReadResponse ) {
                    break;
                }
                if ( resp instanceof Smb2IoctlResponse ) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Wed Jan 18 23:47:00 UTC 2023
    - 67K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb1/netbios/SocketInputStream.java

                    case SessionServicePacket.SESSION_KEEP_ALIVE:
                        break;
                    case SessionServicePacket.SESSION_MESSAGE:
                        bip = SessionServicePacket.readLength( header, 0 );
                        break;
                    case -1:
                        if( tot > 0 ) {
                            return tot;
                        }
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 20:39:42 UTC 2019
    - 3.3K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/AbstractService.java

            listeners.enqueue(TERMINATED_FROM_NEW_EVENT);
            break;
          case STARTING:
            listeners.enqueue(TERMINATED_FROM_STARTING_EVENT);
            break;
          case RUNNING:
            listeners.enqueue(TERMINATED_FROM_RUNNING_EVENT);
            break;
          case STOPPING:
            listeners.enqueue(TERMINATED_FROM_STOPPING_EVENT);
            break;
          case TERMINATED:
          case FAILED:
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 20.4K bytes
    - Viewed (0)
  9. internal/s3select/select.go

    OuterLoop:
    	for {
    		if s3Select.statement.LimitReached() {
    			if !sendRecord() {
    				break
    			}
    			if err = writer.Finish(s3Select.getProgress()); err != nil {
    				// FIXME: log this error.
    				err = nil
    			}
    			break
    		}
    
    		if rec, err = s3Select.recordReader.Read(rec); err != nil {
    			if err != io.EOF {
    				break
    			}
    
    			if s3Select.statement.IsAggregated() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 21.2K bytes
    - Viewed (0)
  10. src/main/java/jcifs/internal/smb1/trans2/Trans2QueryFSInformationResponse.java

                inf = new SmbInfoAllocation();
                break;
            case FileSystemInformation.FS_SIZE_INFO:
                inf = new FileFsSizeInformation();
                break;
            case FileSystemInformation.FS_FULL_SIZE_INFO:
                inf = new FileFsFullSizeInformation();
                break;
            default:
                return null;
            }
            return inf;
        }
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 4.2K bytes
    - Viewed (0)
Back to top