Class: DangoServerFramework

Inherits:
Object show all
Includes:
DangoFrameworkModule
Defined in:
lib/dango/server_framework.rb

Overview

フレームワーククラス

Defined Under Namespace

Classes: DangoGServer

Constant Summary collapse

DefaultNetworkPort =

以下すべてデフォルト値

15000
DefaultServerHost =

デフォルトのポート番号

'localhost'
DefaultMaxConnections =

デフォルトのホスト名 # 接続制限ホスト “0.0.0.0”にすれば全接続オッケイ

10
DefaultLogFile =

デフォルトの最大接続人数

"log/dango_development.log"
DefaultLogLevel = 
Logger::INFO
DefaultLogMaxSize = 
1048576
DefaultLogShiftAge = 
99
DefaultGServerLogFile = 
""
SendReceiveSleepIntervalSec =

ここから先は普通は変更しなくていいだろうというもの

0.2
SendReceiveTimeoutDefaultSec =

データ送信時のタイムアウトチェック間隔秒

5.0
SendTimeoutSec =

データ送受信時のデフォルトタイムアウト秒数

4.0
HeartBeatIntervalSec =

データ送受信時の送信のタイムアウト秒数

10.0
HeartBeatResponseWaitSec =

heart beatのチェック間隔秒数

10.0
HeartBeatReceiveWaitSec =

S=>Cのheart beatの返信待ち秒数

30.0
GCIntervalSec =

C=>Sのheart beatの受信待ち秒数

5.0
ServerStopWait =

GCの発生タイミング

0.2

Constants included from DangoFrameworkModule

DangoFrameworkModule::CommMaxDigit, DangoFrameworkModule::DefaultDataType, DangoFrameworkModule::MaxLen

Instance Attribute Summary collapse

Attributes included from DangoFrameworkModule

#dango_logger

Class Method Summary collapse

Instance Method Summary collapse

Methods included from DangoFrameworkModule

#dango_receive_data, #dango_send_data, #debug_print, #logger

Methods included from ErrorMessage

#error_message

Constructor Details

#initialize(config) ⇒ DangoServerFramework

Returns a new instance of DangoServerFramework.



91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
 
# File 'lib/dango/server_framework.rb', line 91

def initialize(config)
  @config           = config # 設定ファイル

  
  @gserver = nil # Gserver用の変数

  @server_reload = nil # サーバーのリロード用フラグ

  
  # SIGINT の捕捉

  Signal.trap(:INT) do 
    exit_process() # プロセス終了処理

  end
  
  # 終了処理を登録しておく(これが無いとWindowsではエラーが出てもプロセスが落ちないことがある)

  at_exit do
    exit_process() # プロセス終了処理

  end
  
  # サーバー開始

  server_start()
  
  loop do # 待ちで無限ループに入る

    sleep 3
#      p( Time.now_to_s + ":#{@server_reload.inspect}")

    check_reload_class()
  end
end

Dynamic Method Handling

This class handles dynamic methods through the method_missing method

#method_missing(name, *args) ⇒ Object

必要に応じて追加するメソッド



802
803
804
805
806
807
808
809
810
 
# File 'lib/dango/server_framework.rb', line 802

def method_missing(name, *args)
  if name.to_s =~ /^dango_receive_action_notice_shared_(.+)/ # 共有メモリ変更通知なら

    key = $1
    method_action_notice_shared(key, name, *args)
  else
    logger.error "method not found. #{name.inspect} #{args.inspect}"
    raise(NameError, "method not found. #{name.inspect} #{args.inspect}")
  end
end

Instance Attribute Details

#config ⇒ Object (readonly)

読みよみのみのアクセサ



117
118
119
 
# File 'lib/dango/server_framework.rb', line 117

def config
  @config
end

#log_file ⇒ Object (readonly)

Returns the value of attribute log_file.



454
455
456
 
# File 'lib/dango/server_framework.rb', line 454

def log_file
  @log_file
end

#log_level_str ⇒ Object (readonly)

Returns the value of attribute log_level_str.



454
455
456
 
# File 'lib/dango/server_framework.rb', line 454

def log_level_str
  @log_level_str
end

#log_max_size ⇒ Object (readonly)

Returns the value of attribute log_max_size.



454
455
456
 
# File 'lib/dango/server_framework.rb', line 454

def log_max_size
  @log_max_size
end

#log_shift_age ⇒ Object (readonly)

Returns the value of attribute log_shift_age.



454
455
456
 
# File 'lib/dango/server_framework.rb', line 454

def log_shift_age
  @log_shift_age
end

#mutex_socket_list ⇒ Object

Returns the value of attribute mutex_socket_list.



593
594
595
 
