这是indexloc提供的服务,不要输入任何密码
Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
data: <IDS|MSG> more: True
data: b27e4588f37f9d106875a3de5082622d4475874432c1973c423c4c44690f9fd9 more: True
data: {"msg_id":"00000000-0000-0000-0000-000000000000","username":"dotnet_kernel","session":"test session","date":"0001-01-01T00:00:00Z","msg_type":"complete_reply","version":"5.3"} more: True
data: null more: True
data: {} more: True
data: {} more: True
data: {"matches":["Write","WriteLine"],"cursor_start":0,"cursor_end":0,"metadata":{},"status":"ok"} more: False
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
data: <IDS|MSG> more: True
data: c5121da74f5ffb064d676a281b3d48f643c9b26f60929966870dc52572cb7912 more: True
data: {"msg_id":"00000000-0000-0000-0000-000000000000","username":"dotnet_kernel","session":"test session","date":"0001-01-01T00:00:00Z","msg_type":"display_data","version":"5.3"} more: True
data: null more: True
data: {} more: True
data: {} more: True
data: {"data":{"text/html":"some result","text/plain":"some result"},"metadata":{},"transient":{"display_id":"none"}} more: False
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
data: <IDS|MSG> more: True
data: 6e64ac95f5a15be7e5efa2a0361145e55c6341b921954889de2a5b0a83161ccf more: True
data: {"msg_id":"00000000-0000-0000-0000-000000000000","username":"dotnet_kernel","session":"test session","date":"0001-01-01T00:00:00Z","msg_type":"execute_result","version":"5.3"} more: True
data: null more: True
data: {} more: True
data: {} more: True
data: {"data":{"text/html":"some result","text/plain":"some result"},"metadata":{},"transient":{"display_id":"none"},"execution_count":12} more: False
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
data: <IDS|MSG> more: True
data: 5f5b73dad44a06065f04b1d1b0b4656083a8c7bcc7fbbb170663283dcf91da20 more: True
data: {"msg_id":"00000000-0000-0000-0000-000000000000","username":"dotnet_kernel","session":"test session","date":"0001-01-01T00:00:00Z","msg_type":"kernel_info_reply","version":"5.3"} more: True
data: null more: True
data: {} more: True
data: {} more: True
data: {"protocol_version":"5.3","implementation":".NET","implementation_version":"0.0.3","language_info":{"name":"C#","version":"4.0.30319","mimetype":"text/x-csharp","file_extension":".cs","pygments_lexer":"c#"},"banner":null,"status":"ok","help_links":[]} more: False
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
data: <IDS|MSG> more: True
data: 6622cc56c4ef7c59c1d81a2f7e81cbf6cdeeadaa78a5b17541be690ed04de665 more: True
data: {"msg_id":"00000000-0000-0000-0000-000000000000","username":"dotnet_kernel","session":"test session","date":"0001-01-01T00:00:00Z","msg_type":"update_display_data","version":"5.3"} more: True
data: null more: True
data: {} more: True
data: {} more: True
data: {"data":{"text/html":"some result","text/plain":"some result"},"metadata":{},"transient":{"display_id":"none"}} more: False
2 changes: 1 addition & 1 deletion Microsoft.DotNet.Interactive.Jupyter/MessageSender.cs
Original file line number Diff line number Diff line change
Expand Up @@ -35,7 +35,7 @@ public bool Send(Message message)
Send(Constants.DELIMITER, _socket);
Send(hmac, _socket);
Send(message.Header.ToJson(), _socket);
Send(message.ParentHeader.ToJson(), _socket);
Send((message.ParentHeader?? new object()).ToJson(), _socket);
Send(message.MetaData.ToJson(), _socket);
Send(message.Content.ToJson(), _socket, false);

Expand Down
16 changes: 8 additions & 8 deletions Microsoft.DotNet.Interactive.Jupyter/Shell.cs
Original file line number Diff line number Diff line change
Expand Up @@ -81,25 +81,25 @@ public async Task StartAsync(CancellationToken cancellationToken)

using (var activity = Log.OnEnterAndExit())
{
SetStarting();
//SetStarting();
while (!cancellationToken.IsCancellationRequested)
{
var message = _shell.GetMessage();

activity.Info("Received: {message}", message.ToJson());

SetBusy();
SetBusy(message.Header);

switch (message.Header.MessageType)
{
case JupyterMessageContentTypes.KernelInfoRequest:
id = Encoding.Unicode.GetString(message.Identifiers[0].ToArray());
HandleKernelInfoRequest(message);
SetIdle();
SetIdle(message.Header);
break;

case JupyterMessageContentTypes.KernelShutdownRequest:
SetIdle();
SetIdle(message.Header);
break;

default:
Expand All @@ -112,19 +112,19 @@ public async Task StartAsync(CancellationToken cancellationToken)

await context.Done();

SetIdle();
SetIdle(message.Header);

break;
}


}

void SetBusy() => _ioPubSender.Send(Message.Create(new Status(StatusValues.Busy), identifiers:new []{Message.Topic("status", id)}));
void SetBusy(Header parentHeader) => _ioPubSender.Send(Message.Create(new Status(StatusValues.Busy), parentHeader: parentHeader, identifiers:new []{Message.Topic("status", id)}));

void SetIdle() => _ioPubSender.Send(Message.Create(new Status(StatusValues.Idle), identifiers: new[] { Message.Topic("status", id) }));
void SetIdle(Header parentHeader) => _ioPubSender.Send(Message.Create(new Status(StatusValues.Idle), parentHeader: parentHeader, identifiers: new[] { Message.Topic("status", id) }));

void SetStarting() => _ioPubSender.Send(Message.Create(new Status(StatusValues.Starting), identifiers: new[] { Message.Topic("status", id) }));

}

}
Expand Down
6 changes: 6 additions & 0 deletions NotebookExamples/.ipynb_checkpoints/Untitled-checkpoint.ipynb
Original file line number Diff line number Diff line change
@@ -0,0 +1,6 @@
{
"cells": [],
"metadata": {},
"nbformat": 4,
"nbformat_minor": 2
}
6 changes: 6 additions & 0 deletions NotebookExamples/Untitled.ipynb
Original file line number Diff line number Diff line change
@@ -0,0 +1,6 @@
{
"cells": [],
"metadata": {},
"nbformat": 4,
"nbformat_minor": 2
}