Search Options

Results per page
Sort
Preferred Languages
Advance

Results 181 - 190 of 873 for Breaks (0.05 sec)

  1. cmd/mrf.go

    				return
    			}
    			if n != len(data) {
    				w.CloseWithError(io.ErrShortWrite)
    				return
    			}
    			for item := range m.opCh {
    				err = item.EncodeMsg(mw)
    				if err != nil {
    					break
    				}
    			}
    			mw.Flush()
    			w.CloseWithError(err)
    		}()
    		return r
    	}
    
    	globalLocalDrivesMu.RLock()
    	localDrives := cloneDrives(globalLocalDrivesMap)
    	globalLocalDrivesMu.RUnlock()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:26:05 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  2. src/main/java/jcifs/internal/smb2/Smb2SigningDigest.java

                signingKey = sessionKey;
                break;
            case Smb2Constants.SMB2_DIALECT_0300:
            case Smb2Constants.SMB2_DIALECT_0302:
                signingKey = Smb3KeyDerivation.deriveSigningKey(dialect, sessionKey, new byte[0] /* unimplemented */);
                m = Mac.getInstance("AESCMAC", Crypto.getProvider());
                break;
            case Smb2Constants.SMB2_DIALECT_0311:
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Tue Aug 17 17:34:29 UTC 2021
    - 4.9K bytes
    - Viewed (0)
  3. src/test/java/jcifs/tests/OplockTests.java

                    try {
                        tree.send(create2);
                    }
                    catch ( Exception e ) {
                        // timeout is expected for now as we do not ack the break
                        if ( ! ( e.getCause() instanceof RequestTimeoutException ) ) {
                            throw e;
                        }
                    }
                }
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Thu Jan 05 13:09:03 UTC 2023
    - 6.1K bytes
    - Viewed (0)
  4. clause/where.go

    	for idx, expr := range where.Exprs {
    		if v, ok := expr.(OrConditions); !ok || len(v.Exprs) > 1 {
    			if idx != 0 {
    				where.Exprs[0], where.Exprs[idx] = where.Exprs[idx], where.Exprs[0]
    			}
    			break
    		}
    	}
    
    	buildExprs(where.Exprs, builder, AndWithSpace)
    }
    
    func buildExprs(exprs []Expression, builder Builder, joinCond string) {
    	wrapInParentheses := false
    
    	for idx, expr := range exprs {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Apr 25 12:22:53 UTC 2024
    - 5.1K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/-HostnamesCommon.kt

        val labelLength =
          when (dot) {
            -1 -> length - labelStart
            else -> dot - labelStart
          }
        if (labelLength !in 1..63) return true
        if (dot == -1) break
        if (dot == length - 1) break // Trailing '.' is allowed.
        labelStart = dot + 1
      }
    
      return false
    }
    
    internal fun String.containsInvalidHostnameAsciiCodes(): Boolean {
      for (i in 0 until length) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 11.2K bytes
    - Viewed (0)
  6. internal/s3select/simdj/reader_amd64_test.go

    					t.Fatal(err)
    				}
    				switch typ {
    				case simdjson.TypeNone:
    					close(dst)
    					break parser
    				case simdjson.TypeRoot:
    					typ, obj, err := next.Root(nil)
    					if err != nil {
    						t.Fatal(err)
    					}
    					if typ != simdjson.TypeObject {
    						if typ == simdjson.TypeNone {
    							close(dst)
    							break parser
    						}
    						t.Fatal("Unexpected type:", typ.String())
    					}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 3.9K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java

            case VALID_INPUT_DATA:
              outputFuture.set(RESULT_DATA);
              break;
            case SLOW_OUTPUT_VALID_INPUT_DATA:
              break; // do nothing to the result
            case SLOW_FUNC_VALID_INPUT_DATA:
              funcIsWaitingLatch.countDown();
              awaitUninterruptibly(funcCompletionLatch);
              break;
            case EXCEPTION_DATA:
              throw EXCEPTION;
          }
          return outputFuture;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java

            case VALID_INPUT_DATA:
              outputFuture.set(RESULT_DATA);
              break;
            case SLOW_OUTPUT_VALID_INPUT_DATA:
              break; // do nothing to the result
            case SLOW_FUNC_VALID_INPUT_DATA:
              funcIsWaitingLatch.countDown();
              awaitUninterruptibly(funcCompletionLatch);
              break;
            case EXCEPTION_DATA:
              throw EXCEPTION;
          }
          return outputFuture;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  9. src/cmd/addr2line/main.go

    // license that can be found in the LICENSE file.
    
    // Addr2line is a minimal simulation of the GNU addr2line tool,
    // just enough to support pprof.
    //
    // Usage:
    //
    //	go tool addr2line binary
    //
    // Addr2line reads hexadecimal addresses, one per line and with optional 0x prefix,
    // from standard input. For each input address, addr2line prints two output lines,
    // first the name of the function containing the address and second the file:line
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Jun 21 19:58:04 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  10. src/main/java/jcifs/internal/smb2/info/Smb2QueryDirectoryResponse.java

                if ( cur == null ) {
                    break;
                }
                cur.decode(buffer, bufferIndex, bufferLength);
                infos.add(cur);
                int nextEntryOffset = cur.getNextEntryOffset();
                if ( nextEntryOffset > 0 ) {
                    bufferIndex += nextEntryOffset;
                }
                else {
                    break;
                }
            }
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 3.6K bytes
    - Viewed (0)
Back to top