chad - Code Search

fess-crawler/src/main/java/org/codelibs/fess/crawler/util/XmlUtil.java

    public static String stripInvalidXMLCharacters(final String in) {
        if (StringUtil.isEmpty(in)) {
            return in;
        }

        final StringBuilder buf = new StringBuilder(in.length());
        char c;
        for (int i = 0; i < in.length(); i++) {
            c = in.charAt(i);
            if (c == 0x9 || c == 0xA || c == 0xD || c >= 0x20 && c <= 0xD7FF || c >= 0xE000 && c <= 0xFFFD

Registered: Sun Nov 10 03:50:12 UTC 2024

- Last Modified: Thu Feb 22 01:36:27 UTC 2024

- 6.1K bytes

- Viewed (0)

github.com/tensorflow/tensorflow

tensorflow/c/eager/parallel_device/parallel_device.cc

// ParallelDevice.
void DeleteParallelDevice(void* device_info) {
  delete reinterpret_cast<NamedParallelDevice*>(device_info);
}

}  // namespace

void AllocateParallelDevice(const char* device_name,
                            const char* const* underlying_devices,
                            int num_underlying_devices,
                            TFE_CustomDevice* device, void** device_info) {

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

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

- 18.3K bytes

- Viewed (0)

github.com/minio/minio

cmd/erasure.go

// Updates are sent on a regular basis and the caller *must* consume them.
func (er erasureObjects) nsScanner(ctx context.Context, buckets []BucketInfo, wantCycle uint32, updates chan<- dataUsageCache, healScanMode madmin.HealScanMode) error {
	if len(buckets) == 0 {
		return nil
	}

	// Collect disks we can use.
	disks, healing := er.getOnlineDisksWithHealing(false)
	if len(disks) == 0 {

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

- Last Modified: Fri Oct 04 22:23:33 UTC 2024

- 16.1K bytes

- Viewed (0)

github.com/minio/minio

cmd/storage-rest-server.go

	if !s.checkID(params.DiskID) {
		return grid.NewRemoteErr(errDiskNotFound)
	}
	if params.Cache == nil {
		return grid.NewRemoteErrString("NSScannerHandler: provided cache is nil")
	}

	// Collect updates, stream them before the full cache is sent.
	updates := make(chan dataUsageEntry, 1)
	var wg sync.WaitGroup
	wg.Add(1)

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

- Last Modified: Wed Aug 14 17:11:51 UTC 2024

- 45.7K bytes

- Viewed (0)

github.com/google/guava

android/guava/src/com/google/common/xml/XmlEscapers.java

 * @author David Beaumont
 * @since 15.0
 */
@GwtCompatible
@ElementTypesAreNonnullByDefault
public class XmlEscapers {
  private XmlEscapers() {}

  private static final char MIN_ASCII_CONTROL_CHAR = 0x00;
  private static final char MAX_ASCII_CONTROL_CHAR = 0x1F;

  // For each xxxEscaper() method, please add links to external reference pages
  // that are considered authoritative for the behavior of that escaper.

  /**

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

- Last Modified: Tue Jan 18 20:55:09 UTC 2022

- 6.5K bytes

- Viewed (0)

github.com/tensorflow/tensorflow

tensorflow/c/c_api_function_test.cc

            expect_failure);
  }

  // Caller must delete[] the returned value
  static const char** ToArray(const std::vector<string>& strs) {
    const char** ptr = nullptr;
    if (!strs.empty()) {
      ptr = new const char*[strs.size()];
      for (size_t i = 0; i < strs.size(); ++i) {
        ptr[i] = strs[i].c_str();
      }
    }
    return ptr;
  }

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

- Last Modified: Thu Jul 20 22:08:54 UTC 2023

- 63.6K bytes

- Viewed (0)

github.com/tensorflow/tensorflow

tensorflow/c/eager/c_api_distributed_test.cc

  TFE_ContextSetServerDef(ctx, 0, serialized.data(), serialized.size(), status);
  EXPECT_EQ(TF_GetCode(status), TF_OK) << TF_Message(status);

  const char task0_name[] = "/job:localhost/replica:0/task:0/device:CPU:0";
  const char task1_name[] = "/job:localhost/replica:0/task:1/device:CPU:0";
  const char task2_name[] = "/job:localhost/replica:0/task:2/device:CPU:0";

  // Create one variable per task.

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

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

- 23.4K bytes

- Viewed (0)

github.com/tiangolo/fastapi

docs_src/websockets/tutorial002.py

    WebSocketException,
    status,
)
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)">
            <label>Item ID: <input type="text" id="itemId" autocomplete="off" value="foo"/></label>

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

- Last Modified: Sun Nov 13 16:10:54 UTC 2022

- 2.8K bytes

- Viewed (0)

github.com/google/guava

guava-tests/test/com/google/common/io/CharSourceTest.java

    BufferedReader reader = source.openBufferedStream();
    assertTrue(source.wasStreamOpened());
    assertFalse(source.wasStreamClosed());

    StringWriter writer = new StringWriter();
    char[] buf = new char[64];
    int read;
    while ((read = reader.read(buf)) != -1) {
      writer.write(buf, 0, read);
    }
    reader.close();
    writer.close();

    assertTrue(source.wasStreamClosed());

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

- Last Modified: Tue May 07 15:26:58 UTC 2024

- 11.4K bytes

- Viewed (0)

github.com/tensorflow/tensorflow

tensorflow/c/c_api_experimental_test.cc

  TF_DeletePluggableDeviceLibraryHandle(lib);
#endif  // !defined(TENSORFLOW_NO_SHARED_OBJECTS)
#endif  // !defined(PLATFORM_WINDOWS)
}

void DefineFunction(const char* name, TF_Function** func,
                    const char* description = nullptr,
                    bool append_hash = false) {
  std::unique_ptr<TF_Graph, decltype(&TF_DeleteGraph)> func_graph(
      TF_NewGraph(), TF_DeleteGraph);

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

- Last Modified: Tue Jan 17 22:27:52 UTC 2023

- 13.1K bytes

- Viewed (0)

Search Options