# File 'lib/dango/server_framework.rb', line 593

def mutex_socket_list
  @mutex_socket_list
end

#notice_shared ⇒ Object

Returns the value of attribute notice_shared.



557
558
559
 
# File 'lib/dango/server_framework.rb', line 557

def notice_shared
  @notice_shared
end

#recv_count ⇒ Object (readonly)

Returns the value of attribute recv_count.



453
454
455
 
# File 'lib/dango/server_framework.rb', line 453

def recv_count
  @recv_count
end

#recv_fail_count ⇒ Object (readonly)

Returns the value of attribute recv_fail_count.



453
454
455
 
# File 'lib/dango/server_framework.rb', line 453

def recv_fail_count
  @recv_fail_count
end

#send_count ⇒ Object (readonly)

Returns the value of attribute send_count.



453
454
455
 
# File 'lib/dango/server_framework.rb', line 453

def send_count
  @send_count
end

#send_fail_count ⇒ Object (readonly)

Returns the value of attribute send_fail_count.



453
454
455
 
# File 'lib/dango/server_framework.rb', line 453

def send_fail_count
  @send_fail_count
end

#session_list ⇒ Object (readonly)

Returns the value of attribute session_list.



580
581
582
 
# File 'lib/dango/server_framework.rb', line 580

def session_list
  @session_list
end

#session_th_list ⇒ Object (readonly)

Returns the value of attribute session_th_list.



581
582
583
 
# File 'lib/dango/server_framework.rb', line 581

def session_th_list
  @session_th_list
end

#shared ⇒ Object

Returns the value of attribute shared.



472
473
474
 
# File 'lib/dango/server_framework.rb', line 472

def shared
  @shared
end

#socket_list ⇒ Object

Returns the value of attribute socket_list.



587
588
589
 
# File 'lib/dango/server_framework.rb', line 587

def socket_list
  @socket_list
end

#start_time ⇒ Object (readonly)

Returns the value of attribute start_time.



453
454
455
 
# File 'lib/dango/server_framework.rb', line 453

def start_time
  @start_time
end

Class Method Details

.start(config = {}) ⇒ Object

起動用のインスタンスメソッド



120
121
122
 
# File 'lib/dango/server_framework.rb', line 120

def self.start(config = {})
  self.new(config)
end

Instance Method Details

#action_name_is_response(ret_obj) ⇒ Object

action_nameが送信パケットの返事なら



397
398
399
400
401
402
 
# File 'lib/dango/server_framework.rb', line 397

def action_name_is_response(ret_obj)
  logger.debug "action_name_is_response: #{ret_obj['_id']} #{session[:sid]} " 
  @mutex_send_response.synchronize do
    @arr_send_response.push({:_id => ret_obj["_id"], :time => Time.now})
  end
end

#check_reload_class ⇒ Object

サーバーのループ時のクラス読み直し処理



173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
 
# File 'lib/dango/server_framework.rb', line 173

def check_reload_class()
  begin
    if @server_reload
      @server_reload = nil
      
      debug_print("-- stopping server")
      
      # 強制的に接続しているsocketをクローズ

      logger.info "socket_list.keys:#{socket_list.keys.inspect}"
      socket_list.keys.each do |sk|
        logger.debug "sk:#{socket_list[sk].inspect}"
        socket_list[sk].close if ! socket_list[sk].closed?
        socket_list[sk]
      end
      
      # サーバーを停止

      @gserver.shutdown
      @gserver.stop
      while(!@gserver.stopped?) do
        sleep ServerStopWait
        debug_print("waiting... #{@gserver.stopped?} #{@gserver.connections}")
      end
      
      @gserver = nil
      
      debug_print("-- stopped server")
      
      # GCを行う

      GC.enable
      GC.start 
      GC.disable
      
      # サーバーファイルを読み直し

      debug_print("-- reload classes")
      tmp_verbose = $VERBOSE
      $VERBOSE = nil

      # serverファイル名一覧を取得

      load_files = []
      glob_str = 'dango/server/*.rb'
      Dir.glob(glob_str) do |srv_file|
        load_files.push({:file=>srv_file, :mtime=>File.mtime(srv_file)})
      end

      # ファイル名順にソート

      load_files = load_files.sort_by{|f| f[:file] }
      load_files.each do |f|
        begin
          load f[:file]
        rescue Exception
          debug_print("#{$!.class} #{$!.message} #{$!.backtrace.pretty_inspect}")
        end
      end

      $VERBOSE = tmp_verbose
      
      # サーバーを再度起動

      debug_print("-- start server")
      server_start() # サーバー開始

    end
  rescue Exception
    logger.error "#{$!.class}:#{$!.message}\n#{$!.backtrace.pretty_inspect}"
  end
