chan - Code Search

okhttp/src/main/kotlin/okhttp3/internal/http/RetryAndFollowUpInterceptor.kt

 */
class RetryAndFollowUpInterceptor(private val client: OkHttpClient) : Interceptor {
  @Throws(IOException::class)
  override fun intercept(chain: Interceptor.Chain): Response {
    val realChain = chain as RealInterceptorChain
    var request = chain.request
    val call = realChain.call
    var followUpCount = 0
    var priorResponse: Response? = null
    var newRoutePlanner = true

Registered: Fri Nov 01 11:42:11 UTC 2024

- Last Modified: Mon Apr 15 13:24:48 UTC 2024

- 12.1K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb1/smb1/SmbRandomAccessFile.java

            throw new SmbException( "EOF" );
        }
        return Encdec.dec_uint16be( tmp, 0 ) & 0xFFFF;
    }
    public final char readChar() throws SmbException {
        if((read( tmp, 0, 2 )) < 0 ) {
            throw new SmbException( "EOF" );
        }
        return (char)Encdec.dec_uint16be( tmp, 0 );
    }
    public final int readInt() throws SmbException {
        if((read( tmp, 0, 4 )) < 0 ) {

Registered: Sun Nov 03 00:10:13 UTC 2024

- Last Modified: Fri Mar 22 21:10:40 UTC 2019

- 10.9K bytes

- Viewed (0)

github.com/tensorflow/tensorflow

tensorflow/c/eager/custom_device_testutil.h

#include "tensorflow/c/eager/c_api_experimental.h"
#include "tensorflow/c/tf_status.h"

void RegisterLoggingDevice(TFE_Context* context, const char* name,
                           bool strict_scope_placement, bool* arrived_flag,
                           bool* executed_flag, TF_Status* status);
void AllocateLoggingDevice(const char* name, bool* arrived_flag,
                           bool* executed_flag, TFE_CustomDevice** device,

Registered: Tue Nov 05 12:39:12 UTC 2024

- Last Modified: Thu Aug 27 23:39:24 UTC 2020

- 1.6K bytes

- Viewed (0)

github.com/tiangolo/fastapi

docs_src/websockets/tutorial001.py

from fastapi import FastAPI, WebSocket
from fastapi.responses import HTMLResponse

app = FastAPI()

html = """
<!DOCTYPE html>
<html>
    <head>
        <title>Chat</title>
    </head>
    <body>
        <h1>WebSocket Chat</h1>
        <form action="" onsubmit="sendMessage(event)">
            <input type="text" id="messageText" autocomplete="off"/>
            <button>Send</button>
        </form>
        <ul id='messages'>

Registered: Sun Nov 03 07:19:11 UTC 2024

- Last Modified: Thu Mar 26 19:09:53 UTC 2020

- 1.4K bytes

- Viewed (0)

github.com/apache/maven

compat/maven-embedder/src/main/java/org/fusesource/jansi/Ansi.java

        return this;
    }

    public Ansi a(char value) {
        flushAttributes();
        builder.append(value);
        return this;
    }

    public Ansi a(char[] value, int offset, int len) {
        flushAttributes();
        builder.append(value, offset, len);
        return this;
    }

    public Ansi a(char[] value) {
        flushAttributes();
        builder.append(value);

Registered: Sun Nov 03 03:35:11 UTC 2024

- Last Modified: Fri Oct 25 12:31:46 UTC 2024

- 23.1K bytes

- Viewed (0)

github.com/tensorflow/tensorflow

tensorflow/c/eager/c_api_experimental_reader.cc

template <typename... LabelType>
int64_t TFE_MonitoringCounterReader::Read(const LabelType&... labels) {
  return counter->Read(labels...);
}

TFE_MonitoringCounterReader* TFE_MonitoringNewCounterReader(const char* name) {
  auto* result = new TFE_MonitoringCounterReader(name);

  return result;
}

int64_t TFE_MonitoringReadCounter0(TFE_MonitoringCounterReader* cell_reader) {
  int64_t result = cell_reader->Read();

Registered: Tue Nov 05 12:39:12 UTC 2024

- Last Modified: Thu Apr 20 03:14:47 UTC 2023

- 1.4K bytes

- Viewed (0)

github.com/google/guava

android/guava/src/com/google/common/base/Verify.java

   *
   * <p>See {@link #verify(boolean, String, Object...)} for details.
   *
   * @since 23.1 (varargs overload since 17.0)
   */
  public static void verify(boolean expression, String errorMessageTemplate, char p1, char p2) {
    if (!expression) {
      throw new VerifyException(lenientFormat(errorMessageTemplate, p1, p2));
    }
  }

  /**

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Mon May 17 14:07:47 UTC 2021

- 18.5K bytes

- Viewed (0)

github.com/tensorflow/tensorflow

tensorflow/c/eager/c_api_unified_experimental.cc

  for (const auto& factory : GetFactories())
    factories_sorted.insert(factory.first);
  const char* comma = "";
  for (const string& factory : factories_sorted) {
    msg += comma + factory;
    comma = ", ";
  }
  msg += ")";

  return errors::InvalidArgument(msg.c_str());
}

static TracingContext* CreateTracingExecutionContext(const char* fn_name,
                                                     TF_Status* s) {

Registered: Tue Nov 05 12:39:12 UTC 2024

- Last Modified: Sat Oct 12 05:11:17 UTC 2024

- 9K bytes

- Viewed (0)

github.com/gradle/gradle

build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/docbook/JavadocScanner.java

    public void mark() {
        markPos = pos;
    }

    public void next() {
        next(1);
    }

    public void next(int n) {
        pos += n;
    }

    public boolean lookingAt(char c) {
        return input.charAt(pos) == c;
    }

    public boolean lookingAt(CharSequence prefix) {
        int i = 0;
        int cpos = pos;
        while (i < prefix.length() && cpos < input.length()) {

Registered: Wed Nov 06 11:36:14 UTC 2024

- Last Modified: Wed Dec 09 08:14:05 UTC 2020

- 4.3K bytes

- Viewed (0)

github.com/tensorflow/tensorflow

tensorflow/c/eager/parallel_device/parallel_device_lib.cc

  // the operation, its `StartCancel` method will be called if op execution
  // fails on any device in order to cancel the others.
  void StartExecute(TFE_Context* context, const char* operation_name,
                    std::vector<TFE_TensorHandle*> inputs,
                    const TFE_OpAttrs* attributes, int expected_max_outputs,
                    CancellationManager& cancellation_manager,

Registered: Tue Nov 05 12:39:12 UTC 2024

- Last Modified: Mon Oct 21 04:14:14 UTC 2024

- 25.9K bytes

- Viewed (0)

Search Options