|
@@ -421,7 +421,7 @@ class OpenFileCtx {
|
|
if (existantWriteCtx != null) {
|
|
if (existantWriteCtx != null) {
|
|
if (!existantWriteCtx.getReplied()) {
|
|
if (!existantWriteCtx.getReplied()) {
|
|
if (LOG.isDebugEnabled()) {
|
|
if (LOG.isDebugEnabled()) {
|
|
- LOG.debug("Repeated write request which hasn't be served: xid="
|
|
|
|
|
|
+ LOG.debug("Repeated write request which hasn't been served: xid="
|
|
+ xid + ", drop it.");
|
|
+ xid + ", drop it.");
|
|
}
|
|
}
|
|
} else {
|
|
} else {
|
|
@@ -579,7 +579,7 @@ class OpenFileCtx {
|
|
* writing, and there is no other threads writing (i.e., asyncStatus is
|
|
* writing, and there is no other threads writing (i.e., asyncStatus is
|
|
* false), start the writing and set asyncStatus to true.
|
|
* false), start the writing and set asyncStatus to true.
|
|
*
|
|
*
|
|
- * @return True if the new write is sequencial and we can start writing
|
|
|
|
|
|
+ * @return True if the new write is sequential and we can start writing
|
|
* (including the case that there is already a thread writing).
|
|
* (including the case that there is already a thread writing).
|
|
*/
|
|
*/
|
|
private synchronized boolean checkAndStartWrite(
|
|
private synchronized boolean checkAndStartWrite(
|
|
@@ -898,7 +898,7 @@ class OpenFileCtx {
|
|
long offset = nextOffset.get();
|
|
long offset = nextOffset.get();
|
|
if (range.getMin() > offset) {
|
|
if (range.getMin() > offset) {
|
|
if (LOG.isDebugEnabled()) {
|
|
if (LOG.isDebugEnabled()) {
|
|
- LOG.debug("The next sequencial write has not arrived yet");
|
|
|
|
|
|
+ LOG.debug("The next sequential write has not arrived yet");
|
|
}
|
|
}
|
|
processCommits(nextOffset.get()); // handle race
|
|
processCommits(nextOffset.get()); // handle race
|
|
this.asyncStatus = false;
|
|
this.asyncStatus = false;
|