ToOutput - Code Search

src/main/java/jcifs/internal/smb2/io/Smb2ReadRequest.java

     * @param fileId
     *            the file ID to read from
     * @param outputBuffer
     *            the buffer to read data into
     * @param outputBufferOffset
     *            the offset in the output buffer to start writing data
     */
    public Smb2ReadRequest(final Configuration config, final byte[] fileId, final byte[] outputBuffer, final int outputBufferOffset) {
        super(config, SMB2_READ);

Registered: Sun Sep 07 00:10:21 UTC 2025

- Last Modified: Sat Aug 23 05:11:12 UTC 2025

- 7.8K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Stream.kt

    }
  }

  /**
   * Returns true if this stream is open. A stream is open until either:
   *
   *  * A `SYN_RESET` frame abnormally terminates the stream.
   *  * Both input and output streams have transmitted all data and headers.
   *
   * Note that the input stream may continue to yield data even after a stream reports itself as
   * not open. This is because input data is buffered.
   */

Registered: Fri Sep 05 11:42:10 UTC 2025

- Last Modified: Mon Jul 07 18:57:05 UTC 2025

- 22.4K bytes

- Viewed (0)

github.com/tensorflow/tensorflow

ci/official/utilities/generate_index_html.sh

# ==============================================================================

# Generates a handy index.html with a bunch of Kokoro links for GitHub
# presubmits.
# Usage: generate_index_html.sh /path/to/output/index.html

cat > "$1" <<EOF
<html>
<head>
<title>$(basename "$KOKORO_JOB_NAME")</title>
</head>
<body>
<h1>TensorFlow Job Logs and Links</h1>
<h2>Job Details</h2>
<ul>

Registered: Tue Sep 09 12:39:10 UTC 2025

- Last Modified: Fri Sep 29 20:26:13 UTC 2023

- 2.3K bytes

- Viewed (0)

github.com/minio/minio

cmd/metacache-server-pool.go

					rpc.UpdateMetacacheListing(ctx, *c)
				}
			}
		}()
		o.ID = ""
	}

	if contextCanceled(ctx) {
		return entries, ctx.Err()
	}
	// Do listing in-place.
	// Create output for our results.
	// Create filter for results.
	o.debugln("Raw List", o)
	filterCh := make(chan metaCacheEntry, o.Limit)
	listCtx, cancelList := context.WithCancel(ctx)

Registered: Sun Sep 07 19:28:11 UTC 2025

- Last Modified: Mon May 26 07:06:43 UTC 2025

- 12.9K bytes

- Viewed (0)

github.com/google/guava

guava/pom.xml

              <!--
                JPMS needs access to the module sources to complete a modular Java build. We also need to override the
                base compile settings (in the root `pom.xml`) to enable MRJAR output.
              -->
              <compilerArgs combine.self="override">
                <arg>-sourcepath</arg>
                <arg>${project.basedir}/src</arg>

Registered: Fri Sep 05 12:43:10 UTC 2025

- Last Modified: Fri Jun 06 21:05:32 UTC 2025

- 9.4K bytes

- Viewed (0)

github.com/tensorflow/tensorflow

ci/official/utilities/setup.sh

fi

# Create and expand to the full path of TFCI_OUTPUT_DIR
export TFCI_OUTPUT_DIR=$(realpath "$TFCI_OUTPUT_DIR")
mkdir -p "$TFCI_OUTPUT_DIR"

# In addition to dumping all script output to the terminal, place it into
# $TFCI_OUTPUT_DIR/script.log
exec > >(tee "$TFCI_OUTPUT_DIR/script.log") 2>&1

# Setup tfrun, a helper function for executing steps that can either be run

Registered: Tue Sep 09 12:39:10 UTC 2025

- Last Modified: Thu Jan 09 18:37:25 UTC 2025

- 6.2K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/idn/Punycode.kt

      result.writeUtf8(string, pos, limit)
      return true
    }

    result.write(PREFIX)

    val input = string.codePoints(pos, limit)

    // Copy all the basic code points to the output.
    var b = 0
    for (codePoint in input) {
      if (codePoint < INITIAL_N) {
        result.writeByte(codePoint)
        b++
      }
    }

    // Copy a delimiter if any basic code points were emitted.

Registered: Fri Sep 05 11:42:10 UTC 2025

- Last Modified: Fri Dec 27 13:39:56 UTC 2024

- 8.5K bytes

- Viewed (0)

github.com/minio/minio

cmd/xl-storage-errors.go

	return errors.Is(err, syscall.ENOSPC)
}

// Invalid argument, unsupported flags such as O_DIRECT
func isSysErrInvalidArg(err error) bool {
	return errors.Is(err, syscall.EINVAL)
}

// Input/output error
func isSysErrIO(err error) bool {
	return errors.Is(err, syscall.EIO)
}

// Check if the given error corresponds to EISDIR (is a directory).
func isSysErrIsDir(err error) bool {

Registered: Sun Sep 07 19:28:11 UTC 2025

- Last Modified: Mon Mar 06 16:56:29 UTC 2023

- 3.8K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache/DiskLruCache.kt

          null
        }
      }
    }

    /**
     * Returns a new unbuffered output stream to write the value at [index]. If the underlying
     * output stream encounters errors when writing to the filesystem, this edit will be aborted
     * when [commit] is called. The returned output stream does not throw IOExceptions.
     */
    fun newSink(index: Int): Sink {
      synchronized(this@DiskLruCache) {

Registered: Fri Sep 05 11:42:10 UTC 2025

- Last Modified: Wed May 28 23:28:25 UTC 2025

- 34.7K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/util/ThreadDumpUtil.java

        }
    }

    /**
     * Processes all thread information and sends it to the provided consumer.
     *
     * @param writer the consumer that will handle each line of thread dump output
     */
    public static void processThreadDump(final Consumer<String> writer) {
        for (final Map.Entry<Thread, StackTraceElement[]> entry : Thread.getAllStackTraces().entrySet()) {

Registered: Thu Sep 04 12:52:25 UTC 2025

- Last Modified: Thu Jul 17 08:28:31 UTC 2025

- 3.3K bytes

- Viewed (0)

Search Options