Skip to content

Commit ee2fb76

Browse files
committed
Minor reformat, refactoring, and fix comment
1 parent 0c69093 commit ee2fb76

File tree

4 files changed

+29
-24
lines changed

4 files changed

+29
-24
lines changed

src/core/aws-net-websocket-protocol-rfc6455.adb

Lines changed: 23 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -124,21 +124,24 @@ package body AWS.Net.WebSocket.Protocol.RFC6455 is
124124
-------------------------
125125

126126
overriding procedure Add_Connect_Headers
127-
(Protocol : State;
128-
Host : String;
129-
Headers : in out AWS.Headers.List)
127+
(Protocol : State;
128+
Host : String;
129+
Headers : in out AWS.Headers.List)
130130
is
131+
use AWS.Messages;
132+
131133
pragma Unreferenced (Protocol);
134+
132135
Ints : array (1 .. 4) of AWS.Utils.Random_Integer :=
133136
(others => Utils.Random);
134137
H : Stream_Element_Array (1 .. 16) with Import, Address => Ints'Address;
135138

136139
begin
137-
Headers.Add ("Host", Host);
138-
Headers.Add ("Upgrade", "WebSocket");
139-
Headers.Add ("Connection", "Upgrade");
140-
Headers.Add ("Sec-WebSocket-Key", Translator.Base64_Encode (H));
141-
Headers.Add ("Sec-WebSocket-Version", "13");
140+
Headers.Add (Host_Token, Host);
141+
Headers.Add (Upgrade_Token, "WebSocket");
142+
Headers.Add (Connection_Token, "Upgrade");
143+
Headers.Add (Sec_WebSocket_Key_Token, Translator.Base64_Encode (H));
144+
Headers.Add (Sec_WebSocket_Version_Token, "13");
142145
end Add_Connect_Headers;
143146

144147
----------------------------
@@ -152,12 +155,14 @@ package body AWS.Net.WebSocket.Protocol.RFC6455 is
152155
return Boolean
153156
is
154157
pragma Unreferenced (Protocol);
158+
155159
Expected : constant String :=
156160
Get_Websocket_Accept
157-
(AWS.Headers.Get
158-
(Request, AWS.Messages.Sec_WebSocket_Key_Token));
159-
Actual : constant String := AWS.Response.Header
160-
(Response, AWS.Messages.Sec_WebSocket_Accept_Token);
161+
(AWS.Headers.Get
162+
(Request, Messages.Sec_WebSocket_Key_Token));
163+
Actual : constant String :=
164+
AWS.Response.Header
165+
(Response, Messages.Sec_WebSocket_Accept_Token);
161166
begin
162167
return Expected = Actual;
163168
end Check_Connect_Response;
@@ -622,13 +627,12 @@ package body AWS.Net.WebSocket.Protocol.RFC6455 is
622627
Mask := Create_Random_Mask;
623628
end if;
624629

625-
if Socket.State.Kind = Text then
626-
Send_Frame_Header (Protocol, Socket, O_Text, Data'Length,
627-
Has_Mask => From_Client, Mask => Mask);
628-
else
629-
Send_Frame_Header (Protocol, Socket, O_Binary, Data'Length,
630-
Has_Mask => From_Client, Mask => Mask);
631-
end if;
630+
Send_Frame_Header
631+
(Protocol, Socket,
632+
(if Socket.State.Kind = Text then O_Text else O_Binary),
633+
Data'Length,
634+
Has_Mask => From_Client,
635+
Mask => Mask);
632636

633637
-- Send payload
634638

src/core/aws-net-websocket-registry.adb

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -345,8 +345,6 @@ package body AWS.Net.WebSocket.Registry is
345345
WebSocket : Object_Class;
346346
Message : Unbounded_String;
347347
begin
348-
Message := Null_Unbounded_String;
349-
350348
Message_Queue.Get (WebSocket);
351349

352350
-- A WebSocket is null when termination is requested

src/core/aws-net-websocket.adb

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -432,15 +432,18 @@ package body AWS.Net.WebSocket is
432432
Obj : Object_Class := Socket'Unrestricted_Access;
433433
Event : AWS.Net.Event_Set;
434434
Msg : Ada.Strings.Unbounded.Unbounded_String;
435+
435436
begin
436437
Event := Socket.Poll
437438
((AWS.Net.Input => True, others => False), Timeout => Timeout);
438439

439440
if Event (AWS.Net.Input) then
440441
-- Block until we have received all chunks of the frame
441-
while not Read_Message (Obj, Msg) loop
442-
null;
442+
443+
loop
444+
exit when Read_Message (Obj, Msg);
443445
end loop;
446+
444447
return True;
445448

446449
elsif Event (AWS.Net.Error) then

src/core/aws-net-websocket.ads

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -412,7 +412,7 @@ private
412412
-- Process the current message on the socket.
413413
-- Return True if a complete message was read.
414414
-- Data is accumulated in Message, until the message is complete. At this
415-
-- stage, Socket.On_Message will be called.
415+
-- stage, Socket.On_Success will be called.
416416
-- In case of error, other callbacks will be used as appropriate.
417417

418418
overriding function Is_Secure (Socket : Object) return Boolean

0 commit comments

Comments
 (0)