Home
last modified time | relevance | path

Searched refs:stream_name (Results 1 – 21 of 21) sorted by relevance

/external/tensorflow/tensorflow/contrib/kinesis/python/kernel_tests/
Dkinesis_test.py46 stream_name = "tf_kinesis_test_1"
47 client.create_stream(StreamName=stream_name, ShardCount=1)
49 client.get_waiter('stream_exists').wait(StreamName=stream_name)
53 StreamName=stream_name, Data=data, PartitionKey="TensorFlow" + str(i))
71 sess.run(init_op, feed_dict={stream: stream_name, num_epochs: 1})
77 client.delete_stream(StreamName=stream_name)
79 client.get_waiter('stream_not_exists').wait(StreamName=stream_name)
85 stream_name = "tf_kinesis_test_2"
86 client.create_stream(StreamName=stream_name, ShardCount=2)
88 client.get_waiter('stream_exists').wait(StreamName=stream_name)
[all …]
/external/google-breakpad/src/common/windows/
Ddia_util.cc48 CComBSTR stream_name; in FindDebugStream() local
49 if (FAILED(temp_debug_stream->get_name(&stream_name))) { in FindDebugStream()
55 if (wcsncmp((LPWSTR)stream_name, name, stream_name.Length()) == 0) { in FindDebugStream()
/external/google-breakpad/src/processor/
Dminidump_dump.cc57 const char *stream_name, in DumpRawStream() argument
64 printf("Stream %s:\n", stream_name); in DumpRawStream()
/external/autotest/client/common_lib/
Dlogging_manager.py311 def _sys_stream_setter(self, stream_name): argument
312 assert stream_name in ('stdout', 'stderr'), stream_name
314 setattr(sys, stream_name, file_object)
/external/webrtc/webrtc/sound/
Dpulseaudiosoundsystem.h132 const char *stream_name,
Dpulseaudiosoundsystem.cc1360 const char *stream_name, in OpenDevice() argument
1404 pa_stream *stream = symbol_table_.pa_stream_new()(context_, stream_name, in OpenDevice()
/external/llvm/utils/unittest/googletest/src/
Dgtest-port.cc596 void CaptureStream(int fd, const char* stream_name, CapturedStream** stream) { in CaptureStream() argument
598 GTEST_LOG_(FATAL) << "Only one " << stream_name in CaptureStream()
/external/swiftshader/third_party/LLVM/utils/unittest/googletest/
Dgtest-port.cc592 void CaptureStream(int fd, const char* stream_name, CapturedStream** stream) { in CaptureStream() argument
594 GTEST_LOG_(FATAL) << "Only one " << stream_name in CaptureStream()
/external/google-breakpad/src/testing/gtest/src/
Dgtest-port.cc621 void CaptureStream(int fd, const char* stream_name, CapturedStream** stream) { in CaptureStream() argument
623 GTEST_LOG_(FATAL) << "Only one " << stream_name in CaptureStream()
/external/python/cpython2/Lib/test/support/
D__init__.py1211 def captured_output(stream_name): argument
1215 orig_stdout = getattr(sys, stream_name)
1216 setattr(sys, stream_name, StringIO.StringIO())
1218 yield getattr(sys, stream_name)
1220 setattr(sys, stream_name, orig_stdout)
/external/python/cpython3/Lib/test/support/
D__init__.py1491 def captured_output(stream_name): argument
1495 orig_stdout = getattr(sys, stream_name)
1496 setattr(sys, stream_name, io.StringIO())
1498 yield getattr(sys, stream_name)
1500 setattr(sys, stream_name, orig_stdout)
/external/mesa3d/src/gtest/src/
Dgtest-port.cc1018 void CaptureStream(int fd, const char* stream_name, CapturedStream** stream) { in CaptureStream() argument
1020 GTEST_LOG_(FATAL) << "Only one " << stream_name in CaptureStream()
/external/libvpx/libvpx/third_party/googletest/src/src/
Dgtest-port.cc1076 static void CaptureStream(int fd, const char* stream_name, in CaptureStream() argument
1079 GTEST_LOG_(FATAL) << "Only one " << stream_name in CaptureStream()
/external/swiftshader/third_party/llvm-7.0/llvm/utils/unittest/googletest/src/
Dgtest-port.cc1018 void CaptureStream(int fd, const char* stream_name, CapturedStream** stream) { in CaptureStream() argument
1020 GTEST_LOG_(FATAL) << "Only one " << stream_name in CaptureStream()
/external/libaom/libaom/third_party/googletest/src/googletest/src/
Dgtest-port.cc1018 void CaptureStream(int fd, const char* stream_name, CapturedStream** stream) { in CaptureStream() argument
1020 GTEST_LOG_(FATAL) << "Only one " << stream_name in CaptureStream()
/external/kernel-headers/original/uapi/sound/
Dasoc.h543 char stream_name[SNDRV_CTL_ELEM_ID_NAME_MAXLEN]; /* stream name - used to match */ member
/external/googletest/googletest/src/
Dgtest-port.cc1141 static void CaptureStream(int fd, const char* stream_name, in CaptureStream() argument
1144 GTEST_LOG_(FATAL) << "Only one " << stream_name in CaptureStream()
/external/python/cpython3/Lib/test/
D_test_multiprocessing.py588 for stream_name, action in break_std_streams.items():
595 setattr(sys, stream_name, None)
602 for stream_name in ('stdout', 'stderr'):
604 old_stream = getattr(sys, stream_name)
605 setattr(sys, stream_name, stream)
615 setattr(sys, stream_name, old_stream)
620 for stream_name in ('stdout', 'stderr'):
622 old_stream = getattr(sys, stream_name)
626 args=(evt, {stream_name: action}))
632 setattr(sys, stream_name, old_stream)
Dtest_io.py4069 def check_daemon_threads_shutdown_deadlock(self, stream_name): argument
/external/epid-sdk/ext/gtest/
Dgtest-all.cc9571 void CaptureStream(int fd, const char* stream_name, CapturedStream** stream) { in CaptureStream() argument
9573 GTEST_LOG_(FATAL) << "Only one " << stream_name in CaptureStream()
/external/smali/smali/src/main/java/org/jf/smali/
DsmaliParser.java8575 RewriteRuleTokenStream stream_name=new RewriteRuleTokenStream(adaptor,"token name",name); in local_directive() local
8593 if ( stream_name.hasNext() ) { in local_directive()
8594 adaptor.addChild(root_1, stream_name.nextNode()); in local_directive()
8596 stream_name.reset(); in local_directive()