Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 15 of 15 for blocked (0.24 sec)

  1. src/net/http/transport_test.go

    	req.Cancel = cancelReq
    
    	res, err := cst.c.Do(req)
    	if err != nil {
    		close(cancelHandler)
    		t.Fatalf("Get error: %v", err)
    	}
    
    	// Cancel the request while the handler is still blocked on sending to the
    	// inHandler channel. Then read it until it fails, to verify that the
    	// connection is broken before the handler itself closes it.
    	close(cancelReq)
    	got, err := io.ReadAll(res.Body)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Jun 06 21:59:21 UTC 2024
    - 192.6K bytes
    - Viewed (0)
  2. subprojects/diagnostics/src/integTest/groovy/org/gradle/api/tasks/diagnostics/DependencyInsightReportTaskIntegrationTest.groovy

            succeeds 'dependencyInsight', '--configuration', 'lockedConf', '--dependency', 'foo'
    
            then:
            outputContains """
    org:foo:1.0 FAILED
       Selection reasons:
          - By constraint: dependency was locked to version '1.0'
       Failures:
          - Could not resolve org:foo:{strictly 1.0}.
              - Cannot find a version of 'org:foo' that satisfies the version constraints:
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed May 08 15:15:56 UTC 2024
    - 102.3K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/cache/LocalCache.java

              readCount.set(0);
            } finally {
              unlock();
            }
          }
        }
    
        void runUnlockedCleanup() {
          // locked cleanup may generate notifications we can send unlocked
          if (!isHeldByCurrentThread()) {
            map.processPendingNotifications();
          }
        }
      }
    
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Sat May 18 03:24:34 UTC 2024
    - 143.6K bytes
    - Viewed (0)
  4. guava/src/com/google/common/cache/LocalCache.java

              readCount.set(0);
            } finally {
              unlock();
            }
          }
        }
    
        void runUnlockedCleanup() {
          // locked cleanup may generate notifications we can send unlocked
          if (!isHeldByCurrentThread()) {
            map.processPendingNotifications();
          }
        }
      }
    
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Sat May 18 03:24:34 UTC 2024
    - 149.2K bytes
    - Viewed (0)
  5. cmd/admin-handlers.go

    		if err != nil {
    			bugLogIf(ctx, err)
    			return nil
    		}
    		return out
    	}
    }
    
    func bytesToPublicKey(pub []byte) (*rsa.PublicKey, error) {
    	block, _ := pem.Decode(pub)
    	if block != nil {
    		pub = block.Bytes
    	}
    	key, err := x509.ParsePKCS1PublicKey(pub)
    	if err != nil {
    		return nil, err
    	}
    	return key, nil
    }
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 98K bytes
    - Viewed (0)
Back to top