Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for MakeCall (0.12 sec)

  1. tensorflow/compiler/jit/resource_operation_safety_analysis_test.cc

          /*attr_def*/
          {}, /*node_def=*/{FunctionDefHelper::Const("one", 1.0f)},
          /*ret_def=*/{{"out", "out:output:0"}});
      *flib_def.add_function() = std::move(func);
      return flib_def;
    }
    
    Node* MakeCall(Graph* graph, const string& callee_name, const string& node_name,
                   Status* status) {
      NodeDef call_node;
      call_node.set_name(node_name);
      call_node.set_op(callee_name);
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Tue Apr 28 16:53:59 UTC 2020
    - 18.7K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerTest.kt

        assertThat(log).containsExactly()
    
        taskFaker.advanceUntil(100.µs)
        assertThat(log).containsExactly("run@100000")
    
        taskFaker.assertNoMoreTasks()
    
        assertThat(testLogHandler.takeAll()).containsExactly(
          "FINE: Q10000 scheduled after 100 µs: task",
          "FINE: Q10000 starting              : task",
          "FINE: Q10000 finished run in   0 µs: task",
        )
      }
    
      @Test fun executeRepeated() {
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Apr 29 00:33:04 UTC 2024
    - 23K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/TestLogHandler.kt

          override fun evaluate() {
            beforeEach(null)
            try {
              base.evaluate()
            } finally {
              afterEach(null)
            }
          }
        }
      }
    
      fun takeAll(): List<String> {
        val list = mutableListOf<String>()
        logs.drainTo(list)
        return list
      }
    
      fun take(): String {
        return logs.poll(10, TimeUnit.SECONDS)
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt

              .build(),
          )
        val response = call.execute()
        assertThat(response.body.string()).isEqualTo("ABC")
        assertThat(response.protocol).isEqualTo(protocol)
        val logs = testLogHandler.takeAll()
        assertThat(firstFrame(logs, "HEADERS")!!, "header logged")
          .contains("HEADERS       END_STREAM|END_HEADERS")
      }
    
      @ParameterizedTest
      @ArgumentsSource(ProtocolParamProvider::class)
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Thu Apr 11 22:09:35 UTC 2024
    - 75.3K bytes
    - Viewed (0)
  5. src/runtime/mgcwork.go

    	}
    	// Since all workbufs are on the empty list, we don't care
    	// which ones are in which spans. We can wipe the entire empty
    	// list and move all workbuf spans to the free list.
    	work.empty = 0
    	work.wbufSpans.free.takeAll(&work.wbufSpans.busy)
    	unlock(&work.wbufSpans.lock)
    }
    
    // freeSomeWbufs frees some workbufs back to the heap and returns
    // true if it should be called again to free more.
    func freeSomeWbufs(preemptible bool) bool {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  6. src/runtime/mheap.go

    	} else {
    		// The list contains no spans, so this is also the first span.
    		list.first = span
    	}
    	list.last = span
    	span.list = list
    }
    
    // takeAll removes all spans from other and inserts them at the front
    // of list.
    func (list *mSpanList) takeAll(other *mSpanList) {
    	if other.isEmpty() {
    		return
    	}
    
    	// Reparent everything in other to list.
    	for s := other.first; s != nil; s = s.next {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 22:31:00 UTC 2024
    - 78K bytes
    - Viewed (0)
Back to top