Search Options

Results per page
Sort
Preferred Languages
Advance

Results 271 - 280 of 462 for slop (0.05 sec)

  1. okhttp/src/main/kotlin/okhttp3/ResponseBody.kt

     * Each response body is backed by a limited resource like a socket (live network responses) or
     * an open file (for cached responses). Failing to close the response body will leak resources and
     * may ultimately cause the application to slow down or crash.
     *
     * Both this class and [Response] implement [Closeable]. Closing a response simply
     * closes its response body. If you invoke [Call.execute] or implement [Callback.onResponse] you
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/collect/QueuesTest.java

        try {
          // if waiting works, this should get stuck
          Queues.drain(q, newArrayList(), 1, MAX_VALUE, NANOSECONDS);
          fail();
        } catch (InterruptedException expected) {
          // we indeed waited; a slow thread had enough time to interrupt us
        }
      }
    
      // same as above; uninterruptible version
      @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  3. docs/site-replication/run-multi-site-oidc.sh

    	exit_1
    fi
    
    sleep 10
    val=$(./mc tag list minio1/newbucket --json | jq -r .tagset | jq -r .key)
    if [ "${val}" != "val1" ]; then
    	echo "expected bucket tag to have replicated, exiting..."
    	exit_1
    fi
    # stop minio1 instance
    kill -9 ${site1_pid}
    # Update tag on minio2/newbucket when minio1 is down
    ./mc tag set minio2/newbucket "key=val2"
    # create a new bucket on minio2. This should replicate to minio1 after it comes online.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 08:03:58 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  4. callbacks/associations.go

    	}
    
    	return
    }
    
    func saveAssociations(db *gorm.DB, rel *schema.Relationship, rValues reflect.Value, selectColumns map[string]bool, restricted bool, defaultUpdatingColumns []string) error {
    	// stop save association loop
    	if checkAssociationsSaved(db, rValues) {
    		return nil
    	}
    
    	var (
    		selects, omits []string
    		onConflict     = onConflictOption(db.Statement, rel.FieldSchema, defaultUpdatingColumns)
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Tue Apr 11 03:06:13 UTC 2023
    - 14.3K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/CallTest.kt

        assertThat(server.takeRequest().sequenceNumber).isEqualTo(1)
      }
    
      @Tag("Slow")
      @Test
      fun successfulExpectContinuePermitsConnectionReuseWithHttp2() {
        enableProtocol(Protocol.HTTP_2)
        successfulExpectContinuePermitsConnectionReuse()
      }
    
      @Tag("Slow")
      @Test
      fun unsuccessfulExpectContinuePreventsConnectionReuse() {
        server.enqueue(MockResponse())
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 10 19:46:48 UTC 2024
    - 142.5K bytes
    - Viewed (0)
  6. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/storage/StorageClient.java

            }
    
            try {
                return getResponseData(uri, includeContent);
            } finally {
                if (accessTimeoutTarget != null) {
                    accessTimeoutTarget.stop();
                    if (!accessTimeoutTask.isCanceled()) {
                        accessTimeoutTask.cancel();
                    }
                }
            }
        }
    
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:47:32 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  7. internal/event/targetlist.go

    		list.eventsSkipped.Add(int64(len(list.queue)))
    		return
    	default:
    		list.eventsSkipped.Add(1)
    		err := fmt.Errorf("concurrent target notifications exceeded %d, configured notification target is too slow to accept events for the incoming request rate", maxConcurrentAsyncSend)
    		for id := range targetIDset {
    			reqInfo := &logger.ReqInfo{}
    			reqInfo.AppendTags("targetID", id.String())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  8. internal/logger/target/kafka/kafka.go

    		return
    	}
    	// Delete the event from store.
    	return h.store.Del(key)
    }
    
    // Cancel - cancels the target
    func (h *Target) Cancel() {
    	// If queuestore is configured, cancel it's context to
    	// stop the replay go-routine.
    	if h.store != nil {
    		h.storeCtxCancel()
    	}
    
    	// Set logch to nil and close it.
    	// This will block all Send operations,
    	// and finish the existing ones.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/collect/ContiguousSetTest.java

        assertTrue(enormous instanceof RegularContiguousSet);
        // We can't use reserializeAndAssert because it calls hashCode, which is enormously slow.
        ContiguousSet<Integer> enormousReserialized = reserialize(enormous);
        assertEquals(enormous, enormousReserialized);
      }
    
      private static final DiscreteDomain<Integer> UNBOUNDED_THROWING_DOMAIN =
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Oct 15 17:36:06 UTC 2024
    - 19K bytes
    - Viewed (0)
  10. src/main/resources/fess_message.properties

    errors.document_not_found=Not found URL of Doc ID:{0}
    errors.not_load_from_server=Could not load from this server: {0}
    errors.failed_to_start_job=Failed to start job {0}.
    errors.failed_to_stop_job=Failed to stop job {0}.
    errors.failed_to_download_synonym_file=Failed to download the Synonym file.
    errors.failed_to_upload_synonym_file=Failed to upload the Synonym file.
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sat Mar 18 03:05:44 UTC 2023
    - 12.5K bytes
    - Viewed (0)
Back to top