Home
last modified time | relevance | path

Searched refs:writeAsync (Results 1 – 25 of 25) sorted by relevance

/dports/devel/spark/spark-2.1.1/streaming/src/test/scala/org/apache/spark/streaming/util/
H A DWriteAheadLogSuite.scala482 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 Dosxbtl2capchannel_p.h114 - (IOReturn) writeAsync:(void*)data length:(UInt16)length;
H A Dosxbtrfcommchannel_p.h105 - (IOReturn) writeAsync:(void*)data length:(UInt16)length;
H A Dosxbtl2capchannel.mm248 - (IOReturn) writeAsync:(void*)data length:(UInt16)length
254 return [channel writeAsync:data length:length refcon:nullptr];
H A Dosxbtrfcommchannel.mm251 - (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 DAsyncDataService.java97 void writeAsync(OpenFileCtx openFileCtx) { in writeAsync() method in AsyncDataService
/dports/www/wt/wt-4.6.1/src/isapi/
H A DIsapiRequest.C161 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 DIsapiRequest.h94 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 Dasyncstatemachine.py233 self.writer = self.tlsConnection.writeAsync(writeBuffer)
/dports/security/py-tlslite/tlslite-0.4.9/tlslite/integration/
H A Dasyncstatemachine.py233 self.writer = self.tlsConnection.writeAsync(writeBuffer)
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/tlslite/tlslite/integration/
H A Dasyncstatemachine.py233 self.writer = self.tlsConnection.writeAsync(writeBuffer)
/dports/biology/bbmap/bbmap/current/align2/
H A DBlock.java105 ReadWrite.writeAsync(starts, fname+"2.gz", allowSubprocess); in write()
/dports/www/chromium-legacy/chromium-88.0.4324.182/device/bluetooth/
H A Dbluetooth_rfcomm_channel_mac.mm127 return [channel_ writeAsync:data length:length refcon:refcon];
H A Dbluetooth_l2cap_channel_mac.mm124 return [channel_ writeAsync:data length:length refcon:refcon];
H A Dbluetooth_socket_mac.mm717 // |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 Dbluetooth_l2cap_channel_mac.mm124 return [channel_ writeAsync:data length:length refcon:refcon];
H A Dbluetooth_rfcomm_channel_mac.mm127 return [channel_ writeAsync:data length:length refcon:refcon];
H A Dbluetooth_socket_mac.mm713 // |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 Dqbluetoothsocket_osx.mm196 // 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 Dtlsrecordlayer.py254 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 DIOdarwin.mm228 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 Dtlsrecordlayer.py256 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 Dtlsrecordlayer.py256 for result in self.writeAsync(s):
259 def writeAsync(self, s): member in TLSRecordLayer
/dports/biology/bbmap/bbmap/current/consensus/
H A DConsensusMaker.java574 ReadWrite.writeAsync(graphList, ffmodel.name(), true);
/dports/biology/bbmap/bbmap/current/fileIO/
H A DReadWrite.java102 writeAsync(x, fname, allowSubprocess); in run()
221 public static <X> void writeAsync(X x, String fname, boolean allowSubprocess){ in writeAsync() method in ReadWrite