/dports/devel/spark/spark-2.1.1/streaming/src/test/scala/org/apache/spark/streaming/util/ |
H A D | WriteAheadLogSuite.scala | 482 private def writeAsync(wal: WriteAheadLog, event: String, time: Long): Promise[Unit] = { method 503 writeAsync(batchedWal, event1, 3L) 509 writeAsync(batchedWal, event2, 5L) 510 writeAsync(batchedWal, event3, 8L) 513 writeAsync(batchedWal, event5, 12L) 518 writeAsync(batchedWal, event4, 10L) 558 val promise1 = writeAsync(batchedWal, event1, 3L) 564 val promise2 = writeAsync(batchedWal, event2, 5L) 565 val promise3 = writeAsync(batchedWal, event3, 8L)
|
/dports/comms/qt5-connectivity/kde-qtconnectivity-5.15.2p1/src/bluetooth/osx/ |
H A D | osxbtl2capchannel_p.h | 114 - (IOReturn) writeAsync:(void*)data length:(UInt16)length;
|
H A D | osxbtrfcommchannel_p.h | 105 - (IOReturn) writeAsync:(void*)data length:(UInt16)length;
|
H A D | osxbtl2capchannel.mm | 248 - (IOReturn) writeAsync:(void*)data length:(UInt16)length 254 return [channel writeAsync:data length:length refcon:nullptr];
|
H A D | osxbtrfcommchannel.mm | 251 - (IOReturn) writeAsync:(void*)data length:(UInt16)length 257 return [channel writeAsync:data length:length refcon:nullptr];
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs-nfs/src/main/java/org/apache/hadoop/hdfs/nfs/nfs3/ |
H A D | AsyncDataService.java | 97 void writeAsync(OpenFileCtx openFileCtx) { in writeAsync() method in AsyncDataService
|
/dports/www/wt/wt-4.6.1/src/isapi/ |
H A D | IsapiRequest.C | 161 req->writeAsync(cbIO, dwError, false); in completionCallback() 310 writeAsync(0, 0, true); in flush() 347 void IsapiRequest::writeAsync(DWORD cbIO, DWORD dwError, bool first) in writeAsync() function
|
H A D | IsapiRequest.h | 94 void writeAsync(DWORD cbIO, DWORD dwError, bool first);
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/tlslite/tlslite/integration/ |
H A D | asyncstatemachine.py | 233 self.writer = self.tlsConnection.writeAsync(writeBuffer)
|
/dports/security/py-tlslite/tlslite-0.4.9/tlslite/integration/ |
H A D | asyncstatemachine.py | 233 self.writer = self.tlsConnection.writeAsync(writeBuffer)
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/tlslite/tlslite/integration/ |
H A D | asyncstatemachine.py | 233 self.writer = self.tlsConnection.writeAsync(writeBuffer)
|
/dports/biology/bbmap/bbmap/current/align2/ |
H A D | Block.java | 105 ReadWrite.writeAsync(starts, fname+"2.gz", allowSubprocess); in write()
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/device/bluetooth/ |
H A D | bluetooth_rfcomm_channel_mac.mm | 127 return [channel_ writeAsync:data length:length refcon:refcon];
|
H A D | bluetooth_l2cap_channel_mac.mm | 124 return [channel_ writeAsync:data length:length refcon:refcon];
|
H A D | bluetooth_socket_mac.mm | 717 // |writeAsync| accepts buffers of max. mtu bytes per call, so we need to emit
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/device/bluetooth/ |
H A D | bluetooth_l2cap_channel_mac.mm | 124 return [channel_ writeAsync:data length:length refcon:refcon];
|
H A D | bluetooth_rfcomm_channel_mac.mm | 127 return [channel_ writeAsync:data length:length refcon:refcon];
|
H A D | bluetooth_socket_mac.mm | 713 // |writeAsync| accepts buffers of max. mtu bytes per call, so we need to emit
|
/dports/comms/qt5-connectivity/kde-qtconnectivity-5.15.2p1/src/bluetooth/ |
H A D | qbluetoothsocket_osx.mm | 196 // IOBluetoothL2CAPChannel is buffered (writeAsync). 435 …status = [rfcommChannel.getAs<ObjCRFCOMMChannel>() writeAsync:writeChunk.data() length:UInt16(size… 437 …status = [l2capChannel.getAs<ObjCL2CAPChannel>() writeAsync:writeChunk.data() length:UInt16(size)];
|
/dports/security/py-tlslite/tlslite-0.4.9/tlslite/ |
H A D | tlsrecordlayer.py | 254 for result in self.writeAsync(s): 257 def writeAsync(self, s): member in TLSRecordLayer
|
/dports/emulators/dolphin-emu/dolphin-3152428/Source/Core/Core/HW/WiimoteReal/ |
H A D | IOdarwin.mm | 228 ret = [m_ichan writeAsync:const_cast<void*>((void*)buf) length:(int)len refcon:nil];
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/tlslite/tlslite/ |
H A D | tlsrecordlayer.py | 256 for result in self.writeAsync(s): 259 def writeAsync(self, s): member in TLSRecordLayer
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/tlslite/tlslite/ |
H A D | tlsrecordlayer.py | 256 for result in self.writeAsync(s): 259 def writeAsync(self, s): member in TLSRecordLayer
|
/dports/biology/bbmap/bbmap/current/consensus/ |
H A D | ConsensusMaker.java | 574 ReadWrite.writeAsync(graphList, ffmodel.name(), true);
|
/dports/biology/bbmap/bbmap/current/fileIO/ |
H A D | ReadWrite.java | 102 writeAsync(x, fname, allowSubprocess); in run() 221 public static <X> void writeAsync(X x, String fname, boolean allowSubprocess){ in writeAsync() method in ReadWrite
|