f.puts "integrity check : #{@integrity}"
f.puts "auto sync : #{@auto_sync_flag}"
f.puts "sync interval : #{@sync_interval}"
+ f.puts "server port : #{@port}"
f.puts "server_url : #{dist_name} -> #{server_url}"
end
Utils.file_unlock(lock_file)
@log.output( "package server [#{@id}] created successfully", Log::LV_USER )
+ @log.output( " - server location : #{@location}", Log::LV_USER )
+ @log.output( " - server configure file : #{@config_file_path}", Log::LV_USER )
+ @log.output( " - default server port : #{@port}", Log::LV_USER )
end
def register( file_path_list, dist_name, snapshot, test_flag, internal_flag = false )
# start server daemon
def start( port, passwd )
@log.info "Package server Start..."
- # set port number. default port is 3333
- @port = port
+ # if user input exsist, set port number.
+ if (port != "") then
+ # update server port information
+ # config file
+ original_string = "server port : #{@port}"
+ replacement_string = "server port : #{port}"
+ contents = File.read(@config_file_path).gsub("#{original_string}", "#{replacement_string}")
+ File.open(@config_file_path, "w") { |f| f.puts contents }
+
+ # global variable
+ @port = port
+ end
+
+ # write package server port for server lock
+ File.open(@run_file_path, "w") { |f| f.puts @port }
- # write package server port
- File.open(@run_file_path, "w") do |f|
- f.puts @port
- end
-
#lock the package server. Do not run the same server at the same time
- if (not lockServer())
- printErrorMessage("Server \"#{id}\" is already running.")
- return
+ if (not lockServer()) then
+ printErrorMessage("Server \"#{id}\" is already running.")
+ return
end
#check that the port is open
- if BuildCommServer.port_open? port then
- printErrorMessage("Port \"#{port}\" is already in use.")
- return
- end
+ if BuildCommServer.port_open? port then
+ printErrorMessage("Port \"#{port}\" is already in use.")
+ return
+ end
-
# set job request listener
@log.info "Setting listener..."
listener = SocketRegisterListener.new(self)
@auto_sync_flag = l.split(" :")[1].strip.upcase
elsif l.start_with?( "sync interval :" ) then
@sync_interval = l.split(" :")[1].strip.to_i
+ elsif l.start_with?( "server port :" ) then
+ @port = l.split(" :")[1].strip.to_i
elsif l.start_with?( "server_url :" ) then
info = l.split(" :")[1].split("->")
@dist_to_server_url[info[0].strip] = info[1].strip