JP2008160557A - Receiving device, transmitting device, and relay device - Google Patents
Receiving device, transmitting device, and relay device Download PDFInfo
- Publication number
- JP2008160557A JP2008160557A JP2006348054A JP2006348054A JP2008160557A JP 2008160557 A JP2008160557 A JP 2008160557A JP 2006348054 A JP2006348054 A JP 2006348054A JP 2006348054 A JP2006348054 A JP 2006348054A JP 2008160557 A JP2008160557 A JP 2008160557A
- Authority
- JP
- Japan
- Prior art keywords
- file
- priority
- transmission
- transfer
- reception
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Pending
Links
Images
Landscapes
- Data Exchanges In Wide-Area Networks (AREA)
- Communication Control (AREA)
Abstract
【課題】特定のファイルを他のファイルに優先して転送するよう転送速度を制御することができる受信装置、送信装置及び中継装置を提供すること。
【解決手段】ノード1は、ファイルの送受信に係る制御を行うファイル送受信手段10を備え、ファイル送受信手段10は、送信するファイルの転送速度の管理及び制御を行う送信管理部11と、受信するファイルの転送速度の管理及び制御を行う受信管理部12とを備え、通常ファイル及び優先ファイルを受信する際に、受信管理部12は、通常ファイルを受信する受信状態と通常ファイルの受信を所定時間待機する受信待機状態とを設定し、受信状態及び受信待機状態の切替制御を行うことによって、通常ファイルの転送速度を抑制し、優先ファイルの転送を優先するよう優先ファイル及び通常ファイルの転送速度を制御するようにした。
【選択図】図1To provide a receiving device, a transmitting device, and a relay device capable of controlling a transfer speed so that a specific file is transferred with priority over other files.
A node includes a file transmission / reception unit that performs control related to transmission / reception of a file. The file transmission / reception unit includes a transmission management unit that manages and controls a transfer rate of a file to be transmitted, and a file that is received. A reception management unit 12 for managing and controlling the transfer rate of the file, and when receiving the normal file and the priority file, the reception management unit 12 waits for a predetermined time to receive the normal file and receive the normal file. By setting the reception standby state to be performed and switching control between the reception state and the reception standby state, the normal file transfer speed is suppressed, and the transfer speed of the priority file and the normal file is controlled to give priority to the transfer of the priority file. I tried to do it.
[Selection] Figure 1
Description
本発明は、ネットワークを介して授受されるデータの転送速度の制御を行う受信装置、送信装置及び中継装置に関する。 The present invention relates to a receiving device, a transmitting device, and a relay device that control the transfer rate of data exchanged over a network.
従来、ネットワークに接続されたノード間において、送信元ノードや送信先ノードの異なる複数のファイルを同時に転送する技術は既に提案されており、この技術は例えばインターネットでは既に実現されている。しかしながら、ネットワーク全体を管理するノードが存在せず、それぞれのノードが独立して動作しているので、特定のファイルを他のファイルに優先して転送することはできない。 Conventionally, a technique for simultaneously transferring a plurality of files having different transmission source nodes and transmission destination nodes between nodes connected to a network has been proposed, and this technique has already been realized in the Internet, for example. However, since there is no node that manages the entire network and each node operates independently, a specific file cannot be transferred with priority over other files.
従来のネットワークでは、転送時間の制約がないファイル転送(以下「通常のファイル転送」という。)や、映像や音声等のデータをリアルタイムで転送するストリーミング転送が行われている。通常のファイル転送では、転送時間の制約がないものの、可能な限り高速で転送されるのが望ましい。一方、ストリーミング転送では、伝送帯域がある一定値以上確保される必要がある。したがって、通常のファイル転送とストリーミング転送とが混在するネットワークでは、ストリーミング転送を通常のファイル転送よりも優先させる必要がある。 In conventional networks, file transfer with no restriction on transfer time (hereinafter referred to as “normal file transfer”) and streaming transfer for transferring data such as video and audio in real time are performed. In normal file transfer, although there is no restriction on transfer time, it is desirable to transfer at the highest possible speed. On the other hand, in streaming transfer, it is necessary to secure a transmission band above a certain value. Therefore, in a network in which normal file transfer and streaming transfer are mixed, it is necessary to give priority to streaming transfer over normal file transfer.
前述のように、ネットワークに接続されたノード間において、特定のファイルを他のファイルに優先して転送することが要求される場合があり、この要求に対して例えば特許文献1に示すような通信中継システムが提案されている。 As described above, there is a case where it is required to transfer a specific file with priority over other files between nodes connected to the network. A relay system has been proposed.
特許文献1に示されたものは、無線通信を行う無線端末と、無線端末の通信を中継する無線中継局と、無線端末が行う通信を管理するストリームサーバとを備え、無線中継局は、ストリームサーバが管理する通信のうち優先的に中継する通信の識別子を登録した優先テーブルと、この優先テーブルに登録された優先通信の優先順位を管理する優先順位管理部とを有し、優先テーブルに登録された通信識別子で特定される通信を他の通信よりも優先的に中継するようになっている。
しかしながら、特許文献1に示された従来のものでは、優先順位管理部が、通常は到着順に優先順位を決定し、同時に複数の優先通信が発生したときにはどちらを他方よりも優先するかを決定する構成となっているので、ユーザが特定した特定のファイルを他のファイルに優先して転送するよう転送速度を制御することができないという課題があった。 However, in the prior art disclosed in Patent Document 1, the priority order management unit usually determines the priority order in the order of arrival, and when multiple priority communications occur at the same time, determines which one has priority over the other. Because of the configuration, there is a problem that the transfer speed cannot be controlled so that a specific file specified by the user is transferred with priority over other files.
したがって、従来のものは、特定のファイル転送を優先させながら他のファイル転送を可能な限り高速で転送することができないという課題や、優先した特定のファイル転送に関してユーザの指定した転送速度を維持させることやユーザの指定した時刻までに転送を完了させることができないという課題があった。 Therefore, in the conventional method, priority is given to a specific file transfer, while other file transfers cannot be transferred as fast as possible, and the transfer speed specified by the user is maintained for the specific file transfer with priority. There is a problem that the transfer cannot be completed by the time specified by the user.
本発明は、従来の課題を解決するためになされたものであり、特定のファイルを他のファイルに優先して転送するよう転送速度を制御することができる受信装置、送信装置及び中継装置を提供することを目的とする。 The present invention has been made to solve the conventional problems, and provides a receiving device, a transmitting device, and a relay device capable of controlling a transfer speed so that a specific file is transferred with priority over other files. The purpose is to do.
本発明の受信装置は、転送速度が予め定められた優先ファイル及び前記優先ファイルよりも転送の優先度が低い通常ファイルの少なくとも一方を受信する受信装置であって、前記優先ファイル及び前記通常ファイルの少なくとも一方を受信するファイル受信手段と、前記優先ファイルの転送速度を示す転送速度情報を受信する転送速度情報受信手段と、前記ファイル受信手段が前記優先ファイル及び前記通常ファイルを受信する際に、前記転送速度情報に基づいて、前記通常ファイルの転送速度を抑制し、前記優先ファイルの転送を優先するよう前記優先ファイル及び前記通常ファイルの転送速度を制御する受信側転送速度制御手段とを備えた構成を有している。 The receiving device of the present invention is a receiving device that receives at least one of a priority file having a transfer speed determined in advance and a normal file having a transfer priority lower than that of the priority file, the priority file and the normal file being File receiving means for receiving at least one, transfer speed information receiving means for receiving transfer speed information indicating the transfer speed of the priority file, and when the file receiving means receives the priority file and the normal file, A receiving side transfer rate control means for controlling the transfer rate of the priority file and the normal file so that the transfer rate of the normal file is controlled based on transfer rate information and the transfer of the priority file is prioritized. have.
この構成により、本発明の受信装置は、優先ファイル及び通常ファイルを受信する際に、転送速度情報に基づいて、通常ファイルの転送速度を抑制し、優先ファイルの転送を優先するよう優先ファイル及び通常ファイルの転送速度を制御することができる。その結果、本発明の受信装置は、ネットワーク接続されている複数のノード間でファイルの転送が行われている状況においても、優先ファイルの転送を通常ファイルの転送よりも優先させながら通常ファイルを可能な限り高速で転送することができる。 With this configuration, when receiving the priority file and the normal file, the receiving device of the present invention suppresses the transfer speed of the normal file based on the transfer speed information and prioritizes the transfer of the priority file and the normal file. You can control the file transfer rate. As a result, the receiving device of the present invention enables normal file transfer while giving priority to priority file transfer over normal file transfer even in a situation where file transfer is performed between multiple nodes connected to the network. It can be transferred as fast as possible.
また、本発明の受信装置は、前記受信側転送速度制御手段は、前記通常ファイルを受信する受信状態と前記通常ファイルの受信を所定時間待機する受信待機状態とを設定することによって前記通常ファイルの転送速度を制御する構成を有している。 In the receiving apparatus of the present invention, the transfer rate control means on the receiving side sets the reception state for receiving the normal file and the reception standby state for waiting for the reception of the normal file for a predetermined time. It has a configuration for controlling the transfer rate.
この構成により、本発明の受信装置は、通常ファイルの転送速度を抑制し、優先ファイルの転送を優先するよう優先ファイル及び通常ファイルの転送速度を制御することができるので、ネットワーク接続されている複数のノード間でファイルの転送が行われている状況においても、優先ファイルの転送を通常ファイルの転送よりも優先させながら通常ファイルを可能な限り高速で転送することができる。 With this configuration, the receiving apparatus of the present invention can control the transfer speed of the priority file and the normal file so as to suppress the transfer speed of the normal file and give priority to the transfer of the priority file. Even in a situation where files are transferred between the nodes, the normal file can be transferred as fast as possible while giving priority to the priority file transfer over the normal file transfer.
さらに、本発明の受信装置は、前記受信側転送速度制御手段は、前記優先ファイル及び前記通常ファイルのデータを記憶する所定数のバッファと、前記優先ファイルのデータが記憶されるバッファ数と前記通常ファイルのデータが記憶されるバッファ数との比率を設定するバッファ数比率設定部とを備えた構成を有している。 Furthermore, in the receiving apparatus of the present invention, the receiving-side transfer rate control means includes a predetermined number of buffers for storing the priority file and the normal file data, a number of buffers for storing the priority file data, and the normal file. And a buffer number ratio setting unit for setting a ratio with the number of buffers in which file data is stored.
この構成により、本発明の受信装置は、優先ファイルのデータが記憶されるバッファ数と通常ファイルのデータが記憶されるバッファ数との比率を設定することにより、優先ファイル及び通常ファイルを受信する際に、転送速度情報に基づいて、通常ファイルの転送速度を抑制し、優先ファイルの転送を優先するよう優先ファイル及び通常ファイルの転送速度を制御することができる。その結果、本発明の受信装置は、ネットワーク接続されている複数のノード間でファイルの転送が行われている状況においても、優先ファイルの転送を通常ファイルの転送よりも優先させながら通常ファイルを可能な限り高速で転送することができる。 With this configuration, the receiving device of the present invention sets the ratio between the number of buffers storing priority file data and the number of buffers storing normal file data, thereby receiving the priority file and the normal file. In addition, based on the transfer rate information, it is possible to control the transfer rate of the priority file and the normal file so as to suppress the transfer rate of the normal file and give priority to the transfer of the priority file. As a result, the receiving device of the present invention enables normal file transfer while giving priority to priority file transfer over normal file transfer even in a situation where file transfer is performed between multiple nodes connected to the network. It can be transferred as fast as possible.
さらに、本発明の受信装置は、前記優先ファイルの受信期限を示す受信期限時刻情報を取得する受信期限時刻情報取得手段と、前記優先ファイルのファイルサイズ情報を取得するファイルサイズ情報取得手段と、現在時刻情報を取得する現在時刻情報取得手段と、前記受信期限時刻情報と前記ファイルサイズ情報と前記現在時刻情報とに基づいて前記優先ファイルの転送速度を計算するファイル転送速度計算手段とを備えた構成を有している。 Further, the receiving device of the present invention includes a reception deadline time information acquisition unit that acquires reception deadline time information indicating a reception deadline of the priority file, a file size information acquisition unit that acquires file size information of the priority file, Configuration comprising: current time information acquisition means for acquiring time information; and file transfer speed calculation means for calculating a transfer speed of the priority file based on the reception deadline time information, the file size information, and the current time information have.
この構成により、本発明の受信装置は、受信期限時刻までに優先ファイルの受信が完了するよう優先ファイルの転送速度を計算するので、優先ファイル及び通常ファイルを受信する状況においても、優先ファイルを受信期限時刻までに受信することができる。 With this configuration, the receiving device of the present invention calculates the transfer rate of the priority file so that the reception of the priority file is completed by the reception deadline time. Therefore, even in the situation where the priority file and the normal file are received, the priority file is received. It can be received before the deadline time.
本発明の送信装置は、前記優先ファイル及び前記通常ファイルの少なくとも一方を送信するファイル送信手段と、前記優先ファイルの転送速度を示す転送速度情報を受信する転送速度情報受信手段と、前記転送速度情報を前記受信装置に通知する転送速度情報通知手段と、前記優先ファイル及び前記通常ファイルを送信する際に、前記転送速度情報に基づいて、前記通常ファイルの転送速度を抑制し、前記優先ファイルの転送を優先するよう前記優先ファイル及び前記通常ファイルの転送速度を制御する送信側転送速度制御手段とを備えた構成を有している。 The transmission device of the present invention includes a file transmission unit that transmits at least one of the priority file and the normal file, a transfer rate information reception unit that receives transfer rate information indicating a transfer rate of the priority file, and the transfer rate information Transfer rate information notification means for notifying the receiving device, and when transmitting the priority file and the normal file, the transfer rate of the normal file is suppressed based on the transfer rate information, and the transfer of the priority file is performed. And a transmission-side transfer rate control means for controlling the transfer rate of the priority file and the normal file to give priority to the file.
この構成により、本発明の送信装置は、優先ファイル及び通常ファイルを送信する際に、転送速度情報に基づいて、通常ファイルの転送速度を抑制し、優先ファイルの転送を優先するよう優先ファイル及び通常ファイルの転送速度を制御することができる。その結果、本発明の送信装置は、ネットワーク接続されている複数のノード間でファイルの転送が行われている状況においても、優先ファイルの転送を通常ファイルの転送よりも優先させながら通常ファイルを可能な限り高速で転送することができる。 With this configuration, when transmitting the priority file and the normal file, the transmission device of the present invention suppresses the transfer speed of the normal file based on the transfer speed information and prioritizes the transfer of the priority file and the normal file. You can control the file transfer rate. As a result, the transmission device of the present invention enables normal files while giving priority to priority file transfer over normal file transfer even in a situation where file transfer is performed between multiple nodes connected to the network. It can be transferred as fast as possible.
また、本発明の送信装置は、前記送信側転送速度制御手段は、前記通常ファイルを送信する送信状態と前記通常ファイルの送信を所定時間待機する送信待機状態とを設定することによって前記通常ファイルの転送速度を制御する構成を有している。 In the transmission apparatus of the present invention, the transmission-side transfer rate control means sets the transmission state for transmitting the normal file and the transmission standby state for waiting for a predetermined time for transmission of the normal file. It has a configuration for controlling the transfer rate.
この構成により、本発明の送信装置は、通常ファイルの転送速度を抑制し、優先ファイルの転送を優先するよう優先ファイル及び通常ファイルの転送速度を制御することができるので、ネットワーク接続されている複数のノード間でファイルの転送が行われている状況においても、優先ファイルの転送を通常ファイルの転送よりも優先させながら通常ファイルを可能な限り高速で転送することができる。 With this configuration, the transmission device of the present invention can control the transfer speed of the priority file and the normal file so as to suppress the transfer speed of the normal file and give priority to the transfer of the priority file. Even in a situation where files are transferred between the nodes, the normal file can be transferred as fast as possible while giving priority to the priority file transfer over the normal file transfer.
さらに、本発明の送信装置は、前記優先ファイルの送信期限を示す送信期限時刻情報を取得する送信期限時刻情報取得手段と、前記優先ファイルのファイルサイズ情報を取得するファイルサイズ情報取得手段と、現在時刻情報を取得する現在時刻情報取得手段と、前記送信期限時刻情報と前記ファイルサイズ情報と前記現在時刻情報とに基づいて前記優先ファイルの転送速度を算出するファイル転送速度算出手段とを備えた構成を有している。 Further, the transmission device of the present invention includes a transmission deadline time information acquisition unit that acquires transmission deadline time information indicating a transmission deadline of the priority file, a file size information acquisition unit that acquires file size information of the priority file, Configuration comprising: current time information acquisition means for acquiring time information; and file transfer speed calculation means for calculating a transfer speed of the priority file based on the transmission deadline time information, the file size information, and the current time information have.
この構成により、本発明の送信装置は、送信期限時刻までに優先ファイルの送信が完了するよう優先ファイルの転送速度を計算するので、優先ファイル及び通常ファイルを送信する状況においても、優先ファイルを送信期限時刻までに送信することができる。 With this configuration, the transmission device of the present invention calculates the transfer speed of the priority file so that the transmission of the priority file is completed by the transmission deadline time, so the priority file can be transmitted even in a situation where the priority file and the normal file are transmitted. It can be sent before the deadline time.
本発明の中継装置は、受信装置と、送信装置とを備え、前記優先ファイル及び前記通常ファイルを中継する構成を有している。 The relay device of the present invention includes a receiving device and a transmitting device, and has a configuration for relaying the priority file and the normal file.
この構成により、本発明の中継装置は、優先ファイル及び通常ファイルを中継する際に、転送速度情報に基づいて、通常ファイルの転送速度を抑制し、優先ファイルの転送を優先するよう優先ファイル及び通常ファイルの転送速度を制御することができる。その結果、本発明の中継装置は、ネットワーク接続されている複数のノード間でファイルの転送が行われている状況においても、優先ファイルの転送を通常ファイルの転送よりも優先させながら通常ファイルを可能な限り高速で転送することができる。 With this configuration, when relaying the priority file and the normal file, the relay apparatus of the present invention suppresses the transfer speed of the normal file based on the transfer speed information and prioritizes the transfer of the priority file and the normal file. You can control the file transfer rate. As a result, the relay device of the present invention enables normal files while giving priority to priority file transfer over normal file transfer even in a situation where file transfer is performed between multiple nodes connected to the network. It can be transferred as fast as possible.
本発明は、特定のファイルを他のファイルに優先して転送するよう転送速度を制御することができるという効果を有する受信装置、送信装置及び中継装置を提供することができるものである。 The present invention can provide a receiving apparatus, a transmitting apparatus, and a relay apparatus having an effect that the transfer speed can be controlled so that a specific file is transferred with priority over other files.
以下、本発明の実施の形態について図面を用いて説明する。なお、本発明の受信装置、送信装置及び中継装置を、ネットワーク上でファイルの転送を行うノードに適用した例を挙げて説明する。ここで、各ノードは、全二重のギガビットイーサネット(登録商標)(IEEE802.3z準拠、通信速度は送受信とも最大1000Mbps)を使用し、ノード間のネットワークの通信プロトコルはTCP/IP(Transmission Control Protocol/Internet Protocol)を使用するものとする。 Hereinafter, embodiments of the present invention will be described with reference to the drawings. An example in which the receiving apparatus, transmitting apparatus, and relay apparatus of the present invention are applied to a node that transfers files on a network will be described. Here, each node uses a full-duplex Gigabit Ethernet (registered trademark) (compliant with IEEE 802.3z, the maximum communication speed is 1000 Mbps for both transmission and reception), and the communication protocol of the network between the nodes is TCP / IP (Transmission Control Protocol). / Internet Protocol).
(第1の実施の形態)
まず、本発明に係るノードの第1の実施の形態における構成について説明する。
(First embodiment)
First, the configuration of the node according to the first embodiment of the present invention will be described.
図1に示すように、本実施の形態におけるノード1は、ファイルの送受信に係る制御を行うファイル送受信手段10と、ノード2及び3と通信する通信部16と、ファイルを蓄積する蓄積装置17とを備えている。
As shown in FIG. 1, the node 1 in the present embodiment includes a file transmission / reception means 10 that performs control related to file transmission / reception, a
なお、ノード1が送受信するファイルには、転送速度が特に定められていないファイル(以下「通常ファイル」という。)と、転送速度が予め定められたファイル(以下「優先ファイル」という。)とがある。また、図示を省略したが、ノード1は、時刻情報を出力する時計(以下「内部時計」という。)を有している。 Note that the files transmitted and received by the node 1 include a file whose transfer rate is not particularly defined (hereinafter referred to as “normal file”) and a file whose transfer rate is determined in advance (hereinafter referred to as “priority file”). is there. Although not shown, the node 1 has a clock (hereinafter referred to as “internal clock”) that outputs time information.
また、本実施の形態におけるノード1は、例えばCPU(Central Processing Unit)、ROM(Read−Only Memory)、RAM(Random−Access Memory)等で構成され、ネットワークを介してノード2及び3に接続されているものとする。また、図1に示すように、ノード2及び3の構成は、ノード1と同様であり、ノード1に対応した符号をそれぞれ付して示しているが、ノード1の蓄積装置制御部14及び蓄積装置17に対応する構成の図示は省略している。
Further, the node 1 in the present embodiment is configured by, for example, a CPU (Central Processing Unit), a ROM (Read-Only Memory), a RAM (Random-Access Memory), and the like, and is connected to the nodes 2 and 3 via a network. It shall be. Further, as shown in FIG. 1, the configurations of the nodes 2 and 3 are the same as those of the node 1, and are denoted by reference numerals corresponding to the nodes 1, respectively. Illustration of the configuration corresponding to the
通信部16は、通信に必要な機能、例えば送信側であればデータをTCP/IPのパケットに分割し受信側であればTCP/IPのパケットを再構成し、TCP/IPのプロトコルで通信する機能を有しており、1つ以上のノードと通信することができるようになっている。また、送信側にはTCP/IP化された送信待ちのパケットを一時的に記憶するバッファを備えており、受信側には送信されたパケットが再構成されるまでの間一時的に記憶するバッファを備えている。
The
蓄積装置17は、例えば半導体メモリ、HDD(ハードディスクドライブ)単体又はRAID(Redundant Arrays of Inexpensive Disks)構成された複数のHDD等で構成され、ネットワークの転送速度よりも十分に高速に読み書きが可能で、かつ高速ランダムアクセスが可能な装置である。
The
ファイル送受信手段10は、送信するファイルの転送速度の管理及び制御を行う送信管理部11と、受信するファイルの転送速度の管理及び制御を行う受信管理部12と、ファイルの送受信に係る制御を行うファイル送受信部13と、蓄積装置17の動作を制御する蓄積装置制御部14と、ユーザからの制御情報を伝達するユーザインターフェース部(以下「ユーザIF部」という。)15とを備えている。なお、ファイル送受信手段10は、本発明のファイル受信手段及びファイル送信手段に対応している。
The file transmission / reception means 10 performs a
ファイル送受信手段10は、OSI(Open System Interconnection)参照モデルのアプリケーション層で動作するアプリケーションソフトウェアによって、ファイルの送受信に係る制御を行うようになっており、1つのネットワーク接続に対して1つのスレッドが起動するようになっている。また、ファイル送受信手段10は、通信部16及び蓄積装置17の動作を制御するようになっている。以上の構成により、ファイル送受信手段10は、ノード2及び3の少なくとも一方から転送されたファイルを蓄積装置17に蓄積することができ、また蓄積装置17に蓄積されているファイルをノード2及び3の少なくとも一方に転送することができるようになっている。
The file transmission / reception means 10 performs control related to file transmission / reception by application software operating in the application layer of the OSI (Open System Interconnection) reference model, and one thread is activated for one network connection. It is supposed to be. The file transmission / reception means 10 controls operations of the
送信管理部11は、送信できる最大の転送速度をノード2及び3に対して個々に設定することができ、設定した最大の転送速度を上限として、ファイルを送信することができるようになっている。なお、図示を省略したが、送信管理部11は、設定した転送速度のデータを記憶するメモリ(以下「転送速度メモリ」という。)を備えている。転送速度メモリは、ファイル送受信手段10が複数スレッド起動されても、どのスレッドからでも参照できるようになっている。また、送信管理部11は、通信部16を介して、ユーザIF部15が取得した転送速度情報をノード2又は3に通知することができるようになっている。また、送信管理部11は、内部時計から時刻情報を取得することができるようになっている。また、送信管理部11は、本発明の送信側転送速度制御手段及び転送速度情報通知手段に対応している。
The
受信管理部12は、受信できる最大の転送速度をノード2及び3に対して個々に設定することができ、設定した最大の転送速度を上限として、ファイルを受信することができるようになっている。なお、図示を省略したが、受信管理部12は、設定した転送速度のデータを記憶する転送速度メモリを備えている。転送速度メモリは、ファイル送受信手段10が複数スレッド起動されても、どのスレッドからでも参照できるようになっている。また、受信管理部12は、通信部16を介して、ノード2又は3から転送速度情報を受信することができるようになっている。また、受信管理部12は、内部時計から時刻情報を取得することができるようになっている。また、受信管理部12は、本発明の受信側転送速度制御手段及び転送速度情報受信手段に対応している。
The
なお、送信管理部11及び受信管理部12は、ユーザIF部15、ノード2又は3からの制御信号により、送受信時の最大の転送速度を逐次変更することができるようになっている。
The
次に、送信管理部11、21、31、及び受信管理部12、22、32についてさらに詳細に説明する。
Next, the
ノード1が有する送信管理部11及び受信管理部12は、ノード1がファイルの送信側であるとき、及び受信側であるときのそれぞれについて転送速度の上限値を管理し、さらに1つの接続ごとに送信側及び受信側のそれぞれについて転送速度の希望値及び実施値の2つのパラメータを管理する。送信管理部11及び受信管理部12は、それぞれ、転送速度の上限値を別個に設定でき、その上限値以内に転送速度を抑えることが可能である。ノード2が有する送信管理部21及び受信管理部22、ノード3が有する送信管理部31及び受信管理部32についても同様である。
The
したがって、例えば、ノード1からノード2にファイルを転送する場合、ノード1の送信管理部11又はノード2の受信管理部22が転送速度を設定すれば、当該転送速度でファイルをノード1からノード2に転送することができる。また、例えば、ノード2及び3からノード1にファイルを同時に転送する場合でも、各ノードの送信管理部又は受信管理部が転送速度を設定すればよい。以下、具体例を2つ挙げて、送信管理部11及びノード2の受信管理部22の機能を説明する。
Therefore, for example, when transferring a file from node 1 to node 2, if the
第1の具体例は、ノード1からノード2に転送速度500Mbpsでファイルを転送する場合であり、図2に示すような態様となる。なお、図2に示された表において、「送信側」及び「受信側」の各列に記載された数値は、ノード1及び2がそれぞれ有する送信管理部及び受信管理部の各転送速度メモリに記憶される転送速度のデータを示すものである。 The first specific example is a case where a file is transferred from the node 1 to the node 2 at a transfer rate of 500 Mbps, and the mode is as shown in FIG. In the table shown in FIG. 2, the numerical values described in the “transmission side” and “reception side” columns are stored in the transfer rate memories of the transmission management unit and the reception management unit of the nodes 1 and 2, respectively. The data of the transfer rate memorize | stored is shown.
まず、本実施の形態においては通信規格としてIEEE802.3zを用いているので、転送速度の上限値は、送信側及び受信側とも転送速度1000Mbpsとしてファイルの転送前(例えばアプリケーション起動時)に予め設定される。 First, since IEEE 802.3z is used as a communication standard in the present embodiment, the upper limit value of the transfer rate is set in advance on the transmission side and the reception side as a transfer rate of 1000 Mbps before file transfer (for example, when an application is started). Is done.
次いで、ノード1の送信管理部11は、例えばユーザIF部15からの制御信号に基づき、ファイルの送信時の転送速度希望値を500Mbpsに設定する。
Next, the
さらに、送信管理部11は、転送速度希望値が上限値を超えていないため、ノード2に対して500Mbpsでファイルを送信することを要求する。ノード2は、この要求を受け取り、受信管理部22の転送速度メモリに希望値として500Mbpsの値を格納したうえで、この希望値が受信時の転送速度の上限値を超えていないことを確認し、この要求を承諾する(図2(a))。
Furthermore, since the desired transfer rate does not exceed the upper limit value, the
その後、ノード2は、受信管理部22の転送速度メモリに実施値として500Mbpsの値を格納し、ノード1に対し500Mbpsでファイルを転送することを指示する。ノード1はこの指示に対し、送信時の転送速度の実施値として500Mbpsの値を送信管理部11の転送速度メモリに格納する(図2(b))。そして、ノード1はノード2に対しファイルを500Mbpsで転送する(図2(c))。
Thereafter, the node 2 stores a value of 500 Mbps as the implementation value in the transfer rate memory of the
なお、ファイルの転送速度の制御は、ノード1の送信管理部11が行う方法と、ノード2の受信管理部22が行う方法の2つがある。受信管理部22が転送速度を制御する場合は、送信側のノードが転送速度を知る必要がなければ、図2(b)に示すような送信指示の動作は必須ではなく、また送信側の希望値や実施値を管理することは必須ではない。
There are two methods for controlling the file transfer rate: a method performed by the
第2の具体例は、ノード2からノード1に通常ファイルを転送し、同時に、ノード3からノード1に転送速度800Mbpsで優先ファイルを転送する場合であり、図3(a)に示すような態様となる。なお、図3(a)に示された表において、「送信側」及び「受信側」の各列に記載された数値は、ノード1〜3がそれぞれ有する送信管理部及び受信管理部の各転送速度メモリに記憶される転送速度のデータを示すものである。 The second specific example is a case where a normal file is transferred from the node 2 to the node 1 and at the same time, a priority file is transferred from the node 3 to the node 1 at a transfer rate of 800 Mbps, as shown in FIG. It becomes. In the table shown in FIG. 3A, the numerical values described in the columns “transmission side” and “reception side” are the values of the transmission management unit and the reception management unit respectively included in the nodes 1 to 3. It shows transfer rate data stored in the speed memory.
図3(a)に示すように、ノード2においては転送速度の希望値は「自動」となっており、ノード3においては転送速度の希望値として800Mbpsが設定されている。この場合、ノード1は、ノード3からのファイルは転送速度が指定されているので当該ファイルを優先ファイルと判断し、ノード2からのファイルは転送速度が指定されていないので当該ファイルを通常ファイルとして扱う。その結果、ノード3からのファイルの転送速度実施値として800Mbpsが設定され、ノード2からのファイルの転送速度実施値として、上限値である1000Mbpsから800Mbpsを差し引いた200Mbpsが設定される。
As shown in FIG. 3A, the desired value of the transfer rate is “automatic” in the
本実施の形態における通信部16は、例えばファイルを送信するノードのポート番号を識別し、入力されたファイルを優先ファイル又は通常ファイルは別々のファイル送受信手段10のスレッドがそれぞれ断続的に受信し蓄積装置11に出力されるようになっている。通常ファイルを受信しているファイル送受信手段10のスレッドはノード2から時間5tのうちtだけ受信し、優先ファイルを受信しているファイル送受信手段10のスレッドはノード3から時間5tのうち4tだけ受信する。2つのスレッドの受信のタイミングが異なっても、TCP/IPのフロー制御により、ノード1の受信はおおよそ図3(b)の概念図に示すようになる。その結果、ノード2及び3からの各ファイルの転送速度は、それぞれ200Mbps及び800Mbpsとなる。
The
すなわち、ノード1の受信管理部12は、通常ファイルを受信する受信状態と通常ファイルの受信を所定時間待機する受信待機状態とを設定し、受信状態及び受信待機状態の切替制御を行うことによって、通常ファイルの転送速度を抑制し、優先ファイルの転送を優先するよう優先ファイル及び通常ファイルの転送速度を制御するものである。
That is, the
なお、前述の説明では、ファイルの転送速度の制御をノード1の受信管理部12、すなわち優先ファイルの受信側で行うものとしたが、優先ファイルの送信側で行うこともできる。例えば、ノード3が、優先ファイルをノード1に送信し、同時に通常ファイルをノード2に送信する場合では、ノード3の送信管理部31は、通常ファイルを送信する送信状態と通常ファイルの送信を所定時間待機する送信待機状態とを設定し、送信状態及び送信待機状態の切替制御を行うことによって、通常ファイルの転送速度を抑制し、優先ファイルの転送を優先するよう優先ファイル及び通常ファイルの転送速度を制御する。
In the above description, the file transfer rate is controlled on the
図1に戻り、ノード1の構成の説明を続ける。
ファイル送受信部13は、送受信するファイルのデータを一時保存するリングバッファを備えており、このリングバッファの状態を把握するようになっている。また、このリングバッファの状態は、送信管理部11及び受信管理部12によっても把握できるようになっている。
Returning to FIG. 1, the description of the configuration of the node 1 will be continued.
The file transmitting / receiving
また、ファイル送受信部13は、予め設定された通信プロトコルに従ってファイルを送信又は受信するようになっている。この通信プロトコルには、少なくとも、コマンド及びコマンドに付随する引数を送信して当該コマンドに対するステータスを返すコマンド転送フェーズと、データを送受信するデータ転送フェーズとが含まれるものが好ましい。
Further, the file transmission /
例えば、コマンド転送フェーズの中で、送受信元ノードの希望送受信データ転送速度をコマンドの引数として送ることができ、希望に対する送受信先ノードの送受信可能データ転送速度をステータスの一部として返すことができるような仕組みにしておく。転送するファイルのサイズが比較的大きい場合は、データの送受信単位を小さく設定しておき、このデータの送受信単位ごとに、コマンド転送フェーズ及びデータ転送フェーズを行う。なお、データの送受信単位は、小さくしすぎるとファイルの転送速度が遅くなり、逆に大きくしすぎるとデータ転送速度の変更指示やデータ転送停止コマンドなどに対する応答が遅くなるため、ファイルの転送速度が遅くならない範囲でデータの送受信単位を小さくするのが好ましい。 For example, in the command transfer phase, the desired transmission / reception data transfer rate of the transmission / reception source node can be sent as an argument of the command, and the transmit / receive data transfer rate of the transmission / reception destination node corresponding to the request can be returned as a part of the status. Keep it in good working order. When the size of the file to be transferred is relatively large, the data transmission / reception unit is set small, and the command transfer phase and the data transfer phase are performed for each data transmission / reception unit. If the data transmission / reception unit is too small, the file transfer speed will be slow, and if it is too large, the response to the data transfer speed change command or data transfer stop command will be slow, so the file transfer speed will be low. It is preferable to reduce the data transmission / reception unit within a range that does not slow down.
ここで、前述の通信プロトコルの一例を図4に示す。図4は、蓄積装置17に蓄積されているファイルをノード1がノード2に転送するときのTCP上での通信プロトコルの一例を示すものである。なお、図4ではTCPよりも下のレイヤの処理、例えばACK(ACKnowledgement)パケットや再送パケットの送信等の処理は省略している。
Here, an example of the above-described communication protocol is shown in FIG. FIG. 4 shows an example of a communication protocol on the TCP when the node 1 transfers the file stored in the
図4に示すように、まず、コマンド転送フェーズにおいて、ノード1からノード2に対して、コマンド及びコマンドの引数を送信し、ノード2からノード1に対してそのコマンド応答を返す。次に、ノード1は、コマンド応答が返ってきたら、データ転送フェーズにおいて、所定サイズに分割されたファイルを1ブロック分ずつ順次送信する。なお、ノード1は、転送を中断するときは中断するためのコマンドをノード2に送信する。また、ノード1は、送信速度を変更したいときはコマンドの引数として送信希望速度の情報をノード2に送信し、ノード2は受信可能速度の情報をコマンド応答の中でノード1に返す。 As shown in FIG. 4, first, in the command transfer phase, the command and command arguments are transmitted from the node 1 to the node 2, and the command response is returned from the node 2 to the node 1. Next, when the command response is returned, the node 1 sequentially transmits the files divided into predetermined sizes one block at a time in the data transfer phase. Note that the node 1 transmits a command to the node 2 to suspend the transfer. Further, when the node 1 wants to change the transmission rate, the node 1 transmits information on the desired transmission rate to the node 2 as an argument of the command, and the node 2 returns information on the receivable rate to the node 1 in the command response.
以上のように、ファイル送受信部13は、ファイル転送中であっても、例えばユーザの指示によりファイルの転送の中断や転送レートの変更を行うことができる。
As described above, even during file transfer, the file transmission /
再び図1に戻り、ノード1の構成の説明を続ける。 Returning to FIG. 1 again, the description of the configuration of the node 1 will be continued.
蓄積装置制御部14は、ファイル送受信部13からの制御信号に基づいて動作し、蓄積装置17からファイルを読み出す動作、及び蓄積装置17にファイルを書き込む動作を制御するようになっている。
The storage
ユーザIF部15は、例えばキーボードやディスプレイ等の入出力デバイスに接続され、ユーザが入力した転送速度情報を含む制御情報を送信管理部11、受信管理部12及びファイル送受信部13に伝達するようになっている。
The user IF unit 15 is connected to an input / output device such as a keyboard or a display, for example, and transmits control information including transfer speed information input by the user to the
次に、本実施の形態におけるノード1〜3の動作について図1を用いて説明する。 Next, the operation of the nodes 1 to 3 in the present embodiment will be described with reference to FIG.
最初に、ノード2の指示で、ノード2から転送されたファイルをノード1が蓄積装置17に蓄積する場合の動作例について説明する。この場合、ノード1及び2は、それぞれ、本発明の受信装置及び送信装置に対応する。
First, an operation example when the node 1 stores the file transferred from the node 2 in the
まず、ノード2のファイル送受信部23は、ノード1に転送する所定ファイルの送信を要求するためのputコマンドを発行する。このputコマンドを含む信号は、ノード2の送信管理部21及び通信部26、ノード1の通信部16及び受信管理部12を順次経由してノード1のファイル送受信部13に入力される。
First, the file transmitting / receiving
次いで、送信コマンドを受信したファイル送受信部13は、ファイルの送り先として蓄積装置制御部14を指定する。また、ファイル送受信部13は、送信コマンドを正しく受け取ったことをノード2に知らせるためにステータス信号を生成して送信する。このステータス信号は、ノード1の送信管理部11及び通信部16、ノード2の通信部26及び受信管理部22を順次経由して、ノード2のファイル送受信部23に入力される。
Next, the file transmission /
続いて、ノード2の通信部26から転送されたファイルのデータは、ノード1の通信部16で受信された後、受信管理部12に送られる。受信管理部12には、受信できる最大転送速度が例えばユーザIF部15によって予め設定されており、受信管理部12は、この最大転送速度を超えないようにファイル送受信部13にファイルのデータを渡す。ファイル送受信部13に入るファイルのデータはそのまま蓄積装置制御部14に渡され、蓄積装置制御部14の制御のもと蓄積装置17に蓄積される。
Subsequently, the file data transferred from the
次に、ノード2の指示で、ノード1の蓄積装置17に蓄積されているファイルをノード1からノード2に転送する場合の動作例について説明する。この場合、ノード1及び2は、それぞれ、本発明の送信装置及び受信装置に対応する。
Next, an operation example in the case where a file stored in the
まず、ノード2のファイル送受信部23は、ノード1から転送される所定ファイルの受信を要求するためのgetコマンドを発行する。このgetコマンドを含む信号は、ノード2の送信管理部21及び通信部26、ノード1の通信部16及び受信管理部12を順次経由してノード1のファイル送受信部13に入力される。
First, the file transmitting / receiving
次いで、受信コマンドを受信したファイル送受信部13は、ファイル取り出し先として蓄積装置制御部14を指定する。また、ファイル送受信部13は、受信コマンドを正しく受け取ったことをノード2に知らせるためにステータス信号を生成して送信する。このステータス信号は、ノード1の送信管理部11及び通信部16、ノード2の通信部26及び受信管理部22を順次経由して、ノード2のファイル送受信部23に入力される。
Next, the file transmission /
続いて、ファイル送受信部13は、蓄積装置制御部14に対して所定ファイルを取り出すよう指示する。蓄積装置制御部14は、蓄積装置17から所定ファイルを取り出し、ファイル送受信部13が受け取る。所定ファイルのデータはそのままノード1の送信管理部11に送られる。送信管理部11には、送信できる最大転送速度が例えばユーザIF部15により予め設定されており、所定ファイルのデータは、この最大転送速度を超えないようにノード1の通信部16に渡され、そのままノード2の通信部26に転送される。
Subsequently, the file transmission /
次に、ノード2の指示で、ノード1が、ノード2から転送されたファイルを中継してノード3に転送する場合の動作例について説明する。この場合、ノード2及び3は、それぞれ、本発明の送信装置及び受信装置に対応し、ノード1は、本発明の中継装置に対応する。 Next, an operation example when the node 1 relays the file transferred from the node 2 and transfers it to the node 3 in accordance with the instruction of the node 2 will be described. In this case, the nodes 2 and 3 correspond to the transmission device and the reception device of the present invention, respectively, and the node 1 corresponds to the relay device of the present invention.
まず、ノード2のファイル送受信部23は、ノード1経由でノード3に転送する所定ファイルの送信を要求するためのputコマンドを発行する。このputコマンドを含む信号は、ノード2の送信管理部21及び通信部26、ノード1の通信部16及び受信管理部12を順次経由してノード1のファイル送受信部13に入力される。
First, the file transmitting / receiving
putコマンドを受信したファイル送受信部13は、ファイル送り先としてノード3を指定する。putコマンドは、さらに、ノード2からノード1に送られた手順と同様な手順でノード1からノード3に送られる。ファイル送受信部13はコマンドを正しく受け取ったことをノード2に知らせるために、ノード3から返ってくるステータス信号を受け取り、そのままノード1にステータス信号を返す。ステータス信号は、ノード3のファイル送受信部33から、ノード3の送信管理部31及び通信部36、ノード1の通信部16、受信管理部12、ファイル送受信部13、送信管理部11及び通信部16、ノード2の通信部26及び受信管理部22を順次経由して、ノード2のファイル送受信部23に伝えられる。
The file transmission /
続いて、ノード2の通信部26から転送された所定ファイルのデータは、ノード1の通信部16で受け取られ、所定ファイルのデータはそのままノード1の受信管理部12に送られる。受信管理部12には、受信できる最大転送速度が例えばユーザIF部15により予め設定されており、所定ファイルのデータは、この最大転送速度を超えないようにファイル送受信部13に渡される。
Subsequently, the data of the predetermined file transferred from the
ファイル送受信部13に届いた所定ファイルのデータは、さらに、ノード1の送信管理部11及び通信部16、ノード3の通信部36及び受信管理部32を順次経由して、ノード3のファイル送受信部33に送られる。ここで、送信管理部11には、送信できる最大転送速度が例えばユーザIF部15により予め設定されており、送信管理部11は、この最大転送速度を超えないように通信部16に所定ファイルのデータを渡す。
The data of the predetermined file that has arrived at the file transmission /
前述の動作の説明から明らかなように、本発明の係るノードは、複数のノードから転送されたファイルを受信して蓄積する受信装置や、蓄積されているファイルを複数ノードに送信する送信装置、あるノードから転送されたファイルを蓄積しながら別のノードに当該ファイルを送信する中継装置を兼ねた受信装置等に適用することができる。 As is apparent from the above description of the operation, the node according to the present invention includes a receiving device that receives and accumulates files transferred from a plurality of nodes, and a transmitting device that transmits accumulated files to the plurality of nodes. The present invention can be applied to a receiving device that also serves as a relay device that transmits a file to another node while accumulating the file transferred from a certain node.
次に、送信管理部11が転送速度を制御する場合の動作の詳細について図1及び図5を用いて説明する。なお、ファイル送信時の転送速度をrとする。
Next, details of the operation when the
図5は、ファイル送受信部13及び送信管理部11の動作例を示すフロー図である。図5に示すように、ファイル送受信部13及び送信管理部11は、別々のスレッドで並列に動作する。前述したように、ファイル送受信部13はリングバッファを備えており、このリングバッファの状態をファイル送受信部13が把握するとともに送信管理部11も参照できる。リングバッファへの読み書きはブロック単位で行うものとする。ブロックサイズは任意であるが、ノード1内のメインメモリの空き容量や転送のパフォーマンスを考慮すると、通常、数キロバイトから数メガバイトのオーダーが好ましい。なお、図5において、開始時点ではリングバッファの初期化や他のノードとの通信は既に確立しているものとし、終了時点ではノードとの通信は切断されるものとする。
FIG. 5 is a flowchart showing an operation example of the file transmission /
ユーザからのファイル転送要求は、図1に示されたユーザIF部15を介してファイル送受信手段10で処理されるアプリケーション内に用意された変数であるコマンド値に逐次記録されるものとする。例えば、ノード1に蓄積されているファイルをノード1がノード2に転送する場合は、putコマンドを示す値がコマンド値に記録される。putコマンドを中断するときは、stopコマンドを示す値がコマンド値に記録される。また、図5において、開始時点では既にputコマンドが発行されており、コマンド値には既にputコマンドを示す値が記録されているものとする。 The file transfer request from the user is sequentially recorded in a command value which is a variable prepared in an application processed by the file transmitting / receiving means 10 via the user IF unit 15 shown in FIG. For example, when the node 1 transfers the file stored in the node 1 to the node 2, a value indicating the put command is recorded in the command value. When the put command is interrupted, a value indicating the stop command is recorded in the command value. In FIG. 5, it is assumed that a put command has already been issued at the start time, and a value indicating the put command has already been recorded in the command value.
まず、ファイル送受信部13では、コマンド確認処理(S11)において、コマンド値がputコマンドかstopコマンドかを確認し、putコマンドであればリングバッファ空き領域確認処理(S12)に進み、stopコマンドであれば終了フラグセット処理(S16)に進む。
First, the file transmission /
次いで、リングバッファ空き領域確認処理(S12)において、リングバッファの空き領域を確認し、空き領域がある場合はファイル読出処理(S13)に進み、空き領域がない場合はスリープ処理(S15)を経てコマンド確認処理(S11)に戻る。ここで、スリープ処理(S15)は、数マイクロ秒から数ミリ秒程度一定時間休止する処理である。 Next, in the ring buffer free area confirmation process (S12), the ring buffer free area is confirmed, and if there is a free area, the process proceeds to the file reading process (S13), and if there is no free area, the process proceeds to the sleep process (S15). The process returns to the command confirmation process (S11). Here, the sleep process (S15) is a process of pausing for a certain period of time from several microseconds to several milliseconds.
さらに、ファイル読出処理(S13)において、蓄積装置17からファイルのデータを1ブロック分だけ読み出し、ファイル送受信部13のリングバッファに書き込む。
Further, in the file reading process (S 13), the file data is read from the
続いて、データ読出確認処理(S14)において、ファイルデータの読み出しが完了したか否かを確認し、読み出しが完了した場合は終了フラグセット処理(S16)に進み、読み出しが完了していない場合はコマンド確認処理(S11)に戻る。 Subsequently, in the data reading confirmation process (S14), it is confirmed whether or not the reading of the file data is completed. If the reading is completed, the process proceeds to the end flag setting process (S16), and when the reading is not completed. The process returns to the command confirmation process (S11).
一方、送信管理部11では、開始直後に現在時刻取得処理(S21)において内部時計から現在時刻情報をマイクロ秒からミリ秒の精度で取得し、アプリケーション内に用意された変数tに代入する。ここで、初期値が0である積算時間tsを定義し、ts:=ts+(t−t0)によりtsの値を更新する。なお、t0は前回に現在時刻取得処理(S21)が実行された後に得られたtの値であり、初めて現在時刻取得処理(S21)が実行された後にはt0の値はないため、t−t0=0とする。また、tsの値を更新後、t0:=tにより、t0の値も更新する。
On the other hand, the
次いで、リングバッファデータ有無確認処理(S22)において、リングバッファにデータがあるか否かを確認し、データがある場合はデータ量を変数bに代入した後に送信判定処理(S23)に進み、データがない場合はスリープ処理(S26)を経て現在時刻取得処理(S21)に戻る。ここで、スリープ処理(S26)は、数マイクロ秒から数秒程度一定時間休止する処理である。この休止時間をtpとする。休止時間tpは、上記t−t0と同じ値ではなく、現在時刻取得処理(S21)、リングバッファデータ有無確認処理(S22)等の処理に要した時間だけ小さな値となる。 Next, in the ring buffer data presence / absence confirmation process (S22), it is confirmed whether or not there is data in the ring buffer. If there is data, the data amount is substituted into the variable b and then the process proceeds to the transmission determination process (S23). If there is not, the process returns to the current time acquisition process (S21) through the sleep process (S26). Here, the sleep process (S26) is a process of pausing for a certain period of time from several microseconds to several seconds. This pause time is assumed to be tp. The pause time tp is not the same value as the above-mentioned t−t0, but is a value that is smaller by the time required for the current time acquisition process (S21), the ring buffer data presence / absence confirmation process (S22), and the like.
なお、現在時刻取得処理(S21)において取得される時刻の精度が粗い場合は、休止時間tpとt−t0とが同じ値になることもある。また、休止時間tpを小さな値にするほどデータ転送速度を細かな時間単位で制御できるがCPUの負荷は大きくなる。 If the accuracy of the time acquired in the current time acquisition process (S21) is rough, the pause time tp and t−t0 may be the same value. Further, as the pause time tp is decreased, the data transfer rate can be controlled in fine time units, but the load on the CPU increases.
ここで、初期値が0である積算データ量bsを定義し、bs:=bs+(b−b0)によりbsの値を更新する。b0は前回にリングバッファデータ有無確認処理(S22)が実行された後に得られたbの値であり、初めてリングバッファデータ有無確認処理(S22)が実行された後にはb0=0となっている。積算データ量bsの値を更新後、b0:=bにより、b0の値も更新する。ファイルのデータをブロック単位で扱うため、b、b0及びbsの値は1ブロックのデータ量buの倍数となる。送信判定処理(S23)では、ts×r>buを満たすときはファイル送信処理(S24)に進み、上記条件を満たさないときはスリープ処理(S26)を経由して現在時刻取得処理(S21)に戻る。 Here, an integrated data amount bs whose initial value is 0 is defined, and the value of bs is updated by bs: = bs + (b−b0). b0 is the value of b obtained after the previous execution of the ring buffer data presence / absence confirmation processing (S22), and b0 = 0 after the first execution of the ring buffer data presence / absence confirmation processing (S22). . After updating the value of the integrated data amount bs, the value of b0 is also updated by b0: = b. Since the file data is handled in units of blocks, the values of b, b0 and bs are multiples of the data amount bu of one block. In the transmission determination process (S23), the process proceeds to the file transmission process (S24) when ts × r> bu is satisfied, and to the current time acquisition process (S21) via the sleep process (S26) when the above condition is not satisfied. Return.
ファイル送信処理(S24)では、例えば前述の図4に示すファイル転送プロトコルに従って1ブロック分のデータをファイル送信先のノードに送信し、bs:=bs−bu、ts:=ts−bu/rに従って変数bs、tsの値を更新する。終了フラグ確認処理(S25)では、ファイル送受信部13における終了フラグセット処理(S16)において終了フラグがセットされているか否かを確認し、終了フラグがセットされていればstopコマンド送信処理(S27)に進み、終了フラグがセットされていなければ現在時刻取得処理(S21)に戻る。stopコマンド送信処理(S27)では、stopコマンドをファイル送信先であるノードに送信する。
In the file transmission process (S24), for example, one block of data is transmitted to the file transmission destination node in accordance with the file transfer protocol shown in FIG. 4, and according to bs: = bs-bu, ts: = ts-bu / r. The values of the variables bs and ts are updated. In the end flag confirmation process (S25), it is confirmed whether or not the end flag is set in the end flag setting process (S16) in the file transmission /
以上のように、送信管理部11が転送速度を制御する場合は、送信判定処理(S23)及びスリープ処理(S26)を設けたことにより、ファイルの送信を断続的に行うことができる。したがって、図5に示された処理工程を送信管理部11に複数並行して同時に実行させることにより、本実施の形態に係るノード1は、優先ファイル及び通常ファイルを例えば図3(b)に示すように断続的に送信することができ、優先ファイルを指定された転送速度で、また通常ファイルをできる限り高速な転送速度で所定のノードに送信することができる。
As described above, when the
次に、受信管理部12が転送速度を制御する場合の動作の詳細について図1及び図6を用いて説明する。なお、ファイル受信時の転送速度をrとする。
Next, details of the operation when the
図6は、ファイル送受信部13及び受信管理部12の動作例を示すフロー図である。図6に示すように、ファイル送受信部13及び受信管理部12は、別々のスレッドで並列に動作する。前述したように、ファイル送受信部13はリングバッファを備えており、このリングバッファの状態をファイル送受信部13が把握するとともに受信管理部12も参照できる。リングバッファに対する読み書きはブロック単位で行うものとする。ブロックサイズは任意であるが、ノード1内のメインメモリの空き容量や転送のパフォーマンスを考慮すると、通常、数キロバイトから数メガバイトのオーダーのブロックサイズが好ましい。なお、図6において、開始時点ではリングバッファの初期化や他のノードとの通信は既に確立しているものとし、終了時点では他のノードとの通信は切断されるものとする。
FIG. 6 is a flowchart showing an operation example of the file transmission /
ユーザからのファイル転送要求は、図1に示されたユーザIF部15を介してファイル送受信手段10で処理されるアプリケーション内の変数であるコマンド値に逐次記録される。例えば、ノード1に蓄積されているファイルをノード1がノード2に転送する場合は、putコマンドを示す値がコマンド値に記録される。putコマンドを中断するときは、stopコマンドを示す値がコマンド値に記録される。また、図6において、開始時点では既にputコマンドが発行されており、コマンド値は既にputコマンドを示す値が記録されているものとする。 The file transfer request from the user is sequentially recorded in a command value which is a variable in the application processed by the file transmitting / receiving means 10 via the user IF unit 15 shown in FIG. For example, when the node 1 transfers the file stored in the node 1 to the node 2, a value indicating the put command is recorded in the command value. When the put command is interrupted, a value indicating the stop command is recorded in the command value. In FIG. 6, it is assumed that a put command has already been issued at the start time, and a value indicating the put command has already been recorded as the command value.
まず、ファイル送受信部13では、コマンド確認処理(S31)において、コマンド値がputコマンドかstopコマンドかを確認し、putコマンドであればリングバッファデータ有無確認処理(S32)に進み、stopコマンドであれば終了フラグセット処理(S36)に進む。
First, the file transmission /
次いで、リングバッファデータ有無確認処理(S32)において、リングバッファのデータの有無を確認し、データが有る場合は蓄積装置残量確認処理(S33)に進み、データが無い場合はスリープ処理(S35)を経てコマンド確認処理(S31)に戻る。ここで、スリープ処理(S35)は、数マイクロ秒から数ミリ秒程度一定時間休止する処理である。 Next, in the ring buffer data presence / absence confirmation processing (S32), the presence / absence of data in the ring buffer is confirmed. If there is data, the flow proceeds to the storage device remaining amount confirmation processing (S33), and if there is no data, the sleep processing (S35). After that, the process returns to the command confirmation process (S31). Here, the sleep process (S35) is a process of pausing for a certain period of time from several microseconds to several milliseconds.
蓄積装置残量確認処理(S33)では、蓄積装置17に残量があるか否かを確認し、残量がない場合は終了フラグセット処理(S36)に進み、残量がある場合はファイル書込処理(S34)を経てコマンド確認処理(S31)に戻る。ファイル書込処理(S34)では、リングバッファのデータを1ブロック分読み出し、ノード1の蓄積装置17に書き込む。
In the storage device remaining amount confirmation process (S33), it is confirmed whether or not the
一方、受信管理部12では、開始直後に現在時刻取得処理(S41)において内部時計より現在時刻をマイクロ秒からミリ秒の精度で取得し、アプリケーション内に用意された変数tに代入する。ここで初期値が0である積算時間tsを定義し、ts:=ts+(t−t0)によりtsの値を更新する。なお、t0は前回に現在時刻取得処理(S21)が実行された後に得られたtの値であり、初めて現在時刻取得処理(S21)が実行された後にはt0の値はないため、t−t0=0とする。またtsの値を更新後、t0:=tにより、t0の値も更新する。
On the other hand, the
次いで、リングバッファ空き領域確認処理(S42)において、リングバッファに空き領域があるか否かを確認し、空き領域がある場合は、アプリケーション内に用意された変数bにデータ量を代入してから受信判定処理(S43)に進み、空き領域がない場合はスリープ処理(S46)を経て現在時刻取得処理(S41)に戻る。ここで、スリープ処理(S46)は数マイクロ秒から数秒程度一定時間休止する処理である。この休止時間をtpとする。休止時間tpは上記t−t0と同じ値ではなく、現在時刻取得処理(S41)、リングバッファ空き領域確認処理(S42)等の処理に要した時間だけ小さな値となる。 Next, in the ring buffer free space confirmation process (S42), it is confirmed whether or not there is a free space in the ring buffer. If there is a free space, the data amount is substituted into the variable b prepared in the application. The process proceeds to the reception determination process (S43). If there is no free space, the process returns to the current time acquisition process (S41) through the sleep process (S46). Here, the sleep process (S46) is a process of pausing for a certain period of time from several microseconds to several seconds. This pause time is assumed to be tp. The pause time tp is not the same value as the above-mentioned t−t0, and is a value that is smaller by the time required for the current time acquisition process (S41), the ring buffer free space confirmation process (S42), and the like.
なお、現在時刻取得処理(S41)の時刻の精度が粗い場合は、休止時間tpとt−t0が同じ値になることもある。また、休止時間を小さな値にするほどデータ転送速度を細かな時間単位で制御できるがCPUの負荷は大きくなる。 Note that when the time accuracy of the current time acquisition process (S41) is rough, the pause time tp and t−t0 may be the same value. Further, the data transfer speed can be controlled in finer time units as the pause time is made smaller, but the load on the CPU increases.
ここで、初期値が0である積算データ量bsを定義し、bs:=bs+(b−b0)によりbsの値を更新する。b0は前回にリングバッファ空き領域確認処理(S42)が実行された後に得られたbの値であり、初めてリングバッファ空き領域確認処理(S42)が実行された後にはb0=0となっている。積算データ量bsの値を更新後、b0:=bにより、b0の値も更新する。ファイルのデータをブロック単位で扱うため、b、b0及びbsの値は1ブロックのデータ量buの倍数となる。受信判定処理(S43)では、ts×r>buを満たすときはファイル受信処理(S44)に進み、上記条件を満たさないときはスリープ処理(S46)を経由して現在時刻取得処理(S41)に戻る。 Here, an integrated data amount bs whose initial value is 0 is defined, and the value of bs is updated by bs: = bs + (b−b0). b0 is the value of b obtained after the previous ring buffer empty area confirmation process (S42) is executed, and b0 = 0 after the ring buffer empty area confirmation process (S42) is executed for the first time. . After updating the value of the integrated data amount bs, the value of b0 is also updated by b0: = b. Since the file data is handled in units of blocks, the values of b, b0 and bs are multiples of the data amount bu of one block. In the reception determination process (S43), the process proceeds to the file reception process (S44) when ts × r> bu is satisfied, and to the current time acquisition process (S41) via the sleep process (S46) when the above condition is not satisfied. Return.
ファイル受信処理(S44)では、例えば前述の図4に示すファイル転送プロトコルに従って1ブロック分のデータをファイル送信元のノードから受信し、bs:=bs−bu、ts:=ts−bu/rに従って変数bs,tsの値を更新する。終了フラグ確認処理(S45)では、ファイル送受信部13における終了フラグセット処理(S36)において終了フラグがセットされているか否かを確認し、終了フラグがセットされていればstopコマンド送信処理(S47)に進み、終了フラグがセットされていなければ現在時刻取得処理(S41)に戻る。stopコマンド送信処理(S47)では、stopコマンドをファイル送信元であるノードに送信する。
In the file reception process (S44), for example, one block of data is received from the file transmission source node according to the file transfer protocol shown in FIG. 4, and according to bs: = bs-bu, ts: = ts-bu / r. The values of the variables bs and ts are updated. In the end flag confirmation process (S45), it is confirmed whether or not the end flag is set in the end flag setting process (S36) in the file transmitting / receiving
以上のように、受信管理部12が転送速度を制御する場合は、受信判定処理(S43)及びスリープ処理(S46)を設けたことにより、ファイルの送信を断続的に行うことができる。したがって、図6に示された処理工程を受信管理部12に複数並行して同時に実行させることにより、本実施の形態に係るノード1は、優先ファイル及び通常ファイルを例えば図3(b)に示すように断続的に送信することができ、優先ファイルを指定された転送速度で、また通常ファイルをできる限り高速な転送速度で所定のノードに送信することができる。
As described above, when the
次に、2つのノードから同時に1つのノードにファイルを転送する場合であって、ファイル転送中に転送速度を変更する際の制御例について図7〜10を用いて説明する。以下の説明では、図7に示すように、2台のクライアント41及び42と、1台のサーバ43の合計3台のノードがあり、これらが1つのネットワークスイッチ44を介して接続されているものとする。ここで、図7に示されたクライアント41、42及びサーバ43は、それぞれ、図1に示されたノード2、3及び1に対応するものである。なお、図8〜10に示された表において、「送信側」及び「受信側」の各列に記載された数値は、クライアント41、42及びサーバ43がそれぞれ有する送信管理部及び受信管理部の各転送速度メモリに記憶される転送速度のデータを示すものである。
Next, a control example for changing the transfer speed during file transfer when transferring a file from two nodes to one node at the same time will be described with reference to FIGS. In the following description, as shown in FIG. 7, there are a total of three nodes, two
以下、次の3つステップにおける制御を順に行うときの3つのノード間のファイル転送について説明する。
(1)第1ステップ:クライアント41の指示でクライアント41に蓄積されているファイルをクライアント41からサーバ43に転送する。
(2)第2ステップ:続いて、クライアント41の指示でクライアント42に蓄積されているファイルをクライアント42からサーバ43に転送する。
(3)第3ステップ:さらに、クライアント41の指示でクライアント42からのファイルの転送速度を所望の転送速度に変更し、当該ファイルを優先ファイルとして転送する。
Hereinafter, file transfer between three nodes when the control in the following three steps is performed in order will be described.
(1) First step: The file stored in the
(2) Second step: Subsequently, the file stored in the
(3) Third step: Furthermore, the transfer rate of the file from the
以下の説明において、ネットワークの帯域を最大限に利用するため、ノードから転送速度の指定がない場合は最高速度で転送するものとする。また、転送速度の指定がある場合は、当該転送速度で転送されるファイルを優先ファイルとする。なお、IEEE802.3zを用いているので、転送速度の上限値は送信側、受信側とも1000Mbpsがファイルの転送前(例えばアプリケーション起動時)に予め設定されるものとする。 In the following description, in order to make maximum use of the network bandwidth, it is assumed that data is transferred at the maximum speed when no transfer speed is specified by the node. If the transfer rate is specified, the file transferred at the transfer rate is set as the priority file. Since IEEE802.3z is used, the upper limit of the transfer rate is set in advance to 1000 Mbps before the file transfer (for example, when the application is started) on both the transmission side and the reception side.
最初に、クライアント41に蓄積されているファイルをクライアント41からサーバ43に転送するときの手順を図8に示す。
First, FIG. 8 shows a procedure for transferring files stored in the
まず、クライアント41の送信側の転送速度希望値を「自動」に設定する。クライアント41の送信側は、サーバ43に対して「自動」で送信することを要求する。サーバ43は、この要求を受け取り、受信側の希望値に「自動」を示すデータを格納する(図8(a))。その後、サーバ43は、サーバ43の受信側の実施値にサーバ43の受信上限値である1000Mbpsの値を格納し、クライアント41に対し1000Mbpsで転送することを指示する。クライアント41はこの指示に対し、送信側の実施値に1000Mbpsの値を格納する(図8(b))。クライアント41はサーバ43に対しファイルを1000Mbpsで転送する(図8(c))。
First, the desired transfer rate on the transmission side of the
次に、図8(c)に示す状態で、クライアント42に蓄積されているファイルをクライアント42からサーバ43に転送するときの手順を図9に示す。
Next, FIG. 9 shows a procedure for transferring files stored in the
まず、クライアント42の送信側の転送速度希望値を「自動」に設定する。クライアント42の送信側は、サーバ43に対して「自動」で送信することを要求する。サーバ43は、この要求を受け取り、受信側の希望値に「自動」を示すデータを格納する(図9(a))。その後、サーバ43は、サーバ43の受信上限値である1000Mbpsの値を、受信側の希望値が「自動」となっている個数である2で割り、その値となる500Mbpsの値をサーバ43の受信側の両方の実施値に格納し、クライアント41及び42に対しそれぞれ500Mbpsで転送することを指示する。クライアント41及び42は、この指示に対し、それぞれ送信側の実施値に500Mbpsの値を格納する(図9(b))。クライアント41とクライアント42は、それぞれサーバ43に対しファイルを500Mbpsで転送する(図9(c))。
First, the desired transfer rate on the transmission side of the
次に、図9(c)に示す状態で、クライアント42からのファイルの転送速度を500Mbpsから800Mbpsに変更するときの手順を図10に示す。
Next, FIG. 10 shows a procedure for changing the file transfer rate from the
まず、クライアント42の送信側の転送速度希望値を800Mbpsに設定する。クライアント42の送信側は、サーバ43に対して800Mbpsで送信することを要求する。サーバ43は、この要求を受け取り、受信側の希望値に800Mbpsの値を格納する(図10(a))。その後、サーバ43は、この希望値が受信側の上限値を超えていないことを確認し、サーバ43の受信側のクライアント42に対する実施値に800Mbpsの値を格納し、サーバ43の受信上限値である1000Mbpsから800Mbpsを差し引いた200Mbpsの値をサーバ43の受信側のクライアント42に対する実施値に格納し、クライアント41及び42に対しそれぞれ200Mbps、800Mbpsの転送速度でファイルを転送することを指示する。クライアント41及び42は、この指示に対し、送信側の実施値にそれぞれ200Mbps及び800Mbpsの値を格納する(図10(b))。クライアント41及び42は、それぞれ、サーバ43に対しファイルを200Mbps及び800Mbpsで転送する(図10(c))。
First, the desired transfer rate on the transmission side of the
なお、転送が終了するときには、終了するノードが転送速度希望値を0に設定することで、他の転送にネットワークリソースを譲ることができる。例えば、仮にクライアント42からサーバ43への転送が先に完了すると、クライアント41からのファイルの転送速度は200Mbpsから1000Mbpsに戻る。また、前述の説明において、受信管理部で転送速度を制御する場合は、送信指示は必須ではなく、ノード1の送信側の希望値や実施値を管理することは必須ではない。
When the transfer ends, the node that ends sets the desired transfer rate to 0, so that network resources can be transferred to another transfer. For example, if the transfer from the
以上のように、本実施の形態におけるノード1によれば、優先ファイル及び通常ファイルの受信又は送信を行う際に、優先ファイルの転送速度を所定の転送速度に設定し、通常ファイルの転送速度を優先ファイルの転送速度に応じた転送速度に設定する構成としたので、優先ファイルを通常ファイルに優先して転送するよう転送速度を制御することができる。 As described above, according to the node 1 in the present embodiment, when the priority file and the normal file are received or transmitted, the transfer speed of the priority file is set to a predetermined transfer speed, and the transfer speed of the normal file is set. Since the transfer speed is set according to the transfer speed of the priority file, the transfer speed can be controlled so that the priority file is transferred with priority over the normal file.
したがって、本実施の形態におけるノード1は、ネットワーク接続されている複数のノード間でファイルの転送が行われている状況においても、優先ファイルの転送を通常ファイルの転送よりも優先させながら通常ファイル転送を可能な限り高速で転送することができる。 Therefore, the node 1 according to the present embodiment performs normal file transfer while giving priority to priority file transfer over normal file transfer even in a situation where file transfer is performed between a plurality of nodes connected to the network. Can be transferred as fast as possible.
また、本実施の形態におけるノード1は、前述の構成により、例えばユーザが指定した転送速度を維持しながら優先ファイルを転送することができる。 Further, the node 1 in the present embodiment can transfer the priority file with the above-described configuration, for example, while maintaining the transfer speed designated by the user.
また、本実施の形態におけるノード1は、前述の構成により、優先ファイルをストリーミング転送のファイルとして転送することもできる。 Further, the node 1 in the present embodiment can also transfer the priority file as a streaming transfer file by the above-described configuration.
また、本実施の形態におけるノード1によれば、優先ファイル及び通常ファイルの受信又は送信を行う際に、優先ファイル及び通常ファイルのデータを断続的に受信し、又は送信する構成としたので、処理負荷を増大させることなくファイルの送信又は受信を行うことができる。 In addition, according to the node 1 in the present embodiment, when receiving or transmitting the priority file and the normal file, the data of the priority file and the normal file is intermittently received or transmitted. A file can be transmitted or received without increasing the load.
なお、前述の実施の形態において、ノード1が1つの通信部16を備え、通信部16が2つのノード2及び3と通信する構成を例に挙げて説明したが、本発明はこれに限定されるものではなく、例えばノード1に接続されるノードの個数だけ通信部を設け、各通信部が各ノードとそれぞれ別個に通信する構成としてもよい。この場合、各通信部には送信管理部及び受信管理部がそれぞれ設けられる構成となる。
In the above-described embodiment, the configuration in which the node 1 includes one
(第2の実施の形態)
本発明に係るノードの第2の実施の形態における主要部は、図11に示すように構成されている。すなわち、本実施の形態におけるノードは、第1の実施の形態におけるノード1の受信管理部12(図1参照)及び通信部16の構成を変更したものである。なお、第1の実施の形態におけるノード1と同じ符号を用いて説明する。また、図11に示す主要部の構成以外は、第1の実施の形態におけるノード1と同じ構成であるので、説明を省略する。
(Second Embodiment)
The main part of the second embodiment of the node according to the present invention is configured as shown in FIG. That is, the node in the present embodiment is obtained by changing the configuration of the reception management unit 12 (see FIG. 1) and the
図11に示すように、本実施の形態におけるノードの受信管理部12は、通信部16から優先ファイル及び通常ファイルを受信するようになっており、優先ファイルを一時的に記憶するリングバッファを有する優先ファイルリングバッファ12aと、通常ファイルを一時的に記憶するリングバッファを有する通常ファイルリングバッファ12bと、優先ファイルリングバッファ12a及び通常ファイルリングバッファ12bのバッファ数を設定するバッファ数設定部12cとを備えている。
As shown in FIG. 11, the
本実施の形態における通信部16は、例えばファイルを送信するノードのポート番号を識別し、入力されたファイルを優先ファイル又は通常ファイルに分別して受信管理部12に出力するようになっている。
The
優先ファイルリングバッファ12aは、例えばFIFO(First In First Out)型のメモリで構成され、複数に区分された記憶領域を備えている。優先ファイルリングバッファ12aは、通信部16から優先ファイルのみを入力して記憶し、入力した順序でファイル送受信部13に出力するようになっている。
The priority
通常ファイルリングバッファ12bは、例えばFIFO型のメモリで構成され、複数に区分された記憶領域を備えている。通常ファイルリングバッファ12bは、通信部16から通常ファイルのみを入力して記憶し、入力した順序でファイル送受信部13に出力するようになっている。
The normal
バッファ数設定部12cは、優先ファイルリングバッファ12a及び通常ファイルリングバッファ12bがそれぞれ有する記憶領域の区分数(以下「バッファ数」という。)を設定するようになっている。
The buffer
具体的には、バッファ数設定部12cは、優先ファイルリングバッファ12aが有するバッファ数をn、通常ファイルリングバッファ12bが有するバッファ数をmとし、ファイル受信時の転送速度をr、転送速度の上限値をrmaxとすると、n:m=r:rmax−rとなるようn及びmを設定するようになっている。
Specifically, the buffer
なお、優先ファイルリングバッファ12a及び通常ファイルリングバッファ12bは、本発明のバッファに対応している。また、バッファ数設定部12cは、本発明のバッファ数比率設定部に対応している。
The priority
本実施の形態におけるノードは、前述のように構成されているので、ノードに入力されたファイルが、優先ファイルであれば優先ファイルリングバッファ12aに、通常ファイルであれば通常ファイルリングバッファ12bに入力される。
Since the node in the present embodiment is configured as described above, if the file input to the node is a priority file, the file is input to the priority
優先ファイルリングバッファ12aには優先ファイルしか入ることができないため、通常ファイルは、通常ファイルリングバッファ12bに空き領域がなく、かつ優先ファイルリングバッファ12aに空き領域があっても、優先ファイルリングバッファ12aには入力されない。この場合、通常ファイルリングバッファ12bに空き領域ができるまでは、TCPのフロー制御により通常ファイルの転送は中断され、通信部16のリングバッファに留まることとなる。通常ファイルの転送が中断している間は、優先ファイルのみが転送される。なお、優先ファイルリングバッファ12aに既に記憶された優先ファイルと、通常ファイルリングバッファ12bに既に記憶された通常ファイルは、平等にファイル送受信部13に送られる。
Since only the priority file can enter the priority
以上のように、バッファ数設定部12cが、優先ファイルリングバッファ12a及び通常ファイルリングバッファ12bの各バッファ数を逐次制御することにより、優先ファイルは指定された受信転送速度を維持して転送される。一方、通常ファイルは、TCPのフロー制御に従って自動的に残りの帯域が割り当てられ、優先ファイルの転送に影響を及ぼすことなく可能な限り高速に転送される。
As described above, the priority number file is transferred while maintaining the designated reception transfer rate by the buffer
次に、第1の実施の形態において図7〜10を用いて説明した第1〜3ステップにおける動作について説明する。 Next, the operation in the first to third steps described with reference to FIGS. 7 to 10 in the first embodiment will be described.
第1ステップでは、転送速度が特に指定されていないので、バッファ数設定部12cは、優先ファイルリングバッファ12aのバッファ数を0に設定し、クライアント41からのファイルは通常ファイルリングバッファ12bにのみに記憶される。このときの転送速度は最大転送速度である1000Mbpsとなる。
In the first step, since the transfer rate is not particularly specified, the buffer
第2ステップでは、第1ステップと同様に、転送速度が特に指定されていないので、バッファ数設定部12cは、優先ファイルリングバッファ12aのバッファ数を0に設定し、クライアント42からのファイルは通常ファイルリングバッファ12bにのみに記憶される。ここで、クライアント41及び42からのファイルは、TCPのフロー制御に従ってほぼ平等に入力されるため、転送速度は、共に約500Mbpsとなる。
In the second step, as in the first step, since the transfer rate is not particularly specified, the buffer
第3ステップでは、500Mbpsから800Mbpsに転送速度を変更する要求があるため、バッファ数設定部12cは、優先ファイルリングバッファ12aのバッファ数と、通常ファイルリングバッファ12bのバッファ数との比率を4:1に設定し、クライアント42からのファイルは優先ファイルリングバッファ12aに、クライアント41からのファイルは通常ファイルリングバッファ12bに、それぞれ入力される。この結果、クライアント41からのファイルの転送速度は200Mbps、クライアント42からのファイルの転送速度は800Mbpsとなる。
In the third step, since there is a request for changing the transfer rate from 500 Mbps to 800 Mbps, the buffer
以上のように、本実施の形態におけるノードによれば、バッファ数設定部12cは、優先ファイルリングバッファ12a及び通常ファイルリングバッファ12bの各バッファ数を逐次制御する構成としたので、指定された受信転送速度を維持して優先ファイルを転送することができ、通常ファイルをTCPのフロー制御に従って自動的に残りの帯域に割り当てて優先ファイルの転送に影響を及ぼすことなく可能な限り高速に転送することができる。
As described above, according to the node in the present embodiment, the buffer
(第3の実施の形態)
本発明に係るノードの第3の実施の形態における主要部は、図12に示すように構成されている。すなわち、本実施の形態におけるノードは、第1の実施の形態におけるノード1の受信管理部12(図1参照)の構成及び受信管理部12に係る構成を変更したものである。なお、第1の実施の形態におけるノード1と同じ符号を用いて説明する。また、図12に示す主要部の構成以外は、第1の実施の形態におけるノード1と同じ構成であるので、説明を省略する。
(Third embodiment)
The main part of the third embodiment of the node according to the present invention is configured as shown in FIG. That is, the node in the present embodiment is obtained by changing the configuration of the reception management unit 12 (see FIG. 1) of the node 1 and the configuration related to the
図12に示すように、本実施の形態におけるノードは、受信するファイルのファイルサイズ情報を取得する受信管理部12と、現在時刻情報を取得する現在時刻取得部51と、受信期限時刻情報を出力するユーザIF部52と、転送速度を計算する転送速度計算部53とを備えている。
As shown in FIG. 12, the node in the present embodiment outputs a
本実施の形態における受信管理部12は、受信するファイルのファイルサイズ情報を取得し、転送速度計算部53に出力するようになっている。例えば、受信管理部12は、ファイルの送信元のファイル送受信部から通信部16を経由してファイルサイズ情報を取得することができる。なお、本実施の形態における受信管理部12は、本発明のファイルサイズ情報取得手段に対応している。
The
現在時刻取得部51は、内部時計から現在時刻情報を取得して転送速度計算部53に出力するようになっている。なお、現在時刻取得部51は、本発明の現在時刻情報取得手段に対応している。
The current
ユーザIF部52は、ユーザが設定した受信期限時刻情報を転送速度計算部53に出力するようになっており、本発明の受信期限情報取得手段に対応する。ここで、受信期限時刻情報とは、ファイル送受信部13が受信するファイルの受信の期限時刻を示す情報をいう。なお、ノード2又は3(図1参照)から受信期限時刻情報を送信させ、当該受信期限時刻情報を受信管理部12が受信する構成としてもよい。この場合、本実施の形態における受信管理部12は、本発明の受信期限情報取得手段に対応する。
The user IF
転送速度計算部53は、受信管理部12から受信したファイルサイズ情報と、現在時刻取得部51から受信した現在時刻情報と、ユーザIF部52から受信した受信期限時刻情報とに基づいて、受信管理部12がファイルを受信する際の転送速度を計算し、転送速度情報として受信管理部12に出力するようになっている。なお、転送速度計算部53は、本発明のファイル転送速度計算手段に対応している。
Based on the file size information received from the
また、転送速度計算部53は、受信期限時刻が設定されている場合、ファイル受信速度を計算し、その値を受信管理部12に設定するようになっている。この構成により、本実施の形態におけるノードは、受信時刻が設定されたファイルを当該受信期限時刻までに受信することができる。なお、本実施の形態におけるノードは、受信期限時刻が設定されていない場合、転送速度計算部53を用いず、指定された転送速度でファイルを転送することができる。
Further, when the reception deadline time is set, the transfer
次に、本実施の形態におけるノードの動作について説明する。 Next, the operation of the node in this embodiment will be described.
現在時刻をt0秒、受信期限時刻をt1秒、転送するファイルのファイルサイズをsビットとする。このとき、転送速度は最低でもs/(t−t0)ビット/秒は必要であるので、転送速度の初期値rは、適当な正の値△rを用いて、r0=S/(t1−t0)+△rとする。ここで、△rの値はs/(t1−t0)の値の10分の1から100分の1程度が望ましい。 The current time is t0 seconds, the reception deadline time is t1 seconds, and the file size of the file to be transferred is s bits. At this time, since the transfer rate needs to be at least s / (t−t0) bits / second, the initial value r of the transfer rate is set to r0 = S / (t1−) using an appropriate positive value Δr. t0) + Δr. Here, the value of Δr is desirably about 1/10 to 1/100 of the value of s / (t1-t0).
ファイルの転送中、例えばユーザからの指定により、受信期限時刻t1の値が変更された場合は、その時点での現在時刻t0と転送中のファイルの残りのサイズsを用いて、再度上記の式によりr0を計算し直す。 If the value of the reception deadline time t1 is changed during file transfer, for example, by designation from the user, the above expression is again used by using the current time t0 at that time and the remaining size s of the file being transferred. Recalculate r0.
以上のように、本実施の形態におけるノードによれば、転送速度計算部53は、受信期限時刻までに優先ファイルの受信が完了するよう優先ファイルの転送速度を計算するので、優先ファイル及び通常ファイルを受信する状況においても、優先ファイルを受信期限時刻までに受信することができる。
As described above, according to the node in the present embodiment, the transfer
なお、前述の実施の形態において、転送中に何らかの理由により、設定した転送速度が維持できず、最初に設定した転送速度r0では受信期限時刻t1に間に合わなくなる恐れがある場合に備えて、転送中であるファイルの未転送のファイルサイズと現在時刻とを一定時間間隔で確認し、上記の式により受信時の転送速度を求め、この値がr0を超えた場合は、受信時の転送速度を上記の式により再設定するルーチンを含む構成としてもよい。 In the above-described embodiment, the transfer rate that has been set cannot be maintained for some reason during the transfer, and the transfer rate r0 that is initially set may not be in time for the reception deadline time t1. The untransferred file size of the file and the current time are confirmed at regular time intervals, the transfer speed at the time of reception is obtained by the above formula, and if this value exceeds r0, the transfer speed at the time of reception is It is good also as a structure including the routine reset by the type | formula of this.
また、前述の実施の形態では、受信時の転送速度を受信管理部12が制御する例を挙げて説明したが、送信管理部11が送信時の転送速度を制御する構成とすることもできる。この場合、送信管理部31に転送速度計算部53が接続され、この転送速度計算部53には、現在時刻取得部51及びユーザIF部52が接続される構成となる。この場合、前述の受信期限時刻を送信期限時刻と読み替えればよい。
In the above-described embodiment, an example in which the
以上の構成では、送信管理部11は、転送するファイルのファイルサイズ情報をファイル送受信部13より取得することができるので、転送速度計算部53は、ファイルサイズ情報、現在時刻情報及び送信期限時刻情報を受信し、送信時の転送速度情報を送信管理部11に送信する。その結果、送信管理部11は、転送するファイルの送信期限時刻を設定することができる。なお、この構成において、ユーザIF部52又は受信管理部12は、本発明の送信期限情報取得手段に対応する。
In the above configuration, the
以上のように、本発明に係る受信装置、送信装置及び中継装置は、特定のファイルを他のファイルに優先して転送するよう転送速度を制御することができるという効果を有し、ネットワークを介して授受されるデータの転送速度の制御を行う受信装置、送信装置及び中継装置等として有用である。 As described above, the receiving device, the transmitting device, and the relay device according to the present invention have the effect of being able to control the transfer speed so that a specific file is transferred with priority over other files, and can be transmitted via a network. It is useful as a receiving device, a transmitting device, a relay device, or the like that controls the transfer rate of data exchanged.
1、2、3 ノード
10 ファイル送受信手段
11、21、31 送信管理部
12、22、32 受信管理部
12a 優先ファイルリングバッファ
12b 通常ファイルリングバッファ
12c バッファ数設定部
13、23、33 ファイル送受信部
14 蓄積装置制御部
15 ユーザIF部
16、26、36 通信部
17 蓄積装置
41、42 クライアント
43 サーバ
44 ネットワークスイッチ
51 現在時刻取得部
52 ユーザIF部
53 転送速度計算部
1, 2, 3
Claims (8)
前記優先ファイル及び前記通常ファイルの少なくとも一方を受信するファイル受信手段と、前記優先ファイルの転送速度を示す転送速度情報を受信する転送速度情報受信手段と、前記ファイル受信手段が前記優先ファイル及び前記通常ファイルを受信する際に、前記転送速度情報に基づいて、前記通常ファイルの転送速度を抑制し、前記優先ファイルの転送を優先するよう前記優先ファイル及び前記通常ファイルの転送速度を制御する受信側転送速度制御手段とを備えたことを特徴とする受信装置。 A receiving device that receives at least one of a priority file having a predetermined transfer speed and a normal file having a lower transfer priority than the priority file,
File receiving means for receiving at least one of the priority file and the normal file, transfer speed information receiving means for receiving transfer speed information indicating a transfer speed of the priority file, and the file receiving means for the priority file and the normal file When the file is received, the transfer on the receiving side controls the transfer speed of the priority file and the normal file so as to give priority to the transfer of the priority file by suppressing the transfer speed of the normal file based on the transfer speed information. And a speed control means.
前記優先ファイル及び前記通常ファイルの少なくとも一方を送信するファイル送信手段と、前記優先ファイルの転送速度を示す転送速度情報を受信する転送速度情報受信手段と、前記転送速度情報を前記受信装置に通知する転送速度情報通知手段と、前記優先ファイル及び前記通常ファイルを送信する際に、前記転送速度情報に基づいて、前記通常ファイルの転送速度を抑制し、前記優先ファイルの転送を優先するよう前記優先ファイル及び前記通常ファイルの転送速度を制御する送信側転送速度制御手段とを備えたことを特徴とする送信装置。 A transmission device that transmits at least one of the priority file and the normal file to at least one reception device according to any one of claims 1 to 4,
File transmitting means for transmitting at least one of the priority file and the normal file, transfer speed information receiving means for receiving transfer speed information indicating the transfer speed of the priority file, and notifying the transfer apparatus of the transfer speed information When transmitting the transfer rate information notification means, the priority file and the normal file, the priority file is configured so as to suppress the transfer rate of the normal file and prioritize transfer of the priority file based on the transfer rate information. And a transmission-side transfer rate control means for controlling the transfer rate of the normal file.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP2006348054A JP2008160557A (en) | 2006-12-25 | 2006-12-25 | Receiving device, transmitting device, and relay device |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP2006348054A JP2008160557A (en) | 2006-12-25 | 2006-12-25 | Receiving device, transmitting device, and relay device |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| JP2008160557A true JP2008160557A (en) | 2008-07-10 |
Family
ID=39660957
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| JP2006348054A Pending JP2008160557A (en) | 2006-12-25 | 2006-12-25 | Receiving device, transmitting device, and relay device |
Country Status (1)
| Country | Link |
|---|---|
| JP (1) | JP2008160557A (en) |
Cited By (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JP2008250370A (en) * | 2007-03-29 | 2008-10-16 | Brother Ind Ltd | Information processing apparatus and information processing program |
| JP2010039902A (en) * | 2008-08-07 | 2010-02-18 | Nomura Research Institute Ltd | Data processor and processing method |
| JP2012063904A (en) * | 2010-09-15 | 2012-03-29 | Toshiba Corp | File communication device and file communication method |
Citations (10)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JPH0677987A (en) * | 1992-08-28 | 1994-03-18 | Fujitsu Ltd | Transfer control method for each quality class in ATM switch |
| JPH0927825A (en) * | 1995-07-11 | 1997-01-28 | Matsushita Electric Ind Co Ltd | Computer network communication system |
| JP2000244552A (en) * | 1999-02-17 | 2000-09-08 | Nippon Telegr & Teleph Corp <Ntt> | File transfer device |
| JP2001223716A (en) * | 1999-11-29 | 2001-08-17 | Matsushita Electric Ind Co Ltd | Wireless communication system |
| JP2002132615A (en) * | 2000-10-23 | 2002-05-10 | Nippon Telegr & Teleph Corp <Ntt> | File transfer device, file transfer method, and recording medium |
| JP2002358259A (en) * | 2001-05-31 | 2002-12-13 | Toshiba Corp | File server having priority control function, file access method and file access program in the server |
| JP2003223384A (en) * | 2002-01-31 | 2003-08-08 | Nippon Telegr & Teleph Corp <Ntt> | File distribution system |
| JP2003258887A (en) * | 2002-03-04 | 2003-09-12 | Nippon Telegr & Teleph Corp <Ntt> | Visual and dynamic downstream bandwidth control system, terminal device, control method, program, and recording medium |
| JP2005130150A (en) * | 2003-10-23 | 2005-05-19 | Sony Corp | COMMUNICATION PROCESSING DEVICE, COMMUNICATION PROCESSING METHOD, AND COMPUTER PROGRAM |
| JP2006203639A (en) * | 2005-01-21 | 2006-08-03 | Matsushita Electric Ind Co Ltd | COMMUNICATION DEVICE, COMMUNICATION SYSTEM, RECORDING MEDIUM, INTEGRATED CIRCUIT, AND CONTROL METHOD |
-
2006
- 2006-12-25 JP JP2006348054A patent/JP2008160557A/en active Pending
Patent Citations (10)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JPH0677987A (en) * | 1992-08-28 | 1994-03-18 | Fujitsu Ltd | Transfer control method for each quality class in ATM switch |
| JPH0927825A (en) * | 1995-07-11 | 1997-01-28 | Matsushita Electric Ind Co Ltd | Computer network communication system |
| JP2000244552A (en) * | 1999-02-17 | 2000-09-08 | Nippon Telegr & Teleph Corp <Ntt> | File transfer device |
| JP2001223716A (en) * | 1999-11-29 | 2001-08-17 | Matsushita Electric Ind Co Ltd | Wireless communication system |
| JP2002132615A (en) * | 2000-10-23 | 2002-05-10 | Nippon Telegr & Teleph Corp <Ntt> | File transfer device, file transfer method, and recording medium |
| JP2002358259A (en) * | 2001-05-31 | 2002-12-13 | Toshiba Corp | File server having priority control function, file access method and file access program in the server |
| JP2003223384A (en) * | 2002-01-31 | 2003-08-08 | Nippon Telegr & Teleph Corp <Ntt> | File distribution system |
| JP2003258887A (en) * | 2002-03-04 | 2003-09-12 | Nippon Telegr & Teleph Corp <Ntt> | Visual and dynamic downstream bandwidth control system, terminal device, control method, program, and recording medium |
| JP2005130150A (en) * | 2003-10-23 | 2005-05-19 | Sony Corp | COMMUNICATION PROCESSING DEVICE, COMMUNICATION PROCESSING METHOD, AND COMPUTER PROGRAM |
| JP2006203639A (en) * | 2005-01-21 | 2006-08-03 | Matsushita Electric Ind Co Ltd | COMMUNICATION DEVICE, COMMUNICATION SYSTEM, RECORDING MEDIUM, INTEGRATED CIRCUIT, AND CONTROL METHOD |
Cited By (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JP2008250370A (en) * | 2007-03-29 | 2008-10-16 | Brother Ind Ltd | Information processing apparatus and information processing program |
| JP2010039902A (en) * | 2008-08-07 | 2010-02-18 | Nomura Research Institute Ltd | Data processor and processing method |
| JP2012063904A (en) * | 2010-09-15 | 2012-03-29 | Toshiba Corp | File communication device and file communication method |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| JP5563979B2 (en) | Bandwidth reservation for data flow in interconnected networks | |
| US20120213077A1 (en) | Network bandwidth detection and distribution | |
| CN115087043B (en) | Multi-path redundancy transmission method, user equipment, network entity and storage medium | |
| CN111713056B (en) | Data packet sending method and related equipment | |
| CN107454017B (en) | A collaborative scheduling method for mixed data flow in cloud data center network | |
| JP2009532954A (en) | Memory management for high-speed media access control | |
| US20130016609A1 (en) | Network equipment and frame transmission control method | |
| KR20060063652A (en) | Efficient Transmission of Messages Using Reliable Messaging Protocols for Web Services | |
| US20200252337A1 (en) | Data transmission method, device, and computer storage medium | |
| US8838782B2 (en) | Network protocol processing system and network protocol processing method | |
| WO2019244966A1 (en) | Communication device, communication method, and program | |
| WO2012103701A1 (en) | Method and gateway device for sending data | |
| JP4988487B2 (en) | Data transfer method, apparatus, and program | |
| JPWO2009093473A1 (en) | Relay device, terminal, priority communication control method, program, and recording medium | |
| JP2003152787A (en) | Multi-path file transmission device | |
| JP2008160557A (en) | Receiving device, transmitting device, and relay device | |
| JP2009188655A (en) | Communication control method, information processing system, information processing apparatus, and program | |
| WO2014010189A1 (en) | Proxy device, communication system, program | |
| CN115396357B (en) | Traffic load balancing method and system in data center network | |
| JP2015154232A (en) | VIDEO TRANSMISSION SYSTEM, VIDEO TRANSMISSION METHOD, ACCESS ROUTER, ACCESS CONTROL DEVICE, AND RATE CONVERTER | |
| CN120567842B (en) | Web end real-time communication method and system based on dynamic channel management | |
| KR20110075166A (en) | Method and apparatus for transmitting signal in wireless communication system | |
| JP2010056990A (en) | Data communication method employing multiple connections | |
| JP7704287B2 (en) | System, method and program for collecting data | |
| JP5125643B2 (en) | Relay device, data transfer system, data transfer method, and data transfer program |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| A621 | Written request for application examination |
Free format text: JAPANESE INTERMEDIATE CODE: A621 Effective date: 20090319 |
|
| A977 | Report on retrieval |
Free format text: JAPANESE INTERMEDIATE CODE: A971007 Effective date: 20110120 |
|
| A131 | Notification of reasons for refusal |
Free format text: JAPANESE INTERMEDIATE CODE: A131 Effective date: 20110412 |
|
| A521 | Written amendment |
Free format text: JAPANESE INTERMEDIATE CODE: A523 Effective date: 20110609 |
|
| A02 | Decision of refusal |
Free format text: JAPANESE INTERMEDIATE CODE: A02 Effective date: 20110830 |