end

#connecting(sock) ⇒ Object

gserver接続開始処理



239
240
241
 
# File 'lib/dango/server_framework.rb', line 239

def connecting(sock)
  logger.info "connecting:sock=#{sock} peeraddr=#{sock.peeraddr.inspect} addr=#{sock.addr.inspect}"
end

#dango_close ⇒ Object

接続解除時に呼び出されるメソッド



600
601
 
# File 'lib/dango/server_framework.rb', line 600

def dango_close
end

#dango_connect ⇒ Object

接続時に呼び出されるメソッド



596
597
 
# File 'lib/dango/server_framework.rb', line 596

def dango_connect
end

#dango_receive__notice_heart_beat(ret_obj) ⇒ Object

クライアントから来たheart_beatなら



684
685
686
687
688
689
690
691
 
# File 'lib/dango/server_framework.rb', line 684

def dango_receive__notice_heart_beat(ret_obj)
  logger.debug "dango_receive__notice_heart_beat:#{session[:sid]}:#{ret_obj['_hb_id']} " 
  
  shared.transaction(:_heart_beat_time_hash) do |heart_beat_time_hash|
    heart_beat_time_hash[session[:sid]] = Time.now
    heart_beat_time_hash
  end
end

#dango_receive_decrypt(str) ⇒ Object

フレームワークから呼ばれる部分



616
617
618
 
# File 'lib/dango/server_framework.rb', line 616

def dango_receive_decrypt(str) # フレームワークから呼ばれる部分

  dango_server_receive_decrypt(str)
end

#dango_send_encrypt(str) ⇒ Object

フレームワークから呼ばれる部分



608
609
610
 
# File 'lib/dango/server_framework.rb', line 608

def dango_send_encrypt(str) # フレームワークから呼ばれる部分

  dango_server_send_encrypt(str)
end

#dango_server_init ⇒ Object

初期設定



456
457
 
# File 'lib/dango/server_framework.rb', line 456

def dango_server_init # 初期設定

end

#dango_server_receive_decrypt(str) ⇒ Object

サーバーの復号化処理



613
614
615
 
# File 'lib/dango/server_framework.rb', line 613

def dango_server_receive_decrypt(str) # 継承用

  str
end

#dango_server_send_encrypt(str) ⇒ Object

サーバーの暗号化処理



605
606
607
 
# File 'lib/dango/server_framework.rb', line 605

def dango_server_send_encrypt(str) # 継承用

  str
end

#disconnecting(port) ⇒ Object

gserver接続開始処理



244
245
246
 
# File 'lib/dango/server_framework.rb', line 244

def disconnecting(port)
  logger.info "disconnecting:port=#{port}"
end

#exit_process ⇒ Object

プロセス終了処理



70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
 
# File 'lib/dango/server_framework.rb', line 70

def exit_process() # プロセス終了処理

  # サーバーを停止

  if @gserver && !@gserver.stopped?
    @gserver.shutdown
    @gserver.stop
#      while([email protected]?) do

#        sleep ServerStopWait

#        debug_print("waiting... #{@gserver.stopped?} #{@gserver.connections}")

#      end

    10.times do
      break if @gserver.stopped?
      sleep ServerStopWait
      debug_print("waiting... #{@gserver.stopped?} #{@gserver.connections}")
    end
  end
  
  debug_print("shutdown")
  puts "shutdown"
  exit!
end

#flameloop_thread(loop_method, options = {}) ⇒ Object

メインループ用の定義をするためのメソッド



820
821
822
823
824
825
826
827
828
829
830
831
832
833
834
835
836
837
838
839
840
841
842
843
 
# File 'lib/dango/server_framework.rb', line 820

def flameloop_thread(loop_method, options={})
  logger.warn "flameloop_thread options:#{options.inspect}"

  options = options.deep_dup
  options[:rate] ||= 10
  
  wait_sec = 1.0 / options[:rate]
  logger.warn "flameloop_thread wait_sec:#{wait_sec.inspect}"
  
  th = Thread.new do 
    loop do
      @mutex_proc_thread.synchronize do
        begin
          __send__(loop_method)
        rescue Exception
          logger.error "flameloop_thread error:#{error_message($!, 'u')}"
        end
      end
      sleep wait_sec
    end
  end
#    th.priority = 1

  
end

#gc_thread_start ⇒ Object

GCスレッドの開始



621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
 
# File 'lib/dango/server_framework.rb', line 621

