diff options
Diffstat (limited to 'veslibrary/ves_javalibrary/evel_javalib2/src/main/java/evel_javalibrary/att/com/RingBuffer.java')
| -rw-r--r-- | veslibrary/ves_javalibrary/evel_javalib2/src/main/java/evel_javalibrary/att/com/RingBuffer.java | 14 |
1 files changed, 5 insertions, 9 deletions
diff --git a/veslibrary/ves_javalibrary/evel_javalib2/src/main/java/evel_javalibrary/att/com/RingBuffer.java b/veslibrary/ves_javalibrary/evel_javalib2/src/main/java/evel_javalibrary/att/com/RingBuffer.java index 144fc24..460e84a 100644 --- a/veslibrary/ves_javalibrary/evel_javalib2/src/main/java/evel_javalibrary/att/com/RingBuffer.java +++ b/veslibrary/ves_javalibrary/evel_javalib2/src/main/java/evel_javalibrary/att/com/RingBuffer.java @@ -73,8 +73,7 @@ public class RingBuffer { spacesem.acquire();
lock.acquire();
} catch (InterruptedException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
+ Thread.currentThread().interrupt();
}
@@ -107,8 +106,7 @@ public class RingBuffer { spacesem.acquire();
lock.acquire();
} catch (InterruptedException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
+ Thread.currentThread().interrupt();
}
int readPos = 0;
@@ -178,8 +176,7 @@ public class RingBuffer { countsem.acquire();
lock.acquire();
} catch (InterruptedException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
+ Thread.currentThread().interrupt();
}
if(available == 0){
@@ -201,7 +198,7 @@ public class RingBuffer { }
- public int take(EvelObject[] into){
+ public int take(EvelObject[] into) {
return take(into, into.length);
}
@@ -214,8 +211,7 @@ public class RingBuffer { countsem.acquire();
lock.acquire();
} catch (InterruptedException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
+ Thread.currentThread().interrupt();
}
if(available <= writePos){
|