`reader.cc`

1 files changed, 11 insertions, 12 deletions

diff --git a/src/writer.cc b/src/writer.cc
index f4d5589..dbe0cb0 100644
--- a/src/writer.cc
+++ b/src/writer.cc
@@ -197,8 +197,7 @@ void InsertOrder(TWriterThreadOrderType OrderType, const void *Data){
 
 void GetOrder(TWriterThreadOrder *Order){
 	OrderBufferFull.down();
-	int ReadPos = OrderPointerRead % NARRAY(OrderBuffer);
-	*Order = OrderBuffer[ReadPos];
+	*Order = OrderBuffer[OrderPointerRead % NARRAY(OrderBuffer)];
 	OrderPointerRead += 1;
 	OrderBufferEmpty.up();
 }
@@ -857,6 +856,15 @@ void InsertReply(TWriterThreadReplyType ReplyType, const void *Data){
 	ReplyPointerWrite += 1;
 }
 
+bool GetReply(TWriterThreadReply *Reply){
+	bool Result = (ReplyPointerRead < ReplyPointerWrite);
+	if(Result){
+		*Reply = ReplyBuffer[ReplyPointerRead % NARRAY(ReplyBuffer)];
+		ReplyPointerRead += 1;
+	}
+	return Result;
+}
+
 void BroadcastReply(const char *Text, ...){
 	if(Text == NULL){
 		error("BroadcastReply: Kein Text angegeben.\n");
@@ -905,15 +913,6 @@ void LogoutReply(const char *PlayerName){
 	InsertReply(WRITER_REPLY_LOGOUT, Data);
 }
 
-bool GetReply(TWriterThreadReply *Reply){
-	bool Result = (ReplyPointerRead < ReplyPointerWrite);
-	if(Result){
-		*Reply = ReplyBuffer[ReplyPointerRead % NARRAY(ReplyBuffer)];
-		ReplyPointerRead += 1;
-	}
-	return Result;
-}
-
 void ProcessBroadcastReply(TBroadcastReplyData *Data){
 	if(Data == NULL){
 		error("ProcessBroadcastReply: Keine Daten übergeben.\n");
@@ -981,7 +980,7 @@ void ProcessWriterThreadReplies(void){
 	}
 }
 
-// Writer Initialization
+// Initialization
 // =============================================================================
 void ClearPlayers(void){
 	int NumberOfAffectedPlayers;