def gc_thread_start
  th = Thread.start do
    loop do
      begin
        sleep @gc_interval_sec
        
        Thread.critical = true
        logger.debug "GC start "
        gc_start_time = Time.now
        GC.enable
        GC.start 
        GC.disable
        logger.debug "GC end #{Time.now - gc_start_time}sec "
        Thread.critical = false
        
      rescue Exception
        logger.error "Exception gc_thread_start  #{error_message($!, 'u')}"
      end
    end
  end
  th.priority = -1
end

#heart_beat_thread_start ⇒ Object

ハートビートスレッドの開始



645
646
647
648
649
650
651
652
653
654
655
656
657
658
659
660
661
662
663
664
665
666
667
668
669
670
671
672
673
674
675
676
677
678
679
680
681
 
# File 'lib/dango/server_framework.rb', line 645

def heart_beat_thread_start
  shared[:_heart_beat_time_hash] = {}
  
  th = Thread.start do
    loop do
      begin
        sleep @herat_beat_interval_sec
        
        if ! @gserver.stopped? # gserverが起動していれば

          logger.debug "heart_beat_thread_start "
          
          # クライアントから来るハートビートのチェック

          heart_beat_time_hash = shared[:_heart_beat_time_hash]
          
          # 全員へheart_beatパケットを送信

          socket_list.keys.each do |sid|
            sock = socket_list[sid]
#              logger.debug "heart_beat_thread_start:sid=#{sid} #{sock} #{sock.closed?}"

#              send_notice(sid, "_heart_beat", {}, {:timeout=>@heart_beat_response_wait_sec})

            
            # クライアントから来たハートビートの時間チェックし、古ければsocketを閉じて、threadを殺す

            if heart_beat_time_hash[sid] && heart_beat_time_hash[sid] < Time.now - @heart_beat_receive_wait_sec
              logger.warn "!!!! heart_beat_thread_start:heart beat old:#{sid}:#{heart_beat_time_hash[sid]}:#{sock}:#{sock.closed?}"
              sock.close if !sock.closed?
              logger.warn "!!!! heart_beat_thread_start:thread kill:#{session_th_list[sid]}"
              session_th_list[sid].kill
            end
          end
        end
        
      rescue Exception
        logger.error "Exception heart_beat_thread_start  #{error_message($!, 'u')}"
      end
    end
  end
  th.priority = 1
end

#method_action_notice_shared(key, name, *args) ⇒ Object

共有メモリ変更通知のメソッド



813
814
815
816
817
 
# File 'lib/dango/server_framework.rb', line 813

def method_action_notice_shared(key, name, *args) 
  logger.debug "method_name:#{name}"
  send_obj = args[0]
  notice_shared.notice_change(key.to_sym, send_obj) 
end

#mutex_socket_list_init ⇒ Object

ソケット毎用のmutex



590
591
592
 
# File 'lib/dango/server_framework.rb', line 590

def mutex_socket_list_init()
  @mutex_socket_list = MutexSocketList.new()  # ソケット毎用のmutex

end

#notice_shared_init ⇒ Object

通知共有メモリ



475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
 
# File 'lib/dango/server_framework.rb', line 475

def notice_shared_init
#   @notice_shared = NoticeShared.new(self)

  @notice_shared = select_shared_database_manager()
  
  class << @notice_shared ## 各種メソッド追加

    def initialize2(parent)
      @parent = parent
      self[:notice_list] = {}
    end

    def init_key(key) # そのキーを作成する

      if self[:notice_list].has_key?(key) || key == :notice_list # キーがすでにあるか予約語なら

        raise(DangoFrameworkError, "notice_list already has key. key=#{key.inspect}")
      end
      
      self.transaction(:notice_list) do |notice_list|
        notice_list[key] = []
        notice_list
      end
    end
    
    def add_connectable(key, sid) # 接続許可にする

      if !self[:notice_list].has_key?(key) # キーがなければ

        raise(DangoFrameworkError, "notice_list not has key. key=#{key.inspect}")
      end
      
      self.transaction(:notice_list) do |notice_list|
        notice_list[key] << sid
        notice_list
      end
    end
    
    def remove_connectable(key, sid) # 接続を不許可にする

      if !self[:notice_list].has_key?(key) # キーがなければ

        raise(DangoFrameworkError, "notice_list not has key. key=#{key.inspect}")
      end
      
      self.transaction(:notice_list) do |notice_list|
        notice_list[key].delete(sid)
        notice_list
      end
    end
    
    def get_connectables(key) # 接続許可一覧を返す

      if !self[:notice_list].has_key?(key) # キーがなければ

        raise(DangoFrameworkError, "notice_list not has key. key=#{key.inspect}")
      end
      
      self[:notice_list][key]
    end
    
    def notice_change(key, value) # 変更時に通知する変更

      if !self[:notice_list].has_key?(key) # キーがなければ

        raise(DangoFrameworkError, "notice_list not has key. key=#{key.inspect}")
      end
      
      self[key] = value
      
      @parent.logger.debug "self.get_connectables(key):#{self.get_connectables(key).inspect}"
      
      self.get_connectables(key).each do |sid|
        @parent.send_notice(sid, "notice_shared_#{key}".to_sym, value)
      end
    end
    
    def not_notice_change(key, value) # 変更時に通知しない変更

      if !self[:notice_list].has_key?(key) # キーがなければ

        raise(DangoFrameworkError, "notice_list not has key. key=#{key.inspect}")
      end
      
      self[key] = value
    end
    
    def []=(key, value) # データの変更

      if key != :notice_list && !self[:notice_list].has_key?(key) # キーがなければ

        raise(DangoFrameworkError, "notice_list not has key. key=#{key.inspect}")
      end
      
      super(key, value) # データの変更

    end
  end
