1 // SoftEther UT-VPN SourceCode
\r
3 // Copyright (C) 2004-2010 SoftEther Corporation.
\r
4 // Copyright (C) 2004-2010 University of Tsukuba, Japan.
\r
5 // Copyright (C) 2003-2010 Daiyuu Nobori.
\r
6 // All Rights Reserved.
\r
8 // http://utvpn.tsukuba.ac.jp/
\r
10 // This program is free software; you can redistribute it and/or
\r
11 // modify it under the terms of the GNU General Public License
\r
12 // version 2 as published by the Free Software Foundation.
\r
14 // This program is distributed in the hope that it will be useful,
\r
15 // but WITHOUT ANY WARRANTY; without even the implied warranty of
\r
16 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
\r
17 // GNU General Public License for more details.
\r
19 // You should have received a copy of the GNU General Public License version 2
\r
20 // along with this program; if not, write to the Free Software
\r
21 // Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
\r
23 // このファイルは GPL バージョン 2 ライセンスで公開されています。
\r
24 // 誰でもこのファイルの内容を複製、改変したり、改変したバージョンを再配布
\r
25 // することができます。ただし、原著作物を改変した場合は、原著作物の著作権表示
\r
26 // を除去することはできません。改変した著作物を配布する場合は、改変実施者の
\r
27 // 著作権表示を原著作物の著作権表示に付随して記載するようにしてください。
\r
29 // この SoftEther UT-VPN オープンソース・プロジェクトは、日本国の
\r
30 // ソフトイーサ株式会社 (SoftEther Corporation, http://www.softether.co.jp/ )
\r
31 // および筑波大学 (University of Tsukuba, http://www.tsukuba.ac.jp/ ) によって
\r
33 // 本プログラムの配布者は、本プログラムを、業としての利用以外のため、
\r
34 // および、試験または研究のために利用が行われることを想定して配布
\r
36 // SoftEther UT-VPN プロジェクトの Web サイトは http://utvpn.tsukuba.ac.jp/ に
\r
38 // 本ソフトウェアの不具合の修正、機能改良、セキュリティホールの修復などのコード
\r
39 // の改変を行った場合で、その成果物を SoftEther UT-VPN プロジェクトに提出して
\r
40 // いただける場合は、 http://utvpn.tsukuba.ac.jp/ までソースコードを送付して
\r
41 // ください。SoftEther UT-VPN プロジェクトの本体リリースまたはブランチリリース
\r
44 // GPL に基づいて原著作物が提供される本ソフトウェアの改良版を配布、販売する
\r
45 // 場合は、そのソースコードを GPL に基づいて誰にでも開示する義務が生じます。
\r
47 // 本ソフトウェアに関連する著作権、特許権、商標権はソフトイーサ株式会社
\r
48 // (SoftEther Corporation) およびその他の著作権保持者が保有しています。
\r
49 // ソフトイーサ株式会社等はこれらの権利を放棄していません。本ソフトウェアの
\r
50 // 二次著作物を配布、販売する場合は、これらの権利を侵害しないようにご注意
\r
53 // お願い: どのような通信ソフトウェアにも通常は必ず未発見の
\r
54 // セキュリティホールが潜んでいます。本ソースコードをご覧いただいた結果、
\r
55 // UT-VPN にセキュリティホールを発見された場合は、当該セキュリティホールの
\r
56 // 情報を不特定多数に開示される前に、必ず、ソフトイーサ株式会社
\r
57 // および脆弱性情報の届出を受け付ける公的機関まで通報いただき、
\r
58 // 公益保護にご協力いただきますようお願い申し上げます。
\r
60 // ソフトイーサ株式会社は、当該セキュリティホールについて迅速に対処を
\r
61 // 行い、UT-VPN および UT-VPN に関連するソフトウェアのユーザー・顧客
\r
64 // ソフトイーサへの届出先: http://www.softether.co.jp/jp/contact/
\r
65 // 日本国内の脆弱性情報届出受付公的機関:
\r
67 // http://www.ipa.go.jp/security/vuln/report/
\r
69 // 上記各事項について不明な点は、ソフトイーサ株式会社までご連絡ください。
\r
70 // 連絡先: http://www.softether.co.jp/jp/contact/
\r
72 // -----------------------------------------------
\r
75 // 新規リリース by SoftEther
\r
76 // -----------------------------------------------
\r
81 #include "CedarPch.h"
\r
84 void EndRpc(RPC *rpc)
\r
90 void RpcFree(RPC *rpc)
\r
98 Disconnect(rpc->Sock);
\r
99 ReleaseSock(rpc->Sock);
\r
101 DeleteLock(rpc->Lock);
\r
107 UINT RpcGetError(PACK *p)
\r
112 return ERR_DISCONNECTED;
\r
115 return PackGetInt(p, "error_code");
\r
119 bool RpcIsOk(PACK *p)
\r
127 if (PackGetInt(p, "error") == 0)
\r
138 void RpcError(PACK *p, UINT err)
\r
146 PackAddInt(p, "error", 1);
\r
147 PackAddInt(p, "error_code", err);
\r
150 // RPC ディスパッチャを起動する
\r
151 PACK *CallRpcDispatcher(RPC *r, PACK *p)
\r
153 char func_name[MAX_SIZE];
\r
155 if (r == NULL || p == NULL)
\r
160 if (PackGetStr(p, "function_name", func_name, sizeof(func_name)) == false)
\r
165 return r->Dispatch(r, func_name, p);
\r
168 // 次の RPC 呼び出しを待機する
\r
169 bool RpcRecvNextCall(RPC *r)
\r
185 if (RecvAll(s, &size, sizeof(UINT), s->SecureMode) == false)
\r
190 size = Endian32(size);
\r
192 if (size > MAX_PACK_SIZE)
\r
197 tmp = MallocEx(size, true);
\r
199 if (RecvAll(s, tmp, size, s->SecureMode) == false)
\r
206 WriteBuf(b, tmp, size);
\r
218 ret = CallRpcDispatcher(r, p);
\r
223 ret = PackError(ERR_NOT_SUPPORTED);
\r
226 b = PackToBuf(ret);
\r
229 size = Endian32(b->Size);
\r
230 SendAdd(s, &size, sizeof(UINT));
\r
231 SendAdd(s, b->Buf, b->Size);
\r
233 if (SendNow(s, s->SecureMode) == false)
\r
245 void RpcServer(RPC *r)
\r
258 // 次の RPC 呼び出しを待機する
\r
259 if (RpcRecvNextCall(r) == false)
\r
268 PACK *RpcCall(RPC *r, char *function_name, PACK *p)
\r
271 UINT num_retry = 0;
\r
274 if (r == NULL || function_name == NULL)
\r
279 // Debug("RpcCall: %s\n", function_name);
\r
288 PackAddStr(p, "function_name", function_name);
\r
292 ret = RpcCallInternal(r, p);
\r
296 if (r->IsVpnServer && r->Sock != NULL)
\r
302 // VPN Server に RPC 再接続を試みる
\r
303 err = AdminReconnect(r);
\r
305 if (err == ERR_NO_ERROR)
\r
319 err = ERR_DISCONNECTED;
\r
322 ret = PackError(err);
\r
323 PackAddInt(ret, "error_code", err);
\r
332 PACK *RpcCallInternal(RPC *r, PACK *p)
\r
339 if (r == NULL || p == NULL)
\r
344 if (r->Sock == NULL)
\r
351 size = Endian32(b->Size);
\r
352 SendAdd(r->Sock, &size, sizeof(UINT));
\r
353 SendAdd(r->Sock, b->Buf, b->Size);
\r
356 if (SendNow(r->Sock, r->Sock->SecureMode) == false)
\r
361 if (RecvAll(r->Sock, &size, sizeof(UINT), r->Sock->SecureMode) == false)
\r
366 size = Endian32(size);
\r
367 if (size > MAX_PACK_SIZE)
\r
372 tmp = MallocEx(size, true);
\r
373 if (RecvAll(r->Sock, tmp, size, r->Sock->SecureMode) == false)
\r
380 WriteBuf(b, tmp, size);
\r
384 ret = BufToPack(b);
\r
397 RPC *StartRpcServer(SOCK *s, RPC_DISPATCHER *dispatch, void *param)
\r
406 r = ZeroMallocEx(sizeof(RPC), true);
\r
409 r->Lock = NewLock();
\r
412 r->ServerMode = true;
\r
413 r->Dispatch = dispatch;
\r
416 Format(r->Name, sizeof(r->Name), "RPC-%u", s->socket);
\r
422 RPC *StartRpcClient(SOCK *s, void *param)
\r
431 r = ZeroMalloc(sizeof(RPC));
\r
434 r->Lock = NewLock();
\r
437 r->ServerMode = false;
\r