end

#select_shared_database_manager ⇒ Object

コンフィグのshared_database_managerによる使用クラスの選択



460
461
462
463
464
465
466
 
# File 'lib/dango/server_framework.rb', line 460

def select_shared_database_manager()
  if @config['server']['shared_database_manager'] == 'MemoryStore'
    SharedMemoryStore.new
  else
    SharedMemoryStore.new
  end
end

#send_notice(sid, notice_name, send_obj, options = {}) ⇒ Object

サーバーからクライアントへのデータ送信

Raises:



694
695
696
697
698
699
700
701
702
703
704
705
706
707
708
709
710
711
712
713
714
715
716
717
718
719
720
721
722
723
724
725
726
727
728
729
730
731
732
733
734
735
736
737
738
739
740
741
742
743
744
745
746
747
748
749
750
751
752
753
754
755
756
757
758
759
760
761
762
763
764
765
766
767
768
769
770
771
772
773
774
775
776
777
778
779
780
781
782
783
784
785
786
787
788
789
790
791
792
793
794
795
796
797
798
799
 
# File 'lib/dango/server_framework.rb', line 694

def send_notice(sid, notice_name, send_obj, options = {})
  logger.info "send_notice(#{sid.inspect}, #{notice_name.inspect}) "
#    logger.debug "send_notice(#{sid.inspect}, #{notice_name.inspect}, #{send_obj.inspect}, #{options.inspect})"

  
  raise(DangoFrameworkError, "send_obj is not Hash.") if ! send_obj.is_a?(Hash)
  
  timeout = options[:timeout] || @send_receive_timeout_default_sec
  dtype = options[:type] || 0
  
  sock = socket_list[sid]
  if !sock || sock.closed? # sockがないという事はすでに切断済み

    logger.info "send_notice:already closed socket. sid=#{sid.inspect} sock=#{sock.inspect} #{sock ? sock.closed? : nil} "
    return(self)
  end
  
  # sidの通知の場合はレスポンスを気にしない

  if notice_name.to_s == "_notice_sid"
    raise(DangoFrameworkError, "not found sid=#{sid}") if !sock
    raise(DangoFrameworkConnectionError, "socket closed. sid=#{sid}") if sock.closed?
    
    send_obj_dup = send_obj.deep_dup
    send_obj_dup["notice"] = notice_name.to_s
    
    dango_send_data(sock, send_obj_dup, :type=>dtype) # データ送信

#      logger.debug "send_notice:finish send data notice_name=#{notice_name.inspect}\n"

  else
    Thread.start(sid, notice_name, send_obj, dtype, timeout, sock) do
      begin
        raise(DangoFrameworkError, "not found sid=#{sid}") if !sock
        raise(DangoFrameworkConnectionError, "socket closed. sid=#{sid}") if sock.closed?
        
        send_obj_dup = send_obj.deep_dup
        send_obj_dup["notice"] = notice_name.to_s
        
        mutex_socket_list.synchronize(sid) do
#            logger.debug "mutex_socket_list:synchronize:#{notice_name} #{sid} "

          
          digest_key = sid.to_s + notice_name.to_s + Time.now.to_f.to_s + rand().to_s
          send_obj_dup["_id"] = Digest::MD5.hexdigest(digest_key)
          have_came_response = nil
          
          receive_thread = Thread.start(sock, send_obj_dup, dtype) do
            begin
              dango_send_data(sock, send_obj_dup, :type=>dtype) # データ送信

#                logger.debug "send_notice:sent:notice_name=#{send_obj_dup['_id']} #{notice_name.inspect} #{sid} "

            rescue DangoFrameworkConnectionError
              logger.warn "send_notice:DangoFrameworkConnectionError:notice_name=#{notice_name.inspect} #{sid} "
            rescue DangoFrameworkError
              logger.warn "ERROR:send_notice:DangoFrameworkError:notice_name=#{notice_name.inspect} #{sid} \n #{error_message($!, 'u')}"
            rescue Exception
              logger.warn "ERROR:send_notice:Exception:notice_name=#{notice_name.inspect} #{sid} \n #{error_message($!, 'u')}"
            end
          end
          
          # データ送信スレッドの終了待ち

          if !receive_thread.join(@send_timeout_sec)
            # タイムアウトの場合は

            logger.warn "send_notice:send timeout:#{notice_name} #{sid} " 
          else
#              logger.warn "send_notice:sent after join:#{notice_name} #{sid} " 

            end_reserved_time = Time.now + timeout
            
            # タイムアウトチェック

            catch(:send_timeout) do
              (timeout.to_f / @send_receive_sleep_interval_sec).to_i.times do
                sleep @send_receive_sleep_interval_sec # スリープ

                
                @mutex_send_response.synchronize do # データ送信の返信が来たかどうかの確認

                  find_res = @arr_send_response.find{|r| r[:_id] == send_obj_dup["_id"]}
                  
                  if find_res
                    logger.debug "send_notice:find_res _heart_beat #{sid}" if notice_name.to_s == "_heart_beat"
                    
                    @arr_send_response.delete(find_res)
                    have_came_response = true
                    throw(:send_timeout)
                  end
                end
                
                if Time.now > end_reserved_time
                  logger.debug "send_notice:receive timeout:#{notice_name} #{sid}  #{end_reserved_time}" 
                  
#                    if notice_name.to_s == "_heart_beat" # heart beatだったらsockを止める

#                      logger.info "!!!! send_notice:heart_beat timeout" 

#                      sock.close if !sock.closed?

#                    end

                  break
                end
                
              end # タイムアウト処理終わり

            end # catch 終わり

            
            if !have_came_response # 戻ってきたデータがあるかどうかチェック

              logger.warn "!!! received data is none:#{notice_name} #{sid} #{send_obj_dup['_id']} "
            end
          end
        end # mutex

      rescue Exception
        logger.error "send_response_thread error:#{error_message($!, 'u')}"
      end
    end # Thread:end

    
  end
  
  self
end

#server_start ⇒ Object

サーバー開始処理



125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
 
# File 'lib/dango/server_framework.rb', line 125

def server_start()
  set_server_variables()                # 各種サーバー仕様の変数設定

  
  logger.warn("===== server initialize =====") # loggerの準備

  logger.warn("Process.pid=#{Process.pid}")
  logger.warn("port=#{@server_port}")
  logger.warn("host=#{@server_host}")
  logger.warn("max_connections=#{@server_max_connections}")
  
  open("tmp/pids/dango.pid", "wb"){|fh| fh.write Process.pid.to_s }
  
  session_init()                        # セッション情報の初期化

  shared_init()                         # 共有メモリを初期化

  notice_shared_init()                  # 通知共有メモリを初期化

  socket_list_init()                    # ソケット一覧を初期化

  mutex_socket_list_init()              # ソケット毎用のmutexを初期化

  @mutex_proc_thread = Mutex.new        # スレッドが同時起動しないようにするためのMutex

  dango_server_init()                   # 初期設定読み込み

  heart_beat_thread_start()             # ハートビートスレッドの開始

  gc_thread_start()                     # GCスレッドの開始

  
  @mutex_send_response = Mutex.new      # 送信レスポンス用のMutex

  @arr_send_response = []               # 送信レスポンス用のキャッシュ

  
  TCPSocket.do_not_reverse_lookup = true # 逆引きを行わない

#    TCPSocket.do_not_reverse_lookup = false # 逆引きを行う

  
  @gserver = DangoGServer.new(self, @server_port, @server_host, @server_max_connections)
  @gserver.audit = true                 # Turn logging on.

  @gserver.debug = true                 # debug

  
  if @gserver_log_file && @gserver_log_file != ""
    gserver_log_fh = open(@gserver_log_file, "a")
    @gserver.stdlog = gserver_log_fh
  end
  
  GC.disable
  
  begin
    @gserver.start
  rescue Exception
    error_msg = "#{$!.class} #{$!.message} #{$!.backtrace.pretty_inspect}"
    logger.error error_msg
    puts error_msg
  end
end

#session ⇒ Object 



564
565
566
567
568
569
570
571
572
573
574
 
# File 'lib/dango/server_framework.rb', line 564

def session
  if !Thread.current[:session]
    Thread.current[:session] = {}
    @session_list[Thread.current.object_id] = Thread.current[:session]
    @session_th_list[Thread.current.object_id] = Thread.current
  end
  Thread.current[:session]
#    sid = Thread.current.object_id

#    @session[sid] = Session.new if !@session[sid]

#    @session[sid]

end

#session_del ⇒ Object

@session



575
576
577
578
 
# File 'lib/dango/server_framework.rb', line 575

def session_del # セッション情報の初期化

  @session_list.delete(Thread.current.object_id)
  @session_th_list.delete(Thread.current)
end

#session_init ⇒ Object

セッション



560
561
562
563
 
# File 'lib/dango/server_framework.rb', line 560

def session_init # セッション情報の初期化

  @session_list = {}
  @session_th_list = {}
end

#set_server_variables ⇒ Object

各種サーバー仕様の変数設定



405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
 
# File 'lib/dango/server_framework.rb', line 405

def set_server_variables() 
  # debug

  @server_debug = @config['server']['debug'] || false
  Thread.abort_on_exception = true if @server_debug
  
  # 変数の初期設定

  @server_port                       = @config['network']['port'] || DefaultNetworkPort
  @server_host                       = @config['server']['host'] || DefaultServerHost
  @server_max_connections            = @config['server']['max_connections'] || DefaultMaxConnections
  @log_file                          = @config['server']['log_file'] || DefaultLogFile
  @log_max_size                      = @config['server']['log_max_size'] || DefaultLogMaxSize
  @log_shift_age                     = @config['server']['log_shift_age'] || DefaultLogShiftAge
  @gserver_log_file                  = @config['server']['gserver_log_file'] || DefaultGServerLogFile
  
  @policy_file_request               = @config['server']['policy_file_request'] || true
  @send_receive_sleep_interval_sec   = @config['server']['send_receive_sleep_interval_sec'] || SendReceiveSleepIntervalSec
  @send_receive_timeout_default_sec  = @config['server']['send_receive_timeout_default_sec'] || SendReceiveTimeoutDefaultSec
  @send_timeout_sec                  = @config['server']['send_timeout_sec'] || SendTimeoutSec
  @herat_beat_interval_sec           = @config['server']['heart_beat_interval_sec'] || HeartBeatIntervalSec
  @heart_beat_response_wait_sec      = @config['server']['heart_beat_response_wait_sec'] || HeartBeatResponseWaitSec
  @heart_beat_receive_wait_sec       = @config['server']['heart_beat_receive_wait_sec'] || HeartBeatReceiveWaitSec
  @gc_interval_sec                   = @config['server']['gc_interval_sec'] || GCIntervalSec
  
  # ログレベルの設定

  log_level_hash = {
    "FATAL" => Logger::FATAL, 
    "ERROR" => Logger::ERROR, 
    "WARN"  => Logger::WARN, 
    "INFO"  => Logger::INFO, 
    "DEBUG" => Logger::DEBUG, 
  }
  log_level_hash.each do |str, const|
    @log_level = const if str.downcase == @config['server']['log_level'].downcase
  end
  @log_level = @log_level || DefaultLogLevel
  
  log_level_hash.each do |str, const|
    @log_level_str = str if const == @log_level
  end
  
  
  @start_time = Time.now # サーバー起動時間

  @recv_count = 0        # 受信回数

  @send_count = 0        # 送信回数

  @recv_fail_count = 0   # 受信失敗回数

  @send_fail_count = 0   # 送信失敗回数

end

#shared_init ⇒ Object

共有メモリ



469
470
471
 
# File 'lib/dango/server_framework.rb', line 469

def shared_init
  @shared = select_shared_database_manager()
end

#socket_list_init ⇒ Object

ソケットとIDの対応



584
585
586
 
# File 'lib/dango/server_framework.rb', line 584

def socket_list_init
  @socket_list = SocketList.new
end

#starting ⇒ Object

gserver開始処理



249
250
251
252
253
 
# File 'lib/dango/server_framework.rb', line 249

def starting()
  msg = "#{self.class.to_s} #{@server_host}:#{@server_port}/#{@server_max_connections} start"
  logger.warn msg
  puts "[#{Time.now_to_s}] #{msg}"
end

#stopping ⇒ Object

gserver終了処理



256
257
258
259
260
 
# File 'lib/dango/server_framework.rb', line 256

def stopping()
  msg = "#{self.class.to_s} #{@server_host}:#{@server_port} stop"
  logger.warn msg
  puts "[#{Time.now_to_s}] #{msg}"
end

#thread_main(sock) ⇒ Object

gserverのserveメソッド：スレッド開始処理



263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
 
# File 'lib/dango/server_framework.rb', line 263

def thread_main(sock)
  logger.info "#{sock} is accepted. thread.current=#{Thread.current.object_id} "
  
  begin
    sock.binmode
    sock.sync = true
    
    sid = Thread.current.object_id.deep_dup
#      sid = sock.object_id

    session[:sid] = sid
    socket_list.add(sid, sock)
    mutex_socket_list.add(sid)
    
    dango_connect() # 接続時メソッド呼び出し

    
    # 接続直後のsid通知

    send_obj = {"_sid"=>sid}
    send_notice(sid, "_notice_sid", send_obj)
    logger.debug "_notice_sid #{sid} "
    
    # 誰かが接続したときに60秒以上経った@arr_send_responseを削除

    @mutex_send_response.synchronize do
      @arr_send_response.delete_if{|r| r[:time] < Time.now - 60}
    end
    
    # メインループ入り

    loop do
      if sock.closed?
        logger.info "#{sock.inspect}:sock is closed..."
        break
      end
      
      ret_obj = nil
      begin
        ret_obj = dango_receive_data(sock) # データ受信処理

        is_flash_policy_file = false
      rescue DangoFrameworkFlashPolicyError
        is_flash_policy_file = true
      end
      
      if is_flash_policy_file && @policy_file_request # Flashのポリシーファイルが来たら

        logger.info "is_flash_policy_file #{sid} "
        policy_data = '<?xml version="1.0"?><cross-domain-policy><allow-access-from domain="*" to-ports="*" /></cross-domain-policy>' + "\0" + "\n"
        logger.debug policy_data
        sock.write policy_data
        sock.flush
        sleep 1
        raise(DangoFrameworkFlashPolicyError, "policy file sent. disconnectiong...")
        
      elsif ret_obj == {} # 受信データがなければ

#          logger.debug "ret_obj is empty. "

        
      else # 受信データがあれば

        if !(ret_obj && ret_obj["action"]) # actionが無い場合はエラー

          logger.warn "no action error:#{ret_obj.inspect}"
          raise(DangoFrameworkError, "no action error") 
        end
        
        # アクション名

        action_name = ret_obj["action"].to_s
        
        @mutex_proc_thread.synchronize do
          
          if action_name == '_response' # 送信パケットの返事なら

#              logger.debug "action_name=#{action_name} #{ret_obj['_id']} "

            action_name_is_response(ret_obj)
            
          elsif action_name[0, 9] == '_monitor_' # メンテナンスアクション名なら

            ServerMonitorAction.new(self, @config, sock, ret_obj)
            
          else # メンテナンスコマンド以外のユーザーアクション名なら

            logger.info "receive_action:#{sid}:#{action_name}:"
            begin
              __send__("dango_receive_#{action_name}", ret_obj)
            rescue NoMethodError
              @recv_fail_count += 1 if @recv_fail_count # 受信失敗回数カウント

              logger.error "not find action #{action_name}:#{sid}:#{error_message($!, 'u')}"
            end
          end
          
        end # @mutex_proc_thread.synchronize

      end
      
    end # loop

    
  rescue DangoFrameworkFlashPolicyError
    logger.info "Flash policy file send. #{sid} "
    
  rescue DangoFrameworkMonitorSecurityError
    logger.warn "Monitor Security Error #{sid} "
    
  rescue DangoFrameworkReadNoDataError
    @recv_fail_count += 1 if @recv_fail_count # 受信失敗回数カウント

    logger.debug "read no data. maybe client closed. #{sid} "
    
  rescue DangoFrameworkConnectionError
    @recv_fail_count += 1 if @recv_fail_count # 受信失敗回数カウント

    logger.debug "connection error. #{sid} \n#{error_message($!, 'u')}"
    
  rescue DangoFrameworkDisconnectError
    logger.debug "DangoFrameworkDisconnectError. #{sid} \n#{error_message($!, 'u')}"
    
  rescue DangoFrameworkError
    logger.debug "DangoFrameworkError. #{sid} \n#{error_message($!, 'u')}"
    
  rescue Exception
    logger.error "Exception #{sid} #{error_message($!, 'u')}"
    
  ensure
    
    @mutex_proc_thread.synchronize do
      begin
        logger.info "#{sock.inspect} #{sid} is closing"
        dango_close() # 接続解除時に呼び出されるメソッド

      rescue Exception
        logger.error "#{sock.inspect} #{sid} ERROR\n#{error_message($!, 'u')}"
      ensure
        socket_list.delete(sid)     # ソケットリストから削除

        begin
          sock.close if !sock.closed?           # ソケットを閉じる

        rescue IOError
          logger.error "IOError #{sock} #{sid}"
        end
        
        logger.info "#{sock.inspect} #{sid} is closed"
        
        session_del()
      end
    end
    
  end
end